fix(transport): Use connection in WebSocket ID

openwallet-foundation · Aug 24, 2023 · a852522 · a852522
1 parent 93276de
commit a852522
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/packages/core/src/transport/WsOutboundTransport.ts b/packages/core/src/transport/WsOutboundTransport.ts
@@ -47,8 +47,9 @@ export class WsOutboundTransport implements OutboundTransport {
       throw new AriesFrameworkError("Missing connection or endpoint. I don't know how and where to send the message.")
     }
 
-    const isNewSocket = !this.hasOpenSocket(endpoint)
-    const socket = await this.resolveSocket({ socketId: endpoint, endpoint, connectionId })
+    const socketId = `${endpoint}-${connectionId}`
+    const isNewSocket = !this.hasOpenSocket(socketId)
+    const socket = await this.resolveSocket({ socketId, endpoint, connectionId })
 
     socket.send(Buffer.from(JSON.stringify(payload)))