wait for send to complete

Author: sevenbitbyte

public/example.html

@@ -10,6 +10,19 @@
 
 <script>
 
+function makeid(length) {
+    let result = '';
+    const characters = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789';
+    const charactersLength = characters.length;
+    let counter = 0;
+    while (counter < length) {
+      result += characters.charAt(Math.floor(Math.random() * charactersLength));
+      counter += 1;
+    }
+    return result;
+}
+
+
 async function init(){
 
   config = new Dataparty.Config.MemoryConfig({
@@ -58,6 +71,36 @@
     console.log(name, msg)
   })
 
+
+  let text = makeid(500*1024)
+
+  let first = true
+
+  async function onTimeout(){
+
+    let num = first ? 2:1
+
+    first = false
+
+    let statusId = 'publish:'+timeTopic.name+':'+ (party.comms.ros.idCounter+num)
+
+    console.log(statusId)
+
+    
+    party.comms.once(statusId,(status)=>{
+      console.log('status', status)
+      
+      setTimeout(onTimeout, 0)
+    })
+    
+    await timeTopic.publish({number: Date.now(), text:text})
+    
+
+  }
+
+  window.onTimeout = onTimeout
+
+  //onTimeout()
 }
 
 init()

src/comms/peer-comms.js

@@ -128,7 +128,7 @@ class PeerComms extends SocketComms {
           ...op.result 
         }
 
-        debug(response.id, response.state, response.stats.duration_ms, 'ms')
+        debug('finished', response.id, response.state, response.stats.duration_ms, 'ms')
 
         this.send(response)
       })

src/comms/ros-shim.js

@@ -26,6 +26,9 @@ class RosShim extends ROSLIB.Ros {
 
 
     handleMessage(message) {
+
+      console.log(message)
+
         if (message.op === 'publish') {
           debug('publish op')
           this.emit(message.topic, message.msg);
@@ -34,6 +37,9 @@ class RosShim extends ROSLIB.Ros {
         } else if (message.op === 'call_service') {
             this.emit(message.service, message);
         }*/ else if(message.op === 'status'){
+
+          console.log('status', message)
+
           if(message.id){
             this.emit('status:'+message.id, message);
           } else {