First pass at buffering incoming data until a complete message has arrived

lpf2hub.ts

@@ -25,6 +25,9 @@ export class LPF2Hub extends Hub {
     private _lastTiltX: number = 0;
     private _lastTiltY: number = 0;
 
+    private _incomingData: Buffer = Buffer.alloc(0);
+    private _outgoingData: Buffer = Buffer.alloc(0);
+
 
     constructor (peripheral: Peripheral, autoSubscribe: boolean = true) {
         super(peripheral, autoSubscribe);
@@ -184,29 +187,49 @@ export class LPF2Hub extends Hub {
     }
 
 
-    private _parseMessage (data: Buffer) {
+    private _parseMessage (data?: Buffer) {
 
-        switch (data[2]) {
+        if (data) {
-            case 0x01:
+            this._incomingData = Buffer.concat([this._incomingData, data]);
-            {
+        }
-                this._parseDeviceInfo(data);
+
-                break;
+        if (this._incomingData.length <= 0) {
+            return;
+        }
+
+        const len = this._incomingData[0];
+        if (len >= this._incomingData.length) {
+
+            const message = this._incomingData.slice(0, len);
+            this._incomingData = this._incomingData.slice(len);
+
+            switch (message[2]) {
+                case 0x01:
+                {
+                    this._parseDeviceInfo(message);
+                    break;
+                }
+                case 0x04:
+                {
+                    this._parsePortMessage(message);
+                    break;
+                }
+                case 0x45:
+                {
+                    this._parseSensorMessage(message);
+                    break;
+                }
+                case 0x82:
+                {
+                    this._parsePortAction(message);
+                    break;
+                }
             }
-            case 0x04:
+
-            {
+            if (this._incomingData.length > 0) {
-                this._parsePortMessage(data);
+                this._parseMessage();
-                break;
-            }
-            case 0x45:
-            {
-                this._parseSensorMessage(data);
-                break;
-            }
-            case 0x82:
-            {
-                this._parsePortAction(data);
-                break;
             }
+
         }
     }
 
@@ -341,6 +364,12 @@ export class LPF2Hub extends Hub {
                     this.emit("rotate", port.id, rotation);
                     break;
                 }
+                case Consts.Devices.BOOST_MOVE_HUB_MOTOR:
+                {
+                    const rotation = data.readInt32LE(2);
+                    this.emit("rotate", port.id, rotation);
+                    break;
+                }
                 case Consts.Devices.BOOST_TILT:
                 {
                     const tiltX = data[4] > 160 ? data[4] - 255 : data[4];