fix: code review

src/core/ipns/publisher.js

@@ -182,10 +182,9 @@ class IpnsPublisher {
           return callback(err)
         }
 
-        this._routing.get(keys.routingKey, (err, res) => {
+        this._routing.get(keys.routingKey.toBuffer(), (err, res) => {
           if (err) {
-            log(`error when determining the last published IPNS record for ${peerId.id}`)
-            return callback(null, null)
+            return callback(err)
           }
 
           // unmarshal data
@@ -206,7 +205,7 @@ class IpnsPublisher {
       const errMsg = `found ipns record that we couldn't convert to a value`
 
       log.error(errMsg)
-      return callback(null, null)
+      return callback(errcode(new Error(errMsg), 'ERR_INVALID_RECORD_DATA'))
     }
 
     callback(null, result)
@@ -226,11 +225,17 @@ class IpnsPublisher {
 
     this._getPublished(peerId, getPublishedOptions, (err, record) => {
       if (err) {
-        return callback(err)
+        if (err.code !== 'ERR_NOT_FOUND') {
+          const errMsg = `unexpected error when determining the last published IPNS record for ${peerId.id}`
+
+          log.error(errMsg)
+          return callback(errcode(new Error(errMsg), 'ERR_DETERMINING_PUBLISHED_RECORD'))
+        }
       }
 
       // Determinate the record sequence number
       let seqNumber = 0
+
       if (record && record.sequence !== undefined) {
         seqNumber = record.value.toString() !== value ? record.sequence + 1 : record.sequence
       }

src/core/ipns/routing/offline-datastore.js

@@ -50,7 +50,7 @@ class OfflineDatastore {
     }
 
     // Marshal to libp2p record as the DHT does
-    let record = new Record(key, value)
+    const record = new Record(key, value)
 
     this._repo.datastore.put(routingKey, record.serialize(), callback)
   }

test/core/name.js

@@ -340,7 +340,7 @@ describe('name', function () {
 
       node.name.publish(ipfsRef, { resolve: false }, (err, res) => {
         expect(err).to.exist()
-        expect(err.code).to.equal('ERR_UNEXPECTED_DATASTORE_RESPONSE')
+        expect(err.code).to.equal('ERR_DETERMINING_PUBLISHED_RECORD')
 
         stub.restore()
         done()

test/fixtures/go-ipfs-repo/datastore/CURRENT

@@ -1 +1 @@
-MANIFEST-000017
+MANIFEST-000021

test/fixtures/go-ipfs-repo/datastore_spec

@@ -0,0 +1 @@
+{"mounts":[{"mountpoint":"/blocks","path":"blocks","shardFunc":"/repo/flatfs/shard/v1/next-to-last/2","type":"flatfs"},{"mountpoint":"/","path":"datastore","type":"levelds"}],"type":"mount"}