feat: next-gen protocol commands (streaming function)

lib/communication/completed_state.dart

@@ -7,9 +7,11 @@ import 'package:badgemagic/view/widgets/ble_progress_dialog_controller.dart';
 class CompletedState extends NormalBleState {
   final bool isSuccess;
   final String message;
+  final bool isNextGen;
   final bleDialogController = GetIt.instance<BleDialogController>();
 
-  CompletedState({required this.isSuccess, required this.message});
+  CompletedState(
+      {required this.isSuccess, required this.message, this.isNextGen = false});
 
   @override
   Future<BleState?> processState() async {

lib/communication/ng_command_state.dart

@@ -0,0 +1,65 @@
+import 'dart:async';
+import 'dart:typed_data';
+import 'package:badgemagic/others/globals.dart';
+import 'package:universal_ble/universal_ble.dart';
+import 'base_ble_state.dart';
+import 'completed_state.dart';
+
+class NgCommandState extends NormalBleState {
+  final BleDevice device;
+  final List<int> command;
+
+  NgCommandState({required this.device, required this.command});
+
+  @override
+  Future<BleState?> processState() async {
+    final deviceId = device.deviceId;
+    final completer = Completer<int>();
+
+    await UniversalBle.discoverServices(deviceId);
+
+    await UniversalBle.setNotifiable(
+      deviceId,
+      ngServiceUuid,
+      ngNotifyCharUuid,
+      BleInputProperty.notification,
+    );
+
+    late final StreamSubscription sub;
+    sub = UniversalBle.characteristicValueStream(deviceId, ngNotifyCharUuid)
+        .listen(
+      (Uint8List value) {
+        if (!completer.isCompleted) {
+          completer.complete(value.isNotEmpty ? value[0] : 0xff);
+        }
+      },
+      onError: (error) {
+        if (!completer.isCompleted) {
+          completer.completeError(error);
+        }
+      },
+    );
+
+    try {
+      await UniversalBle.write(
+        deviceId,
+        ngServiceUuid,
+        ngWriteCharUuid,
+        Uint8List.fromList(command),
+        withoutResponse: false,
+      );
+
+      final code = await completer.future.timeout(const Duration(seconds: 5));
+
+      if (code != 0x00) {
+        throw Exception(
+            "Command rejected by badge (code 0x${code.toRadixString(16)})");
+      }
+
+      return CompletedState(
+          isSuccess: true, message: "Command executed", isNextGen: true);
+    } finally {
+      await sub.cancel();
+    }
+  }
+}

lib/communication/write_state.dart

@@ -25,6 +25,8 @@ class WriteState extends NormalBleState {
   static const Duration _disconnectTimeout = Duration(seconds: 2);
   static const Duration _postDisconnectDelay = Duration(milliseconds: 500);
 
+  bool verifiedNextGen = false;
+
   WriteState({required this.manager, required this.device});
 
   static Future<void> cancelTransfer() async {
@@ -73,6 +75,12 @@ class WriteState extends NormalBleState {
       await Future.delayed(_initialDelay);
       if (isCancellationRequested) return _handleAbortedState();
 
+      List<BleService> discoveredServices =
+          await UniversalBle.discoverServices(deviceId);
+
+      verifiedNextGen = discoveredServices.any((service) =>
+          service.uuid.toLowerCase() == ngServiceUuid.toLowerCase());
+
       final services = await UniversalBle.discoverServices(deviceId);
       final serviceExists = services.any((s) => s.uuid == serviceUuid);
       if (!serviceExists) {
@@ -106,6 +114,7 @@ class WriteState extends NormalBleState {
       return CompletedState(
         isSuccess: true,
         message: l10n.transferSucceeded,
+        isNextGen: verifiedNextGen,
       );
     } catch (e) {
       logger.e("Transfer failed: $e");
@@ -119,6 +128,18 @@ class WriteState extends NormalBleState {
     } finally {
       progressTimer.cancel();
       await _safeDisconnect(deviceId);
+      if (!verifiedNextGen) {
+        try {
+          logger.d("Disconnecting from legacy device after write...");
+          await UniversalBle.disconnect(deviceId);
+          await Future.delayed(const Duration(milliseconds: 700));
+        } catch (e) {
+          logger.e("Error during disconnect: $e");
+        }
+      } else {
+        logger
+            .i("Keeping GATT connection alive for Next-Gen profile commands.");
+      }
     }
   }
 

lib/l10n/app_en.arb

@@ -249,6 +249,38 @@
   "couldNotGenerateQrImage": "Could not generate QR image.",
   "couldNotShareQrImage": "Could not share QR image.",
   "qrShareInstruction": "Scan this code from another device, or tap share to send the QR image.",
+  "turnBLEOn": "Please turn on Bluetooth in your settings",
+  "qrShareInstruction": "Scan this code from another device, or tap share to send the QR image.",
+  "defaultFont": "Default",
+  "font": "Font",
+  "connected": "Connected",
+  "liveMirroring": "Live Mirroring",
+  "liveMirroringSubtitle": "Sync the app preview to the badge in real time",
+  "powerOff": "Turn off Badge",
+  "disconnect": "Disconnect",
+  "disconnected": "Disconnected",
+  "currentName": "Current Name: ",
+  "renameBadge": "Rename Badge",
+  "bleAlwaysOn": "BLE Always On",
+  "bleAlwaysOnSubtitle": "Keep Bluetooth active during animations",
+  "alwaysOnEnabled": "Always-On Enabled",
+  "alwaysOnDisabled": "Always-On Disabled",
+  "savingAndRebooting": "Saving and rebooting badge...",
+  "nameApplied": "Name applied to device",
+  "savedToFlash": "Saved to Flash!",
+  "turnOff": "Turn Off tha badge",
+  "editingBadgeWithName": "Editing badge: {name}",
+  "@editingBadgeWithName": {
+    "placeholders": {
+      "name": {
+        "type": "String"
+      }
+    }
+  },
+  "saveFlashAndReboot": "Save and Reboot the badge",
+  "appFeaturesTitle": "App Features",
+  "enableBadheStreaming": "Enable Badge Streaming",
+  "enableBadheStreamingWarning": "Only FOSSASIA firmware supports this feature",
   "renameBadge": "Rename Badge",
   "newName": "New name",
   "rename": "Rename",

lib/others/globals.dart

@@ -6,6 +6,9 @@ final scaffoldMessengerKey = GlobalKey<ScaffoldMessengerState>();
 final String serviceUuid = "0000fee0-0000-1000-8000-00805f9b34fb";
 final String characteristicUuid = "0000fee1-0000-1000-8000-00805f9b34fb";
 
+const String ngServiceUuid = "0000f055-0000-1000-8000-00805f9b34fb";
+const String ngWriteCharUuid = "0000f057-0000-1000-8000-00805f9b34fb";
+const String ngNotifyCharUuid = "0000f056-0000-1000-8000-00805f9b34fb";
 Future<bool> autocheckFirmwareUpdates() async {
   final prefs = await SharedPreferences.getInstance();
   bool? check = prefs.getBool('auto_check_updates');