fix: code review

Author: vasco-santos

test/ipns-pubsub.js

@@ -50,7 +50,7 @@ const spawnGoDaemon = (callback) => {
 
 const ipfsRef = '/ipfs/QmPFVLPmp9zv5Z5KUqLhe2EivAGccQW2r7M7jhVJGLZoZU'
 
-describe('ipns-pubsub', () => {
+describe.only('ipns-pubsub', () => {
   let nodeAId
   let nodeBId
   let nodes = []
@@ -87,7 +87,10 @@ describe('ipns-pubsub', () => {
       nodeAId = ids[0]
       nodeBId = ids[1]
 
-      nodes[0].api.swarm.connect(ids[1].addresses[0], () => {
+      nodes[0].api.swarm.connect(ids[1].addresses[0], (err) => {
+        expect(err).to.not.exist()
+
+        console.log('wait for republish as we can receive the republish message first')
         setTimeout(done, 60000) // wait for republish as we can receive the republish message first
       })
     })
@@ -130,21 +133,22 @@ const subscribeToReceiveByPubsub = (nodeA, nodeB, id, callback) => {
   const keys = ipns.getIdKeys(fromB58String(id))
   const topic = `${namespace}${base64url.encode(keys.routingKey.toBuffer())}`
 
-  nodeB.api.name.resolve(id, () => {
+  // try to resolve a unpublished record (will subscribe it)
+  nodeB.api.name.resolve(id, (err) => {
+    expect(err).to.exist() // not found
+
     series([
       (cb) => waitForPeerToSubscribe(nodeB.api, topic, cb),
       (cb) => nodeB.api.pubsub.subscribe(topic, checkMessage, cb),
       (cb) => nodeA.api.name.publish(ipfsRef, { resolve: false }, cb),
-      (cb) => nodeA.api.name.resolve(id, cb),
       (cb) => waitFor(() => subscribed === true, (50 * 1000), cb),
       (cb) => nodeB.api.name.resolve(id, cb)
     ], (err, res) => {
       expect(err).to.not.exist()
       expect(res).to.exist()
 
       expect(res[2].name).to.equal(id) // Published to Node A ID
-      expect(res[3]).to.equal(ipfsRef) // TODO: remove path once not using proc daemon
-      expect(res[5]).to.equal(ipfsRef)
+      expect(res[4]).to.equal(ipfsRef)
 
       callback()
     })

test/utils/wait-for.js

@@ -20,5 +20,5 @@ module.exports = (predicate, ttl, callback) => {
       clearInterval(self)
       return callback(new Error('waitFor time expired'))
     }
-  }, 500)
+  }, 50)
 }