From 11ca9dc51f9c21ce05cf76333575e6ec998a92b6 Mon Sep 17 00:00:00 2001 From: Klagarge Date: Sun, 8 Jun 2025 17:52:44 +0200 Subject: [PATCH] feat(gateway): update Flux query to retrieve data from the last day Signed-off-by: Klagarge --- gateway/src/RequestInflux.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/gateway/src/RequestInflux.go b/gateway/src/RequestInflux.go index 0fff1bc..356ef1a 100644 --- a/gateway/src/RequestInflux.go +++ b/gateway/src/RequestInflux.go @@ -63,13 +63,12 @@ func (gh *Gateway) requestInflux(c *gin.Context) error { // The Flux query uses a large range (-1000d) and aggregates the latest values. // This ensures we always get the most recent data, even if the database contains old entries. query := fmt.Sprintf(`from(bucket: %q) - |> range(start: -1000d) + |> range(start: -1d) |> filter(fn: (r) => r["_measurement"] == %q) |> filter(fn: (r) => r["user"] == %q) |> filter(fn: (r) => r["room"] == %q) |> filter(fn: (r) => r["device"] == %q) |> sort(columns: ["_time"], desc: true) - |> limit(n: 100) `, INFLUXDB_BUCKET, MEASUREMENT_NAME, user, room, device) results, err := queryAPI.Query(context.Background(), query) if err != nil {