const Channel = require('./channel');

exports.config = {
  defaultName: 'Shure Wireless',
  connectionType: 'TCPsocket',
  remotePort: 2202,
  mayChangePorts: false,
  heartbeatInterval: 5000,
  heartbeatTimeout: 10000,
  searchOptions: {
    type: 'TCPport',
    searchBuffer: Buffer.from('< GET DEVICE_ID >', 'ascii'),
    testPort: 2202,
    validateResponse(msg, info) {
      return msg.toString().includes('DEVICE_ID');
    },
  },
};

exports.ready = function ready(_device) {
  const device = _device;
  device.data.channelCount = 0;
  device.data.channels = [{}, new Channel(), new Channel(), new Channel(), new Channel()];

  device.send('< GET 0 ALL >');
  device.send('< SET 0 METER_RATE 00100 >');
  device.send('< SAMPLE 0 AUDIO_LVL>');
};

exports.data = function data(_device, message) {
  const device = _device;
  let msgStr = message.toString();

  if (!msgStr.startsWith('< ')) {
    return;
  }

  // console.log(msgStr);

  msgStr = msgStr.slice(2).slice(0, -1);
  const msgs = msgStr.split('><');

  msgs.forEach((ms, i) => {
    const msg = ms.trim();
    const msgParts = msg.split(' ');
    const channelNumber = Number(msgParts[1]);
    const channel = device.data.channels[channelNumber];

    if (msgParts[0] === 'REP') {
      if (msgParts[2] === 'CHAN_NAME') {
        channel.chan_name = msg.substring(17).slice(0, -2).trim();
        if (device.data.channelCount < channelNumber) {
          device.data.channelCount = channelNumber;
        }
        device.draw();
      } else if (msgParts[2] === 'BATT_BARS') {
        channel.batt_bars = Number(msgParts[3]);
      } else if (msgParts[2] === 'BATT_RUN_TIME') {
        channel.batt_run_time = Number(msgParts[3]);
      } else if (msgParts[2] === 'AUDIO_GAIN') {
        channel.audio_gain = Number(msgParts[3]) - 18;
      } else if (msgParts[2] === 'AUDIO_LVL') {
        channel.audio_lvl = Number(msgParts[3]);
      } else if (msgParts[2] === 'RX_RF_LVL') {
        channel.rx_rf_lvl = Number(msgParts[3]) - 128;
      } else if (msgParts[2] === 'RF_ANTENNA') {
        channel.rf_antenna = msgParts[3];
      } else if (msgParts[2] === 'TX_TYPE') {
        channel.tx_type = msgParts[3];
        device.draw();
      } else if (msgParts[1] === 'DEVICE_ID') {
        const id = msg.substring(15).slice(0, -1).trim();
        this.deviceInfoUpdate(device, 'defaultName', id);
      } else if (msgParts[1] === 'FW_VER') {
        device.data.version = msgParts[2].substring(1);
      }
    } else if (msgParts[0] === 'SAMPLE') {
      channel.rf_antenna = msgParts[3];
      channel.rx_rf_lvl = Number(msgParts[4]) - 128;
      channel.audio_lvl = Number(msgParts[5]);
      if (channelNumber === device.data.channelCount) {
        device.update('updateSample', {
          channels: device.data.channels,
        });
      }
    }
  });
};

exports.update = function update(device, doc, updateType, data) {
  for (let i = 1; i < data.channels.length; i++) {
    const channel = data.channels[i];
    const $audio = doc.getElementById(`ch-${i}-audio`);
    const $audioText = doc.getElementById(`ch-${i}-audio-text`);
    if ($audio) {
      $audio.style.height = 90 - channel.audio_lvl * 2;
    }
    if ($audioText) {
      $audioText.textContent = channel.audio_lvl;
    }

    const $rfA = doc.getElementById(`ch-${i}-a`);
    const $rfB = doc.getElementById(`ch-${i}-b`);
    let rfClass = '';

    if ($rfA) {
      if (channel.rf_antenna.charAt(0) === 'A') {
        $rfA.style.color = '#53c3c3';
        rfClass = 'color-1';
      } else {
        $rfA.style.color = '#333';
      }
    }
    if ($rfB) {
      if (channel.rf_antenna.charAt(1) === 'B') {
        $rfB.style.color = '#53c3c3';
        rfClass = 'color-2';
      } else {
        $rfB.style.color = '#333';
      }
    }

    const $rf = doc.getElementById(`ch-${i}-rf`);
    const $rfGraph = doc.getElementById(`ch-${i}-graph`);
    const $rfText = doc.getElementById(`ch-${i}-rf-text`);
    const rfHeight = 90 - (channel.rx_rf_lvl + 90) * 2;
    if ($rf) {
      $rf.style.height = rfHeight;
    }
    if ($rfGraph) {
      if ($rfGraph.childElementCount > 115) {
        $rfGraph.removeChild($rfGraph.firstElementChild);
      }
      $rfGraph.insertAdjacentHTML(
        'beforeend',
        `<div class="rf-graph-bar ${rfClass}" style="height: ${channel.rx_rf_lvl + 100}px;"></div>`
      );
      channel.rx_graph_bars++;
    }
    if ($rfText) {
      $rfText.textContent = channel.rx_rf_lvl;
    }
  }
};

exports.heartbeat = function heartbeat(device) {
  device.send('< GET 0 ALL >');
  device.send('< SET 0 METER_RATE 00100 >');
  device.send('< SAMPLE 0 AUDIO_LVL>');
};