const PARSER_READLINE_DELIMITER = '\r
  ';

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

  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;