style(core): cleanup libp2p commands

package.json

@@ -81,6 +81,7 @@
     "joi": "^9.0.4",
     "libp2p-ipfs": "^0.14.1",
     "libp2p-ipfs-browser": "^0.15.1",
+    "lodash.flatmap": "^4.5.0",
     "lodash.get": "^4.4.2",
     "lodash.has": "^4.5.2",
     "lodash.set": "^4.3.2",

src/core/ipfs/libp2p.js

@@ -3,6 +3,7 @@
 const multiaddr = require('multiaddr')
 const Libp2pNode = require('libp2p-ipfs').Node
 const promisify = require('promisify-es6')
+const flatMap = require('lodash.flatmap')
 
 const OFFLINE_ERROR = require('../utils').OFFLINE_ERROR
 
@@ -11,21 +12,27 @@ module.exports = function libp2p (self) {
 
   return {
     start: (callback) => {
-      self._libp2pNode = new Libp2pNode(self._peerInfo)
-      self._libp2pNode.start(() => {
-        // TODO connect to bootstrap nodes, it will get us more addrs
-        self._libp2pNode.peerInfo.multiaddrs.forEach((ma) => {
+      const node = self._libp2pNode = new Libp2pNode(self._peerInfo)
+      node.start((err) => {
+        if (err) {
+          return callback(err)
+        }
+
+        // TODO: connect to bootstrap nodes, it will
+        // get us more addrs
+        node.peerInfo.multiaddrs.forEach((ma) => {
           console.log('Swarm listening on', ma.toString())
         })
         callback()
       })
 
-      self._libp2pNode.discovery.on('peer', (peerInfo) => {
-        self._libp2pNode.peerBook.put(peerInfo)
-        self._libp2pNode.dialByPeerInfo(peerInfo, () => {})
+      node.discovery.on('peer', (peerInfo) => {
+        node.peerBook.put(peerInfo)
+        node.dialByPeerInfo(peerInfo, () => {})
       })
-      self._libp2pNode.swarm.on('peer-mux-established', (peerInfo) => {
-        self._libp2pNode.peerBook.put(peerInfo)
+
+      node.swarm.on('peer-mux-established', (peerInfo) => {
+        node.peerBook.put(peerInfo)
       })
     },
     stop: (callback) => {
@@ -37,35 +44,16 @@ module.exports = function libp2p (self) {
           return callback(OFFLINE_ERROR)
         }
 
-        const peers = self._libp2pNode.peerBook.getAll()
-        const mas = []
-        Object
-           .keys(peers)
-           .forEach((b58Id) => {
-             peers[b58Id].multiaddrs.forEach((ma) => {
-               // TODO this should only print the addr we are using
-               mas.push(ma)
-             })
-           })
-
+        const mas = collectAddrs(self._libp2pNode.peerBook)
         callback(null, mas)
       }),
       // all the addrs we know
       addrs: promisify((callback) => {
         if (!self.isOnline()) {
           return callback(OFFLINE_ERROR)
         }
-        const peers = self._libp2pNode.peerBook.getAll()
-        const mas = []
-        Object
-           .keys(peers)
-           .forEach((b58Id) => {
-             peers[b58Id].multiaddrs.forEach((ma) => {
-               // TODO this should only print the addr we are using
-               mas.push(ma)
-             })
-           })
 
+        const mas = collectAddrs(self._libp2pNode.peerBook)
         callback(null, mas)
       }),
       localAddrs: promisify((callback) => {
@@ -109,3 +97,10 @@ module.exports = function libp2p (self) {
     }
   }
 }
+
+function collectAddrs (book) {
+  const peers = book.getAll()
+  return flatMap(Object.keys(peers), (id) => {
+    return peers[id].multiaddrs
+  })
+}