Confirm sent packets via a packetssent message

noflo · Mar 21, 2018 · bb4d6f5 · bb4d6f5
1 parent 3f8fd7e
commit bb4d6f5
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/src/protocol/Runtime.coffee b/src/protocol/Runtime.coffee
@@ -96,7 +96,13 @@ class RuntimeProtocol extends EventEmitter
       when 'packet' then @sendPacket payload, (err) =>
         if err
           @sendError err.message, context
-        # TODO: Ack packet send
+          return
+        @send 'packetsent',
+          port: payload.port
+          event: payload.event
+          graph: payload.graph
+          payload: payload.payload
+        , context
         return
 
   getRuntime: (payload, context) ->
@@ -227,5 +233,6 @@ class RuntimeProtocol extends EventEmitter
     port = findPort network.network, payload.port, true
     return callback new Error "Cannot find internal port for #{payload.port}" if not port
     sendToInport port, payload.event, payload.payload
+    callback()
 
 module.exports = RuntimeProtocol