const PARSER_READLINE_DELIMITER = '\r\n';
const PARSER_WAIT_FOR_OK_OR_ERROR_REGEX = /\r\n(?:OK|ERROR)\r\n/;

const pdu = require('node-pdu');
const ParserReadline = require('@serialport/parser-readline');
const ParserRegex = require('@serialport/parser-regex');

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

const dbCops = require('./db-cops');

let port;

exports.setPort = function setPort(val) {
    logger.info('SERIALPORT-PARSERS: setting port');
    port = val;
};

exports.getPort = function getPort() {
    return port;
};

function parsePdu(data) {
    if (!data) return null;

    try {
        const result = pdu.parse(data.toString().trim() || '');
        return result;
    } catch (e) {
        return null;
    }
}

function onCSQ(data) {
    const val = data.toString().trim().match(/\+CSQ:\s*(.*)/);
    if (!val || !val[1]) return null;

    logger.info('Signal quality extracted', { signalQuality: val[1] });
    return val[1];
}

function onPduDeliver(data, parsedData) {
    const from = parsedData.getAddress && parsedData.getAddress().getPhone
        ? parsedData.getAddress().getPhone() : null;

    const msg = parsedData.getData && parsedData.getData().getData
        ? parsedData.getData().getData() : null;

    logger.verbose('PDU processed', { from, msg });
    return { from, msg };
}

function onCOPS(data) {
    const val = data.toString().trim().match(/\+COPS:\s*(.*)/);
    if (!val || !val[1]) return null;

    const cops = val[1];

    if (!cops) return null;
    const [mode, format, networkId] = cops.split(',');
    const networkName = networkId ? dbCops[networkId] || networkId : null;

    logger.verbose('COPS extracted', {
        cops, mode, format, networkId, networkName,
    });

    return {
        cops, mode, format, networkId, networkName,
    };
}


function isResultCodeIs(data, resultCode) {
    if (!data) return false;
    const cleanedData = (data.toString() || '').trim();
    if (!cleanedData) return false;

    if (resultCode.indexOf('+') !== 0) {
        // eslint-disable-next-line no-param-reassign
        resultCode = `+${resultCode}`;
    }

    if (resultCode.search(/:$/) < 0) {
        // eslint-disable-next-line no-param-reassign
        resultCode += ':';
    }

    return cleanedData.indexOf(resultCode) === 0;
}

const parserReadline = new ParserReadline({ delimiter: PARSER_READLINE_DELIMITER });
parserReadline.on('data', (data) => {
    logger.verbose('INCOMING', { parser: 'parserReadLine', data: `${data.toString()}${PARSER_READLINE_DELIMITER}` });

    if (!data) return;

    const pduParsed = parsePdu(data);
    if (pduParsed) {
        logger.verbose('PDU parsed', { type: (typeof pduParsed.getType === 'function') && pduParsed.getType() });
    }

    if (pduParsed && pduParsed.constructor.name !== 'Deliver') {
        logger.warn('Unknown PDU message type name', { typeName: pduParsed.constructor.name, type: pduParsed.getType(), data: data.toString().trim() });
    }

    if (pduParsed && pduParsed.constructor.name === 'Deliver' && pduParsed.getType && pduParsed.getType().getSrr()) {
        logger.verbose('Got a PDU SMS-DELIVER', { type: pduParsed.getType() });
        onPduDeliver(data, pduParsed);
    } else if (isResultCodeIs(data, 'CSQ')) {
        logger.verbose('Got a signal quality report', { data: data.toString() });
        onCSQ(data);
    } else if (isResultCodeIs(data, 'COPS:')) {
        logger.verbose('Got a COPS report', { data: data.toString() });
        onCOPS(data);
    } else if (isResultCodeIs(data, 'CMT')) {
        logger.verbose('Got a new message report', { data: data.toString() });
    } else if (isResultCodeIs(data, 'CMTI')) {
        logger.verbose('Got a new message notification report', { data: data.toString() });
    }
});

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


exports.parserReadline = parserReadline;
exports.parserWaitForOkOrError = parserWaitForOkOrError;