Merge branch 'develop' into dependabot/npm_and_yarn/chainsafe/libp2p-…

…noise-9.0.0

package.json

@@ -38,42 +38,45 @@
     "release": "aegir release"
   },
   "devDependencies": {
-    "@libp2p/interface-mocks": "^4.0.1",
+    "@libp2p/interface-mocks": "^6.1.0",
     "@libp2p/peer-id-factory": "^1.0.18",
-    "@multiformats/multiaddr": "^10.4.1",
     "@types/uuid": "^8.3.4",
     "@typescript-eslint/parser": "^5.32.0",
     "aegir": "^37.4.6",
+    "chai-bytes": "^0.1.2",
     "it-all": "^1.0.6",
     "it-first": "^1.0.7",
+    "libp2p": "^0.39.5",
     "npm-run-all": "^4.1.5",
     "prettier": "^2.7.1",
     "typescript": "^4.7.4",
     "uint8arrays": "^3.1.0",
     "wait-on": "^6.0.1"
   },
   "dependencies": {
+
     "@chainsafe/libp2p-noise": "^9.0.0",
-    "@libp2p/components": "^2.0.3",
-    "@libp2p/interface-connection": "^3.0.1",
+    "@libp2p/components": "^3.0.0",
+    "@libp2p/interface-connection": "^3.0.2",
     "@libp2p/interface-registrar": "^2.0.3",
-    "@libp2p/interface-transport": "^1.0.3",
+    "@libp2p/interface-stream-muxer": "^3.0.0",
+    "@libp2p/interface-transport": "^2.0.0",
     "@libp2p/interfaces": "^3.0.3",
     "@libp2p/logger": "^2.0.0",
     "@libp2p/multistream-select": "^3.0.0",
     "@libp2p/peer-id": "^1.1.15",
-    "@multiformats/multiaddr": "^10.4.0",
+    "@multiformats/multiaddr": "^11.0.3",
     "@protobuf-ts/plugin": "^2.8.0",
     "@protobuf-ts/protoc": "^2.8.0",
     "@protobuf-ts/runtime": "^2.8.0",
     "abortable-iterator": "^4.0.2",
     "err-code": "^3.0.1",
     "it-merge": "^1.0.4",
-    "multiformats": "^9.7.1",
+    "multiformats": "^9.9.0",
     "multihashes": "^4.0.3",
     "p-defer": "^4.0.0",
     "socket.io-client": "^4.1.2",
     "timeout-abort-controller": "^3.0.0",
-    "uuid": "^8.3.2"
+    "uuid": "^9.0.0"
   }
 }

src/maconn.ts

@@ -0,0 +1,33 @@
+import {MultiaddrConnection, MultiaddrConnectionTimeline} from "@libp2p/interface-connection";
+import { logger } from '@libp2p/logger';
+import {Multiaddr} from "@multiformats/multiaddr";
+import {Source, Sink} from "it-stream-types";
+import {nopSink, nopSource} from "./util";
+
+const log = logger('libp2p:webrtc:connection');
+
+type WebRTCMultiaddrConnectionInit = {
+  peerConnection: RTCPeerConnection;
+  remoteAddr: Multiaddr;
+  timeline: MultiaddrConnectionTimeline;
+};
+
+export class WebRTCMultiaddrConnection implements MultiaddrConnection {
+  private peerConnection: RTCPeerConnection;
+  remoteAddr: Multiaddr;
+  timeline: MultiaddrConnectionTimeline;
+
+  source: Source<Uint8Array> = nopSource
+  sink: Sink<Uint8Array, Promise<void>> = nopSink;
+
+  constructor(init: WebRTCMultiaddrConnectionInit) {
+    this.remoteAddr = init.remoteAddr;
+    this.timeline = init.timeline;
+    this.peerConnection = init.peerConnection;
+  }
+
+  async close(err?: Error | undefined): Promise<void> {
+    log.error("error closing connection", err)
+    this.peerConnection.close()
+  }
+}