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 {