test: add interface-ipfs-core ping tests

License: MIT
Signed-off-by: Alan Shaw <alan@tableflip.io>

Author: alanshaw

src/core/components/ping-pull-stream.js

@@ -55,7 +55,9 @@ function getPeer (libp2pNode, statusStream, peerId, cb) {
     try {
       peerId = PeerId.createFromB58String(peerId)
     } catch (err) {
-      return cb(err)
+      return cb(Object.assign(err, {
+        message: `failed to parse peer address '${peerId}': input isn't valid multihash`
+      }))
     }
 
     return libp2pNode.peerRouting.findPeer(peerId, cb)

test/core/interface/interface.spec.js

@@ -16,6 +16,7 @@ describe('interface-ipfs-core tests', () => {
   require('./key')
   if (isNode) {
     require('./swarm')
+    require('./ping')
     require('./pubsub')
     require('./dht')
   }

test/core/interface/ping.js

@@ -0,0 +1,35 @@
+/* eslint-env mocha */
+'use strict'
+
+const test = require('interface-ipfs-core')
+const parallel = require('async/parallel')
+
+const IPFS = require('../../../src')
+
+const DaemonFactory = require('ipfsd-ctl')
+const df = DaemonFactory.create({ type: 'proc', exec: IPFS })
+
+const nodes = []
+const common = {
+  setup: function (callback) {
+    callback(null, {
+      spawnNode: (cb) => {
+        df.spawn({
+          initOptions: { bits: 512 }
+        }, (err, _ipfsd) => {
+          if (err) {
+            return cb(err)
+          }
+
+          nodes.push(_ipfsd)
+          cb(null, _ipfsd.api)
+        })
+      }
+    })
+  },
+  teardown: function (callback) {
+    parallel(nodes.map((node) => (cb) => node.stop(cb)), callback)
+  }
+}
+
+test.ping(common)