From d71b03f0d8893100721c402b857cb7a5b1354219 Mon Sep 17 00:00:00 2001
From: liamcottle <liam@liamcottle.com>
Date: Fri, 7 Jun 2024 00:12:53 +1200
Subject: [PATCH] save temperature, humidity and pressure to nodes table

---
 .../migration.sql                                            | 4 ++++
 prisma/schema.prisma                                         | 4 ++++
 src/mqtt.js                                                  | 5 +++++
 3 files changed, 13 insertions(+)
 create mode 100644 prisma/migrations/20240606120812_add_temperature_humidity_and_pressure_environment_metrics_to_node_table/migration.sql

diff --git a/prisma/migrations/20240606120812_add_temperature_humidity_and_pressure_environment_metrics_to_node_table/migration.sql b/prisma/migrations/20240606120812_add_temperature_humidity_and_pressure_environment_metrics_to_node_table/migration.sql
new file mode 100644
index 0000000..d597ea5
--- /dev/null
+++ b/prisma/migrations/20240606120812_add_temperature_humidity_and_pressure_environment_metrics_to_node_table/migration.sql
@@ -0,0 +1,4 @@
+-- AlterTable
+ALTER TABLE `nodes` ADD COLUMN `barometric_pressure` DECIMAL(65, 30) NULL,
+    ADD COLUMN `relative_humidity` DECIMAL(65, 30) NULL,
+    ADD COLUMN `temperature` DECIMAL(65, 30) NULL;
diff --git a/prisma/schema.prisma b/prisma/schema.prisma
index dc7aced..e656dc5 100644
--- a/prisma/schema.prisma
+++ b/prisma/schema.prisma
@@ -40,6 +40,10 @@ model Node {
   air_util_tx         Decimal?
   uptime_seconds      BigInt?
 
+  temperature         Decimal?
+  relative_humidity   Decimal?
+  barometric_pressure Decimal?
+
   neighbour_broadcast_interval_secs Int?
   neighbours                        Json?
   neighbours_updated_at             DateTime?
diff --git a/src/mqtt.js b/src/mqtt.js
index 67a1fc7..af0fedf 100644
--- a/src/mqtt.js
+++ b/src/mqtt.js
@@ -666,6 +666,11 @@ client.on("message", async (topic, message) => {
                 const current = telemetry.environmentMetrics.current !== 0 ? telemetry.environmentMetrics.current : null;
                 const iaq = telemetry.environmentMetrics.iaq !== 0 ? telemetry.environmentMetrics.iaq : null;
 
+                // set metrics to update on node table
+                data.temperature = temperature;
+                data.relative_humidity = relativeHumidity;
+                data.barometric_pressure = barometricPressure;
+
                 // create environment metric
                 try {