Update app.py

app.py

@@ -1,17 +1,18 @@
-from fastapi import FastAPI, HTTPException
+from fastapi import FastAPI, HTTPException, Query
 from starlette.responses import JSONResponse
 from obspy.clients.fdsn import Client
 from obspy.core.utcdatetime import UTCDateTime
 import logging
+from datetime import date
 
 # Configure logging
 logging.basicConfig(level=logging.INFO)
 
 # Initialize the FastAPI app
 app = FastAPI(
-    title="Earthquake Catalog API",
-    description="An API to fetch earthquake data from the IRIS FDSN web service, ready for Hugging Face.",
-    version="1.0.0",
+    title="Dynamic Earthquake Catalog API",
+    description="A robust API to fetch earthquake data from the IRIS FDSN web service using URL parameters.",
+    version="2.1.0",
 )
 
 # Initialize the IRIS FDSN client
@@ -27,24 +28,26 @@ def greet_json():
     """
     A simple 'Hello World' endpoint.
     """
-    return {"Hello": "World!", "message": "Go to /earthquakes to fetch data, or /docs for the API documentation.  Dayi"}
+    return {"Hello": "World!", "message": "Go to /docs to try the dynamic earthquake endpoint.  cwadayi"}
 
 @app.get("/earthquakes")
-async def get_earthquake_catalog():
+async def get_earthquake_catalog(
+    start_date: date = Query(default="2024-01-01", description="Start date in YYYY-MM-DD format"),
+    end_date: date = Query(default="2024-01-07", description="End date in YYYY-MM-DD format"),
+    min_magnitude: float = Query(default=4.5, description="Minimum earthquake magnitude (e.g., 5.5)", gt=0, le=10)
+):
     """
-    Fetches earthquake data with a magnitude larger than 5.0
-    from 2015-01-05 to 2016-03-05.
+    Fetches earthquake data based on date and magnitude parameters provided in the URL.
     """
     if not client:
-        raise HTTPException(
-            status_code=503, # Service Unavailable
-            detail="The IRIS FDSN client is not available or failed to initialize.",
-        )
+        raise HTTPException(status_code=503, detail="The IRIS FDSN client is not available.")
+    
+    if start_date > end_date:
+        raise HTTPException(status_code=400, detail="The start_date cannot be after the end_date.")
 
     try:
-        starttime = UTCDateTime("2015-01-05")
-        endtime = UTCDateTime("2016-03-05")
-        min_magnitude = 5.0
+        starttime = UTCDateTime(start_date)
+        endtime = UTCDateTime(end_date)
 
         logging.info(f"Fetching events from {starttime} to {endtime} with min magnitude {min_magnitude}.")
         catalog = client.get_events(
@@ -55,21 +58,22 @@ async def get_earthquake_catalog():
         logging.info(f"Found {len(catalog)} events. Now processing.")
 
         earthquake_list = []
-        # --- Key Change Start ---
-        # Loop through each event and process it individually to prevent one bad event from crashing the app.
         for event in catalog:
             try:
-                # Ensure the event has a preferred origin and magnitude
-                if not event.preferred_origin() or not event.preferred_magnitude():
-                    continue # Skip to the next event if essential data is missing
-
                 origin = event.preferred_origin()
                 magnitude = event.preferred_magnitude()
 
-                # Safely extract the place description
+                if not origin or not magnitude:
+                    continue
+
+                # --- Key Change Start ---
+                # Safely get the description using getattr. This avoids errors if the 'descriptions'
+                # attribute doesn't exist, by providing a default empty list [].
                 place = "N/A"
-                if event.descriptions: # Check if the descriptions list exists and is not empty
-                    place = event.descriptions[0].text
+                descriptions = getattr(event, 'descriptions', [])
+                if descriptions:
+                    place = descriptions[0].text
+                # --- Key Change End ---
 
                 earthquake_list.append({
                     "time": origin.time.isoformat(),
@@ -81,17 +85,12 @@ async def get_earthquake_catalog():
                     "place": place,
                 })
             except Exception as e:
-                # If a single event fails, log it and continue with the others.
-                logging.warning(f"Skipping one event due to a processing error: {e}")
+                logging.warning(f"Skipping event due to unexpected processing error: {e}")
                 continue
-        # --- Key Change End ---
-
+        
         logging.info(f"Successfully processed {len(earthquake_list)} events.")
         return JSONResponse(content={"earthquakes": earthquake_list})
 
     except Exception as e:
         logging.error(f"A major error occurred during the request: {e}")
-        raise HTTPException(
-            status_code=500, # Internal Server Error
-            detail=f"An internal error occurred: {e}",
-        )
+        raise HTTPException(status_code=500, detail=f"An internal error occurred: {e}")