Fix tracking expected acks per client

Signed-off-by: Nicko Guyer <[email protected]>
hyperledger · Feb 26, 2024 · 2aef64d · 2aef64d
1 parent 0b76326
commit 2aef64d
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/eventstream-proxy/eventstream-proxy.base.ts b/src/eventstream-proxy/eventstream-proxy.base.ts
@@ -69,6 +69,11 @@ export abstract class EventStreamProxyBase extends WebSocketEventsBase {
 
   handleConnection(client: WebSocketEx) {
     super.handleConnection(client);
+
+    if (!this.awaitingAck.get(client.id)) {
+      this.awaitingAck.set(client.id, []);
+    }
+
     client.on('message', async (message: string) => {
       const action = JSON.parse(message) as WebSocketActionBase;
       switch (action.type) {