mirror of
https://github.com/fluencelabs/js-libp2p
synced 2025-03-28 05:11:04 +00:00
feat: new discovery interface
This commit is contained in:
parent
6c3dd4b780
commit
5dd5d37f6a
17
src/index.js
17
src/index.js
@ -61,7 +61,7 @@ class Node {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Attach discovery mechanisms
|
// Attach discovery mechanisms
|
||||||
if (this.discovery) {
|
if (this.modules.discovery) {
|
||||||
let discoveries = this.modules.discovery
|
let discoveries = this.modules.discovery
|
||||||
discoveries = Array.isArray(discoveries) ? discoveries : [discoveries]
|
discoveries = Array.isArray(discoveries) ? discoveries : [discoveries]
|
||||||
discoveries.forEach((discovery) => {
|
discoveries.forEach((discovery) => {
|
||||||
@ -115,6 +115,13 @@ class Node {
|
|||||||
}
|
}
|
||||||
|
|
||||||
this.isOnline = true
|
this.isOnline = true
|
||||||
|
|
||||||
|
if (this.modules.discovery) {
|
||||||
|
this.modules.discovery.forEach((discovery) => {
|
||||||
|
setImmediate(() => discovery.start(() => {}))
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
callback()
|
callback()
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
@ -124,6 +131,14 @@ class Node {
|
|||||||
*/
|
*/
|
||||||
stop (callback) {
|
stop (callback) {
|
||||||
this.isOnline = false
|
this.isOnline = false
|
||||||
|
|
||||||
|
if (this.modules.discovery) {
|
||||||
|
this.modules.discovery.forEach((discovery) => {
|
||||||
|
console.log(discovery)
|
||||||
|
setImmediate(() => discovery.stop(() => {}))
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
this.swarm.close(callback)
|
this.swarm.close(callback)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user