feat: Added next gen profile for streaming feature

lib/bademagic_module/bluetooth/base_ble_state.dart

@@ -18,15 +18,18 @@ abstract class NormalBleState extends BleState {
       return await processState();
     } on Exception catch (e) {
       String errorMessage = e.toString().replaceFirst('Exception: ', '');
-      return CompletedState(isSuccess: false, message: errorMessage);
+      return CompletedState(
+        isSuccess: false,
+        message: errorMessage,
+        shouldDisconnect: true,
+      );
     }
   }
 }
 
 abstract class RetryBleState extends BleState {
   final logger = Logger();
   final toast = ToastUtils();
-
   final _maxRetries = 3;
 
   Future<BleState?> processState();
@@ -43,6 +46,7 @@ abstract class RetryBleState extends BleState {
         logger.e(e);
         lastException = e;
         attempt++;
+
         if (attempt < _maxRetries) {
           logger.d("Retrying ($attempt/$_maxRetries)...");
         } else {
@@ -53,9 +57,10 @@ abstract class RetryBleState extends BleState {
       }
     }
 
-    // After max retries, return a CompletedState indicating failure.
     return CompletedState(
-        isSuccess: false,
-        message: lastException?.toString() ?? "Unknown error");
+      isSuccess: false,
+      message: lastException?.toString() ?? "Unknown error",
+      shouldDisconnect: true,
+    );
   }
 }

lib/bademagic_module/bluetooth/completed_state.dart

@@ -1,18 +1,47 @@
 import 'package:badgemagic/bademagic_module/bluetooth/base_ble_state.dart';
+import 'package:badgemagic/bademagic_module/bluetooth/datagenerator.dart';
 
 class CompletedState extends NormalBleState {
   final bool isSuccess;
   final String message;
+  final TransferMode? mode;
+  final bool shouldDisconnect;
+  final DataTransferManager? manager;
 
-  CompletedState({required this.isSuccess, required this.message});
+  CompletedState({
+    required this.isSuccess,
+    required this.message,
+    this.mode,
+    this.shouldDisconnect = false,
+    this.manager,
+  });
 
   @override
   Future<BleState?> processState() async {
+    if (shouldDisconnect && manager?.connectedDevice != null) {
+      try {
+        logger.d("Disconnecting device as requested...");
+
+        if (mode == TransferMode.streaming && manager!.isStreamingActive) {
+          await manager!.exitStreamingMode();
+          await Future.delayed(const Duration(milliseconds: 200));
+        }
+
+        await manager!.connectedDevice!.disconnect();
+        await Future.delayed(const Duration(milliseconds: 700));
+        manager!.clearConnectedDevice();
+
+        logger.d("Device disconnected successfully");
+      } catch (e) {
+        logger.e("Error during disconnection: $e");
+      }
+    }
     if (isSuccess) {
       toast.showToast(message);
     } else {
       toast.showErrorToast(message);
     }
+
     return null;
   }
 }

lib/bademagic_module/bluetooth/connect_state.dart

@@ -1,47 +1,40 @@
+import 'package:badgemagic/bademagic_module/bluetooth/base_ble_state.dart';
+import 'package:badgemagic/bademagic_module/bluetooth/completed_state.dart';
 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 'base_ble_state.dart';
 
-class ConnectState extends RetryBleState {
+class ConnectState extends NormalBleState {
   final ScanResult scanResult;
   final DataTransferManager manager;
 
-  ConnectState({required this.manager, required this.scanResult});
+  ConnectState({required this.scanResult, required this.manager});
 
   @override
   Future<BleState?> processState() async {
-    try {
-      try {
-        await scanResult.device.disconnect();
-        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;
+    BluetoothDevice device = scanResult.device;
+    manager.connectedDevice = device;
 
-      if (connectionState == BluetoothConnectionState.connected) {
-        logger.d("Device connected successfully");
-        toast.showToast('Device connected successfully.');
+    try {
+      toast.showToast("Connecting to ${device.platformName}...");
+      logger.d("Attempting to connect to ${device.platformName}...");
 
-        manager.connectedDevice = scanResult.device;
+      await device.connect(autoConnect: false);
+      await Future.delayed(const Duration(milliseconds: 500));
 
-        final writeState = WriteState(
-          device: scanResult.device,
-          manager: manager,
-        );
+      logger.d("Connected to device: ${device.platformName}");
+      toast.showToast("Connected to ${device.platformName}");
 
-        return await writeState.process();
-      } else {
-        throw Exception("Failed to connect to the device");
-      }
+      return WriteState(manager: manager, device: device);
     } catch (e) {
-      toast.showErrorToast('Failed to connect. Retrying...');
-      rethrow;
+      logger.e("Connection failed: $e");
+      return CompletedState(
+        isSuccess: false,
+        message: "Failed to connect to device. Please retry.",
+        mode: manager.mode,
+        shouldDisconnect: true,
+        manager: manager,
+      );
     }
   }
 }