From bb4d6f5fab5e69604cb80457ed2a5e1fcc86099b Mon Sep 17 00:00:00 2001 From: Henri Bergius Date: Wed, 21 Mar 2018 23:43:22 +0100 Subject: [PATCH] Confirm sent packets via a packetssent message --- src/protocol/Runtime.coffee | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/src/protocol/Runtime.coffee b/src/protocol/Runtime.coffee index b724632..1e5e022 100644 --- 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