meb/OLD-server-architecture
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: update sessionBucket to use 'boat' and refine session query logic

Browse Source
This commit is contained in:
Giuseppe Raffa
2026-04-18 12:57:03 +02:00
parent ba0dbe6baf
commit 9e6bb26a2c
2 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
api/src/routes/sessions.js
View File

@@ -11,7 +11,6 @@ router.get('/history', async (req, res) => {
try { try {
const sessions = await listInfluxSessions(); const sessions = await listInfluxSessions();
// Arricchisci con dati PostgreSQL (opzionale — può fallire senza bloccare)
let pgMap = {}; let pgMap = {};
try { try {
const result = await dbQuery( const result = await dbQuery(

7
api/src/storage/influx.js
View File

@@ -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. * Query storica per una sessione di registrazione.
@@ -144,11 +144,10 @@ async function listInfluxSessions(lookback = '-5y') {
|> range(start: ${lookback}) |> range(start: ${lookback})
|> filter(fn: (r) => r._measurement == "logs") |> filter(fn: (r) => r._measurement == "logs")
|> group(columns: ["sensor", "session"]) |> group(columns: ["sensor", "session"])
|> keep(columns: ["_time", "sensor", "session"])
`; `;
const [firstRows, lastRows] = await Promise.all([ const [firstRows, lastRows] = await Promise.all([
runFlux(base + '|> first()'), runFlux(base + '|> first() |> keep(columns: ["_time", "sensor", "session"])'),
runFlux(base + '|> last()'), runFlux(base + '|> last() |> keep(columns: ["_time", "sensor", "session"])'),
]); ]);
const map = {}; const map = {};