feat(issue-1852): now supports multiple api and gateways

License: MIT
Signed-off-by: Grant Herman [email protected]

Author: grantlouisherman

src/http/index.js

@@ -29,6 +29,24 @@ function hapiInfoToMultiaddr (info) {
   return toMultiaddr(uri)
 }
 
+async function serverCreator (serverAddrsArr, createServerFunc, hapiInfoToMultiaddr, ipfs) {
+  if (!serverAddrsArr.length) {
+    debug(Error('There are no addresses'))
+  }
+  // just in case the address is just string
+  let serversAddrs = [].concat(serverAddrsArr)
+  const processServer = async (serverInstance, createServerFunc, hapiInfoToMultiaddr, ipfs) => {
+    let addr = serverInstance.split('/')
+    let _Server = await createServerFunc(addr[2], addr[4], ipfs)
+    await _Server.start()
+    _Server.info.ma = hapiInfoToMultiaddr(_Server.info)
+    return _Server
+  }
+  return Promise.all(
+    serversAddrs.map(server => processServer(server, createServerFunc, hapiInfoToMultiaddr, ipfs))
+  ).catch(err => debug(err))
+}
+
 class HttpApi {
   constructor (options) {
     this._options = options || {}
@@ -89,24 +107,28 @@ class HttpApi {
 
     const config = await ipfs.config.get()
 
-    const apiAddr = config.Addresses.API.split('/')
-    const apiServer = await this._createApiServer(apiAddr[2], apiAddr[4], ipfs)
-    await apiServer.start()
-    apiServer.info.ma = hapiInfoToMultiaddr(apiServer.info)
-    this._apiServer = apiServer
+    const apiAddrs = config.Addresses.API
 
+    this._apiServers = await Promise.resolve(
+      serverCreator.apply(this, [apiAddrs, this._createApiServer, hapiInfoToMultiaddr, ipfs])
+    )
     // for the CLI to know the where abouts of the API
-    await promisify(ipfs._repo.apiAddr.set)(apiServer.info.ma)
+    await promisify(ipfs._repo.apiAddr.set)(this._apiServers[0].info.ma)
 
-    const gatewayAddr = config.Addresses.Gateway.split('/')
-    const gatewayServer = await this._createGatewayServer(gatewayAddr[2], gatewayAddr[4], ipfs)
-    await gatewayServer.start()
-    gatewayServer.info.ma = hapiInfoToMultiaddr(gatewayServer.info)
-    this._gatewayServer = gatewayServer
+    const gatewayAddr = config.Addresses.Gateway
 
-    ipfs._print('API listening on %s', apiServer.info.ma)
-    ipfs._print('Gateway (read only) listening on %s', gatewayServer.info.ma)
-    ipfs._print('Web UI available at %s', toUri(apiServer.info.ma) + '/webui')
+    this._gatewayServer = await Promise.resolve(
+      serverCreator.apply(this, [gatewayAddr, this._createGatewayServer, hapiInfoToMultiaddr, ipfs])
+    )
+    this._apiServers.forEach(apiServer => {
+      ipfs._print('API listening on %s', apiServer.info.ma)
+    })
+    this._gatewayServer.forEach(gatewayServer => {
+      ipfs._print('Gateway (read only) listening on %s', gatewayServer.info.ma)
+    })
+    this._apiServers.forEach(apiServer => {
+      ipfs._print('Web UI available at %s', toUri(apiServer.info.ma) + '/webui')
+    })
     this._log('started')
     return this
   }
@@ -177,14 +199,19 @@ class HttpApi {
 
   get apiAddr () {
     if (!this._apiServer) throw new Error('API address unavailable - server is not started')
-    return multiaddr('/ip4/127.0.0.1/tcp/' + this._apiServer.info.port)
+    return multiaddr('/ip4/127.0.0.1/tcp/' + this._apiServers[0].info.port)
   }
 
   async stop () {
+    function stopServer (serverArr) {
+      for (let i = 0; i < serverArr.length; i++) {
+        serverArr[i].stop()
+      }
+    }
     this._log('stopping')
     await Promise.all([
-      this._apiServer && this._apiServer.stop(),
-      this._gatewayServer && this._gatewayServer.stop(),
+      this._apiServer && stopServer(this._apiServer),
+      this._gatewayServer && stopServer(this._gatewayServer),
       this._ipfs && this._ipfs.stop()
     ])
     this._log('stopped')

test/http-api/inject/dht.js

@@ -10,7 +10,7 @@ chai.use(dirtyChai)
 module.exports = (http) => {
   describe('/dht', () => {
     let api
-
+    console.log('HTTT', http)
     before(() => {
       api = http.api._apiServer
     })
@@ -21,7 +21,6 @@ module.exports = (http) => {
           method: 'GET',
           url: `/api/v0/dht/findpeer`
         })
-
         expect(res.statusCode).to.equal(400)
         expect(res.result.Code).to.be.eql(1)
       })