index.js

'use strict';
const fs = require('fs');
const {spawn} = require('child_process');
const SerialPort = require('serialport');
const nconf = require('nconf');
const cjson = require('cjson');
const chalk = require('chalk');
const {version} = require('./package.json');

nconf.use('memory').argv().env();
const configFile = nconf.get('CONFIG_FILE') || nconf.get('config_file') || 'config.json';
nconf.defaults(readConfig(configFile));
nconf.set('port', nconf.get('PORT') || nconf.get('port') || 3000)
nconf.set('testmode', nconf.get('TESTMODE') || nconf.get('testmode'));
verifyConfig(nconf);

if (nconf.get('version')) showVersionQuit();
if (nconf.get('list')) showPortsQuit();

if (nconf.get('help')) {
  console.log('Options:');
  console.log('  --help          - Prints this usage info');
  console.log('  --list          - Prints available serial ports');
  console.log('  --port n        - Listen port number for HTTP server (default: 3000)');
  console.log("  --testmode      - Simulate serial port activity, don't open real ports");
  console.log('  --wrap-cmd cmd  - Spawn `cmd` as a subprocess; kill server when subprocess dies and vice versa');
  console.log('  --wrap-dir dir  - Working directory for wrapped command');
  console.log('  --version       - Prints server version number');
  process.exit();
}

const server = require('./lib/server.js');
server
  .start(nconf)
  .then(() => console.log(chalk.blue.bold('Press CTRL+C to quit.')))
  .then(() => nconf.get('wrap-cmd') && spawnChild())
  .catch(console.error);

function showVersionQuit() {
  console.log(version);
  process.exit();
}

function showPortsQuit() {
  SerialPort.list()
    .then(portList => {
      console.log(chalk.yellow.bold("Paste one or more of these serial ports into 'config.json':"));
      for (let port of portList) {
        let attrs = Object.keys(port)
          .filter(key => key !== 'comName')
          .reduce((sum, key) => port[key] ? sum.concat(`${key}: ${port[key]}`) : sum, []);
        console.log(chalk.yellow(`"${port.comName}", ` + (attrs.length ? `// ${attrs.join(', ')}` : '')));
      }
      process.exit();
    })
    .catch(console.error);
}

function readConfig(file) {
  if (!fs.existsSync('./config.json')) {
    console.warn(chalk.red.bold(`Could not find ${file}. Please copy` +
      ` ${file}.example to ${file}) and edit it.`));
    throw new Error(`File not found: ${file}`)
  }

  return cjson.load(file);
}

function verifyConfig(config) {
  const ports = config.get('serialPorts');
  if (!ports || !Array.isArray(ports) || !ports.length) {
    console.warn(`No serial ports configured! Please specify serial port(s) in ${configFile}.`);
    throw new Error('Serial ports not configured.');
  }
}

// Spawn a child process with a suicide pact; parent & child die together.
function spawnChild() {
  const cmd = nconf.get('wrap-cmd');
  const cwd = nconf.get('wrap-dir');

  console.log(chalk.green(`Spawning subprocess '${cmd}'...`))
  const spawnOpts = {
    stdio: 'inherit',
    shell: true,
    cwd: cwd
  };
  const child = spawn(cmd, [], spawnOpts);

  function onChildExit(code) {
    console.log(chalk.green('Wrapped process exited, server exiting...'));
    process.removeListener('exit', onExit);
    process.exit(code);
  }
  function onExit(code) {
    console.log(chalk.green('Exiting, killing subprocess...'))
    child.removeAllListeners();
    process.removeListener('exit', onExit);
    child.kill.bind(child);
    process.exit(code);
  }

  process.on('SIGINT', onExit);
  process.on('exit', onExit);
  child.on('exit', onChildExit)
}