now issue ble written event for proper IDE throttling

Author: gfwilliams

README.md

@@ -190,6 +190,8 @@ on a Puck.js BLE UART connection with:
 /ble/data/c7:f9:36:dd:b0:ca/nus/nus_rx => "23\r\n"
 ```
 
+Once a `/ble/write/DEVICE/SERVICE/CHARACTERISTIC` has been executed, a `/ble/written/DEVICE/SERVICE/CHARACTERISTIC` packet will be sent in response.
+
 **You can also gather historical data over MQTT - see the `History` section
 below.**
 

lib/connect.js

@@ -191,7 +191,7 @@ function setNotBusy() {
 
 
 /* Write to the given device */
-exports.write = function(device, service, characteristic, data) {
+exports.write = function(device, service, characteristic, data, callback) {
   if (isBusy) {
     queue.push(function() { exports.write(device,service,characteristic,data); });
     return;
@@ -207,6 +207,7 @@ exports.write = function(device, service, characteristic, data) {
        writeToCharacteristic(char, util.obj2buf(data), function() {
            log(connection.name+": Written.");
            setNotBusy();
+           if (callback) callback();
          });
      });
   });

lib/mqttclient.js

@@ -74,7 +74,9 @@ client.on('message', function (topic, message) {
        var device = discovery.inRange[id].peripheral;
        var service = attributes.lookup(path[3].toLowerCase());
        var charc = attributes.lookup(path[4].toLowerCase());
-       connect.write(device, service, charc, convertMessage(message));
+       connect.write(device, service, charc, convertMessage(message), function() {
+         client.publish("/ble/written/"+topic.substr("/ble/write/".length), message);
+       });
       } else {
         log("Write to "+id+" but not in range");
       }

www/ide.html

@@ -16,6 +16,7 @@
   var websocket;
   var pingInterval;
   var onPong;
+  var onDataWritten;
   // IDE IFrame
   var IDE = EspruinoIDE(document.getElementById('ideframe'));
   IDE.onready = function(data) {
@@ -65,6 +66,7 @@
     // Subscribe to data
     websocket.subscribe("/ble/data/"+deviceAddress+"/nus/nus_rx");
     websocket.subscribe("/ble/pong/"+deviceAddress);
+    websocket.subscribe("/ble/written/"+deviceAddress+"/nus/nus_tx");
     // request notifications of serial RX
     sendMessage("/ble/notify/"+deviceAddress+"/nus/nus_rx","");
     // send a ping so when we get a pong we know we're connected
@@ -76,8 +78,8 @@
   };
   IDE.onwritecb = function(data, callback) {
     if (!deviceAddress) return;
+    onDataWritten = callback;    
     sendMessage("/ble/write/"+deviceAddress+"/nus/nus_tx", data);
-    setTimeout(callback, 100); // force a delay when sending data
   };
   IDE.ondisconnect = function(data) {
     closeSerial();    
@@ -104,6 +106,9 @@
         // When we get a 'pong' back, call this - so we know we're connected
         if (onPong) onPong();
         onPong = undefined;
+      } else if (deviceAddress && message.destinationName == "/ble/written/"+deviceAddress+"/nus/nus_tx") {
+        if (onDataWritten) onDataWritten();
+        onDataWritten = undefined;
       } else if (message.destinationName.substr(0,15)=="/ble/advertise/") {
         // advertising for new devices
         var address = message.destinationName.substr(15);