diff --git a/examples/s.js b/examples/s.js index b4ce4497..856730d0 100644 --- a/examples/s.js +++ b/examples/s.js @@ -20,9 +20,9 @@ b.on('error', function (err) { b.listen() b.registerHandler('/ipfs/sparkles/1.2.3', function (stream) { -// if (err) { -// return console.log(err) -// } + // if (err) { + // return console.log(err) + // } console.log('woop got a stream') }) diff --git a/src/swarm.js b/src/swarm.js index c5278b22..cb4dda5e 100644 --- a/src/swarm.js +++ b/src/swarm.js @@ -55,8 +55,8 @@ function Swarm () { // FOR IDENTIFY self.emit('connection-unknown', conn) - // IDENTIFY DOES THIS FOR US - // conn.on('close', function () { delete self.connections[conn.peerId] }) + // IDENTIFY DOES THIS FOR US + // conn.on('close', function () { delete self.connections[conn.peerId] }) }) }).listen(self.port, ready) errorUp(self, self.listener) diff --git a/tests/swarm-test.js b/tests/swarm-test.js index bdd8f4cb..dc3e1870 100644 --- a/tests/swarm-test.js +++ b/tests/swarm-test.js @@ -76,7 +76,6 @@ experiment('BASE', function () { */ experiment('IDENTIFY', function () { test('Attach Identify, open a stream, see a peer update', function (done) { - swarmA.on('error', function (err) { console.log('A - ', err) }) @@ -103,31 +102,31 @@ experiment('IDENTIFY', function () { identifyA.on('peer-update', function (answer) {}) }, 500) }) - /* - test('Attach Identify, open a stream, reuse stream', function (done) { - var protocol = '/sparkles/3.3.3' +/* +test('Attach Identify, open a stream, reuse stream', function (done) { + var protocol = '/sparkles/3.3.3' - var identifyA = new Identify(swarmA, peerA) - var identifyB = new Identify(swarmB, peerB) + var identifyA = new Identify(swarmA, peerA) + var identifyB = new Identify(swarmB, peerB) - swarmA.registerHandler(protocol, function (stream) {}) - swarmB.registerHandler(protocol, function (stream) {}) + swarmA.registerHandler(protocol, function (stream) {}) + swarmB.registerHandler(protocol, function (stream) {}) - swarmA.openStream(peerB, protocol, function theOTHER (err, stream) { - expect(err).to.not.be.instanceof(Error) - }) - - identifyB.on('peer-update', function (answer) { - expect(Object.keys(swarmB.connections).length).to.equal(1) - swarmB.openStream(peerA, protocol, function theCALLBACK (err, stream) { - expect(err).to.not.be.instanceof(Error) - expect(Object.keys(swarmB.connections).length).to.equal(1) - done() - }) - }) - identifyA.on('peer-update', function (answer) {}) + swarmA.openStream(peerB, protocol, function theOTHER (err, stream) { + expect(err).to.not.be.instanceof(Error) }) - */ + + identifyB.on('peer-update', function (answer) { + expect(Object.keys(swarmB.connections).length).to.equal(1) + swarmB.openStream(peerA, protocol, function theCALLBACK (err, stream) { + expect(err).to.not.be.instanceof(Error) + expect(Object.keys(swarmB.connections).length).to.equal(1) + done() + }) + }) + identifyA.on('peer-update', function (answer) {}) +}) +*/ }) experiment('HARDNESS', function () {})