fix: update interfaces (#168)

Update to the latest interfaces version

package.json

@@ -149,11 +149,12 @@
     "it-pushable": "^2.0.1",
     "it-stream-types": "^1.0.4",
     "uint8arraylist": "^1.4.0",
+    "uint8arrays": "^3.0.0",
     "varint": "^6.0.0"
   },
   "devDependencies": {
-    "@libp2p/interface-compliance-tests": "^1.1.21",
-    "@libp2p/interfaces": "^1.3.20",
+    "@libp2p/interface-compliance-tests": "^1.1.32",
+    "@libp2p/interfaces": "^1.3.31",
     "@types/varint": "^6.0.0",
     "aegir": "^37.0.10",
     "cborg": "^1.8.1",
@@ -163,7 +164,6 @@
     "it-foreach": "^0.1.1",
     "it-map": "^1.0.6",
     "p-defer": "^4.0.0",
-    "random-int": "^3.0.0",
-    "uint8arrays": "^3.0.0"
+    "random-int": "^3.0.0"
   }
 }

src/mplex.ts

@@ -4,7 +4,7 @@ import { abortableSource } from 'abortable-iterator'
 import { encode } from './encode.js'
 import { decode } from './decode.js'
 import { restrictSize } from './restrict-size.js'
-import { MessageTypes, MessageTypeNames, Message } from './message-types.js'
+import { MessageTypes, MessageTypeNames, Message, ReceiverMessageTypes, InitiatorMessageTypes } from './message-types.js'
 import { createStream } from './stream.js'
 import { toString as uint8ArrayToString } from 'uint8arrays'
 import { trackedMap } from '@libp2p/tracked-map'
@@ -233,7 +233,13 @@ export class MplexStreamMuxer implements StreamMuxer {
     const stream = list.get(id)
 
     if (stream == null) {
-      return log('missing stream %s', id)
+      log('missing stream %s', id)
+
+      // send a reset
+      this._source.push({ id, type: InitiatorMessageTypes.RESET })
+      this._source.push({ id, type: ReceiverMessageTypes.RESET })
+
+      return
     }
 
     switch (type) {