refactor: return peer ids as strings

package.json

@@ -68,7 +68,7 @@
     "async": "^3.1.0",
     "browser-process-platform": "~0.1.1",
     "go-ipfs-dep": "^0.4.22",
-    "interface-ipfs-core": "^0.129.0",
+    "interface-ipfs-core": "ipfs/interface-js-ipfs-core#return-peer-ids-as-strings",
     "ipfsd-ctl": "^1.0.2",
     "it-all": "^1.0.1",
     "it-concat": "^1.0.0",

src/bitswap/stat.js

@@ -23,7 +23,7 @@ function toCoreInterface (res) {
   return {
     provideBufLen: res.ProvideBufLen,
     wantlist: (res.Wantlist || []).map(k => new CID(k['/'])),
-    peers: (res.Peers || []).map(p => new CID(p)),
+    peers: (res.Peers || []),
     blocksReceived: new Big(res.BlocksReceived),
     dataReceived: new Big(res.DataReceived),
     blocksSent: new Big(res.BlocksSent),

src/dht/find-peer.js

@@ -37,7 +37,7 @@ module.exports = configure(({ ky }) => {
         // https://github.com/ipfs/go-ipfs/blob/eb11f569b064b960d1aba4b5b8ca155a3bd2cb21/core/commands/dht.go#L395-L396
         for (const { ID, Addrs } of message.Responses) {
           return {
-            id: new CID(ID),
+            id: ID,
             addrs: (Addrs || []).map(a => multiaddr(a))
           }
         }

src/dht/find-provs.js

@@ -35,7 +35,7 @@ module.exports = configure(({ ky }) => {
       if (message.Type === 4 && message.Responses) {
         for (const { ID, Addrs } of message.Responses) {
           yield {
-            id: new CID(ID),
+            id: ID,
             addrs: (Addrs || []).map(a => multiaddr(a))
           }
         }

src/dht/provide.js

@@ -36,7 +36,7 @@ module.exports = configure(({ ky }) => {
       message.id = new CID(message.id)
       if (message.responses) {
         message.responses = message.responses.map(({ ID, Addrs }) => ({
-          id: new CID(ID),
+          id: ID,
           addrs: (Addrs || []).map(a => multiaddr(a))
         }))
       } else {

src/dht/put.js

@@ -38,7 +38,7 @@ module.exports = configure(({ ky }) => {
       message.id = new CID(message.id)
       if (message.responses) {
         message.responses = message.responses.map(({ ID, Addrs }) => ({
-          id: new CID(ID),
+          id: ID,
           addrs: (Addrs || []).map(a => multiaddr(a))
         }))
       }

src/dht/query.js

@@ -26,7 +26,7 @@ module.exports = configure(({ ky }) => {
       message = toCamel(message)
       message.id = new CID(message.id)
       message.responses = (message.responses || []).map(({ ID, Addrs }) => ({
-        id: new CID(ID),
+        id: ID,
         addrs: (Addrs || []).map(a => multiaddr(a))
       }))
       yield message

src/id.js

@@ -2,6 +2,7 @@
 
 const configure = require('./lib/configure')
 const toCamel = require('./lib/object-to-camel')
+const multiaddr = require('multiaddr')
 
 module.exports = configure(({ ky }) => {
   return async options => {
@@ -14,6 +15,12 @@ module.exports = configure(({ ky }) => {
       searchParams: options.searchParams
     }).json()
 
-    return toCamel(res)
+    const output = toCamel(res)
+
+    if (output.addresses) {
+      output.addresses = output.addresses.map(ma => multiaddr(ma))
+    }
+
+    return output
   }
 })

src/swarm/addrs.js

@@ -1,6 +1,5 @@
 'use strict'
 
-const CID = require('cids')
 const multiaddr = require('multiaddr')
 const configure = require('../lib/configure')
 
@@ -16,7 +15,7 @@ module.exports = configure(({ ky }) => {
     }).json()
 
     return Object.keys(res.Addrs).map(id => ({
-      id: new CID(id),
+      id,
       addrs: (res.Addrs[id] || []).map(a => multiaddr(a))
     }))
   }

src/swarm/peers.js

@@ -1,7 +1,6 @@
 'use strict'
 
 const multiaddr = require('multiaddr')
-const CID = require('cids')
 const configure = require('../lib/configure')
 
 module.exports = configure(({ ky }) => {
@@ -25,7 +24,7 @@ module.exports = configure(({ ky }) => {
       const info = {}
       try {
         info.addr = multiaddr(peer.Addr)
-        info.peer = new CID(peer.Peer)
+        info.peer = peer.Peer
       } catch (error) {
         info.error = error
         info.rawPeerInfo = peer