Create putsreq.beep-bob.js

client/TTN/putsreq.beep-bob.js

@@ -0,0 +1,49 @@
+// ------------------------------------
+// B O B
+// https://bee-observer.org/api/sensors
+// ------------------------------------
+
+const input = JSON.parse(request.body);
+const payload_ttn = input.payload_fields;
+
+var output_bob   = {};
+
+switch (input.dev_id) {
+    case "hiveeyes-USER-LOCATION-NAMEOFHIVE":
+        output_bob.key = "YOUR-BOB-KEY-FOR-NODE-A";
+        break;
+    case "hiveeyes-USER-LOCATION-NAMEOFHIVE":
+        output_bob.key = "YOUR-BOB-KEY-FOR-NODE-B";
+        break;
+}
+
+for (var key in payload_ttn) {
+    if (payload_ttn.hasOwnProperty(key)) {
+        if (/load/.test(key)) {
+            output_bob.weight_kg = payload_ttn[key];
+        } else if (/temperature_5/.test(key)) {
+            output_bob.t = payload_ttn[key];
+        } else if (/relative_humidity_5/.test(key)) {
+            output_bob.h = payload_ttn[key];
+        } else if (/barometric_pressure_5/.test(key)) {
+            output_bob.p = payload_ttn[key];
+        } else if (/voltage_0/.test(key)) {
+            output_bob.bv = payload_ttn[key];
+        } else if (/temperature_1/.test(key)) {
+            i = parseInt(key.split("_")[1],10);
+            output_bob["t_i_" + (i-9)] = payload_ttn[key];
+        }
+    }
+}
+
+output_bob.rssi = input.metadata.gateways[0].rssi;
+
+for (i = 1; i < input.metadata.gateways.length; i++) {
+  if (input.metadata.gateways[i].rssi > output_bob.rssi) {
+      output_bob.rssi = input.metadata.gateways[i].rssi;
+  }
+}
+
+//response.body = output_bob;
+request.body = output_bob;
+request.forwardTo = 'https://bee-observer.org/api/sensors';