// @ts-nocheck
import cluster from 'cluster';
import {
    terminal, TextBox, LabeledInput,
} from 'terminal-kit';
import * as bus from './service/bus';

async function terminate() {
    let hasError = false;
    try {
        await require('./service/bus').parallel('app/exit');
    } catch (e) {
        hasError = true;
    }
    if (cluster.isMaster) {
        terminal.hideCursor(false);
        terminal.styleReset();
        terminal.resetScrollingRegion();
        terminal.moveTo(terminal.width, terminal.height);
        terminal('\n');
    }
    process.exit(hasError ? 1 : 0);
}
process.on('SIGINT', terminate);
if (cluster.isMaster) {
    terminal.clear();
    terminal.grabInput();
    terminal.hideCursor();
    // Clipboard doesn't work well over ssh env, it throws an error.
    terminal.getClipboard = () => { };
    terminal.setClipboard = () => { };
    const document = terminal.createDocument({});
    const LogBox = new TextBox({
        parent: document,
        contentHasMarkup: true,
        scrollable: true,
        vScrollBar: true,
        lineWrap: true,
        x: 0,
        y: 0,
        width: terminal.width,
        height: terminal.height - 1,
    });
    const ShellInput = new LabeledInput({
        parent: document,
        label: '>',
        x: 1,
        y: terminal.height - 1,
        width: terminal.width,
    });
    bus.on('message/log', (message) => {
        LogBox.appendLog(message);
    });
    ShellInput.on('submit', async (input) => {
        ShellInput.input.setContent(' '.repeat(terminal.width), false, false);
        ShellInput.input.setContent('', false, false);
        if (input[0] === '@') {
            for (const i in cluster.workers) {
                cluster.workers[i].send({ event: 'message/run', payload: [input.substr(1, input.length - 1)] });
                break;
            }
        } else bus.parallel('message/run', input);
    });
    terminal.on('key', (key, matches, data) => {
        if (key === 'CTRL_C') terminate();
    });
}