Upgrade Uart

package.json

@@ -1,6 +1,6 @@
 {
     "name": "pmsx003",
-    "version": "0.1.2",
+    "version": "0.1.3",
     "description": "Plantower's PM2.5 sensor driver",
     "author": "Nanchao Inc.",
     "license": "MIT",

src/index.js

@@ -2,32 +2,24 @@
 
 var driver = require('ruff-driver');
 var Parser = require('./parser.js');
-var INTERVAL = 10;  // 10ms << 2s
 
 module.exports = driver({
     attach: function (inputs) {
         var self = this;
         var uart = inputs['uart'];
         var parser = new Parser(self.emit.bind(self));
-        var isProcessing = false;
 
-        setInterval(function () {
-            if (!isProcessing) {
-                isProcessing = true;
-                uart.read(function (err, data) {
-                    parser.feed(data);
-                    isProcessing = false;
-                });
-            }
-        }, INTERVAL);
+        uart.on('data', function (data) {
+            parser.feed(data);
+        });
+
+        uart.on('error', function (error) {
+            parser.readError(error);
+        });
 
     },
 
     detach: function () {
-        if (this._intervalHandle) {
-            clearInterval(this._intervalHandle);
-            this._intervalHandle = null;
-        }
     },
 
     events: {

src/parser.js

@@ -25,11 +25,15 @@ Parser.prototype.readLength = function () {
     }
 }
 
+Parser.prototype.readError = function (error) {
+    this._emit('error', error);
+};
+
 Parser.prototype.readData = function () {
     if (this._buf.length >= this._nByte) {
         var lst = parseBuffer(this._buf);
         if (!lst) { 
-            this._emit('error');
+            this.readError(new Error('parse buffer failed'));
             return;
         }
         var json = parseData(lst);