feat: ✨ multiple weather fields can be fetched, fetched data graphically shown and incorporated to the LLM input

Author: marcvergees

app/api/routes/weather.py

@@ -5,15 +5,38 @@
 
 router = APIRouter(prefix="/weather", tags=["weather"])
 
+ALL_HOURLY_FIELDS = [
+    "temperature_2m",
+    "relative_humidity_2m",
+    "rain",
+    "apparent_temperature",
+    "precipitation_probability",
+    "precipitation",
+    "wind_direction_10m",
+    "wind_speed_10m",
+    "soil_temperature_0cm",
+    "uv_index",
+]
+
 
 @router.get("/forecast")
-def get_weather_forecast(latitude: float, longitude: float):
+def get_weather_forecast(
+    latitude: float,
+    longitude: float,
+    fields: str | None = None,
+):
     """
     Fetch weather forecast data for the given coordinates.
+
+    Query params:
+      - latitude, longitude: required floats
+      - fields: optional comma-separated list of hourly variables to include.
+                Defaults to all supported fields when omitted.
     """
     controller = Controller()
     try:
-        weather_data = controller.get_weather(latitude, longitude)
+        requested = [f.strip() for f in fields.split(",") if f.strip()] if fields else []
+        weather_data = controller.get_weather(latitude, longitude, hourly_fields=requested)
         return weather_data
     except Exception as e:
         raise AppError(str(e), status_code=500)

app/services/controller.py

@@ -13,5 +13,5 @@ def fill_form(self, user_input: str, fields: list, pdf_form_path: str, model: st
     def prepare_fillable(self, pdf_path: str):
         return self.file_manipulator.prepare_fillable(pdf_path)
 
-    def get_weather(self, latitude: float, longitude: float):
-        return self.external_apis_coordinator.get_weather(latitude, longitude)
+    def get_weather(self, latitude: float, longitude: float, hourly_fields: list = None):
+        return self.external_apis_coordinator.get_weather(latitude, longitude, hourly_fields=hourly_fields)

app/services/external_apis_coordinator.py

@@ -4,58 +4,74 @@
 import requests_cache
 from retry_requests import retry
 
+# All supported hourly fields exposed by this service
+ALL_HOURLY_FIELDS = [
+    "temperature_2m",
+    "relative_humidity_2m",
+    "rain",
+    "apparent_temperature",
+    "precipitation_probability",
+    "precipitation",
+    "wind_direction_10m",
+    "wind_speed_10m",
+    "soil_temperature_0cm",
+    "uv_index",
+]
+
+
 class ExternalAPIsCoordinator:
     def __init__(self):
         pass
-    
-    def get_weather(self, latitude: float, longitude: float):
+
+    def get_weather(self, latitude: float, longitude: float, hourly_fields: list[str] | None = None):
         """
         Get weather data for a given latitude and longitude.
 
         Args:
             latitude (float): The latitude of the location.
             longitude (float): The longitude of the location.
+            hourly_fields (list[str] | None): Subset of hourly variables to request.
+                Defaults to ALL_HOURLY_FIELDS when None or empty.
 
         Returns:
             dict: A dictionary containing the weather data.
         """
-        
+        requested = [f for f in (hourly_fields or []) if f in ALL_HOURLY_FIELDS]
+        if not requested:
+            requested = list(ALL_HOURLY_FIELDS)
+
         # Setup the Open-Meteo API client with cache and retry on error
-        cache_session = requests_cache.CachedSession('.cache', expire_after = 3600)
-        retry_session = retry(cache_session, retries = 5, backoff_factor = 0.2)
-        openmeteo = openmeteo_requests.Client(session = retry_session)
+        cache_session = requests_cache.CachedSession('.cache', expire_after=3600)
+        retry_session = retry(cache_session, retries=5, backoff_factor=0.2)
+        openmeteo = openmeteo_requests.Client(session=retry_session)
 
-        # Make sure all required weather variables are listed here
-        # The order of variables in hourly or daily is important to assign them correctly below
         url = "https://api.open-meteo.com/v1/forecast"
         params = {
             "latitude": latitude,
             "longitude": longitude,
-            "hourly": "temperature_2m",
+            "hourly": requested,
         }
-        responses = openmeteo.weather_api(url, params = params)
+        responses = openmeteo.weather_api(url, params=params)
 
-        # Process first location. Add a for-loop for multiple locations or weather models
         response = responses[0]
         print(f"Coordinates: {response.Latitude()}°N {response.Longitude()}°E")
         print(f"Elevation: {response.Elevation()} m asl")
         print(f"Timezone difference to GMT+0: {response.UtcOffsetSeconds()}s")
 
-        # Process hourly data. The order of variables needs to be the same as requested.
         hourly = response.Hourly()
-        hourly_temperature_2m = hourly.Variables(0).ValuesAsNumpy()
 
-        hourly_data = {
+        hourly_data: dict = {
             "date": pd.date_range(
-                start = pd.to_datetime(hourly.Time(), unit = "s", utc = True),
-                end =  pd.to_datetime(hourly.TimeEnd(), unit = "s", utc = True),
-                freq = pd.Timedelta(seconds = hourly.Interval()),
-                inclusive = "left"
+                start=pd.to_datetime(hourly.Time(), unit="s", utc=True),
+                end=pd.to_datetime(hourly.TimeEnd(), unit="s", utc=True),
+                freq=pd.Timedelta(seconds=hourly.Interval()),
+                inclusive="left",
             )
         }
 
-        hourly_data["temperature_2m"] = hourly_temperature_2m.tolist()
-        
+        for i, field in enumerate(requested):
+            hourly_data[field] = hourly.Variables(i).ValuesAsNumpy().tolist()
+
         # Convert pandas Timestamp objects to ISO strings for JSON serialization
         hourly_data["date"] = [d.isoformat() for d in hourly_data["date"]]
 
@@ -66,5 +82,5 @@ def get_weather(self, latitude: float, longitude: float):
             "timezone": response.Timezone(),
             "timezone_abbreviation": response.TimezoneAbbreviation(),
             "utc_offset_seconds": response.UtcOffsetSeconds(),
-            "hourly": hourly_data
+            "hourly": hourly_data,
         }