daemons.js

'use strict'
/* eslint max-nested-callbacks: ["error", 8] */ // TODO reduce nesteness

const gulp = require('gulp')
const fs = require('fs')
const path = require('path')

let daemons

function startDisposableDaemons (callback) {
  const ipfsd = require('ipfsd-ctl')

  // a, b, c
  const ipfsNodes = {}

  // a, b, c
  const apiAddrs = {}

  let counter = 0

  function finish () {
    counter++
    if (counter === 3) {
      const targetPath = path.join(__dirname, '/../test/tmp-disposable-nodes-addrs.json')
      fs.writeFileSync(targetPath, JSON.stringify(apiAddrs))
      callback(ipfsNodes)
    }
  }

  function startIndependentNode (nodes, addrs, key, cb) {
    ipfsd.disposable((err, node) => {
      if (err) {
        throw err
      }

      nodes[key] = node

      console.log('  ipfs init done - (bootstrap and mdns off) - ' + key)

      nodes[key].setConfig('Bootstrap', null, (err) => {
        if (err) {
          throw err
        }
        nodes[key].setConfig('Discovery', '{}', (err) => {
          if (err) {
            throw err
          }

          const headers = {
            HTTPHeaders: {
              'Access-Control-Allow-Origin': ['*']
            }
          }
          nodes[key].setConfig('API', JSON.stringify(headers), (err) => {
            if (err) {
              throw err
            }

            nodes[key].startDaemon((err, ignore) => {
              if (err) {
                throw err
              }

              addrs[key] = nodes[key].apiAddr
              cb()
            })
          })
        })
      })
    })
  }

  startIndependentNode(ipfsNodes, apiAddrs, 'a', finish)
  startIndependentNode(ipfsNodes, apiAddrs, 'b', finish)
  startIndependentNode(ipfsNodes, apiAddrs, 'c', finish)
}

function stopDisposableDaemons (ds, callback) {
  let counter = 0
  function finish () {
    counter++
    if (counter === 3) {
      callback()
    }
  }

  function stopIPFSNode (list, key, cb) {
    let nodeStopped
    list[key].stopDaemon((err) => {
      if (err) {
        throw err
      }
      if (!nodeStopped) {
        nodeStopped = true
        cb()
      }
    })
  }

  stopIPFSNode(ds, 'a', finish)
  stopIPFSNode(ds, 'b', finish)
  stopIPFSNode(ds, 'c', finish)
}

gulp.task('daemons:start', (done) => {
  startDisposableDaemons((d) => {
    daemons = d
    done()
  })
})

gulp.task('daemons:stop', (done) => {
  stopDisposableDaemons(daemons, () => {
    daemons = null
    done()
  })
})