Skip to content

Commit 0d4c8e4

Browse files
committed
fix: added transient connection default to identify service (libp2p#1573)
1 parent dbbcbbd commit 0d4c8e4

File tree

3 files changed

+9
-6
lines changed

3 files changed

+9
-6
lines changed

packages/libp2p/src/identify/consts.ts

+2-1
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,8 @@ export const MAX_PUSH_INCOMING_STREAMS = 1
1313
export const MAX_PUSH_OUTGOING_STREAMS = 1
1414
export const MAX_OBSERVED_ADDRESSES = 10
1515

16-
export const RUN_ON_TRANSIENT_CONNECTION = false
16+
export const RUN_ON_TRANSIENT_CONNECTION = true
17+
export const RUN_ON_CONNECTION_OPEN = true
1718

1819
export const IDENTIFY_PROTOCOL_VERSION = '0.1.0'
1920
export const MULTICODEC_IDENTIFY_PROTOCOL_NAME = 'id'

packages/libp2p/src/identify/identify.ts

+3-4
Original file line numberDiff line numberDiff line change
@@ -22,8 +22,7 @@ import {
2222
MAX_IDENTIFY_MESSAGE_SIZE,
2323
TIMEOUT,
2424
MAX_PUSH_OUTGOING_STREAMS,
25-
MAX_OBSERVED_ADDRESSES,
26-
RUN_ON_TRANSIENT_CONNECTION
25+
MAX_OBSERVED_ADDRESSES
2726
} from './consts.js'
2827
import { Identify } from './pb/message.js'
2928
import type { IdentifyService, IdentifyServiceComponents, IdentifyServiceInit } from './index.js'
@@ -61,7 +60,7 @@ export class DefaultIdentifyService implements Startable, IdentifyService {
6160
private readonly maxIdentifyMessageSize: number
6261
private readonly maxObservedAddresses: number
6362
private readonly events: EventEmitter<Libp2pEvents>
64-
private readonly runOnTransientConnection: boolean
63+
private readonly runOnTransientConnection?: boolean
6564

6665
constructor (components: IdentifyServiceComponents, init: IdentifyServiceInit) {
6766
this.started = false
@@ -81,7 +80,7 @@ export class DefaultIdentifyService implements Startable, IdentifyService {
8180
this.maxPushOutgoingStreams = init.maxPushOutgoingStreams ?? MAX_PUSH_OUTGOING_STREAMS
8281
this.maxIdentifyMessageSize = init.maxIdentifyMessageSize ?? MAX_IDENTIFY_MESSAGE_SIZE
8382
this.maxObservedAddresses = init.maxObservedAddresses ?? MAX_OBSERVED_ADDRESSES
84-
this.runOnTransientConnection = init.runOnTransientConnection ?? RUN_ON_TRANSIENT_CONNECTION
83+
this.runOnTransientConnection = init.runOnTransientConnection
8584

8685
// Store self host metadata
8786
this.host = {

packages/libp2p/src/identify/index.ts

+4-1
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,8 @@ import {
77
MULTICODEC_IDENTIFY,
88
MULTICODEC_IDENTIFY_PUSH,
99
PROTOCOL_PREFIX,
10+
RUN_ON_CONNECTION_OPEN,
11+
RUN_ON_TRANSIENT_CONNECTION,
1012
TIMEOUT
1113
} from './consts.js'
1214
import { DefaultIdentifyService } from './identify.js'
@@ -99,7 +101,8 @@ export function identifyService (init: IdentifyServiceInit = {}): (components: I
99101
maxIdentifyMessageSize: number().integer().min(0).default(MAX_IDENTIFY_MESSAGE_SIZE),
100102
maxInboundStreams: number().integer().min(0).default(MAX_INBOUND_STREAMS),
101103
maxOutboundStreams: number().integer().min(0).default(MAX_OUTBOUND_STREAMS),
102-
runOnConnectionOpen: boolean().default(true)
104+
runOnConnectionOpen: boolean().default(RUN_ON_CONNECTION_OPEN),
105+
runOnTransientConnection: boolean().default(RUN_ON_TRANSIENT_CONNECTION)
103106
}).validateSync(init)
104107

105108
return (components) => new DefaultIdentifyService(components, validatedConfig)

0 commit comments

Comments
 (0)