/* This is an example code for Everynet Parser. ** Everynet send several parameters to TagoIO. The job of this parse is to convert all these parameters into a TagoIO format. ** One of these parameters is the payload of your device. We find it too and apply the appropriate sensor parse. ** ** IMPORTANT: In most case, you will only need to edit the parsePayload function. ** ** Testing: ** You can do manual tests to this parse by using the Device Emulator. Copy and Paste the following code: ** [{ "variable": "everynet_payload", "value": "{ \"params\": { \"payload\": \"0109611395\" } }" }] ** ** The ignore_vars variable in this code should be used to ignore variables ** from the device that you don't want. */ // Add ignorable variables in this array. const ignore_vars = ['latitude', 'longitude', 'device_addr', 'port', 'duplicate', 'network', 'packet_hash', 'application', 'device', 'packet_id', 'latitud']; /** * 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; } /** * 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 parsePayload(payload_raw) { const bytes = Buffer.from(payload_raw, 'hex'); var alarm = (bytes[6] & 0x40) ? true : false;//Alarm status value = ((bytes[6] & 0x3f) << 8) | bytes[7]; var batV = value / 1000;//Battery,units:Volts value = bytes[8] << 8 | bytes[9]; if (bytes[8] & 0x80) { value |= 0xFFFF0000; } var roll = value / 100;//roll,units: ° value = bytes[10] << 8 | bytes[11]; if (bytes[10] & 0x80) { value |= 0xFFFF0000; } var pitch = value / 100; //pitch,units: ° var json = { roll: roll, pitch: pitch, batV: batV, alarm: alarm }; var value = bytes[0] << 16 | bytes[1] << 8 | bytes[2]; if (bytes[0] & 0x80) { value |= 0xFFFFFF000000; } var value2 = bytes[3] << 16 | bytes[4] << 8 | bytes[5]; if (bytes[3] & 0x80) { value2 |= 0xFFFFFF000000; } if (value == 0x0FFFFF && value2 == 0x0FFFFF) { json.latitude = 0;//gps latitude,units: ° json.longitude = 0;//gps longitude,units: ° } else { json.latitude = value / 10000;//gps latitude,units: ° json.longitude = value2 / 10000;//gps longitude,units: ° } const data = { roll: { value: json.roll, unit: 'g', location: { lat: json.latitude, lng: json.longitude } }, pitch: { value: json.pitch, unit: 'g', location: { lat: json.latitude, lng: json.longitude } }, battery: { value: json.batV, unit: 'v', location: { lat: json.latitude, lng: json.longitude } }, alarm_status: { value: json.alarm ? 'TRUE' : 'FALSE', location: { lat: json.latitude, lng: json.longitude } }, payload: { value: payload_raw }, location: { value: `${json.latitude}, ${json.longitude}`, location: { lat: json.latitude, lng: json.longitude } }, }; return data; } */ function Decoder(payload_raw) { const bytes = Buffer.from(payload_raw, 'hex'); const json = { // GPS coordinates; signed 32 bits integer, MSB; unit: Â° // When power is low (<2.84v), GPS wonâ€™t be able to get location // info and GPS feature will be disabled and the location field // will be filled with 0x0FFFFFFF, 0x0FFFFFFF. Latitude: (bytes[0]<<24 | bytes[1]<<16 | bytes[2]<<8 | bytes[3]) / 1000000, Longitude: (bytes[4]<<24 | bytes[5]<<16 | bytes[6]<<8 | bytes[7]) / 1000000, // Alarm status: boolean ALARM_status: (bytes[8] & 0x40) > 0, // Battery; 14 bits; unit: V BatV: ((bytes[8] & 0x3f)<<8 | bytes[9]) / 1000, // Motion detection mode; 2 bits MD: { "0": "Disable", "1": "Move", "2": "Collide", "3": "Custom" }[bytes[10]>>6], // LED status for position, uplink and downlink; 1 bit LON: (bytes[10] & 0x20) ? "ON" : "OFF", // Firmware version; 5 bits FW:150+(bytes[10] & 0x1f), // Roll; signed 16 bits integer, MSB; unit: Â° // Sign-extend to 32 bits to support negative values: shift 16 bytes // too far to the left, followed by sign-propagating right shift Roll: (bytes[11]<<24>>16 | bytes[12]) / 100, // Pitch: signed 16 bits integer, MSB, unit: Â° Pitch: (bytes[13]<<24>>16 | bytes[14]) / 100, }; const data = { roll: { value: json.Roll, unit: 'g', location: { lat: json.Latitude, lng: json.Longitude } }, pitch: { value: json.Pitch, unit: 'g', location: { lat: json.Latitude, lng: json.Longitude } }, battery: { value: json.BatV, unit: 'v', location: { lat: json.Latitude, lng: json.Longitude } }, alarm_status: { value: json.ALARM_status ? 'TRUE' : 'FALSE', location: { lat: json.Latitude, lng: json.Longitude } }, payload: { value: payload_raw }, location: { value: `${json.Latitude}, ${json.Longitude}`, location: { lat: json.Latitude, lng: json.Longitude } }, }; return data; } let vars_to_tago = []; const everynet_payload = payload.find(x => x.variable === 'payload' || x.variable === 'data'); if (everynet_payload) { // Get a unique serie for the incoming data. const serie = everynet_payload.serie || new Date().getTime(); // Parse the payload from your sensor to function parsePayload try { vars_to_tago = vars_to_tago.concat(toTagoFormat(Decoder(everynet_payload.value), serie)); } catch (e) { // Catch any error in the parse code and send to parse_error variable. vars_to_tago = vars_to_tago.concat({ variable: 'parse_error', value: e.message || e, metadata: { error: e } }); } payload = vars_to_tago; }

MQflex

About us

Contact us

Our links