homeio

1"use client";
2
3import { useQuery } from "@tanstack/react-query";
4import type { WeatherSnapshot } from "@/lib/shared/contracts/weather";
5import { queryKeys } from "@/lib/shared/query-keys";
6import { useUserLocation } from "@/modules/system/hooks/useUserLocation";
7
8type Coordinates = {
9  latitude: number;
10  longitude: number;
11};
12
13type OpenMeteoResponse = {
14  current?: {
15    temperature_2m?: number;
16    apparent_temperature?: number;
17    relative_humidity_2m?: number;
18    wind_speed_10m?: number;
19    weather_code?: number;
20  };
21  daily?: {
22    time?: string[];
23    weather_code?: number[];
24    temperature_2m_max?: number[];
25    temperature_2m_min?: number[];
26  };
27};
28
29function toNumber(value: unknown) {
30  return typeof value === "number" && Number.isFinite(value) ? value : null;
31}
32
33function toRounded(value: number | null, precision = 1) {
34  if (value === null) return null;
35  return Number(value.toFixed(precision));
36}
37
38function mapWeatherCodeToCondition(code: number | null) {
39  if (code === null) return "Unknown";
40  if (code === 0) return "Clear sky";
41  if (code === 1) return "Mainly clear";
42  if (code === 2) return "Partly cloudy";
43  if (code === 3) return "Overcast";
44  if (code === 45 || code === 48) return "Fog";
45  if (code >= 51 && code <= 57) return "Drizzle";
46  if (code >= 61 && code <= 67) return "Rain";
47  if (code >= 71 && code <= 77) return "Snow";
48  if (code >= 80 && code <= 82) return "Rain showers";
49  if (code === 85 || code === 86) return "Snow showers";
50  if (code === 95) return "Thunderstorm";
51  if (code === 96 || code === 99) return "Thunderstorm with hail";
52  return "Unknown";
53}
54
55function buildDailyForecast(daily: OpenMeteoResponse["daily"]) {
56  const dates = daily?.time ?? [];
57  const weatherCodes = daily?.weather_code ?? [];
58  const maxTemps = daily?.temperature_2m_max ?? [];
59  const minTemps = daily?.temperature_2m_min ?? [];
60  const entriesCount = Math.min(
61    dates.length,
62    weatherCodes.length,
63    maxTemps.length,
64    minTemps.length,
65  );
66  if (entriesCount <= 0) return [] as WeatherSnapshot["dailyForecast"];
67
68  const startIndex = entriesCount > 5 ? 1 : 0;
69  const endExclusive = Math.min(startIndex + 5, entriesCount);
70  const forecast: WeatherSnapshot["dailyForecast"] = [];
71  for (let index = startIndex; index < endExclusive; index += 1) {
72    const weatherCode = toNumber(weatherCodes[index]);
73    forecast.push({
74      date: dates[index] ?? "",
75      weatherCode,
76      condition: mapWeatherCodeToCondition(weatherCode),
77      tempMaxC: toRounded(toNumber(maxTemps[index]), 1),
78      tempMinC: toRounded(toNumber(minTemps[index]), 1),
79    });
80  }
81  return forecast;
82}
83
84function formatLocationLabel(coords: { city?: string; country?: string }) {
85  if (coords.city && coords.country) return `${coords.city}, ${coords.country}`;
86  return coords.city ?? coords.country ?? "Current location";
87}
88
89async function fetchCurrentWeather(
90  coords: Coordinates & { city?: string; country?: string },
91) {
92  const params = new URLSearchParams({
93    latitude: coords.latitude.toString(),
94    longitude: coords.longitude.toString(),
95    current:
96      "temperature_2m,apparent_temperature,relative_humidity_2m,wind_speed_10m,weather_code",
97    daily: "weather_code,temperature_2m_max,temperature_2m_min",
98    timezone: "auto",
99  });
100  const endpoint = `https://api.open-meteo.com/v1/forecast?${params.toString()}`;
101
102  const response = await fetch(endpoint, {
103    cache: "no-store",
104  });
105
106  if (!response.ok) {
107    throw new Error(`Failed to fetch weather (${response.status})`);
108  }
109
110  const json = (await response.json()) as OpenMeteoResponse;
111  const weatherCode = toNumber(json.current?.weather_code);
112  const locationLabel = formatLocationLabel(coords);
113
114  return {
115    timestamp: new Date().toISOString(),
116    source: "navigator",
117    location: {
118      label: locationLabel,
119      latitude: toRounded(coords.latitude, 4),
120      longitude: toRounded(coords.longitude, 4),
121    },
122    current: {
123      temperatureC: toRounded(toNumber(json.current?.temperature_2m), 1),
124      feelsLikeC: toRounded(toNumber(json.current?.apparent_temperature), 1),
125      humidityPercent: toRounded(
126        toNumber(json.current?.relative_humidity_2m),
127        0,
128      ),
129      windSpeedKph: toRounded(toNumber(json.current?.wind_speed_10m), 1),
130      weatherCode,
131      condition: mapWeatherCodeToCondition(weatherCode),
132    },
133    dailyForecast: buildDailyForecast(json.daily),
134  } satisfies WeatherSnapshot;
135}
136
137export function useCurrentWeather() {
138  const { location } = useUserLocation();
139  const coords = location;
140
141  return useQuery({
142    queryKey: queryKeys.currentWeather(
143      coords?.latitude ?? null,
144      coords?.longitude ?? null,
145    ),
146    queryFn: () => {
147      if (!coords) throw new Error("Missing coordinates");
148      return fetchCurrentWeather(coords);
149    },
150    enabled: Boolean(coords),
151    staleTime: 300_000,
152    refetchInterval: 600_000,
153  });
154}
155