From 9e6bb26a2c63a46e2a2bfe06378c23bbf85cb5fc Mon Sep 17 00:00:00 2001
From: Giuseppe Raffa <77052701+sesee3@users.noreply.github.com>
Date: Sat, 18 Apr 2026 12:57:03 +0200
Subject: [PATCH] fix: update sessionBucket to use 'boat' and refine session
 query logic

---
 api/src/routes/sessions.js | 1 -
 api/src/storage/influx.js  | 7 +++----
 2 files changed, 3 insertions(+), 5 deletions(-)

diff --git a/api/src/routes/sessions.js b/api/src/routes/sessions.js
index 4f23c71..f41d5e4 100644
--- a/api/src/routes/sessions.js
+++ b/api/src/routes/sessions.js
@@ -11,7 +11,6 @@ router.get('/history', async (req, res) => {
     try {
         const sessions = await listInfluxSessions();
 
-        // Arricchisci con dati PostgreSQL (opzionale — può fallire senza bloccare)
         let pgMap = {};
         try {
             const result = await dbQuery(
diff --git a/api/src/storage/influx.js b/api/src/storage/influx.js
index a27709e..eb31f57 100644
--- a/api/src/storage/influx.js
+++ b/api/src/storage/influx.js
@@ -60,7 +60,7 @@ async function query(bucket, relativeTime, measurement, sensor, field) {
 
 }
 
-const sessionBucket = process.env.INFLX_BUCKET || 'logs';
+const sessionBucket = 'boat';
 
 /**
  * Query storica per una sessione di registrazione.
@@ -144,11 +144,10 @@ async function listInfluxSessions(lookback = '-5y') {
             |> range(start: ${lookback})
             |> filter(fn: (r) => r._measurement == "logs")
             |> group(columns: ["sensor", "session"])
-            |> keep(columns: ["_time", "sensor", "session"])
     `;
     const [firstRows, lastRows] = await Promise.all([
-        runFlux(base + '|> first()'),
-        runFlux(base + '|> last()'),
+        runFlux(base + '|> first() |> keep(columns: ["_time", "sensor", "session"])'),
+        runFlux(base + '|> last()  |> keep(columns: ["_time", "sensor", "session"])'),
     ]);
 
     const map = {};