1 files changed, 109 insertions, 0 deletions
diff --git a/lib/model/flutter_blue_plus_device_connection.dart b/lib/model/flutter_blue_plus_device_connection.dart
new file mode 100644
index 0000000..93aa67e
--- /dev/null
+++ b/lib/model/flutter_blue_plus_device_connection.dart
@@ -0,0 +1,109 @@
+// 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 = await dev.discoverServices();
+        findCharac(svcs);
+      } catch (e) {
+        logger.e(e);
+      }
+    });
+
+    logger.i("services discovered");
+
+    findCharac(svcs);
+
+    _status = ConnectionStatus.connected;
+  }
+
+  @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");
+    }
+  }
+}