/* eslint-disable no-plusplus */
/* eslint-disable prettier/prettier */
/*
 * LW001-BG-PRO
 */

const packet_type = [
  "heart",
  "fix_success",
  "fix_false",
  "sys_close_info",
  "shake_info",
  "idle_info",
  "demolish_alarm",
  "event",
  "battery_consume",
  "config",
  "store_data",
  "limit_gps_data",
];
const dev_mode = ["standby", "period", "timing", "motion"];
const dev_fix_type = ["work_mode_fix", "down_request_fix"];
function substringBytes(bytes, start, len) {
  const char = [];
  for (let i = 0; i < len; i++) {
    char.push(`0x${bytes[start + i].toString(16)}` < 0x10 ? `0${bytes[start + i].toString(16)}` : bytes[start + i].toString(16));
  }
  return char.join("");
}
function BytestoInt(bytes, start) {
  const value = (bytes[start] << 24) | (bytes[start + 1] << 16) | (bytes[start + 2] << 8) | bytes[start + 3];
  return value;
}
function Decoder(bytes, port) {
  const dev_info = {};
  dev_info.pack_type = packet_type[port - 1];
  // common frame head
  if (port <= 10) {
    dev_info.work_mode = dev_mode[bytes[0] & 0x03];
    dev_info.low_power_state = (bytes[0] >> 2) & 0x01;
    dev_info.demolish_state = (bytes[0] >> 3) & 0x01;
    dev_info.idle_state = (bytes[0] >> 4) & 0x01;
    dev_info.motion_state = (bytes[0] >> 5) & 0x01;
    if (port === 2 || port === 3) {
      dev_info.fix_type = dev_fix_type[(bytes[0] >> 6) & 0x01];
    }

    if (bytes[1] > 0x80) {
      dev_info.temperature = `${bytes[1] - 0x100}°C`;
    } else {
      dev_info.temperature = `${bytes[1]}°C`;
    }

    dev_info.lorawan_downlink_count = bytes[2] & 0x0f;
    dev_info.battery_voltage = `${(22 + ((bytes[2] >> 4) & 0x0f)) / 10}V`;
  }
  if (port === 1) {
    const restart_reason = ["power_restart", "ble_cmd_restart", "lorawan_cmd_restart", "switch_off_mode_restart"];
    dev_info.pre_restart_reason = restart_reason[bytes[3]];

    const ver_major = (bytes[4] >> 6) & 0x03;
    const ver_mijor = (bytes[4] >> 4) & 0x03;
    const ver_patch = bytes[4] & 0x0f;
    dev_info.ver = `V${ver_major}.${ver_mijor}.${ver_patch}`;

    dev_info.motion_count = BytestoInt(bytes, 5);
  } else if (port === 2) {
    const fix_tech = ["wifi", "ble", "gps"];
    let parse_len = 3; // common head is 3 byte
    const datas = [];
    const tech = bytes[parse_len++];
    dev_info.fix_tech = fix_tech[tech];

    const year = bytes[parse_len] * 256 + bytes[parse_len + 1];
    parse_len += 2;
    const mon = bytes[parse_len++];
    const days = bytes[parse_len++];
    const hour = bytes[parse_len++];
    const minute = bytes[parse_len++];
    const sec = bytes[parse_len++];
    const timezone = bytes[parse_len++];

    if (timezone > 0x80) {
      dev_info.utc_time = `${year}-${mon}-${days} ${hour}:${minute}:${sec}  TZ:${timezone - 0x100}`;
    } else {
      dev_info.utc_time = `${year}-${mon}-${days} ${hour}:${minute}:${sec}  TZ:${timezone}`;
    }
    const datalen = bytes[parse_len++];

    if (tech === 0 || tech === 1) {
      for (let i = 0; i < datalen / 7; i++) {
        const data = {};
        data.mac = substringBytes(bytes, parse_len, 6);
        parse_len += 6;
        data.rssi = `${bytes[parse_len++] - 256}dBm`;
        datas.push(data);
      }
      dev_info.mac_data = datas;
    } else {
      let lat = BytestoInt(bytes, parse_len);
      parse_len += 4;
      let lng = BytestoInt(bytes, parse_len);
      parse_len += 4;

      if (lat > 0x80000000) lat -= 0x100000000;
      if (lng > 0x80000000) lng -= 0x100000000;

      dev_info.lat = lat / 10000000;
      dev_info.lng = lng / 10000000;
      lat = dev_info.lat;
      lng = dev_info.lng;
      dev_info.location = { variable: "location", value: `${lat},${lng}`, location: { lat, lng } };
      dev_info.pdop = bytes[parse_len] / 10;
    }
  } else if (port === 3) {
    const fix_false_reason = [
      "wifi_fix_time_timeout",
      "wifi_fix_tech_timeout",
      "wifi_module_nofind",
      "ble_fix_time_timeout",
      "ble_fix_tech_timeout",
      "ble_adv",
      "gps_no_budget",
      "gps_coarse_acc_timeout",
      "gps_fine_acc_timeout",
      "gps_fix_timeout",
      "gps_assistnow_timeout",
      "gps_cold_start_timeout",
      "down_request_fix_interrupt",
      "motion_start_fix_false_by_motion_end",
      "motion_end_fix_false_by_motion_start",
    ];
    let parse_len = 3;
    const datas = [];
    const reason = bytes[parse_len++];
    dev_info.fix_false_reason = fix_false_reason[reason];
    const datalen = bytes[parse_len++];
    if (reason <= 5) {
      // wifi and ble reason
      if (datalen) {
        for (let i = 0; i < datalen / 7; i++) {
          const data = {};
          data.mac = substringBytes(bytes, parse_len, 6);
          parse_len += 6;
          data.rssi = `${bytes[parse_len++] - 256}dBm`;
          datas.push(data);
        }
        dev_info.mac_data = datas;
      }
    } else if (reason <= 11) {
      // gps reason
      const pdop = bytes[parse_len++];
      if (pdop !== 0xff) dev_info.pdop = pdop / 10;
      else dev_info.pdop = "unknow";
      dev_info.gps_satellite_cn = `${bytes[parse_len]}-${bytes[parse_len + 1]}-${bytes[parse_len + 2]}-${bytes[parse_len + 3]}`;
    }
  } else if (port === 4) {
    const sys_close_reason = ["ble_cmd_close", "lorawan_cmd_close", "reed_switch_close"];
    dev_info.sys_close_reason = sys_close_reason[bytes[3]];
  } else if (port === 5) {
    dev_info.shake_num = bytes[3] * 256 + bytes[4];
  } else if (port === 6) {
    dev_info.idle_time = bytes[3] * 256 + bytes[4];
  } else if (port === 7) {
    let parse_len = 3; // common head is 3 byte
    const year = bytes[parse_len] * 256 + bytes[parse_len + 1];
    parse_len += 2;
    const mon = bytes[parse_len++];
    const days = bytes[parse_len++];
    const hour = bytes[parse_len++];
    const minute = bytes[parse_len++];
    const sec = bytes[parse_len++];
    const timezone = bytes[parse_len++];

    if (timezone > 0x80) {
      dev_info.alarm_time = `${year}-${mon}-${days} ${hour}:${minute}:${sec}  TZ:${timezone - 0x100}`;
    } else {
      dev_info.alarm_time = `${year}-${mon}-${days} ${hour}:${minute}:${sec}  TZ:${timezone}`;
    }
  } else if (port === 8) {
    const event = ["motion start", "moving fix start", "motion end", "lorawan downlink trigger uplink"];
    dev_info.event_info = event[bytes[3]];
  } else if (port === 9) {
    let parse_len = 3;
    dev_info.gps_work_time = BytestoInt(bytes, parse_len);
    parse_len += 4;
    dev_info.wifi_work_time = BytestoInt(bytes, parse_len);
    parse_len += 4;
    dev_info.ble_scan_work_time = BytestoInt(bytes, parse_len);
    parse_len += 4;
    dev_info.ble_adv_work_time = BytestoInt(bytes, parse_len);
    parse_len += 4;
    dev_info.lorawan_work_time = BytestoInt(bytes, parse_len);
    parse_len += 4;
  } else if (port === 10) {
    //
  } else if (port === 11) {
    //
  } else if (port === 12) {
    dev_info.work_mode = dev_mode[bytes[0] & 0x03];
    dev_info.low_power_state = bytes[0] & 0x04;
    dev_info.demolish_state = bytes[0] & 0x08;
    dev_info.idle_state = bytes[0] & 0x10;
    dev_info.motion_state = bytes[0] & 0x20;
    dev_info.fix_type = dev_fix_type[(bytes[0] >> 6) & 0x01];

    dev_info.lorawan_downlink_count = bytes[1] & 0x0f;
    dev_info.battery_voltage = `${(22 + ((bytes[2] >> 4) & 0x0f)) / 10}V`;

    let parse_len = 2;
    let lat = BytestoInt(bytes, parse_len);
    parse_len += 4;
    let lng = BytestoInt(bytes, parse_len);
    parse_len += 4;

    if (lat > 0x80000000) lat -= 0x100000000;
    if (lng > 0x80000000) lng -= 0x100000000;

    dev_info.lat = lat / 10000000;
    dev_info.lng = lng / 10000000;
    lat = dev_info.lat;
    lng = dev_info.lng;
    dev_info.location = { variable: "location", value: `${lat},${lng}`, location: { lat, lng } };
    dev_info.pdop = bytes[parse_len] / 10;
  }
  return dev_info;
}

