const REGEX_WAIT_FOR_OK_OR_ERROR = /\r\n(?:OK|ERROR)\r/;
// const REGEX_WAIT_FOR_OK_OR_ERROR = /\nOK\r/;

const SerialPort = require('serialport');

const config = require('komodo-sdk/config');
const logger = require('komodo-sdk/logger');


const ParserRegex = require('@serialport/parser-regex');

const parserWaitForOkOrError = new ParserRegex({ regex: REGEX_WAIT_FOR_OK_OR_ERROR });
parserWaitForOkOrError.on('data', (data) => {
    logger.verbose('INCOMING', { parser: 'parserWaitForOkOrError', data: data.toString() });
});

const ParserInterByteTimeout = require('@serialport/parser-inter-byte-timeout');

const parsers = require('./serialport-parsers');

const parserInterByteTimeout = new ParserInterByteTimeout({ interval: 1000 });
parserInterByteTimeout.on('data', (data) => {
    logger.verbose('INCOMING', { parser: 'parserInterByteTimeout', data: data.toString() });
});

let port;

function sleep(ms) {
    return new Promise((resolve) => {
        setTimeout(() => {
            resolve();
        }, ms || 0);
    });
}

function writeToPort(data) {
    return new Promise((resolve) => {
        port.write(data, (err, bytesWritten) => {
            if (err) logger.warn(`ERROR: ${err.toString()}`);

            logger.verbose('OUTGOING', { bytesWritten, data: data.toString() });
            resolve(bytesWritten);
        });
    });
}

async function writeToPortDelayed(data, ms) {
    await sleep(ms || 500);
    const result = writeToPort(data);
    return result;
}

/*
function isNotBlacklistedCommand(command) {
    let [, cmd] = (command || '').trim().split('+');
    cmd = (cmd || '').replace(/=.*$/, '');
    return !config
        || !config.modem_tester
        || !config.modem_tester.skip_commands
        || (config.modem_tester.skip_commands.indexOf(cmd) < 0);
}
*/

port = new SerialPort(config.modem.device, { baudRate: 115200 }, async (err) => {
    if (err) {
        logger.warn(`Error opening modem. ${err}. Terminating modem ${config.modem.device}.`);
        process.exit(1);
    }

    await writeToPortDelayed('AT\r');

    /*
    if (isNotBlacklistedCommand('CGSN')) await writeToPortDelayed('AT&F\r', 2000);
    if (isNotBlacklistedCommand('CGSN')) await writeToPortDelayed('AT+CGSN\r', 2000);
    if (isNotBlacklistedCommand('CIMI')) await writeToPortDelayed('AT+CIMI\r', 2000);
    if (isNotBlacklistedCommand('CSQ')) await writeToPortDelayed('AT+CSQ\r', 2000);
    if (isNotBlacklistedCommand('COPS?')) await writeToPortDelayed('AT+COPS?\r', 2000);
    // if (isNotBlacklistedCommand('CMGD')) await writeToPortDelayed('AT+CMGD=0,4\r', 2000);
    */

    const commands = [
        'AT&F\r',
        'ATE0\r',
        'AT+CGSN\r',
        'AT+CIMI\r',
        'AT+COPS?\r',
        'AT+CSQ\r',
    ];


    const commandsCount = commands.length;
    // eslint-disable-next-line no-plusplus
    for (let i = 0; i < commandsCount; i++) {
        // eslint-disable-next-line no-await-in-loop
        await writeToPortDelayed(commands[i], 2000);
    }

    if (config && config.modem_tester && config.modem_tester.commands
        && config.modem_tester.commands.length) {
        const additionalCommandsLength = config.modem_tester.commands.length;
        // eslint-disable-next-line no-plusplus
        for (let i = 0; i < additionalCommandsLength; i++) {
            // eslint-disable-next-line no-await-in-loop
            await writeToPortDelayed(config.modem_tester.commands[i], 2000);
        }
    }
});

parsers.setPort(port);

if (config && config.modem_tester && config.modem_tester.parser === 'regex') {
    logger.info('Using parserWaitForOkOrError');
    port.pipe(parserWaitForOkOrError);
} else if (config && config.modem_tester && config.modem_tester.parser === 'interbyte') {
    logger.info('Using parserInterByteTimeout');
    port.pipe(parserInterByteTimeout);
} else {
    logger.info('Using parserReadline');
    port.pipe(parsers.parserReadline);
}