Merge pull request #40 from libp2p/fix/timeout

fix(handshake): improve timeout handling

src/handshake/index.js

@@ -17,6 +17,9 @@ module.exports = function handshake (state) {
     state.cleanSecrets()
 
     if (err) {
+      if (err === true) {
+        err = new Error('Stream ended prematurely')
+      }
       state.shake.abort(err)
     }
   })

src/index.js

@@ -25,12 +25,11 @@ module.exports = {
       callback = (err) => {
         if (err) {
           console.error(err)
-          throw err
         }
       }
     }
 
-    const state = new State(local, key, callback)
+    const state = new State(local, key, 60 * 1000 * 5, callback)
 
     pull(
       insecure,

src/support.js

@@ -100,7 +100,7 @@ exports.selectBest = (local, remote, cb) => {
       const order = Buffer.compare(oh1, oh2)
 
       if (order === 0) {
-        cb(new Error('you are trying to talk to yourself'))
+        return cb(new Error('you are trying to talk to yourself'))
       }
 
       cb(null, {