DRAGINO - Lht65

Codec Preview

const ignore_vars = ['device_addr', 'port', 'duplicate', 'network', 'packet_hash', 'application', 'device', 'packet_id']; /** * Convert an object to TagoIO object format. * Can be used in two ways: * toTagoFormat({ myvariable: myvalue , anothervariable: anothervalue... }) * toTagoFormat({ myvariable: { value: myvalue, unit: 'C', metadata: { color: 'green' }} , anothervariable: anothervalue... }) * * @param {Object} object_item Object containing key and value. * @param {String} serie Serie for the variables * @param {String} prefix Add a prefix to the variables name */ function toTagoFormat(object_item, serie, prefix = '') { const result = []; for (const key in object_item) { if (ignore_vars.includes(key)) continue; if (typeof object_item[key] == 'object') { result.push({ variable: object_item[key].variable || `${prefix}${key}`, value: object_item[key].value, serie: object_item[key].serie || serie, metadata: object_item[key].metadata, location: object_item[key].location, unit: object_item[key].unit, }); } else { result.push({ variable: `${prefix}${key}`, value: object_item[key], serie, }); } } return result; } /** * In the solutions params is where usually latitude and longitude for your antenna signal comes from. * @param {Object} solutions gateway object from everynet * @param {String|Number} serie serie for the variables */ function transformSolutionParam(solutions, serie) { let to_tago = []; for (const s of solutions) { let convert_json = {}; convert_json.base_location = { value: `${s.lat}, ${s.lng}`, location: { lat: s.lat, lng: s.lng } }; delete s.lat; delete s.lng; convert_json = { ...convert_json, ...s }; to_tago = to_tago.concat(toTagoFormat(convert_json, serie)); } return to_tago; } /** * This is the main function to parse the payload. Everything else doesn't require your attention. * @param {String} payload_raw * @returns {Object} containing key and value to TagoIO */ function Decoder13(bytes, serie) { bytes = Buffer.from(bytes, 'hex'); var value = (bytes[0] << 8 | bytes[1]) & 0x3FFF; var batV = value / 1000;//Battery,units:V value = bytes[2] << 8 | bytes[3]; if (bytes[2] & 0x80) { value |= 0xFFFF0000; } var temp_SHT = (value / 100).toFixed(2);//SHT20,temperature,units:℃ value = bytes[4] << 8 | bytes[5]; var hum_SHT = (value / 10).toFixed(1);//SHT20,Humidity,units:% value = bytes[7] << 8 | bytes[8]; if (bytes[7] & 0x80) { value |= 0xFFFF0000; } var temp_ds = (value / 100).toFixed(2);//DS18B20,temperature,units:℃ return { battery: { value: Number(batV), serie, unit: 'V' }, temp_ds: { value: Number(temp_ds), serie, unit: '°C' }, temp_sht: { value: Number(temp_SHT), serie, unit: '°C' }, hum_sht: { value: Number(hum_SHT), serie, unit: '%' }, }; } function Decoder18(bytes, port) { const decoded = []; if(port !== 2) { return decoded; } const ext = bytes[6]; let connected = false; if ((ext & 0x0f) !== 0x09) { // BAT-Battery Info (2 bytes) const value = bytes[0] >> 6; switch(value) { case 0b00: decoded.push({ variable: "bat_status", value: "Ultra Low ( BAT <= 2.50v )" }); break; case 0b01: decoded.push({ variable: "bat_status", value: "Low ( 2.50v <= BAT <= 2.55v )" }); break; case 0b10: decoded.push({ variable: "bat_status", value: "OK ( 2.55v <= BAT <= 2.65v )" }); break; case 0b11: decoded.push({ variable: "bat_status", value: "Good ( BAT >= 2.65v )" }); break; default: break; } decoded.push({ variable: "battery", value: ((bytes[0] & 0x3f) << 8 | bytes[1]) / 1000, unit: "V" }); // Built-In Temperature (2 bytes) decoded.push({ variable: "temp_sht", value: ((bytes[2]<<24>>16 | bytes[3])/100), unit: "°C" }); // Built-In Humidity (2 bytes) decoded.push({ variable: "hum_sht", value: (bytes[4] << 8 | bytes[5]) / 10, unit: "%" }); // Ext (1 byte) & ext value (4 bytes) //const ext = bytes[6]; switch(ext & 0x0f) { case 0x00: decoded.push({ variable: "ext_sensor", value: "No external sensor" }); break; case 0x01: decoded.push({ variable: "ext_sensor", value: "Sensor E1, Temperature Sensor" }); decoded.push({ variable: "temp_ds", value: ((bytes[7]<<24>>16 | bytes[8])/100), unit: "°C" }); break; case 0x04: decoded.push({ variable: "ext_sensor", value: "Sensor E4, Interrupt Sensor" }); connected = (bytes[6] >> 4) === 0; decoded.push({ variable: "cable_connected", value: connected }); if(connected) { decoded.push({ variable: "pin_level", value: bytes[7] & 0x01 }); decoded.push({ variable: "interrupt_uplink", value: bytes[8] === 0x01 }); } break; case 0x05: decoded.push({ variable: "ext_sensor", value: "Sensor E5, Illumination Sensor" }); connected = (bytes[6] >> 4) === 0; decoded.push({ variable: "cable_connected", value: connected }); if(connected) { decoded.push({ variable: "illumination", value: bytes[7] << 8 | bytes[8], unit: "lux" }); } break; case 0x06: decoded.push({ variable: "ext_sensor", value: "Sensor E6, ADC Sensor" }); connected = (bytes[6] >> 4) === 0; decoded.push({ variable: "cable_connected", value: connected }); if(connected) { decoded.push({ variable: "adc", value: (bytes[7] << 8 | bytes[8])/1000, unit: "V" }); } break; case 0x07: decoded.push({ variable: "ext_sensor", value: "Sensor E7, Counting Sensor, 16 bit" }); connected = (bytes[6] >> 4) === 0; decoded.push({ variable: "cable_connected", value: connected }); if(connected) { decoded.push({ variable: "count", value: (bytes[7] << 8 | bytes[8]) }); } break; case 0x08: decoded.push({ variable: "ext_sensor", value: "Sensor E7, Counting Sensor, 32 bit" }); connected = (bytes[6] >> 4) === 0; decoded.push({ variable: "cable_connected", value: connected }); if(connected) { decoded.push({ variable: "count", value: (bytes[7] << 24 | bytes[8] << 16 | bytes[9] << 8 | bytes[10]) }); } break; default: break; } } else { decoded.push({ variable: "ext_sensor", value: "Sensor E1, Temperature Sensor, Datalog Mod" }); // External Temperature decoded.push({ variable: "temp_ds", value: ((bytes[0]<<24>>16 | bytes[1])/100), unit: "°C" }); // Built-In Temperature (2 bytes) decoded.push({ variable: "temp_sht", value: ((bytes[2]<<24>>16 | bytes[3])/100), unit: "°C" }); // BAT Status & Built-In Humidity (2 bytes) const value = bytes[4] >> 6; switch(value) { case 0b00: decoded.push({ variable: "bat_status", value: "Ultra Low ( BAT <= 2.50v )" }); break; case 0b01: decoded.push({ variable: "bat_status", value: "Low ( 2.50v <= BAT <= 2.55v )" }); break; case 0b10: decoded.push({ variable: "bat_status", value: "OK ( 2.55v <= BAT <= 2.65v )" }); break; case 0b11: decoded.push({ variable: "bat_status", value: "Good ( BAT >= 2.65v )" }); break; default: break; } decoded.push({ variable: "hum_sht", value: ((bytes[4] & 0x0f) << 8 | bytes[5]) / 10, unit: "%" }); // Status & Ext decoded.push({ variable: "poll_message_flag", value: (bytes[6] >> 6) & 0x01 }); decoded.push({ variable: "sync_time_ok", value: (bytes[6] >> 5) & 0x01 }); decoded.push({ variable: "unix_time_request", value: (bytes[6] >> 4) & 0x01 }); // Unix Timestamp decoded.push({ variable: "unix_timestamp", value: (bytes[7] << 24 | bytes[8] << 16 | bytes[9] << 8 | bytes[10]) }); } if(bytes.length === 11) { return decoded; } } // let payload = [{ variable: "payload", value: "cb060b5b02770400017fff" }, { variable: "fport", value: "2" }]; // let payload = [{ variable: "payload", value: "cbf60b0d037601addd7fff" }, { variable: "fport", value: "2" }]; // let payload = [{ variable: "payload", value: "cbbdf5c6022e01f54f7fff" }, { variable: "fport", value: "2" }]; // let payload = [{ variable: "payload", value: "cbf60b0d0376010add7fff" }, { variable: "fport", value: "2" }]; // let payload = [{ variable: "payload", value: "cb040b55025a0401007fff" }, { variable: "fport", value: "2" }]; // let payload = [{ variable: "payload", value: "cb030b2d027c0501917fff" }, { variable: "fport", value: "2" }]; // let payload = [{ variable: "payload", value: "cb0b0b640272060b067fff" }, { variable: "fport", value: "2" }]; // let payload = [{ variable: "payload", value: "cbd50b0502e70700067fff" }, { variable: "fport", value: "2" }]; // let payload = [{ variable: "payload", value: "cbcb09e702140800010005" }, { variable: "fport", value: "2" }]; // let payload = [{ variable: "payload", value: "0add0b0dc376596075ad9a" }, { variable: "fport", value: "2" }]; const data = payload.find((x) => x.variable === "payload" || x.variable === "payload_raw" || x.variable === "data" || x.variable === "payload_hex"); const port = payload.find((x) => x.variable === "port" || x.variable === "fport" || x.variable === "FPort" || x.variable === "fPort"); //uplink uses fport === 2 const version = device.params.find((x) => x.key.toLowerCase() === "version"); if (data) { const serie = data.serie || new Date().getTime(); const bytes = Buffer.from(data.value, "hex"); if(!version || !version.value || version.value === "1.8") { payload = payload.concat(Decoder18( bytes, Number(port.value) )).map((x) => ({ ...x, serie})); } else { payload = payload.concat(toTagoFormat(Decoder13( bytes, Number(port.value) ), Number(port.value))).map((x) => ({ ...x, serie })); } }