Merge branch 'property-sendingInterval'

shengyuan · shengyuan · commit 246091247d0d · 2019-07-26T15:56:59.000+08:00
diff --git a/examples/send-interval.html b/examples/send-interval.html
@@ -0,0 +1,57 @@
+<html>
+
+<head>
+  <script src="../dist/webduino-all.js"></script>
+  <script>
+
+  (async function () {
+    var board, led, vv;
+    var tt = 0;
+
+    window.sboard = board = new webduino.WebArduino('O9Qq');
+
+    board.on('ready', async () => {
+      board.systemReset();
+      board.samplingInterval = 250;
+      board.sendingInterval = 50;
+      led = new webduino.module.Led(board, board.getDigitalPin(13));
+      vv = 0;
+
+      for (var count = 0; count < 100; count++) {
+        if (vv == 0) {
+          vv = 1;
+          led.on(() => msg(`${tt++}_light`));
+        } else {
+          vv = 0;
+          led.off(() => msg(`${tt++}_dark`));
+        }
+        await delay(0.02);
+      }
+      await delay(0.5);
+      msg(`end, ${tt}`);
+      console.log('end');
+    });
+
+    function delay(t) {
+      return new Promise(function (resolve, reject) {
+        setTimeout(function () {
+          resolve();
+        }, 1000 * t);
+      });
+    }
+
+    function msg(val) {
+      console.log('TCL: msg -> val', val);
+      document.getElementById("demo-area-01-show").innerHTML = val;
+    }
+
+  })();
+  </script>
+</head>
+
+<body>
+  <div>start</div>
+  <div id='demo-area-01-show'></div>
+</body>
+
+</html>
diff --git a/package.json b/package.json
@@ -12,6 +12,7 @@
   "license": "MIT",
   "scripts": {
     "lint": "eslint src/**/*.js",
+    "dev": "gulp watch",
     "build": "./node_modules/.bin/gulp"
   },
   "devDependencies": {
diff --git a/src/core/Board.js b/src/core/Board.js
@@ -96,6 +96,8 @@
     this._transport = null;
     this._pinStateEventCenter = new EventEmitter();
     this._logger = new Logger('Board');
+    this._sendingInterval = 0;
+    this._sendingRec = [];
 
     this._initialVersionResultHandler = onInitialVersionResult.bind(this);
     this._openHandler = onOpen.bind(this);
@@ -211,6 +213,16 @@
       }
     },
 
+    sendingInterval: {
+      get: function () {
+        return this._sendingInterval;
+      },
+      set: function (interval) {
+        if (typeof interval !== 'number') return;
+        this._sendingInterval = interval < 0 ? 0: interval;
+      }
+    },
+
     isReady: {
       get: function () {
         return this._isReady;
@@ -865,7 +877,24 @@
   };
 
   proto.send = function (data) {
-    this.isConnected && this._transport.send(data);
+    if (!this.isConnected) return;
+    if (this.sendingInterval === 0) {
+      this._transport.send(data);
+      return;
+    }
+
+    var idx = this._sendingRec.findIndex(function (val) {
+      return val.value.toString() === data.toString();
+    });
+    if (idx !== -1) {
+      if (Date.now() - this._sendingRec[idx].timestamp < this.sendingInterval) return;
+      this._sendingRec.splice(idx, 1);
+    }
+    this._sendingRec.push({
+      value: data.slice(),
+      timestamp: Date.now()
+    });
+    this._transport.send(data);
   };
 
   proto.close = function (callback) {
