feat: migrate to flusbserial

Author: AsCress

lib/communication/commands_proto.dart

@@ -1,7 +1,9 @@
+import 'dart:io';
+
 class CommandsProto {
   int acknowledge = 254;
   int maxSamples = 10000;
-  int dataSplitting = 60;
+  late int dataSplitting;
 
   int flash = 1;
   int readFlash = 1;
@@ -200,4 +202,12 @@ class CommandsProto {
   int passUart = 1;
 
   int stopStreaming = 253;
+
+  CommandsProto() {
+    if (Platform.isWindows || Platform.isLinux || Platform.isMacOS) {
+      dataSplitting = 30;
+    } else {
+      dataSplitting = 60;
+    }
+  }
 }

lib/communication/handler/desktop_comms_handler.dart

@@ -1,6 +1,6 @@
 import 'dart:typed_data';
 
-import 'package:flutter_libserialport/flutter_libserialport.dart';
+import 'package:flusbserial/flusbserial.dart';
 import 'package:pslab/communication/handler/base.dart';
 import 'package:pslab/others/logger_service.dart';
 
@@ -9,7 +9,7 @@ class DesktopUSBCommunicationHandler implements CommunicationHandler {
   static const int pslabProductIdV5 = 223;
   static const int pslabVendorIdV6 = 0x10C4;
   static const int pslabProductIdV6 = 0xEA60;
-  SerialPort? mPort;
+  UsbSerialDevice? mDevice;
 
   @override
   bool connected = false;
@@ -19,22 +19,22 @@ class DesktopUSBCommunicationHandler implements CommunicationHandler {
 
   @override
   void close() {
-    if (!connected || mPort == null) return;
-    mPort?.close();
+    if (!connected || mDevice == null) return;
+    mDevice?.close();
     connected = false;
   }
 
   @override
   Future<void> initialize() async {
-    List<String> addresses = SerialPort.availablePorts;
-    for (final address in addresses) {
-      final port = SerialPort(address);
-      if ((port.vendorId == pslabVendorIdV5 &&
-              port.productId == pslabProductIdV5) ||
-          (port.vendorId == pslabVendorIdV6 &&
-              port.productId == pslabProductIdV6)) {
+    UsbSerialDevice.init();
+    List<UsbDevice> availableDevices = await UsbSerialDevice.listDevices();
+    for (final device in availableDevices) {
+      if ((device.vendorId == pslabVendorIdV5 &&
+              device.productId == pslabProductIdV5) ||
+          (device.vendorId == pslabVendorIdV6 &&
+              device.productId == pslabProductIdV6)) {
         deviceFound = true;
-        mPort = port;
+        mDevice = UsbSerialDevice.createDevice(device);
         break;
       }
     }
@@ -60,11 +60,11 @@ class DesktopUSBCommunicationHandler implements CommunicationHandler {
     if (!deviceFound) {
       throw Exception("Device not connected");
     }
-    mPort?.openReadWrite();
-    mPort?.config.baudRate = 1000000;
-    mPort?.config.bits = 8;
-    mPort?.config.stopBits = 1;
-    mPort?.config.parity = SerialPortParity.none;
+    await mDevice?.open();
+    await mDevice?.setBaudRate(1000000);
+    await mDevice?.setDataBits(UsbSerialInterface.dataBits8);
+    await mDevice?.setStopBits(UsbSerialInterface.stopBits1);
+    await mDevice?.setParity(UsbSerialInterface.parityNone);
     connected = true;
   }
 
@@ -74,14 +74,16 @@ class DesktopUSBCommunicationHandler implements CommunicationHandler {
     int bytesToBeReadTemp = bytesToRead;
     try {
       while (numBytesRead < bytesToRead) {
-        Uint8List receivedData = mPort!.read(bytesToBeReadTemp, timeout: 0);
-        int readNow = receivedData.length;
+        Uint8List? receivedData =
+            await mDevice?.read(bytesToBeReadTemp, timeoutMillis);
+        int? readNow = receivedData?.length;
+        logger.d("Received chunk: $receivedData");
         if (readNow == 0) {
           logger.e("Read Error: $bytesToBeReadTemp");
           return numBytesRead;
         } else {
-          int readLength = readNow.clamp(0, bytesToBeReadTemp);
-          dest.setRange(numBytesRead, numBytesRead + readLength, receivedData);
+          int readLength = readNow!.clamp(0, bytesToBeReadTemp);
+          dest.setRange(numBytesRead, numBytesRead + readLength, receivedData!);
           numBytesRead += readLength;
           bytesToBeReadTemp -= readLength;
         }
@@ -96,7 +98,6 @@ class DesktopUSBCommunicationHandler implements CommunicationHandler {
 
   @override
   void write(Uint8List src, int timeoutMillis) {
-    mPort?.write(src, timeout: 0);
-    mPort?.flush();
+    mDevice?.write(src, timeoutMillis);
   }
 }

pubspec.yaml

@@ -69,7 +69,10 @@ dependencies:
   path_provider: ^2.1.5
   file_picker: ^10.3.2
   flutter_screenutil: ^5.9.3
-  flutter_libserialport: ^0.6.0
+  flusbserial: ^0.1.1
+
+dependency_overrides:
+  ffi: ^2.1.3
 
 
 dev_dependencies: