From 641f6af1f0aedc7453a05a8dad0b066e1e5d0ba3 Mon Sep 17 00:00:00 2001 From: Klagarge Date: Sat, 9 May 2026 16:44:38 +0200 Subject: [PATCH] feat(db): remove CO2PPM data over 1'000'000'000 Signed-off-by: Klagarge --- db/src/main.go | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/db/src/main.go b/db/src/main.go index 19a3813..0d3fc93 100644 --- a/db/src/main.go +++ b/db/src/main.go @@ -143,7 +143,15 @@ func main() { {Subject: "room", Content: room}, {Subject: "node", Content: nodeID}, } - translatedDp := provenceMeasurement.CreateDataPoint(influxTags, dp.GetValues(), dp.Timestamp()) + + // If CO2PPM value is present and over 1000000000 delete the field + values := dp.GetValues() + if values.CO2PPM > 1000000000 { + log.Printf("[Main] Warning: CO2PPM value %d is over threshold, setting to 0\n", values.CO2PPM) + values.CO2PPM = 0 + } + + translatedDp := provenceMeasurement.CreateDataPoint(influxTags, values, dp.Timestamp()) if err := influxGateway.AddDatapoint(&translatedDp); err != nil { log.Printf("[Main] Error adding datapoint to influx: %v\n", err)