Merge pull request #600 from ipfs/new-swarm-peers

feat(swarm): update swarm.peers to new api

Author: daviddias

package.json

@@ -59,7 +59,7 @@
     "form-data": "^2.1.2",
     "fs-pull-blob-store": "^0.4.1",
     "gulp": "^3.9.1",
-    "interface-ipfs-core": "^0.21.0",
+    "interface-ipfs-core": "^0.22.0",
     "left-pad": "^1.1.3",
     "lodash": "^4.17.2",
     "ncp": "^2.0.0",

src/core/components/swarm.js

@@ -9,17 +9,41 @@ const OFFLINE_ERROR = require('../utils').OFFLINE_ERROR
 
 module.exports = function swarm (self) {
   return {
-    peers: promisify((callback) => {
+    peers: promisify((opts, callback) => {
+      if (typeof opts === 'function') {
+        callback = opts
+        opts = {}
+      }
+
       if (!self.isOnline()) {
         return callback(OFFLINE_ERROR)
       }
 
+      const verbose = opts.v || opts.verbose
+      // TODO: return latency and streams when verbose is set
+      // we currently don't have this information
+
       const peers = self._libp2pNode.peerBook.getAll()
-      const mas = flatMap(Object.keys(peers), (id) => {
-        return peers[id].multiaddrs
+      const keys = Object.keys(peers)
+
+      const peerList = flatMap(keys, (id) => {
+        const peer = peers[id]
+
+        return peer.multiaddrs.map((addr) => {
+          const res = {
+            addr: addr,
+            peer: peers[id]
+          }
+
+          if (verbose) {
+            res.latency = 'unknown'
+          }
+
+          return res
+        })
       })
 
-      callback(null, mas)
+      callback(null, peerList)
     }),
 
     // all the addrs we know

src/http-api/resources/swarm.js

@@ -26,8 +26,11 @@ exports.parseAddrs = (request, reply) => {
 
 exports.peers = {
   handler: (request, reply) => {
+    const rawVerbose = request.query.v || request.query.verbose
+    const verbose = rawVerbose === 'true'
     const ipfs = request.server.app.ipfs
-    ipfs.swarm.peers((err, peers) => {
+
+    ipfs.swarm.peers({verbose: verbose}, (err, peers) => {
       if (err) {
         log.error(err)
         return reply({
@@ -37,7 +40,18 @@ exports.peers = {
       }
 
       return reply({
-        Strings: peers.map((addr) => addr.toString())
+        Peers: peers.map((p) => {
+          const res = {
+            Peer: p.peer.id.toB58String(),
+            Addr: p.addr.toString()
+          }
+
+          if (verbose) {
+            res.Latency = p.latency
+          }
+
+          return res
+        })
       })
     })
   }