fluencelabs/js-libp2p-tcp
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p-tcp synced 2025-04-25 23:42:32 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #4 from diasdavid/feature/multiaddr-freshness

Browse Source 
Multiaddr freshness
This commit is contained in:
David Dias 2016-03-04 23:29:07 +00:00
commit 8fac0f9dd6
1 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/index.js
View File

@ -1,6 +1,7 @@
const debug = require('debug') // const debug = require('debug')
const log = debug('libp2p:tcp') // const log = debug('libp2p:tcp')
const tcp = require('net') const tcp = require('net')
const multiaddr = require('multiaddr')
exports = module.exports = TCP exports = module.exports = TCP
@ -31,13 +32,24 @@ function TCP () {
} }
var count = 0 var count = 0
const freshMultiaddrs = []
multiaddrs.forEach((m) => { multiaddrs.forEach((m) => {
const listener = tcp.createServer(handler) const listener = tcp.createServer(handler)
listener.listen(m.toOptions(), () => { listener.listen(m.toOptions(), () => {
log('listening on: ', m.toString()) // Node.js likes to convert addr to IPv6 (when 0.0.0.0 for e.g)
const address = listener.address()
if (m.toString().indexOf('ip4')) {
m = m.decapsulate('tcp')
m = m.encapsulate('/tcp/' + address.port)
freshMultiaddrs.push(m)
}
if (address.family === 'IPv6') {
freshMultiaddrs.push(multiaddr('/ip6/' + address.address + '/tcp/' + address.port))
}
if (++count === multiaddrs.length) { if (++count === multiaddrs.length) {
callback() callback(null, freshMultiaddrs)
} }
}) })
listeners.push(listener) listeners.push(listener)