fix: update interfaces (libp2p#406)

Update to the latest version of libp2p interfaces

Author: achingbrain

packages/webrtc-star-transport/src/index.ts

@@ -43,7 +43,7 @@ class WebRTCStarDiscovery extends EventEmitter<PeerDiscoveryEvents> implements P
     this.started = false
   }
 
-  dispatchEvent (event: Event) {
+  dispatchEvent (event: CustomEvent) {
     if (!this.isStarted()) {
       return false
     }

packages/webrtc-star-transport/test/browser.ts

@@ -2,17 +2,30 @@
 
 import { WebRTCStar } from '../src/index.js'
 import { createEd25519PeerId } from '@libp2p/peer-id-factory'
-import { mockUpgrader } from '@libp2p/interface-compliance-tests/transport/utils'
+import { mockRegistrar, mockUpgrader } from '@libp2p/interface-compliance-tests/mocks'
 import dialTests from './transport/dial.js'
 import listenTests from './transport/listen.js'
 import discoveryTests from './transport/discovery.js'
 import filterTests from './transport/filter.js'
+import { pipe } from 'it-pipe'
 
 describe('browser RTC', () => {
   const create = async () => {
+    const protocol = '/echo/1.0.0'
+    const registrar = mockRegistrar()
+    void registrar.handle(protocol, (evt) => {
+      void pipe(
+        evt.detail.stream,
+        evt.detail.stream
+      )
+    })
+    const upgrader = mockUpgrader({
+      registrar
+    })
+
     return new WebRTCStar({
       peerId: await createEd25519PeerId(),
-      upgrader: mockUpgrader()
+      upgrader
     })
   }
 

packages/webrtc-star-transport/test/compliance.spec.ts

@@ -7,7 +7,7 @@ import { Multiaddr } from '@multiformats/multiaddr'
 import testsTransport from '@libp2p/interface-compliance-tests/transport'
 import testsDiscovery from '@libp2p/interface-compliance-tests/peer-discovery'
 import { WebRTCStar } from '../src/index.js'
-import { mockUpgrader } from '@libp2p/interface-compliance-tests/transport/utils'
+import { mockUpgrader } from '@libp2p/interface-compliance-tests/mocks'
 import pWaitFor from 'p-wait-for'
 import { peerIdFromString } from '@libp2p/peer-id'
 

packages/webrtc-star-transport/test/node.ts

@@ -5,7 +5,7 @@ import wrtc from 'wrtc'
 // @ts-expect-error no types
 import electronWebRTC from 'electron-webrtc'
 import { createEd25519PeerId } from '@libp2p/peer-id-factory'
-import { mockUpgrader } from '@libp2p/interface-compliance-tests/transport/utils'
+import { mockUpgrader } from '@libp2p/interface-compliance-tests/mocks'
 import { WebRTCStar } from '../src/index.js'
 import dialTests from './transport/dial.js'
 import listenTests from './transport/listen.js'

packages/webrtc-star-transport/test/transport/dial.ts

@@ -47,7 +47,7 @@ export default (create: () => Promise<WebRTCStar>) => {
         handler: (conn) => {
           expect(conn.remoteAddr).to.exist()
 
-          void conn.newStream(['echo'])
+          void conn.newStream(['/echo/1.0.0'])
             .then(({ stream }) => {
               void pipe(stream, stream)
             })
@@ -60,7 +60,7 @@ export default (create: () => Promise<WebRTCStar>) => {
         handler: (conn) => {
           expect(conn.remoteAddr).to.exist()
 
-          void conn.newStream(['echo'])
+          void conn.newStream(['/echo/1.0.0'])
             .then(({ stream }) => {
               void pipe(stream, stream)
             })
@@ -84,7 +84,7 @@ export default (create: () => Promise<WebRTCStar>) => {
       const [sigRefs] = ws2.sigServers.values()
 
       const conn = await ws1.dial(sigRefs.signallingAddr)
-      const { stream } = await conn.newStream(['echo'])
+      const { stream } = await conn.newStream(['/echo/1.0.0'])
       const data = uint8ArrayFromString('some data')
       const values = await pipe(
         [data],

packages/webrtc-star-transport/test/transport/instance.spec.ts

@@ -2,7 +2,7 @@
 
 import { expect } from 'aegir/utils/chai.js'
 import { WebRTCStar } from '../../src/index.js'
-import { mockUpgrader } from '@libp2p/interface-compliance-tests/transport/utils'
+import { mockUpgrader } from '@libp2p/interface-compliance-tests/mocks'
 import { peerIdFromString } from '@libp2p/peer-id'
 
 describe('instantiate the transport', () => {