georgew/surf-hub
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

Fixed js script
All checks were successful
ci/woodpecker/push/woodpecker Pipeline was successful
Details

Browse source
This commit is contained in:
GeorgeWebberley 2026-01-27 20:38:29 +01:00
parent 72accae032
commit b1459fcbd0
1 changed files with 19 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
fetcher/index.js
View file

@ -11,13 +11,8 @@ const writeApi = client.getWriteApi(org, bucket);
async function fetchSurfData() {
try {
// Change these coordinates to your local beach!
// These are for Bondi Beach, Sydney as an example.
const lat = -33.89;
const lon = 151.27;
console.log("🌊 Fetching latest swell data...");
const response = await axios.get(`https://marine-api.open-meteo.com/v1/marine?latitude=${lat}&longitude=${lon}&current=swell_wave_height,swell_wave_period`);
const response = await axios.get(`https://marine-api.open-meteo.com/v1/marine?latitude=-33.89&longitude=151.27&current=swell_wave_height,swell_wave_period`);
const swellHeight = response.data.current.swell_wave_height;
const swellPeriod = response.data.current.swell_wave_period;
@ -27,16 +22,26 @@ async function fetchSurfData() {
.floatField('swell_height', swellHeight)
.floatField('swell_period', swellPeriod);
console.log(`📡 Sending to InfluxDB: ${swellHeight}m...`);
// Write and explicitly flush
writeApi.writePoint(point);
// Important: Flush the buffer to ensure data is sent
await writeApi.flush();
console.log(`✅ Sent: ${swellHeight}m at ${swellPeriod}s`);
console.log(`✅ Success! Data persisted.`);
} catch (error) {
// If it's a connection error, let's be descriptive
if (error.code === 'ECONNREFUSED') {
console.error("❌ Database is not ready yet. Retrying in the next cycle...");
} else {
console.error("❌ Fetch error:", error.message);
}
}
}
// Fetch every hour
// 10 second delay for the very first run to let InfluxDB boot up
console.log("⏳ Fetcher started. Waiting 10s for DB initialization...");
setTimeout(fetchSurfData, 10000);
// Then run every hour
setInterval(fetchSurfData, 1000 * 60 * 60);
fetchSurfData();