embark-area-51/lib/processes/storageProcesses/swarm.js

const child_process = require('child_process');
const ProcessWrapper = require('../../process/processWrapper');
const constants = require('../../constants');
const fs = require('../../core/fs');

let swarmProcess;

class SwarmProcess extends ProcessWrapper {
  constructor(options) {
    super();
    this.storageConfig = options.storageConfig;
    this.webServerConfig = options.webServerConfig;
  }

  startSwarmDaemon() {
    const self = this;
    if (!this.storageConfig.account || !this.storageConfig.account.address || !this.storageConfig.account.password) {
      return 'Account address and password are needed in the storage config to start the Swarm process';
    }
    let corsDomain = 'http://localhost:8000';
    if (self.webServerConfig && self.webServerConfig && self.webServerConfig.host  && self.webServerConfig.port) {
      corsDomain = `http://${self.webServerConfig.host}:${self.webServerConfig.port}`;
    }

    const args = [
        `--bzzaccount=${this.storageConfig.account.address}`,
        `--password=${fs.dappPath(this.storageConfig.account.password)}`,
        `--corsdomain=${corsDomain}`,
        `--ens-api=''`
      ];
    const child = child_process.spawn(this.storageConfig.swarmPath || 'swarm', args, {shell: true});

    child.on('error', (err) => {
      err = err.toString();
      console.error('Swarm error: ', err);
    });
    let lastMessage;
    child.stdout.on('data', (data) => {
      data = data.toString();
      console.log(`Swarm error: ${data}`);
    });
    // Geth logs appear in stderr somehow
    child.stderr.on('data', (data) => {
      data = data.toString();
      if (!self.readyCalled && data.indexOf('Swarm http proxy started') > -1) {
        self.readyCalled = true;
        self.send({result: constants.storage.initiated});
      }
      lastMessage = data;
      console.log('Swarm: ' + data);
    });
    child.on('exit', (code) => {
      if (code) {
        console.error('Swarm exited with error code ' + code);
        if (lastMessage) {
          console.error(lastMessage);
        }
      }
    });
  }
}

process.on('message', (msg) => {
  if (msg.action === constants.storage.init) {
    swarmProcess = new SwarmProcess(msg.options);
    const error = swarmProcess.startSwarmDaemon();

    if (error) {
      swarmProcess.send({result: constants.storage.initiated, error});
    }
  }
});