Integrate libp2p-ping

package.json

@@ -39,6 +39,7 @@
     "run-parallel": "^1.1.6"
   },
   "dependencies": {
+    "libp2p-ping": "^0.2.0",
     "libp2p-secio": "^0.5.0",
     "libp2p-spdy": "^0.9.0",
     "libp2p-swarm": "^0.23.0",
@@ -67,4 +68,4 @@
     "Stephen Whitmore <stephen.whitmore@gmail.com>",
     "dignifiedquire <dignifiedquire@gmail.com>"
   ]
-}
+}

src/index.js

@@ -9,6 +9,7 @@ const secio = require('libp2p-secio')
 const PeerId = require('peer-id')
 const PeerInfo = require('peer-info')
 const PeerBook = require('peer-book')
+const Ping = require('libp2p-ping')
 const multiaddr = require('multiaddr')
 const mafmt = require('mafmt')
 const EE = require('events').EventEmitter
@@ -197,6 +198,12 @@ exports.Node = function Node (pInfo, pBook) {
     return this.swarm.unhandle(protocol)
   }
 
+  Ping.attach(this.swarm) // Enable this peer to echo Ping requests
+
+  this.ping = (peerDst) => {
+    return new Ping(this.swarm, peerDst) // Ping peerDst, peerDst must be a peer-info object
+  }
+
   this.discovery = new EE()
   this.routing = null
   this.records = null

test/libp2p.spec.js

@@ -415,6 +415,15 @@ describe('libp2p-ipfs', () => {
     }
   })
 
+  it('nodeE ping to nodeF', (done) => {
+    const p = nodeE.ping(nodeF.peerInfo)
+
+    p.once('ping', (time) => {
+      p.stop()
+      done()
+    })
+  })
+
   it('stop', (done) => {
     parallel([
       nodeA.stop,