const MUTEX_COMMAND = 'COMMAND';
// const MUTEX_SUBCOMMAND = 'SUBCOMMAND';

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

const logger = require('komodo-sdk/logger');
const mutex = require('./mutex-common');
const parsers = require('./serialport-parsers');

let port;

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);
        });
    });
}

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


exports.setPort = function setPort(val) {
    port = val;
};

exports.querySignalQuality = function querySignalQuality() {
    return new Promise(async (resolve) => {
        if (!mutex.tryLock(MUTEX_COMMAND, 'querySignalQuality')) {
            resolve(false);
            return;
        }

        await writeToPort('AT+CSQ\r');
        mutex.unlock(MUTEX_COMMAND, 'querySignalQuality');
        resolve(true);
    });
};

exports.queryCOPS = function querySignalQuality() {
    return new Promise(async (resolve) => {
        await mutex.lock(MUTEX_COMMAND, 'queryCOPS');
        await writeToPort('AT+COPS?\r');
        mutex.unlock(MUTEX_COMMAND, 'queryCOPS');
        resolve(true);
    });
};

exports.queryIMEI = function queryIMEI() {
    return new Promise(async (resolve) => {
        const parser = new ParserRegex({ regex: parsers.PARSER_WAIT_FOR_OK_OR_ERROR_REGEX });
        parser.on('data', (data) => {
            logger.verbose('INCOMING', { parser: 'parserIMEI', data: data.toString() });
            port.unpipe(parser);
            mutex.unlock(MUTEX_COMMAND, 'queryIMEI');
            resolve();
        });

        await mutex.lock(MUTEX_COMMAND, 'queryIMEI');

        port.pipe(parser);
        await writeToPort('AT+CGSN\r');
    });
};