index.js

#!/usr/bin/env node

'use strict'

const { serve } = require('reserve')
const { fromCmdLine } = require('./src/job')
const { getOutput } = require('./src/output')
const reserveConfigurationFactory = require('./src/reserve')
const { execute } = require('./src/tests')
const { capabilities } = require('./src/capabilities')
const { watch } = require('fs')
const { recreateDir } = require('./src/tools')

function send (message) {
  if (process.send) {
    process.send({
      pid: process.pid,
      ...message
    })
  }
}

async function notifyAndExecuteTests (job, output) {
  send({ msg: 'begin' })
  try {
    await execute(job)
    let status
    if (job.failed) {
      status = -1
    } else {
      status = 0
    }
    send({ msg: 'end', status })
  } catch (error) {
    getOutput(job).genericError(error)
    send({ msg: 'error', error })
  }
}

let job
let output

async function main () {
  job = fromCmdLine(process.cwd(), process.argv.slice(2))
  output = getOutput(job)
  await recreateDir(job.reportDir)
  if (job.mode === 'capabilities') {
    output.version()
    return capabilities(job)
  }
  const configuration = await reserveConfigurationFactory(job)
  const server = serve(configuration)
  if (job.logServer) {
    server.on('redirected', output.redirected)
  }
  server
    .on('ready', async ({ url, port }) => {
      job.port = port
      send({ msg: 'ready', port: job.port })
      output.serving(url)
      output.reportOnJobProgress()
      if (job.serveOnly) {
        job.status = 'Serving'
        return
      }
      await notifyAndExecuteTests(job)
      if (job.watch) {
        delete job.start
        if (!job.watching) {
          output.watching(job.webapp)
          watch(job.webapp, { recursive: true }, (eventType, filename) => {
            output.changeDetected(eventType, filename)
            if (!job.start) {
              notifyAndExecuteTests(job)
            }
          })
          job.watching = true
        }
      } else if (job.keepAlive) {
        job.status = 'Serving'
      } else if (job.failed) {
        output.stop()
        process.exit(-1)
      } else {
        output.stop()
        process.exit(0)
      }
    })
    .on('error', error => {
      output.serverError(error)
      send({ msg: 'error', error })
    })
}

main()
  .catch(reason => {
    if (output) {
      output.genericError(reason)
      output.stop()
    } else if (reason.name !== 'CommanderError') {
      console.error(reason)
    }
    process.exit(-1)
  })