Add jSerialComm library and create jSerialComm implementations for Bluetooth

Co-authored-by: jyong15 <26561407+jyong15@users.noreply.github.com>

Author: Copilot

ShimmerDriverPC/build.gradle

@@ -83,6 +83,8 @@ dependencies {
     //implementation group: 'org.scream3r', name: 'jssc', version: '2.9.1'
     api group: 'io.github.java-native', name: 'jssc', version: '2.9.6'
 
+    // https://mvnrepository.com/artifact/com.fazecast/jSerialComm
+    api group: 'com.fazecast', name: 'jSerialComm', version: '2.11.0'
 
     // https://mvnrepository.com/artifact/net.sf.bluecove/bluecove
     implementation group: 'net.sf.bluecove', name: 'bluecove', version: '2.1.0'

ShimmerDriverPC/gradlew

@@ -82,6 +82,7 @@
 import com.shimmerresearch.sensors.mpu9x50.SensorMPU9X50;
 import com.shimmerresearch.shimmer3.communication.ByteCommunication;
 import com.shimmerresearch.shimmer3.communication.ByteCommunicationJSSC;
+import com.shimmerresearch.shimmer3.communication.ByteCommunicationJSerialComm;
 import com.shimmerresearch.shimmerConfig.FixedShimmerConfigs.FIXED_SHIMMER_CONFIG_MODE;
 import com.shimmerresearch.driver.CallbackObject;
 import com.shimmerresearch.driver.ObjectCluster;
@@ -355,7 +356,8 @@ public void run(){
 				if (mByteCommunication==null || mTesting){
 					setComPort(address);
 					if (!mTesting) {
-						mByteCommunication = new ByteCommunicationJSSC(address);
+						// Use jSerialComm for better compatibility, especially on macOS
+						mByteCommunication = new ByteCommunicationJSerialComm(address);
 					} else { // do nothingit should already be set
 
 					}
@@ -638,9 +640,29 @@ private void closeConnection(){
 
 	public void setSerialPort(SerialPort sp){
 		if (mByteCommunication == null) {
-			mByteCommunication = new ByteCommunicationJSSC(sp);
+			// Use jSerialComm for better compatibility, especially on macOS
+			mByteCommunication = new ByteCommunicationJSerialComm(convertJsscToJSerialComm(sp));
 		}
-		if(mByteCommunication instanceof ByteCommunicationJSSC) {
+		if(mByteCommunication instanceof ByteCommunicationJSerialComm) {
+			((ByteCommunicationJSerialComm)mByteCommunication).setSerialPort(convertJsscToJSerialComm(sp));
+			getSamplingRateShimmer();
+		
+			if (mByteCommunication.isOpened()){
+				setBluetoothRadioState(BT_STATE.CONNECTING);
+			}
+			if (mByteCommunication.isOpened() && mBluetoothRadioState!=BT_STATE.DISCONNECTED){
+				setIsConnected(true);
+	
+				mIOThread = new IOThread();
+				mIOThread.start();
+				if(mUseProcessingThread){
+					mPThread = new ProcessingThread();
+					mPThread.start();
+				}
+				initialize();
+			}
+		} else if(mByteCommunication instanceof ByteCommunicationJSSC) {
+			// Fallback to JSSC if needed
 			((ByteCommunicationJSSC)mByteCommunication).setSerialPort(sp);
 			getSamplingRateShimmer();
 
@@ -662,6 +684,16 @@ public void setSerialPort(SerialPort sp){
 			}
 		}
 	}
+	
+	/**
+	 * Helper method to convert JSSC SerialPort to jSerialComm SerialPort
+	 * @param jsscPort JSSC SerialPort object
+	 * @return jSerialComm SerialPort object for the same port
+	 */
+	private com.fazecast.jSerialComm.SerialPort convertJsscToJSerialComm(jssc.SerialPort jsscPort) {
+		String portName = jsscPort.getPortName();
+		return com.fazecast.jSerialComm.SerialPort.getCommPort(portName);
+	}
 
 	@Override
 	protected void sendStatusMSGtoUI(String msg) {

ShimmerDriverPC/src/main/java/com/shimmerresearch/pcDriver/ShimmerPC.java

@@ -0,0 +1,61 @@
+package com.shimmerresearch.pcSerialPort;
+
+import com.fazecast.jSerialComm.SerialPort;
+
+import java.io.IOException;
+import java.util.concurrent.TimeoutException;
+
+/**
+ * JSerialCommByteWriter: an implementation of ByteWriter for jSerialComm
+ * 
+ * @author Shimmer Research
+ * Based on JsscByteWriter by Bastien Aracil
+ */
+public class JSerialCommByteWriter implements ByteWriter {
+
+    private final SerialPort serialPort;
+
+    public JSerialCommByteWriter(SerialPort serialPort) {
+        this.serialPort = serialPort;
+    }
+
+    @Override
+    public void cancelWrite() throws IOException {
+        serialPort.flushIOBuffers();
+    }
+
+    @Override
+    public void write(byte[] bytes) throws IOException {
+        int bytesWritten = serialPort.writeBytes(bytes, bytes.length);
+        if (bytesWritten != bytes.length) {
+            throw new IOException("Failed to write all bytes. Expected: " + bytes.length + ", Written: " + bytesWritten);
+        }
+    }
+
+    @Override
+    public void write(byte oneByte) throws IOException {
+        byte[] singleByte = new byte[]{oneByte};
+        int bytesWritten = serialPort.writeBytes(singleByte, 1);
+        if (bytesWritten != 1) {
+            throw new IOException("Failed to write byte");
+        }
+    }
+
+    @Override
+    public void write(byte[] bytes, long timeout) throws IOException, InterruptedException, TimeoutException {
+        if (timeout <= 0) {
+            this.write(bytes);
+        } else {
+            new TimedOutByteWriting(this, bytes, timeout).write();
+        }
+    }
+
+    @Override
+    public void write(byte oneByte, long timeout) throws IOException, InterruptedException, TimeoutException {
+        if (timeout <= 0) {
+            this.write(oneByte);
+        } else {
+            new TimedOutByteWriting(this, oneByte, timeout).write();
+        }
+    }
+}