after many solo-bikeshedding, figured out that I could make it way simpler

This commit is contained in:
David Dias 2015-09-15 19:43:55 +01:00
parent f23ca14556
commit 470d8bfc6a

View File

@ -1,46 +1,10 @@
var tcp = require('net')
var async = require('async')
exports = module.exports
exports.dial = function (peerInfo, callback) {
var socket
async.eachSeries(peerInfo.multiaddrs, function (multiaddr, next) {
if (!multiaddr.protoNames().indexOf('tcp')) {
return next()
}
if (socket) {
return next()
}
var tmp = tcp.connect(multiaddr.toOptions(), function connected () {
socket = tmp
next()
})
tmp.once('error', function (err) {
console.log(multiaddr.toString(), 'on',
peerInfo.id.toB58String(), 'not available', err)
next()
})
}, function done () {
if (!socket) {
return callback(new Error('Not able to open a scoket with peer - ',
peerInfo.id.toB58String()))
}
callback(null, socket)
})
exports.dial = function (multiaddr, options) {
options.ready = options.ready || function noop () {}
return tcp.connect(multiaddr.toOptions(), options.ready)
}
exports.listen = function (options, callback, readyCallback) {
options.port = options.port || 4001
var listener = tcp.createServer(function (socket) {
callback(null, socket)
})
listener.listen(options.port, readyCallback)
return listener
}
exports.createListener = tcp.createServer