feat: ✨ first simple approach introducing fetching data

Author: marcvergees

Makefile

@@ -63,7 +63,7 @@ fireform: build up
 	@echo "Run 'make logs' to view live logs, 'make down' to stop."
 
 build:
-	@$(COMPOSE) build --progress=quiet
+	@$(COMPOSE) build
 
 up:
 	@$(COMPOSE) up -d

app/api/router.py

@@ -5,8 +5,9 @@
 
 from fastapi import APIRouter
 
-from app.api.routes import forms, templates
+from app.api.routes import forms, templates, weather
 
 api_router = APIRouter()
 api_router.include_router(templates.router)
 api_router.include_router(forms.router)
+api_router.include_router(weather.router)

app/api/routes/weather.py

@@ -0,0 +1,19 @@
+from fastapi import APIRouter
+
+from app.core.errors.base import AppError
+from app.services.controller import Controller
+
+router = APIRouter(prefix="/weather", tags=["weather"])
+
+
+@router.get("/forecast")
+def get_weather_forecast(latitude: float, longitude: float):
+    """
+    Fetch weather forecast data for the given coordinates.
+    """
+    controller = Controller()
+    try:
+        weather_data = controller.get_weather(latitude, longitude)
+        return weather_data
+    except Exception as e:
+        raise AppError(str(e), status_code=500)

app/services/controller.py

@@ -1,11 +1,17 @@
 from app.services.file_manipulator import FileManipulator
+from app.services.external_apis_coordinator import ExternalAPIsCoordinator
+
 
 class Controller:
     def __init__(self):
         self.file_manipulator = FileManipulator()
+        self.external_apis_coordinator = ExternalAPIsCoordinator()
 
     def fill_form(self, user_input: str, fields: list, pdf_form_path: str, model: str = None):
         return self.file_manipulator.fill_form(user_input, fields, pdf_form_path, model=model)
 
     def prepare_fillable(self, pdf_path: str):
-        return self.file_manipulator.prepare_fillable(pdf_path)
+        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)

app/services/external_apis_coordinator.py

@@ -0,0 +1,70 @@
+import openmeteo_requests
+
+import pandas as pd
+import requests_cache
+from retry_requests import retry
+
+class ExternalAPIsCoordinator:
+    def __init__(self):
+        pass
+    
+    def get_weather(self, latitude: float, longitude: float):
+        """
+        Get weather data for a given latitude and longitude.
+
+        Args:
+            latitude (float): The latitude of the location.
+            longitude (float): The longitude of the location.
+
+        Returns:
+            dict: A dictionary containing the weather data.
+        """
+        
+        # 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)
+
+        # 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",
+        }
+        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 = {
+            "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"
+            )
+        }
+
+        hourly_data["temperature_2m"] = hourly_temperature_2m.tolist()
+        
+        # Convert pandas Timestamp objects to ISO strings for JSON serialization
+        hourly_data["date"] = [d.isoformat() for d in hourly_data["date"]]
+
+        return {
+            "latitude": response.Latitude(),
+            "longitude": response.Longitude(),
+            "elevation": response.Elevation(),
+            "timezone": response.Timezone(),
+            "timezone_abbreviation": response.TimezoneAbbreviation(),
+            "utc_offset_seconds": response.UtcOffsetSeconds(),
+            "hourly": hourly_data
+        }

requirements.txt

@@ -12,3 +12,7 @@ numpy<2
 ollama
 pypdf
 python-multipart
+openmeteo-requests
+requests-cache
+retry-requests
+pandas