Compare commits

...

4 Commits

Author SHA1 Message Date
7068aae527 chore: release version v0.4.0 2017-01-28 21:13:34 +00:00
d632451f92 chore: update contributors 2017-01-28 21:13:34 +00:00
8047e3fe64 feat: new discovery interface 2017-01-28 21:13:18 +00:00
35af31023c chore: update deps 2017-01-28 20:59:29 +00:00
2 changed files with 24 additions and 9 deletions

View File

@ -1,6 +1,6 @@
{ {
"name": "libp2p", "name": "libp2p",
"version": "0.3.1", "version": "0.4.0",
"description": "JavaScript Skeleton for libp2p bundles", "description": "JavaScript Skeleton for libp2p bundles",
"main": "src/index.js", "main": "src/index.js",
"scripts": { "scripts": {
@ -35,17 +35,17 @@
"homepage": "https://github.com/diasdavid/js-libp2p", "homepage": "https://github.com/diasdavid/js-libp2p",
"devDependencies": { "devDependencies": {
"chai": "^3.5.0", "chai": "^3.5.0",
"aegir": "^9.1.2", "aegir": "^9.4.0",
"pre-commit": "^1.1.1" "pre-commit": "^1.2.2"
}, },
"dependencies": { "dependencies": {
"libp2p-ping": "^0.3.0", "libp2p-ping": "^0.3.0",
"libp2p-swarm": "^0.26.3", "libp2p-swarm": "^0.26.13",
"mafmt": "^2.1.2", "mafmt": "^2.1.6",
"multiaddr": "^2.1.1", "multiaddr": "^2.2.0",
"peer-book": "^0.3.0", "peer-book": "^0.3.0",
"peer-id": "^0.8.0", "peer-id": "^0.8.1",
"peer-info": "^0.8.1" "peer-info": "^0.8.2"
}, },
"contributors": [ "contributors": [
"David Dias <daviddias.p@gmail.com>", "David Dias <daviddias.p@gmail.com>",

View File

@ -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)
} }