robojones/z1

const Worker = require('../lib/class/Worker')
const startWorkers = require('../lib/start-workers')
const killWorkers = require('../lib/kill-workers')
const getPack = require('../lib/getPack')

/*
command {
  app,
  opt: {
    timeout,
    signal
  }
}
*/

async function restart(config, command, connection) {
    // find old app
    const app = config.apps.find(app => app.name === command.app)

    if (!app) {
        throw new Error(`app "${command.app}" not found`)
    }

    // reload package.json
    const pack = getPack(app.dir, app.opt, app.env)

    // if name changed
    const nameChanged = pack.name !== app.name
    if (nameChanged) {
        // check name
        if (config.apps.some(app => app.name === pack.name)) {
            throw new Error(`new name "${pack.name}" already in use`)
        }

        // save new app
        config.apps.push(Object.assign({}, app, {
            name: pack.name,
        }))

        config.save()
    }

    // set default timeout
    const timeout = command.opt.timeout

    // remember old workers
    const workers = Worker.workerList.filter(worker => worker.name === command.app)

    const data = await startWorkers(config, app.dir, pack, pack.workers, app.args, app.env, connection)

    // kill old workers
    const workersKilled = await killWorkers(workers, timeout, command.opt.signal, connection)

    if (nameChanged) {
        // remove old version
        const oldIndex = config.apps.findIndex(app => app.name === command.app)
        config.apps.splice(oldIndex, 1)
        config.save()
    }

    data.killed = workersKilled

    return data
}

module.exports = restart