blob: 29195569d92842367d468fa74d47171911a65564 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
// Copyright (C) 2025, uvok cheetah
//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program. If not, see <https://www.gnu.org/licenses/>.
import 'dart:async';
import 'package:flutter_blue_plus/flutter_blue_plus.dart';
import 'package:logger/logger.dart';
import 'package:uvok_epaper_badge/first_where_ext.dart';
import 'package:uvok_epaper_badge/model/device.dart';
import 'package:uvok_epaper_badge/model/device_connection.dart';
import 'package:uvok_epaper_badge/model/flutter_blue_plus_device.dart';
var logger = Logger();
class FlutterBluePlusDeviceConnection implements DeviceConnection {
ConnectionStatus _status = ConnectionStatus.disconnected;
// Just to have a resonable default subscription?
StreamSubscription<BluetoothConnectionState> subs =
Stream<BluetoothConnectionState>.empty().listen((e) => ());
BluetoothCharacteristic? current;
BluetoothCharacteristic? available;
final FlutterBluePlusDevice device;
FlutterBluePlusDeviceConnection({required this.device});
@override
Future<void> connect() async {
subs.cancel().ignore();
final dev = device.scanResult.device;
subs = dev.connectionState.listen(_onConnStateChange);
// connect timeout doesn't work under Linux
await dev.connect().timeout(Duration(seconds: 2));
// // ???? WTF ????
List<BluetoothService> svcs = await dev.discoverServices();
dev.onServicesReset.listen((_) async {
logger.i("Services Reset");
// try {
// List<BluetoothService> svcs = dev.servicesList;
// findCharac(svcs);
// } catch (e) {
// logger.e(e);
// }
});
logger.i("services discovered");
findCharac(svcs);
_status = ConnectionStatus.connected;
await Future.delayed(Duration(seconds: 5));
logger.i("Try re-discover");
svcs = await dev.discoverServices();
}
@override
Future<void> disconnect() async {
_status = ConnectionStatus.disconnected;
}
void dispose() {
subs.cancel().ignore();
}
@override
ConnectionStatus get status => _status;
void _onConnStateChange(BluetoothConnectionState event) {
logger.i("New conn state: ${event.toString()}");
}
void findCharac(List<BluetoothService> svcs) {
if (svcs.isEmpty) {
logger.w("No services found!");
return;
}
logger.i("Services found!");
BluetoothService? badgeService = svcs.firstWhereOrNull(
(s) => s.serviceUuid.str == "ca260000-b4bb-46b2-bd06-b7b7a61ea990",
);
if (badgeService == null) {
} else {
logger.i("badge service found");
current = badgeService.characteristics.firstWhereOrNull(
(c) =>
c.characteristicUuid.str == "ca260001-b4bb-46b2-bd06-b7b7a61ea990",
);
available = badgeService.characteristics.firstWhereOrNull(
(c) =>
c.characteristicUuid.str == "ca260002-b4bb-46b2-bd06-b7b7a61ea990",
);
}
if (current == null || available == null) {
} else {
logger.i("characteristics found");
}
}
}
|