function ToTagoFormat(object_item, serie, prefix = "") {
  const result = [];
  for (const key in object_item) {
    if (typeof object_item[key] === "object") {
      result.push({
        variable: (object_item[key].MessageType || `${prefix}${key}`).toLowerCase(),
        value: object_item[key].value || object_item[key].Value,
        serie: object_item[key].serie || serie,
        metadata: object_item[key].metadata,
        unit: object_item[key].unit,
        location: object_item[key].location,
      });
    } else {
      result.push({
        variable: `${prefix}${key}`.toLowerCase(),
        value: object_item[key],
        serie,
      });
    }
  }
  return result;
}

const payload_raw = payload.find((x) => x.variable === "payload_raw" || x.variable === "payload" || x.variable === "data");

// Get the port variable.
const port = payload.find((x) => x.variable === "port" || x.variable === "fport").value;

if (payload_raw) {
  try {
    // Convert the data from Hex to Javascript Buffer.
    const buffer = Buffer.from(payload_raw.value, "hex");
    const serie = new Date().getTime();
    const payload_aux = ToTagoFormat(Decoder(buffer, port), serie);
    payload = payload.concat(payload_aux.map((x) => ({ ...x, serie })));
  } catch (e) {
    // Print the error to the Live Inspector.
    console.error(e);
    // Return the variable parse_error for debugging.
    payload = [{ variable: "parse_error", value: e.message }];
  }
}