Async Crypto Endeavour

.gitignore

@@ -31,4 +31,3 @@ node_modules
 coverage
 
 dist
-lib

.travis.yml

@@ -3,7 +3,8 @@ sudo: false
 language: node_js
 node_js:
   - 4
-  - 5
+  - 6
+  - stable
 
 # Make sure we have new NPM.
 before_install:

README.md

@@ -7,6 +7,11 @@
 [![Travis CI](https://travis-ci.org/libp2p/js-libp2p-identify.svg?branch=master)](https://travis-ci.org/libp2p/js-libp2p-identify)
 [![Circle CI](https://circleci.com/gh/libp2p/js-libp2p-identify.svg?style=svg)](https://circleci.com/gh/libp2p/js-libp2p-identify)
 [![Dependency Status](https://david-dm.org/libp2p/js-libp2p-identify.svg?style=flat-square)](https://david-dm.org/libp2p/js-libp2p-identify) [![js-standard-style](https://img.shields.io/badge/code%20style-standard-brightgreen.svg?style=flat-square)](https://github.com/feross/standard)
+![](https://img.shields.io/badge/npm-%3E%3D3.0.0-orange.svg?style=flat-square)
+![](https://img.shields.io/badge/Node.js-%3E%3D4.0.0-orange.svg?style=flat-square)
+
+[![Sauce Test Status](https://saucelabs.com/browser-matrix/js-libp2p-identify.svg)](https://saucelabs.com/u/j
+s-libp2p-identify)
 
 > libp2p Identify Protocol
 

package.json

@@ -2,8 +2,7 @@
   "name": "libp2p-identify",
   "version": "0.2.0",
   "description": "libp2p Identify Protocol",
-  "main": "lib/index.js",
-  "jsnext:main": "src/index.js",
+  "main": "src/index.js",
   "scripts": {
     "lint": "aegir-lint",
     "build": "aegir-build",
@@ -21,7 +20,7 @@
     "test"
   ],
   "engines": {
-    "node": "^4.3.0"
+    "node": ">=4.0.0"
   },
   "repository": {
     "type": "git",
@@ -38,22 +37,22 @@
   },
   "homepage": "https://github.com/libp2p/js-libp2p-identify#readme",
   "devDependencies": {
-    "aegir": "^8.0.0",
+    "aegir": "^9.0.0",
     "chai": "^3.5.0",
     "pre-commit": "^1.1.3",
     "pull-pair": "^1.1.0"
   },
   "dependencies": {
-    "multiaddr": "^2.0.2",
+    "multiaddr": "^2.0.3",
     "peer-id": "^0.7.0",
-    "peer-info": "^0.7.0",
+    "peer-info": "^0.7.1",
     "protocol-buffers": "^3.1.6",
-    "pull-length-prefixed": "^1.0.0",
-    "pull-stream": "^3.4.3"
+    "pull-length-prefixed": "^1.2.0",
+    "pull-stream": "^3.4.5"
   },
   "contributors": [
     "David Dias <[email protected]>",
     "dignifiedquire <[email protected]>",
     "greenkeeperio-bot <[email protected]>"
   ]
-}
+}

src/dialer.js

@@ -19,13 +19,18 @@ module.exports = (conn, callback) => {
 
       const input = msg.decode(data[0])
 
-      const id = PeerId.createFromPubKey(input.publicKey)
-      const info = new PeerInfo(id)
-      input.listenAddrs
-        .map(multiaddr)
-        .forEach((ma) => info.multiaddr.add(ma))
-
-      callback(null, info, getObservedAddrs(input))
+      PeerId.createFromPubKey(input.publicKey, (err, id) => {
+        if (err) {
+          return callback(err)
+        }
+
+        const info = new PeerInfo(id)
+        input.listenAddrs
+          .map(multiaddr)
+          .forEach((ma) => info.multiaddr.add(ma))
+
+        callback(null, info, getObservedAddrs(input))
+      })
     })
   )
 }

src/message/identify.proto → src/message.js

@@ -1,5 +1,8 @@
-message Identify {
+'use strict'
 
+const protobuf = require('protocol-buffers')
+const schema = new Buffer(`
+message Identify {
   // protocolVersion determines compatibility between peers
   optional string protocolVersion = 5; // e.g. ipfs/1.0.0
 
@@ -23,3 +26,6 @@ message Identify {
   // (DEPRECATED) protocols are the services this node is running
   // repeated string protocols = 3;
 }
+`)
+
+module.exports = protobuf(schema).Identify

test/dialer.spec.js

@@ -12,9 +12,20 @@ const msg = require('../src/message')
 const identify = require('../src')
 
 describe('identify.dialer', () => {
+  let original
+  beforeEach((done) => {
+    PeerInfo.create((err, info) => {
+      if (err) {
+        return done(err)
+      }
+
+      original = info
+      done()
+    })
+  })
+
   it('works', (done) => {
     const p = pair()
-    const original = new PeerInfo()
     original.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/5002'))
     const input = msg.encode({
       protocolVersion: 'ipfs/0.1.0',

test/listener.spec.js

@@ -12,9 +12,20 @@ const msg = require('../src/message')
 const identify = require('../src')
 
 describe('identify.listener', () => {
+  let info
+  beforeEach((done) => {
+    PeerInfo.create((err, _info) => {
+      if (err) {
+        return done(err)
+      }
+
+      info = _info
+      done()
+    })
+  })
+
   it('works', (done) => {
     const p = pair()
-    const info = new PeerInfo()
     info.multiaddr.add(multiaddr('/ip4/127.0.0.1/tcp/5002'))
     pull(
       p[1],