Add cctalk parsers

lib/parsers/cctalk.js

@@ -0,0 +1,33 @@
+'use strict';
+const Transform = require('stream').Transform;
+
+module.exports = class CCTalkParser extends Transform {
+  constructor() {
+    super();
+    this.array = [];
+  }
+  _transform(buffer, _, cb) {
+    // TODO: Better Faster es7 no supported by node 4
+    const array = Array.prototype.slice.call(buffer, 0); // [...buffer];
+    this.array.push(array);
+
+    // full frame accumulated
+    const FullMsgLength = this.array[1] + 5;
+    // console.log("FullMsgLength",FullMsgLength);
+
+    while (this.array.length > 1 && this.array.length >= FullMsgLength) {
+      // copy command from the array
+      const frame = new Uint8Array(FullMsgLength);
+      frame.set(this.array.slice(0, FullMsgLength));
+
+      if (this.array.length > FullMsgLength) { // Preserve Extra Data
+        this.array = this.array.slice(frame.length, this.array.length);
+      } else { // flush the array
+        this.array.length = 0;
+      }
+
+      this.push(frame);
+    }
+    cb();
+  }
+};

lib/parsers/index.js

@@ -76,6 +76,7 @@ parser.on('data', console.log);
 
 module.exports = {
   ByteLength: require('./byte-length'),
+  CCTalk: require('./cctalk'),
   Delimiter: require('./delimiter'),
   Readline: require('./readline'),
   Ready: require('./ready'),

package.json

@@ -71,7 +71,7 @@
     "chai": "^4.0.2",
     "chai-subset": "^1.5.0",
     "conventional-changelog-cli": "^1.3.2",
-    "eslint": "^4.5.0",
+    "eslint": "^4.7.2",
     "eslint-config-standard": "^10.2.1",
     "eslint-plugin-import": "^2.7.0",
     "eslint-plugin-node": "^5.1.0",
@@ -82,7 +82,7 @@
     "mocha": "^3.4.2",
     "prebuild": "^6.2.1",
     "proxyquire": "^1.7.10",
-    "sinon": "^3.2.1"
+    "sinon": "^3.3.0"
   },
   "engines": {
     "node": ">=4.0.0"

test/arduinoTest/stress.js

@@ -1,4 +1,4 @@
-/* eslint-disable node/no-missing-require */
+/* eslint-disable node/no-missing-require, node/no-extraneous-require */
 'use strict';
 
 // `npm run stress` to run these tests

test/parser-cctalk.js

@@ -0,0 +1,18 @@
+'use strict';
+/* eslint-disable no-new */
+
+const Buffer = require('safe-buffer').Buffer;
+const sinon = require('sinon');
+const CCTalkParser = require('../lib/parsers/cctalk');
+
+describe('CCTalkParser', () => {
+  it('continues looking for bytes in additional writes', () => {
+    const parser = new CCTalkParser();
+    const spy = sinon.spy();
+    // parser.on('data', spy);
+    // parser.write(Buffer.from([1, 0, 2]));
+    // parser.write(Buffer.from([254, 217]));
+  });
+  // TODO: case crc message got data 2 bits
+  // TODO: case process remaining buffer
+});