feat(swarm): make interface-ipfs-core compliant

Author: dignifiedquire

package.json

@@ -31,11 +31,13 @@
     "multiaddr": "^2.0.2",
     "multipart-stream": "^2.0.1",
     "ndjson": "^1.4.3",
+    "peer-id": "^0.7.0",
+    "peer-info": "^0.7.1",
     "promisify-es6": "^1.0.1",
     "qs": "^6.2.1",
+    "streamifier": "^0.1.1",
     "tar-stream": "^1.5.2",
-    "wreck": "^10.0.0",
-    "streamifier": "^0.1.1"
+    "wreck": "^10.0.0"
   },
   "engines": {
     "node": ">=4.2.2"
@@ -100,4 +102,4 @@
     "url": "https://github.com/ipfs/js-ipfs-api/issues"
   },
   "homepage": "https://github.com/ipfs/js-ipfs-api"
-}
+}

src/api/swarm.js

@@ -2,6 +2,8 @@
 
 const promisify = require('promisify-es6')
 const multiaddr = require('multiaddr')
+const PeerId = require('peer-id')
+const PeerInfo = require('peer-info')
 
 module.exports = (send) => {
   return {
@@ -56,11 +58,17 @@ module.exports = (send) => {
         if (err) {
           return callback(err)
         }
-        callback(null, Object.keys(result.Addrs).map((id) => {
-          return result.Addrs[id].map((maStr) => {
-            return multiaddr(maStr).encapsulate('/ipfs/' + id)
+
+        const peers = Object.keys(result.Addrs).map((id) => {
+          const info = new PeerInfo(PeerId.createFromB58String(id))
+          result.Addrs[id].forEach((addr) => {
+            info.multiaddr.add(multiaddr(addr))
           })
-        })[0])
+
+          return info
+        })
+
+        callback(null, peers)
       })
     }),
     localAddrs: promisify((opts, callback) => {