Update app.py

app.py

@@ -12,7 +12,8 @@ from fastapi.responses import StreamingResponse
 from fastapi.middleware.cors import CORSMiddleware
 from pydantic import BaseModel
 import asyncio
-
+from fastapi import Query
+from bson import ObjectId
 from txagent.txagent import TxAgent
 from db.mongo import get_mongo_client
 
@@ -262,6 +263,40 @@ async def status():
         "version": "2.2.0"
     }
 
+@app.get("/patients/analysis-results")
+async def get_patient_analysis_results(name: Optional[str] = Query(None)):
+    try:
+        query = {}
+
+        # If a name filter is provided, we search the patients collection first
+        if name:
+            name_regex = re.compile(name, re.IGNORECASE)
+            matching_patients = await patients_collection.find({"full_name": name_regex}).to_list(length=None)
+            patient_ids = [p["fhir_id"] for p in matching_patients if "fhir_id" in p]
+            if not patient_ids:
+                return []
+            query = {"patient_id": {"$in": patient_ids}}
+
+        # Find analysis results based on patient_ids (or all if no filter)
+        analyses = await analysis_collection.find(query).sort("timestamp", -1).to_list(length=100)
+
+        # Attach full_name to each analysis result
+        enriched_results = []
+        for analysis in analyses:
+            patient = await patients_collection.find_one({"fhir_id": analysis["patient_id"]})
+            if patient:
+                analysis["full_name"] = patient.get("full_name", "Unknown")
+            analysis["_id"] = str(analysis["_id"])
+            enriched_results.append(analysis)
+
+        return enriched_results
+
+    except Exception as e:
+        logger.error(f"Error fetching analysis results: {e}")
+        raise HTTPException(status_code=500, detail="Failed to retrieve analysis results")
+
+
+
 @app.post("/chat-stream")
 async def chat_stream_endpoint(request: ChatRequest):
     async def token_stream():