TEKTELIC - Tundra Sensor

Codec Preview

/* eslint-disable no-plusplus */ /* eslint-disable prettier/prettier */ /* eslint-disable no-bitwise */ /* * Tundra sensor */ function signed_convert(val, bitwidth) { const isnegative = val & (1 << (bitwidth - 1)); const boundary = 1 << bitwidth; const minval = -boundary; const mask = boundary - 1; return isnegative ? minval + (val & mask) : val; } function Decoder(bytes, port) { // Decode an uplink message from a buffer // (array) of bytes to an object of fields. // Device Info Not Repeated const array_result = []; if (port === 10) { for (let i = 0; i < bytes.length; ) { const channel = bytes[i++]; const type = bytes[i++]; // battery voltage if (channel === 0x00 && type === 0xff) { let battery_voltage = (bytes[i] << 8) | bytes[i + 1]; battery_voltage = signed_convert(battery_voltage, 16); array_result.push({ variable: "battery_voltage", value: Number((battery_voltage * 0.01).toFixed(2)), unit: "V" }); i += 2; } // mcu temperature if (channel === 0x0b && type === 0x67) { let mcu_temperature = (bytes[i] << 8) | bytes[i + 1]; mcu_temperature = signed_convert(mcu_temperature, 16); array_result.push({ variable: "mcu_temperature", value: Number((mcu_temperature * 0.1).toFixed(2)), unit: "°C" }); i += 2; } if (channel === 0x03 && type === 0x67) { let ambient_temperature = (bytes[i] << 8) | bytes[i + 1]; ambient_temperature = signed_convert(ambient_temperature, 16); if (ambient_temperature === 65535) { ambient_temperature = -1; } array_result.push({ variable: "ambient_temperature", value: Number((ambient_temperature * 0.1).toFixed(2)), unit: "°C" }); i += 2; } // impact alarm if (channel === 0x0c && type === 0x00) { let impact_alarm = bytes[i]; if (impact_alarm === 0xff) { impact_alarm = "Impact alarm active"; } if (impact_alarm === 0x00) { impact_alarm = "Impact alarm inactive"; } array_result.push({ variable: "impact_alarm", value: impact_alarm }); i += 1; } // Acceleration Magnitude if (channel === 0x05 && type === 0x02) { const acceleration_magnitude = (bytes[i] << 8) | bytes[i + 1]; array_result.push({ variable: "acceleration_magnitude", value: acceleration_magnitude, unit: "g" }); i += 2; } // Acceleration Vector if (channel === 0x07 && type === 0x71) { const acceleration_vector_x = (bytes[i] << 8) | bytes[i + 1]; array_result.push({ variable: "acceleration_x_axis", value: acceleration_vector_x, unit: "g" }); const acceleration_vector_y = (bytes[i + 2] << 8) | bytes[i + 3]; array_result.push({ variable: "acceleration_y_axis", value: acceleration_vector_y, unit: "g" }); const acceleration_vector_z = (bytes[i + 4] << 8) | bytes[i + 5]; array_result.push({ variable: "acceleration_z_axis", value: acceleration_vector_z, unit: "g" }); i += 6; } } return array_result; } if (port === 32) { let flag_entry = 0; for (let i = 0; i < bytes.length; ) { if (flag_entry === 0) { flag_entry = 1; const tag_entry = (bytes[0] << 8) | bytes[i + 1]; array_result.push({ variable: "tag_entry", value: tag_entry }); i += 2; } const channel = bytes[i++]; const type = bytes[i++]; if (channel === 0x03 && type === 0x67) { let ambient_temperature = (bytes[i] << 8) | bytes[i + 1]; ambient_temperature = signed_convert(ambient_temperature, 16); if (ambient_temperature === 65535) { ambient_temperature = -1; } array_result.push({ variable: "ambient_temperature", value: Number((ambient_temperature * 0.1).toFixed(2)), unit: "°C" }); i += 2; } if (channel === 0x04 && type === 0x68) { const ambient_rh = bytes[i]; array_result.push({ variable: "ambient_rh", value: Number((ambient_rh * 0.5).toFixed(2)), unit: "%" }); i += 1; } } flag_entry = 0; return array_result; } if (port === 33) { for (let i = 0; i < bytes.length; ) { const channel = bytes[i++]; const type = bytes[i++]; if (channel === 0x03 && type === 0x67) { let ambient_temperature = (bytes[i] << 8) | bytes[i + 1]; ambient_temperature = signed_convert(ambient_temperature, 16); array_result.push({ variable: "ambient_temperature", value: Number((ambient_temperature * 0.1).toFixed(2)), unit: "°C" }); i += 2; } if (channel === 0x04 && type === 0x68) { const ambient_rh = bytes[i]; array_result.push({ variable: "ambient_rh", value: Number((ambient_rh * 0.5).toFixed(2)), unit: "%" }); i += 1; } } return array_result; } } const payload_raw = payload.find((x) => x.variable === "payload_raw" || x.variable === "payload" || x.variable === "data" || x.variable === "payload_hex"); const port = payload.find((x) => x.variable === "port" || x.variable === "fport" || x.variable === "FPort"); 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 = Decoder(buffer, port.value); 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 }]; } }