const md5 = require('md5');

exports.config = {
  defaultName: 'PJLink Projector',
  connectionType: 'TCPsocket',
  remotePort: 4352,
  mayChangePorts: false,
  heartbeatInterval: 5000,
  heartbeatTimeout: 15000,
  searchOptions: {
    type: 'UDPsocket',
    searchBuffer: Buffer.from([0x25, 0x32, 0x53, 0x52, 0x43, 0x48, 0x0d]),
    devicePort: 4352,
    listenPort: 4352,
    validateResponse(msg, info) {
      return msg.toString().includes('%2ACKN=');
    },
  },
  fields: [
    {
      key: 'password',
      label: 'Pass',
      type: 'textinput',
      value: '',
      action(device) {
        device.plugin.heartbeat(device);
      },
    },
  ],
};

exports.ready = function ready(device) {
  // Power status query
  // device.send("%1POWR ?\r");
};

const PJLinkCmds = [
  '%1POWR=',
  '%1INPT=',
  '%1AVMT=',
  '%1ERST=',
  '%1LAMP=',
  '%1NAME=',
  '%1INF1=',
  '%1INF2=',
  '%2SNUM=',
  '%2SVER=',
];

let passwordMD5 = false;
let passwordSeed = false;

function processPJLink(_device, str, that) {
  const arr = str.split('%');
  arr.shift();
  const device = _device;

  arr.forEach((response) => {
    const parts = response.split('=');
    const cmd = parts[0];
    const value = parts[1];

    switch (cmd) {
      case '1POWR':
        device.data.power = value;
        break;

      case '1INPT':
        device.data.input = value;
        break;

      case '1AVMT':
        device.data.avmute = value;
        break;

      case '1ERST':
        device.data.fanError = value[0];
        device.data.lampError = value[1];
        device.data.tempError = value[2];
        device.data.coverError = value[3];
        device.data.filterError = value[4];
        device.data.otherError = value[5];
        break;

      case '1LAMP':
        device.data.lamp = value.split(' ');
        break;

      case '1NAME':
        device.data.name = value;
        that.deviceInfoUpdate(device, 'defaultName', device.data.name);
        break;

      case '1INF1':
        device.data.info1 = value;
        break;

      case '1INF2':
        device.data.info2 = value;
        break;

      case '2SNUM':
        device.data.serial = value;
        break;

      case '2SVER':
        device.data.version = value;
        break;

      default:
        break;
    }
  });
  device.draw();
}

exports.data = function data(_device, message) {
  const device = _device;
  this.deviceInfoUpdate(device, 'status', 'ok');
  const msg = message.toString();

  if (msg.substring(0, 8) === 'PJLINK 1') {
    passwordSeed = msg.substring(9, 17);
    passwordMD5 = md5(`${passwordSeed}${device.fields.password}`);
    device.data.authentication = 'ON';

    device.send(
      `${passwordMD5}%1POWR ?\r%1INPT ?\r%1AVMT ?\r%1ERST ?\r%1LAMP ?\r%1NAME ?\r%1INF1 ?\r%1INF2 ?\r%2SNUM ?\r%2SVER ?\r`
    );
    device.draw();
  } else if (msg.substring(0, 8) === 'PJLINK 0') {
    device.data.authentication = 'OFF';
    device.draw();
  } else if (msg.startsWith('PJLINK ERRA')) {
    device.data.passwordOK = false;
    device.draw();
  }

  if (PJLinkCmds.includes(msg.substring(0, 7))) {
    processPJLink(device, msg, this);
    device.data.passwordOK = true;
  }
};

exports.heartbeat = function heartbeat(device) {
  passwordMD5 = md5(`${passwordSeed}${device.fields.password}`);
  if (device.fields.password.length > 0 && device.data.passwordOK) {
    device.send(
      `${passwordMD5}%1POWR ?\r%1INPT ?\r%1AVMT ?\r%1ERST ?\r%1LAMP ?\r%1NAME ?\r%1INF1 ?\r%1INF2 ?\r%2SNUM ?\r%2SVER ?\r`
    );
  } else if (device.fields.password.length > 0) {
    device.send(`${passwordMD5}%1POWR ?\r`);
  } else if (device.data.passwordOK) {
    device.send(`%1POWR ?\r%1INPT ?\r%1AVMT ?\r%1ERST ?\r%1LAMP ?\r%1NAME ?\r%1INF1 ?\r%1INF2 ?\r%2SNUM ?\r%2SVER ?\r`);
  } else {
    device.send(`%1POWR ?\r`);
  }

  device.draw();
};