Skip to content
This repository was archived by the owner on Jun 26, 2023. It is now read-only.

Commit c760e95

Browse files
committed
fix: update mock network components use
1 parent 79a5d8f commit c760e95

File tree

4 files changed

+19
-19
lines changed

4 files changed

+19
-19
lines changed

packages/interface-mocks/src/connection-manager.ts

+7-7
Original file line numberDiff line numberDiff line change
@@ -8,21 +8,21 @@ import errCode from 'err-code'
88
import type { Registrar } from '@libp2p/interface-registrar'
99
import type { PubSub } from '@libp2p/interface-pubsub'
1010

11-
export interface NetworkComponents {
11+
export interface MockNetworkComponents {
1212
peerId: PeerId
1313
registrar: Registrar
1414
connectionManager: ConnectionManager
1515
pubsub?: PubSub
1616
}
1717

1818
class MockNetwork {
19-
private components: NetworkComponents[] = []
19+
private components: MockNetworkComponents[] = []
2020

21-
addNode (components: NetworkComponents): void {
21+
addNode (components: MockNetworkComponents): void {
2222
this.components.push(components)
2323
}
2424

25-
getNode (peerId: PeerId): NetworkComponents {
25+
getNode (peerId: PeerId): MockNetworkComponents {
2626
for (const components of this.components) {
2727
if (peerId.equals(components.peerId)) {
2828
return components
@@ -41,10 +41,10 @@ export const mockNetwork = new MockNetwork()
4141

4242
class MockConnectionManager extends EventEmitter<ConnectionManagerEvents> implements ConnectionManager, Startable {
4343
private connections: Connection[] = []
44-
private readonly components: NetworkComponents
44+
private readonly components: MockNetworkComponents
4545
private started = false
4646

47-
constructor (components: NetworkComponents) {
47+
constructor (components: MockNetworkComponents) {
4848
super()
4949

5050
this.components = components
@@ -154,6 +154,6 @@ class MockConnectionManager extends EventEmitter<ConnectionManagerEvents> implem
154154
}
155155
}
156156

157-
export function mockConnectionManager (components: NetworkComponents) {
157+
export function mockConnectionManager (components: MockNetworkComponents) {
158158
return new MockConnectionManager(components)
159159
}

packages/interface-mocks/src/index.ts

+1-1
Original file line numberDiff line numberDiff line change
@@ -8,4 +8,4 @@ export { mockRegistrar } from './registrar.js'
88
export { mockUpgrader } from './upgrader.js'
99
export { mockDuplex } from './duplex.js'
1010
export type { MockUpgraderInit } from './upgrader.js'
11-
export type { NetworkComponents } from './connection-manager.js'
11+
export type { MockNetworkComponents } from './connection-manager.js'

packages/interface-pubsub-compliance-tests/src/connection-handlers.ts

+9-9
Original file line numberDiff line numberDiff line change
@@ -11,14 +11,14 @@ import { start, stop } from '@libp2p/interfaces/startable'
1111
import { createComponents } from './utils.js'
1212
import { pEvent } from 'p-event'
1313
import { mockNetwork } from '@libp2p/interface-mocks'
14-
import type { NetworkComponents } from '@libp2p/interface-mocks'
14+
import type { MockNetworkComponents } from '@libp2p/interface-mocks'
1515

1616
export default (common: TestSetup<PubSub, PubSubArgs>) => {
1717
describe('pubsub connection handlers', () => {
1818
let psA: PubSub
1919
let psB: PubSub
20-
let componentsA: NetworkComponents
21-
let componentsB: NetworkComponents
20+
let componentsA: MockNetworkComponents
21+
let componentsB: MockNetworkComponents
2222

2323
describe('nodes send state on connection', () => {
2424
// Create pubsub nodes and connect them
@@ -85,8 +85,8 @@ export default (common: TestSetup<PubSub, PubSubArgs>) => {
8585
describe('pubsub started before connect', () => {
8686
let psA: PubSub
8787
let psB: PubSub
88-
let componentsA: NetworkComponents
89-
let componentsB: NetworkComponents
88+
let componentsA: MockNetworkComponents
89+
let componentsB: MockNetworkComponents
9090

9191
// Create pubsub nodes and start them
9292
beforeEach(async () => {
@@ -159,8 +159,8 @@ export default (common: TestSetup<PubSub, PubSubArgs>) => {
159159
describe('pubsub started after connect', () => {
160160
let psA: PubSub
161161
let psB: PubSub
162-
let componentsA: NetworkComponents
163-
let componentsB: NetworkComponents
162+
let componentsA: MockNetworkComponents
163+
let componentsB: MockNetworkComponents
164164

165165
// Create pubsub nodes
166166
beforeEach(async () => {
@@ -240,8 +240,8 @@ export default (common: TestSetup<PubSub, PubSubArgs>) => {
240240
describe('pubsub with intermittent connections', () => {
241241
let psA: PubSub
242242
let psB: PubSub
243-
let componentsA: NetworkComponents
244-
let componentsB: NetworkComponents
243+
let componentsA: MockNetworkComponents
244+
let componentsB: MockNetworkComponents
245245

246246
// Create pubsub nodes and start them
247247
beforeEach(async () => {

packages/interface-pubsub-compliance-tests/src/utils.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ import type { PubSub, SubscriptionChangeData } from '@libp2p/interface-pubsub'
44
import type { PeerId } from '@libp2p/interface-peer-id'
55
import { createEd25519PeerId } from '@libp2p/peer-id-factory'
66
import { mockConnectionManager, mockRegistrar, mockNetwork } from '@libp2p/interface-mocks'
7-
import type { NetworkComponents } from '@libp2p/interface-mocks/src/connection-manager'
7+
import type { MockNetworkComponents } from '@libp2p/interface-mocks'
88

99
export async function waitForSubscriptionUpdate (a: PubSub, b: PeerId) {
1010
await pWaitFor(async () => {
@@ -14,7 +14,7 @@ export async function waitForSubscriptionUpdate (a: PubSub, b: PeerId) {
1414
})
1515
}
1616

17-
export async function createComponents (): Promise<NetworkComponents> {
17+
export async function createComponents (): Promise<MockNetworkComponents> {
1818
const components: any = {
1919
peerId: await createEd25519PeerId(),
2020
registrar: mockRegistrar()

0 commit comments

Comments
 (0)