Skip to content
This repository has been archived by the owner on Apr 24, 2023. It is now read-only.

fix: update interfaces #406

Merged
merged 1 commit into from
Feb 21, 2022
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion packages/webrtc-star-transport/src/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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
}
Expand Down
17 changes: 15 additions & 2 deletions packages/webrtc-star-transport/test/browser.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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
})
}

Expand Down
2 changes: 1 addition & 1 deletion packages/webrtc-star-transport/test/compliance.spec.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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'

Expand Down
2 changes: 1 addition & 1 deletion packages/webrtc-star-transport/test/node.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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'
Expand Down
6 changes: 3 additions & 3 deletions packages/webrtc-star-transport/test/transport/dial.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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)
})
Expand All @@ -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)
})
Expand All @@ -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],
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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', () => {
Expand Down