fix: streams created by peers must initiate with an Ack message

Author: amydevs

src/WebSocketConnection.ts

@@ -196,11 +196,7 @@ class WebSocketConnection {
 
     let stream = this.streamMap.get(streamId);
     if (stream == null) {
-      const messageType = remainder.at(0);
-      if (
-        messageType === StreamMessageType.Close ||
-        messageType === StreamMessageType.Error
-      ) {
+      if (remainder.at(0) !== StreamMessageType.Ack) {
         return;
       }
       stream = await WebSocketStream.createWebSocketStream({

tests/WebSocketStream.test.ts

@@ -53,10 +53,7 @@ jest.mock('@/WebSocketConnection', () => {
       let stream = instance.connectedConnection!.streamMap.get(streamId);
       if (stream == null) {
         const type = remainder.at(0);
-        if (
-          type === StreamMessageType.Close ||
-          type === StreamMessageType.Error
-        ) {
+        if (type !== StreamMessageType.Ack) {
           return;
         }
         stream = await WebSocketStream.createWebSocketStream({