chore: add ping cli test

Author: JGAntunes

test/cli/commands.js

@@ -14,7 +14,7 @@ describe('commands', () => runOnAndOff((thing) => {
     ipfs = thing.ipfs
   })
 
-  it.only('list the commands', () => {
+  it('list the commands', () => {
     return ipfs('commands').then((out) => {
       expect(out.split('\n')).to.have.length(commandCount + 1)
     })

test/cli/ping.js

@@ -24,27 +24,13 @@ const config = {
 }
 
 describe.only('ping', function () {
-  this.timeout(80 * 1000)
-
+  this.timeout(60 * 1000)
   let ipfsdA
   let ipfsdB
+  let bMultiaddr
   let ipfsdBId
   let cli
 
-  before(function (done) {
-    this.timeout(60 * 1000)
-
-    df.spawn({
-      exec: './src/cli/bin.js',
-      config,
-      initoptions: { bits: 512 }
-    }, (err, _ipfsd) => {
-      expect(err).to.not.exist()
-      ipfsdA = _ipfsd
-      done()
-    })
-  })
-
   before((done) => {
     this.timeout(60 * 1000)
     series([
@@ -62,38 +48,102 @@ describe.only('ping', function () {
       (cb) => {
         ipfsdB.api.id((err, peerInfo) => {
           expect(err).to.not.exist()
-          console.log(peerInfo)
           ipfsdBId = peerInfo.id
+          bMultiaddr = peerInfo.addresses[0]
           cb()
         })
       }
     ], done)
   })
 
-  after((done) => ipfsdA.stop(done))
-  after((done) => ipfsdB.stop(done))
+  before(function (done) {
+    this.timeout(60 * 1000)
+
+    df.spawn({
+      exec: './src/cli/bin.js',
+      config,
+      initoptions: { bits: 512 }
+    }, (err, _ipfsd) => {
+      expect(err).to.not.exist()
+      ipfsdA = _ipfsd
+      ipfsdA.api.swarm.connect(bMultiaddr, done)
+    })
+  })
 
   before((done) => {
+    this.timeout(60 * 1000)
     cli = ipfsExec(ipfsdA.repoPath)
     done()
   })
 
+  after((done) => ipfsdA.stop(done))
+  after((done) => ipfsdB.stop(done))
+
   it('ping host', (done) => {
+    this.timeout(60 * 1000)
     const ping = cli(`ping ${ipfsdBId}`)
     const result = []
-    ping.stdout.on('data', (packet) => {
-      console.log('ON DATA')
-      result.push(packet.toString())
+    ping.stdout.on('data', (output) => {
+      const packets = output.toString().split('\n').slice(0, -1)
+      result.push(...packets)
     })
 
-    ping.stdout.on('end', (c) => {
-      console.log('END', result)
+    ping.stdout.on('end', () => {
+      expect(result).to.have.lengthOf(12)
+      expect(result[0]).to.equal(`PING ${ipfsdBId}`)
+      for(let i = 1; i < 11; i++) {
+        expect(result[i]).to.match(/^Pong received: time=\d+ ms$/)
+      }
+      expect(result[11]).to.match(/^Average latency: \d+(.\d+)?ms$/)
       done()
     })
 
     ping.catch((err) => {
       expect(err).to.not.exist()
+    })
+  })
+
+  it('ping host with --n option', (done) => {
+    this.timeout(60 * 1000)
+    const ping = cli(`ping --n 1 ${ipfsdBId}`)
+    const result = []
+    ping.stdout.on('data', (output) => {
+      const packets = output.toString().split('\n').slice(0, -1)
+      result.push(...packets)
+    })
+
+    ping.stdout.on('end', () => {
+      expect(result).to.have.lengthOf(3)
+      expect(result[0]).to.equal(`PING ${ipfsdBId}`)
+      expect(result[1]).to.match(/^Pong received: time=\d+ ms$/)
+      expect(result[2]).to.match(/^Average latency: \d+(.\d+)?ms$/)
       done()
     })
+
+    ping.catch((err) => {
+      expect(err).to.not.exist()
+    })
+  })
+
+  it('ping host with --count option', (done) => {
+    this.timeout(60 * 1000)
+    const ping = cli(`ping --count 1 ${ipfsdBId}`)
+    const result = []
+    ping.stdout.on('data', (output) => {
+      const packets = output.toString().split('\n').slice(0, -1)
+      result.push(...packets)
+    })
+
+    ping.stdout.on('end', () => {
+      expect(result).to.have.lengthOf(3)
+      expect(result[0]).to.equal(`PING ${ipfsdBId}`)
+      expect(result[1]).to.match(/^Pong received: time=\d+ ms$/)
+      expect(result[2]).to.match(/^Average latency: \d+(.\d+)?ms$/)
+      done()
+    })
+
+    ping.catch((err) => {
+      expect(err).to.not.exist()
+    })
   })
 })