diff --git a/package.json b/package.json index 42299d9..4e66750 100644 --- a/package.json +++ b/package.json @@ -143,7 +143,7 @@ "dependencies": { "@libp2p/interface-connection": "^5.0.0", "@libp2p/interface-metrics": "^4.0.0", - "@libp2p/interface-transport": "^3.0.0", + "@libp2p/interface-transport": "^4.0.0", "@libp2p/interfaces": "^3.2.0", "@libp2p/logger": "^2.0.0", "@libp2p/utils": "^3.0.2", @@ -152,8 +152,8 @@ "stream-to-it": "^0.2.2" }, "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", "aegir": "^38.1.0", "it-all": "^3.0.1", "it-pipe": "^3.0.1", diff --git a/test/connection.spec.ts b/test/connection.spec.ts index 8712885..1468f37 100644 --- a/test/connection.spec.ts +++ b/test/connection.spec.ts @@ -4,6 +4,7 @@ import { multiaddr } from '@multiformats/multiaddr' import { mockUpgrader } from '@libp2p/interface-mocks' import type { Connection } from '@libp2p/interface-connection' import type { Transport, Upgrader } from '@libp2p/interface-transport' +import { EventEmitter } from '@libp2p/interfaces/events' describe('valid localAddr and remoteAddr', () => { let transport: Transport @@ -11,7 +12,9 @@ describe('valid localAddr and remoteAddr', () => { beforeEach(() => { transport = tcp()() - upgrader = mockUpgrader() + upgrader = mockUpgrader({ + events: new EventEmitter() + }) }) const ma = multiaddr('/ip4/127.0.0.1/tcp/0') diff --git a/test/listen-dial.spec.ts b/test/listen-dial.spec.ts index cd884de..0cbdc14 100644 --- a/test/listen-dial.spec.ts +++ b/test/listen-dial.spec.ts @@ -10,6 +10,7 @@ import { fromString as uint8ArrayFromString } from 'uint8arrays/from-string' import type { Transport, Upgrader } from '@libp2p/interface-transport' import pDefer from 'p-defer' import type { MultiaddrConnection } from '@libp2p/interface-connection' +import { EventEmitter } from '@libp2p/interfaces/events' const isCI = process.env.CI @@ -20,7 +21,9 @@ describe('listen', () => { beforeEach(() => { transport = tcp()() - upgrader = mockUpgrader() + upgrader = mockUpgrader({ + events: new EventEmitter() + }) }) afterEach(async () => { @@ -171,7 +174,8 @@ describe('dial', () => { ) }) upgrader = mockUpgrader({ - registrar + registrar, + events: new EventEmitter() }) transport = tcp()() diff --git a/test/max-connections-close.spec.ts b/test/max-connections-close.spec.ts index 1cb51c4..b588fb4 100644 --- a/test/max-connections-close.spec.ts +++ b/test/max-connections-close.spec.ts @@ -5,6 +5,7 @@ import { mockUpgrader } from '@libp2p/interface-mocks' import { multiaddr } from '@multiformats/multiaddr' import { tcp } from '../src/index.js' import type { TCPListener } from '../src/listener.js' +import { EventEmitter } from '@libp2p/interfaces/events' describe('close server on maxConnections', () => { const afterEachCallbacks: Array<() => Promise | any> = [] @@ -21,7 +22,9 @@ describe('close server on maxConnections', () => { const seenRemoteConnections = new Set() const trasnport = tcp({ closeServerOnMaxConnections: { listenBelow, closeAbove } })() - const upgrader = mockUpgrader() + const upgrader = mockUpgrader({ + events: new EventEmitter() + }) const listener = trasnport.createListener({ upgrader }) as TCPListener // eslint-disable-next-line @typescript-eslint/promise-function-async afterEachCallbacks.push(() => listener.close()) diff --git a/test/max-connections.spec.ts b/test/max-connections.spec.ts index 24551a0..3e2d888 100644 --- a/test/max-connections.spec.ts +++ b/test/max-connections.spec.ts @@ -4,6 +4,7 @@ import { promisify } from 'node:util' import { mockUpgrader } from '@libp2p/interface-mocks' import { multiaddr } from '@multiformats/multiaddr' import { tcp } from '../src/index.js' +import { EventEmitter } from '@libp2p/interfaces/events' describe('maxConnections', () => { const afterEachCallbacks: Array<() => Promise | any> = [] @@ -20,7 +21,9 @@ describe('maxConnections', () => { const seenRemoteConnections = new Set() const transport = tcp({ maxConnections })() - const upgrader = mockUpgrader() + const upgrader = mockUpgrader({ + events: new EventEmitter() + }) const listener = transport.createListener({ upgrader }) // eslint-disable-next-line @typescript-eslint/promise-function-async afterEachCallbacks.push(() => listener.close())