fix: replaced flutter_blue_plus library with universal_ble (#1718)

Co-authored-by: ctrlVnt <gordanobruno227@gmail.com>
Co-authored-by: Mario Behling <mb@mariobehling.de>
Co-authored-by: Hong Phuc Dang <dhppat@gmail.com>

Author: 4 people

iOS/Podfile

@@ -1,5 +1,5 @@
 # Uncomment this line to define a global platform for your project
-platform :ios, '13.0'
+platform :ios, '15.6'
 
 # CocoaPods analytics sends network stats synchronously affecting flutter build latency.
 ENV['COCOAPODS_DISABLE_STATS'] = 'true'

lib/bademagic_module/bluetooth/connect_state.dart

@@ -1,37 +1,39 @@
 import 'package:badgemagic/bademagic_module/bluetooth/datagenerator.dart';
 import 'package:badgemagic/bademagic_module/bluetooth/write_state.dart';
-import 'package:flutter_blue_plus/flutter_blue_plus.dart';
+import 'package:universal_ble/universal_ble.dart';
 import 'base_ble_state.dart';
 
 class ConnectState extends RetryBleState {
-  final ScanResult scanResult;
+  final BleDevice scanResult;
   final DataTransferManager manager;
 
   ConnectState({required this.manager, required this.scanResult});
 
   @override
   Future<BleState?> processState() async {
+    final deviceId = scanResult.deviceId;
+
     try {
       try {
-        await scanResult.device.disconnect();
+        await UniversalBle.disconnect(deviceId);
         logger.d("Pre-emptive disconnect for clean state");
         await Future.delayed(const Duration(seconds: 1));
       } catch (_) {
         logger.d("No existing connection to disconnect");
       }
 
-      await scanResult.device.connect(autoConnect: false);
-      BluetoothConnectionState connectionState =
-          await scanResult.device.connectionState.first;
+      await UniversalBle.connect(deviceId);
+
+      final connectionState = await UniversalBle.getConnectionState(deviceId);
 
-      if (connectionState == BluetoothConnectionState.connected) {
+      if (connectionState == BleConnectionState.connected) {
         logger.d("Device connected successfully");
         toast.showToast('Device connected successfully.');
 
-        manager.connectedDevice = scanResult.device;
+        manager.connectedDevice = scanResult;
 
         final writeState = WriteState(
-          device: scanResult.device,
+          device: scanResult,
           manager: manager,
         );
 

lib/bademagic_module/bluetooth/datagenerator.dart

@@ -3,13 +3,24 @@ import 'package:badgemagic/bademagic_module/utils/data_to_bytearray_converter.da
 import 'package:badgemagic/bademagic_module/utils/file_helper.dart';
 import 'package:badgemagic/providers/badge_message_provider.dart';
 import 'package:badgemagic/providers/imageprovider.dart';
-import 'package:flutter_blue_plus/flutter_blue_plus.dart';
+import 'package:universal_ble/universal_ble.dart';
 import 'package:get_it/get_it.dart';
 
+import '../utils/toast_utils.dart';
+
+Future<bool> checkAdapterState() async {
+  final adapterState = await UniversalBle.getBluetoothAvailabilityState();
+  if (adapterState != AvailabilityState.poweredOn) {
+    ToastUtils().showErrorToast('Please turn on Bluetooth');
+    return false;
+  }
+  return true;
+}
+
 class DataTransferManager {
   final Data data;
 
-  BluetoothDevice? connectedDevice;
+  BleDevice? connectedDevice;
 
   final BadgeMessageProvider badgeData = BadgeMessageProvider();
   final DataToByteArrayConverter converter = DataToByteArrayConverter();

lib/bademagic_module/bluetooth/scan_state.dart

@@ -2,14 +2,17 @@ import 'dart:async';
 import 'package:badgemagic/bademagic_module/bluetooth/connect_state.dart';
 import 'package:badgemagic/bademagic_module/bluetooth/datagenerator.dart';
 import 'package:badgemagic/providers/BadgeScanProvider.dart';
-import 'package:flutter_blue_plus/flutter_blue_plus.dart';
+import 'package:universal_ble/universal_ble.dart';
+import '../../globals/globals.dart';
 import 'base_ble_state.dart';
 
 class ScanState extends NormalBleState {
   final DataTransferManager manager;
   final BadgeScanMode mode;
   final List<String> allowedNames;
 
+  final String targetServiceUuid = serviceUuid;
+
   ScanState({
     required this.manager,
     required this.mode,
@@ -19,54 +22,51 @@ class ScanState extends NormalBleState {
   @override
   Future<BleState?> processState() async {
     manager.clearConnectedDevice();
-    await FlutterBluePlus.stopScan();
+    await UniversalBle.stopScan();
 
     toast.showToast("Searching for device...");
     Completer<BleState?> nextStateCompleter = Completer();
-    StreamSubscription<List<ScanResult>>? subscription;
+    StreamSubscription<BleDevice>? subscription;
+    Timer? timeoutTimer;
 
     bool isCompleted = false;
     try {
-      subscription = FlutterBluePlus.scanResults.listen(
-        (results) async {
-          if (isCompleted || results.isEmpty) return;
+      subscription = UniversalBle.scanStream.listen(
+        (device) async {
+          if (isCompleted) return;
 
           try {
             final normalizedAllowedNames = allowedNames
                 .map((e) => e.trim().toLowerCase())
                 .where((e) => e.isNotEmpty)
                 .toList();
 
-            final foundDevice = results.firstWhere(
-              (result) {
-                final matchesUuid = result.advertisementData.serviceUuids
-                    .contains(Guid("0000fee0-0000-1000-8000-00805f9b34fb"));
-
-                final deviceName = result.device.name.trim().toLowerCase();
-                final matchesName = mode == BadgeScanMode.any ||
-                    normalizedAllowedNames.contains(deviceName);
+            final matchesUuid = device.services.contains(targetServiceUuid);
 
-                return matchesUuid && matchesName;
-              },
-              orElse: () => throw Exception("Matching device not found."),
-            );
+            final deviceName = (device.name ?? "").trim().toLowerCase();
+            final matchesName = mode == BadgeScanMode.any ||
+                normalizedAllowedNames.contains(deviceName);
 
-            isCompleted = true;
-            FlutterBluePlus.stopScan();
-            toast.showToast('Device found. Connecting...');
+            if (matchesUuid && matchesName) {
+              isCompleted = true;
+              timeoutTimer?.cancel();
+              await UniversalBle.stopScan();
+              toast.showToast('Device found. Connecting...');
 
-            nextStateCompleter.complete(ConnectState(
-              scanResult: foundDevice,
-              manager: manager,
-            ));
+              nextStateCompleter.complete(ConnectState(
+                scanResult: device,
+                manager: manager,
+              ));
+            }
           } catch (e) {
-            logger.w("No matching device found in this batch: $e");
+            logger.w("Device discovered but filtered out: $e");
           }
         },
         onError: (e) {
           if (!isCompleted) {
             isCompleted = true;
-            FlutterBluePlus.stopScan();
+            timeoutTimer?.cancel();
+            UniversalBle.stopScan();
             logger.e("Scan error: $e");
             toast.showErrorToast('Scan error occurred.');
             nextStateCompleter.completeError(
@@ -75,29 +75,30 @@ class ScanState extends NormalBleState {
           }
         },
       );
-      await FlutterBluePlus.startScan(
-        withServices: [Guid("0000fee0-0000-1000-8000-00805f9b34fb")],
-        removeIfGone: Duration(seconds: 5),
-        continuousUpdates: true,
-        timeout: const Duration(seconds: 15), // Reduced scan timeout.
-      );
 
-      await Future.delayed(const Duration(seconds: 1));
+      await UniversalBle.startScan(
+        scanFilter: ScanFilter(
+          withServices: [targetServiceUuid],
+        ),
+      );
 
-      if (!isCompleted) {
-        isCompleted = true;
-        FlutterBluePlus.stopScan();
-        toast.showErrorToast('Device not found.');
-        nextStateCompleter.completeError(Exception('Device not found.'));
-      }
+      timeoutTimer = Timer(const Duration(seconds: 15), () async {
+        if (!isCompleted) {
+          isCompleted = true;
+          await UniversalBle.stopScan();
+          toast.showErrorToast('Device not found.');
+          nextStateCompleter.completeError(Exception('Device not found.'));
+        }
+      });
 
       return await nextStateCompleter.future;
     } catch (e) {
+      timeoutTimer?.cancel();
       logger.e("Exception during scanning: $e");
       throw Exception("Please check if the device is turned on and retry.");
     } finally {
       await subscription?.cancel();
-      await FlutterBluePlus.stopScan();
+      await UniversalBle.stopScan();
     }
   }
 }

lib/bademagic_module/bluetooth/write_state.dart

@@ -1,10 +1,12 @@
+import 'dart:typed_data';
 import 'package:badgemagic/bademagic_module/bluetooth/datagenerator.dart';
-import 'package:flutter_blue_plus/flutter_blue_plus.dart';
+import 'package:universal_ble/universal_ble.dart';
+import '../../globals/globals.dart';
 import 'base_ble_state.dart';
 import 'completed_state.dart';
 
 class WriteState extends NormalBleState {
-  final BluetoothDevice device;
+  final BleDevice device;
   final DataTransferManager manager;
 
   WriteState({required this.manager, required this.device});
@@ -14,46 +16,46 @@ class WriteState extends NormalBleState {
     List<List<int>> dataChunks = await manager.generateDataChunk();
     logger.d("Data to write: $dataChunks");
 
+    final deviceId = device.deviceId;
+
     try {
-      List<BluetoothService> services = await device.discoverServices();
-      for (BluetoothService service in services) {
-        for (BluetoothCharacteristic characteristic
-            in service.characteristics) {
-          if (characteristic.uuid ==
-                  Guid("0000fee1-0000-1000-8000-00805f9b34fb") &&
-              characteristic.properties.write) {
-            for (List<int> chunk in dataChunks) {
-              bool success = false;
-              for (int attempt = 1; attempt <= 3; attempt++) {
-                try {
-                  await characteristic.write(chunk, withoutResponse: false);
-                  logger.d("Chunk written successfully: $chunk");
-                  success = true;
-                  break;
-                } catch (e) {
-                  logger.e("Write failed (attempt $attempt/3): $e");
-                }
-              }
-              if (!success) {
-                throw Exception("Failed to transfer data. Please try again.");
-              }
-              await Future.delayed(Duration(milliseconds: 50));
-            }
+      await Future.delayed(const Duration(milliseconds: 300));
+      await UniversalBle.discoverServices(deviceId);
+
+      for (List<int> chunk in dataChunks) {
+        bool success = false;
 
-            logger.d("Characteristic written successfully");
-            return CompletedState(
-                isSuccess: true, message: "Data transferred successfully");
+        for (int attempt = 1; attempt <= 3; attempt++) {
+          try {
+            await UniversalBle.write(deviceId, serviceUuid, characteristicUuid,
+                Uint8List.fromList(chunk),
+                withoutResponse: false);
+
+            logger.d("Chunk written successfully: $chunk");
+            success = true;
+            break;
+          } catch (e) {
+            logger.e("Write failed (attempt $attempt/3): $e");
           }
         }
+
+        if (!success) {
+          throw Exception("Failed to transfer data. Please try again.");
+        }
+
+        await Future.delayed(const Duration(milliseconds: 120));
       }
-      throw Exception("Please use the correct Badge");
+
+      logger.d("Characteristic written successfully");
+      return CompletedState(
+          isSuccess: true, message: "Data transferred successfully");
     } catch (e) {
       logger.e("Failed to write characteristic: $e");
       throw Exception("Failed to transfer data. Please try again.");
     } finally {
       try {
         logger.d("Disconnecting from device after write attempt...");
-        await device.disconnect();
+        await UniversalBle.disconnect(deviceId);
         await Future.delayed(const Duration(milliseconds: 700));
         logger.d("Device disconnected and delay complete.");
       } catch (e) {

lib/globals/globals.dart

@@ -1,3 +1,6 @@
 import 'package:flutter/material.dart';
 
 final scaffoldMessengerKey = GlobalKey<ScaffoldMessengerState>();
+
+final String serviceUuid = "0000fee0-0000-1000-8000-00805f9b34fb";
+final String characteristicUuid = "0000fee1-0000-1000-8000-00805f9b34fb";