import { attach, push, create, EntitySchema } from "@projectqai/proto/device";

import { MetricComponentSchema } from "@projectqai/proto/metrics";

await attach({

id: "openmeteo.service",

label: "Open-Meteo Weather",

device: { category: "Feeds" },

icon: "cloud-sun",

schema, // poll interval, rendered automatically

run: async (client, config, signal) => {

// Drop a pin on the map -> it becomes a live METOC station.

for await (const station of watchStations(client, signal)) {

const [weather, air, marine, flood] = await Promise.all([

fetchWeather(station), fetchAirQuality(station),

fetchMarine(station), fetchFlood(station),

]);

await push(client, create(EntitySchema, {

id: station.id,

metric: create(MetricComponentSchema, { metrics: [

...buildWeatherMetrics(weather), // temp · wind · gusts · pressure

...buildMarineMetrics(marine), // wave height · swell · currents

...buildAirQualityMetrics(air), // AQI · PM2.5 · CO · NO2

]}),

detection: detectHazards(weather, air), // thunderstorm · gusts · poor air

}));

}

},

});