mirror of
https://github.com/fluencelabs/js-libp2p
synced 2025-06-14 01:31:22 +00:00
fix: catch errors during identify (#1138)
Sometimes identify can be started while we are shutting down (for example) - we should just log these errors.
This commit is contained in:
@ -267,6 +267,7 @@ class IdentifyService {
|
|||||||
* @returns {Promise<void>}
|
* @returns {Promise<void>}
|
||||||
*/
|
*/
|
||||||
async _handleIdentify ({ connection, stream }) {
|
async _handleIdentify ({ connection, stream }) {
|
||||||
|
try {
|
||||||
let publicKey = new Uint8Array(0)
|
let publicKey = new Uint8Array(0)
|
||||||
if (this.peerId.pubKey) {
|
if (this.peerId.pubKey) {
|
||||||
publicKey = this.peerId.pubKey.bytes
|
publicKey = this.peerId.pubKey.bytes
|
||||||
@ -285,7 +286,6 @@ class IdentifyService {
|
|||||||
protocols
|
protocols
|
||||||
}).finish()
|
}).finish()
|
||||||
|
|
||||||
try {
|
|
||||||
await pipe(
|
await pipe(
|
||||||
[message],
|
[message],
|
||||||
lp.encode(),
|
lp.encode(),
|
||||||
@ -343,7 +343,11 @@ class IdentifyService {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Update the protocols
|
// Update the protocols
|
||||||
|
try {
|
||||||
await this.peerStore.protoBook.set(id, message.protocols)
|
await this.peerStore.protoBook.set(id, message.protocols)
|
||||||
|
} catch (/** @type {any} */ err) {
|
||||||
|
log.error('received invalid protocols', err)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
Reference in New Issue
Block a user