nebula.js/scripts/start-mashup.js

#! /usr/bin/env node

const yargs = require('yargs');

const mashupServer = require('../test/mashup/server');
const sseServer = require('../test/fixtures/sse');
const useEngine = require('../commands/serve/lib/engine');

const args = yargs
  .option('start', {
    default: true,
    type: 'boolean',
    describe: 'Start the mashup server',
  })
  .option('sse', {
    default: true,
    type: 'boolean',
    describe: 'Start the SSE plugin',
  })
  .option('engine', {
    default: false,
    type: 'boolean',
    describe: 'Start the engine',
  }).argv;

const { start, sse, engine } = args;

let hasCleanedUp = false;
const services = [];

if (start) {
  let m;
  services.push({
    name: 'Mashup server',
    start: async () => {
      m = await mashupServer();
      process.env.BASE_URL = m.url;
    },
    stop: async () => {
      await m.close();
    },
  });
}

if (sse) {
  const s = sseServer;
  services.push({
    name: 'SSE plugin server',
    start: () => {
      s.start();
    },
    stop: () => s.close(),
  });
}

if (engine) {
  let e;
  services.push({
    name: 'Qlik Engine',
    start: async () => {
      e = await useEngine({
        ACCEPT_EULA: true,
        files: ['./test/fixtures/docker/docker-compose.yml'],
        cwd: process.cwd(),
      });
    },
    stop: async () => {
      await e();
    },
  });
}

function cleanup() {
  if (hasCleanedUp) {
    return;
  }
  hasCleanedUp = true;
  console.log('Stopping services');
  services.forEach(async (service) => {
    console.log(`${service.name}`);
    await service.stop();
  });
}

async function run() {
  console.log('Starting services');

  try {
    services.forEach(async (service) => {
      console.log(`${service.name}`);
      await service.start();
    });
    console.log('All up and running');
  } catch (err) {
    console.log(err);
    cleanup();
    throw err;
  }
}

process.on('exit', cleanup);
process.on('SIGINT', process.exit);
process.on('SIGTERM', process.exit);
process.on('uncaughtException', (err) => {
  if (!hasCleanedUp) {
    console.log(err.stack);
    process.exit(1);
  }
});

run();