src/streamHandler/PacketInfluxPointFactory.js

@@ -37,16 +37,13 @@ class PacketInfluxPointFactory extends Transform{
     _transform(packet, encoding, next){
         // Create measurements
         MEASUREMENT_MAP.forEach((objKey, measurement) => {
-            if(packet[objKey] == null) return;
+            if(!Object.keys(packet).includes(objKey)) return;
 
             let point = new Point(measurement);     // Create point
             
             // Set tags
-            TAG_LIST.filter(tag => Object.keys(packet).includes(tag))   // Filter tags available on object
+            TAG_LIST.filter(tag => Object.keys(packet).includes(tag))
-                    .filter(tag => packet[tag] != null)                         // Filter tags not falsy on object
+                    .forEach(tag => point.tag(tag, packet[tag]));
-                    .forEach(tag => {
-                        tagObjectRecursively(point, tag, packet[tag]);
-                    });
 
             point.setField('value', packet[objKey]);        // Set field
 
@@ -57,15 +54,6 @@ class PacketInfluxPointFactory extends Transform{
     }
 }
 
-function tagObjectRecursively(point, tag, field, suffix = ""){
-    if(typeof(field) == "object"){
-        // TODO: Convert boolean-arrays like "packet.flags" to key: value
-        Object.entries(field).map(([key, value]) => {
-            tagObjectRecursively(point, tag, value, `_${key}${suffix}`);
-        });
-    }
-    else point.tag(tag+suffix, field);
-}
 
 /** Mapping for type -> field-method */
 const POINT_FIELD_TYPE = new Map([