fluencelabs/js-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p synced 2025-04-03 00:01:04 +00:00
Code Issues Projects Releases Wiki Activity

feat: support websockets, even if no listener is added

Browse Source
This commit is contained in:
David Dias 2016-11-27 18:20:25 +00:00
parent e10ec13c33
commit 40fdc4147c
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/index.js
View File

@ -83,13 +83,22 @@ class Node {
if (!this.modules.transport) { if (!this.modules.transport) {
return callback(new Error('no transports were present')) return callback(new Error('no transports were present'))
} }
let ws
let transports = this.modules.transport let transports = this.modules.transport
transports = Array.isArray(transports) ? transports : [transports] transports = Array.isArray(transports) ? transports : [transports]
const multiaddrs = this.peerInfo.multiaddrs const multiaddrs = this.peerInfo.multiaddrs
transports.forEach((transport) => { transports.forEach((transport) => {
if (transport.filter(multiaddrs).length > 0) { if (transport.filter(multiaddrs).length > 0) {
this.swarm.transport.add( this.swarm.transport.add(
transport.tag || transport.constructor.name, transport) transport.tag || transport.constructor.name, transport)
} else if (transport.constructor &&
transport.constructor.name === 'WebSockets') {
// TODO find a cleaner way to signal that a transport is always
// used for dialing, even if no listener
ws = transport
} }
}) })
@ -97,6 +106,9 @@ class Node {
if (err) { if (err) {
return callback(err) return callback(err)
} }
if (ws) {
this.swarm.transport.add(ws.tag || ws.constructor.name, ws)
}
this.isOnline = true this.isOnline = true
callback() callback()