TEKTELIC - Custom Tektelic

Codec Preview

/* This is an example code for TTN Parser. ** TTN 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": "tektelic_payload", "value": "{ \"payload_raw\": \"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 = ['rf_chain', 'channel', 'modulation', 'app_id', 'dev_id', 'time', 'gtw_trusted', 'port', 'rxinfo_time', 'rxinfo_rfchain', 'datarate_modulation', 'datarate_bandwidth', 'rxinfo_coderate', 'datarate_spreadfactor', 'rxinfo_mac', 'rxinfo_antenna', 'rxinfo_timestamp', 'adr']; /** * 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) || object_item[key] === null) 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; } function inspectFormat(object_item, serie, old_key) { let result = []; for (const key in object_item) { if (key === 'lng' || key === 'longitude') continue; else if (key === 'lat' || key === 'latitude') { const lng = object_item.lng || object_item.longitude; result.push({ variable: old_key ? `${old_key}_location` : 'location', value: object_item[key], location: { lat: Number(object_item[key]), lng: Number(lng) }, serie, }); } else if (typeof object_item[key] === 'object') { result = result.concat(inspectFormat(object_item[key], serie, key)); } else { result.push({ variable: old_key ? `${old_key}_${key}`.toLowerCase() : `${key}`.toLowerCase(), value: object_item[key], serie, }); } } return result; } // let payload = [{ variable: 'tektelic_payload', value: "{\"payloadMetaData\":{\"applicationMetaData\":{\"id\":{\"entityType\":\"APPLICATION\",\"id\":\"9cef1ac0-aff7-11ea-b223-b76b06171356\"},\"customerId\":{\"entityType\":\"CUSTOMER\",\"id\":\"119cbeb1-5740-11ea-995a-1151d191886d\"},\"subCustomerId\":null,\"name\":\"TagoIO Fabio's account\"},\"gatewayMetaDataList\":[{\"id\":{\"entityType\":\"GATEWAY\",\"id\":\"34ba0e60-5a7a-11ea-b8bc-838c02a8d77b\"},\"name\":\"Kona Micro Demo GW\",\"mac\":\"647FDAFFFE008637\",\"latitude\":null,\"longitude\":null,\"altitude\":null,\"rxInfo\":{\"channel\":1,\"codeRate\":\"4/5\",\"crcStatus\":1,\"dataRate\":{\"modulation\":\"LORA\",\"spreadFactor\":10,\"bandwidth\":125},\"frequency\":902500000,\"loRaSNR\":11,\"mac\":\"647fdafffe008637\",\"rfChain\":0,\"rssi\":-46,\"size\":20,\"time\":\"\",\"timestamp\":2238869356,\"rsig\":null,\"antenna\":0}}],\"deviceMetaData\":{\"id\":{\"entityType\":\"DEVICE\",\"id\":\"ffbb3cb0-b029-11ea-bc3b-a7a436685523\"},\"name\":\"Kona Home Sensor - ...0464\",\"deviceClass\":\"CLASS_A\",\"deviceEUI\":\"647FDA0000002065\",\"appEUI\":\"647FDA8010000000\"},\"adr\":true,\"fport\":10,\"fcount\":1099},\"payload\":{\"externalInputHigh\":true,\"externalInputCount\":1}}", serie: 1596723266840 }]; // Check if what is being stored is the tektelic_payload. // Payload is an environment variable. Is where what is being inserted to your device comes in. // Payload always is an array of objects. [ { variable, value...}, {variable, value...} ...] let tektelic_payload = payload.find(x => x.variable === 'tektelic_payload'); if (tektelic_payload) { // Get a unique serie for the incoming data. const serie = tektelic_payload.serie || new Date().getTime(); // Parse the tektelic_payload to JSON format (it comes in a String format) tektelic_payload = JSON.parse(tektelic_payload.value); payload = []; // console.log(JSON.stringify(tektelic_payload, null, 4)); if (tektelic_payload.payloadMetaData) { delete tektelic_payload.payloadMetaData.deviceMetaData; delete tektelic_payload.payloadMetaData.applicationMetaData; delete tektelic_payload.payloadMetaData.gatewayMetaDataList[0].id; delete tektelic_payload.payloadMetaData.gatewayMetaDataList[0].name; tektelic_payload.payloadMetaData.gatewayMetaDataList[0].gtw_id = tektelic_payload.payloadMetaData.gatewayMetaDataList[0].mac; delete tektelic_payload.payloadMetaData.gatewayMetaDataList[0].mac; tektelic_payload.payloadMetaData.gatewayMetaDataList[0].gtw = { altitude: tektelic_payload.payloadMetaData.gatewayMetaDataList[0].altitude, latitude: tektelic_payload.payloadMetaData.gatewayMetaDataList[0].latitude, longitude: tektelic_payload.payloadMetaData.gatewayMetaDataList[0].longitude, }; delete tektelic_payload.payloadMetaData.gatewayMetaDataList[0].altitude; delete tektelic_payload.payloadMetaData.gatewayMetaDataList[0].latitude; delete tektelic_payload.payloadMetaData.gatewayMetaDataList[0].longitude; // console.log(JSON.stringify(tektelic_payload, null, 4)); payload = payload.concat(inspectFormat(tektelic_payload.payloadMetaData.gatewayMetaDataList[0], serie)); delete tektelic_payload.payloadMetaData.gatewayMetaDataList[0]; payload = payload.concat(inspectFormat(tektelic_payload.payloadMetaData, serie)); delete tektelic_payload.payloadMetaData; } // Parse the payload_fields. Go to inspectFormat function if you need to change something. if (tektelic_payload.payload) { if (tektelic_payload.payload.data) { tektelic_payload.payload.payload = tektelic_payload.payload.data; delete tektelic_payload.payload.data; } if (tektelic_payload.payload.payload_hex) { tektelic_payload.payload.payload = tektelic_payload.payload.payload_hex; delete tektelic_payload.payload.payload_hex; } payload = payload.concat(toTagoFormat(tektelic_payload.payload, serie)); delete tektelic_payload.payload; // remove, so it's not parsed again later. } payload = payload.filter(x => !ignore_vars.includes(x.variable)); } // console.log(payload);