diff --git a/.aegir.js b/.aegir.js index 54329933be..2e8780e35f 100644 --- a/.aegir.js +++ b/.aegir.js @@ -1,6 +1,7 @@ import { multiaddr } from '@multiformats/multiaddr' import { mockRegistrar, mockUpgrader } from '@libp2p/interface-mocks' import { pipe }from 'it-pipe' +import { EventEmitter } from '@libp2p/interfaces/events' /** @type {import('aegir/types').PartialOptions} */ export default { @@ -17,7 +18,8 @@ export default { ) }) const upgrader = mockUpgrader({ - registrar + registrar, + events: new EventEmitter() }) const ws = webSockets()() diff --git a/package.json b/package.json index fccb1e8319..482dc45bb8 100644 --- a/package.json +++ b/package.json @@ -160,7 +160,7 @@ }, "dependencies": { "@libp2p/interface-connection": "^5.0.0", - "@libp2p/interface-transport": "^3.0.0", + "@libp2p/interface-transport": "^4.0.0", "@libp2p/interfaces": "^3.0.3", "@libp2p/logger": "^2.0.0", "@libp2p/utils": "^3.0.2", @@ -175,8 +175,8 @@ "ws": "^8.12.1" }, "devDependencies": { - "@libp2p/interface-mocks": "^10.0.0", - "@libp2p/interface-transport-compliance-tests": "^3.0.0", + "@libp2p/interface-mocks": "^11.0.0", + "@libp2p/interface-transport-compliance-tests": "^4.0.0", "@types/ws": "^8.2.2", "aegir": "^38.1.7", "is-loopback-addr": "^2.0.1", diff --git a/test/browser.ts b/test/browser.ts index 7d2e5054f8..ed5158017d 100644 --- a/test/browser.ts +++ b/test/browser.ts @@ -10,6 +10,7 @@ import { mockUpgrader } from '@libp2p/interface-mocks' import { isBrowser, isWebWorker } from 'wherearewe' import type { Connection } from '@libp2p/interface-connection' import type { Transport } from '@libp2p/interface-transport' +import { EventEmitter } from '@libp2p/interfaces/events' const protocol = '/echo/1.0.0' @@ -20,7 +21,11 @@ describe('libp2p-websockets', () => { beforeEach(async () => { ws = webSockets()() - conn = await ws.dial(ma, { upgrader: mockUpgrader() }) + conn = await ws.dial(ma, { + upgrader: mockUpgrader({ + events: new EventEmitter() + }) + }) }) afterEach(async () => { diff --git a/test/node.ts b/test/node.ts index 5de5846aec..56ef415655 100644 --- a/test/node.ts +++ b/test/node.ts @@ -21,6 +21,7 @@ import type { Listener, Transport } from '@libp2p/interface-transport' import type { Uint8ArrayList } from 'uint8arraylist' import type { Source } from 'it-stream-types' import './compliance.node.js' +import { EventEmitter } from '@libp2p/interfaces/events' async function * toBuffers (source: Source): AsyncGenerator { for await (const list of source) { @@ -39,7 +40,8 @@ void registrar.handle(protocol, (evt) => { ) }) const upgrader = mockUpgrader({ - registrar + registrar, + events: new EventEmitter() }) describe('instantiate the transport', () => {