fix: serial_server not unpacking messages correctly. mod: serial_server_example with mult callback and stm32 uart setting

Author: eigen-value

extras/examples/serial_server_example.py

@@ -1,11 +1,19 @@
+from serial_server import SerialServer
+
 def add(a, b):
     return a + b
 
 def greet(name):
     return f"Hello, {name}!"
 
-server = SerialServer(port='/dev/ttyUSB0', baudrate=115200)
+def multiply(a, b):
+    return a*b
+
+PORT = '/dev/ttySTM0'
+
+server = SerialServer(port=PORT, baudrate=115200)
 server.register_callback('add', add)
+server.register_callback('mult', multiply)
 server.register_callback('greet', greet)
 server.start()
 

extras/serial_server.py

@@ -1,7 +1,7 @@
 import serial
 import msgpack
 import threading
-
+from io import BytesIO
 
 REQUEST = 0
 RESPONSE = 1
@@ -53,18 +53,18 @@ def start(self):
         threading.Thread(target=self._run, daemon=True).start()
 
     def _run(self):
-        unpacker = msgpack.Unpacker(raw=False)
         while self.running:
             try:
                 data = self.ser.read(1024)
                 if data:
-                    unpacker.feed(data)
+                    unpacker = msgpack.Unpacker(BytesIO(data))
                     for message in unpacker:
                         response = self.handle_message(message)
                         if response is not None:
                             self.ser.write(response)
             except Exception as e:
                 print(f"Error: {e}")
+        print("Server stopped")
 
     def stop(self):
         self.running = False