Update api/routes/patients.py

api/routes/patients.py

@@ -1,5 +1,3 @@
-
-
 from fastapi import APIRouter, HTTPException, Depends, Query, status, Body
 from db.mongo import patients_collection
 from core.security import get_current_user
@@ -35,6 +33,26 @@ BASE_DIR = Path(__file__).resolve().parent.parent.parent
 SYNTHEA_DATA_DIR = BASE_DIR / "output" / "fhir"
 os.makedirs(SYNTHEA_DATA_DIR, exist_ok=True)
 
+@router.get("/debug/count")
+async def debug_patient_count():
+    """Debug endpoint to verify patient counts"""
+    try:
+        total = await patients_collection.count_documents({})
+        synthea = await patients_collection.count_documents({"source": "synthea"})
+        manual = await patients_collection.count_documents({"source": "manual"})
+        return {
+            "total": total,
+            "synthea": synthea,
+            "manual": manual,
+            "message": f"Found {total} total patients ({synthea} from synthea, {manual} manual)"
+        }
+    except Exception as e:
+        logger.error(f"Error counting patients: {str(e)}")
+        raise HTTPException(
+            status_code=status.HTTP_500_INTERNAL_SERVER_ERROR,
+            detail=f"Error counting patients: {str(e)}"
+        )
+
 @router.post("/patients", status_code=status.HTTP_201_CREATED)
 async def create_patient(
     patient_data: PatientCreate,
@@ -349,7 +367,7 @@ async def list_patients(
     skip: int = Query(0, ge=0)
 ):
     logger.info(f"Listing patients with search: {search}, limit: {limit}, skip: {skip}")
-    query = {"source": "synthea"}
+    query = {}  # Removed the default "source": "synthea" filter
     
     if search:
         query["$or"] = [
@@ -363,7 +381,6 @@ async def list_patients(
     if min_conditions > 0:
         query[f"conditions.{min_conditions-1}"] = {"$exists": True}
     
-    # Removed $slice to return full arrays for the frontend
     projection = {
         "fhir_id": 1,
         "full_name": 1,
@@ -374,7 +391,8 @@ async def list_patients(
         "conditions": 1,
         "medications": 1,
         "encounters": 1,
-        "notes": 1
+        "notes": 1,
+        "source": 1  # Added source to projection
     }
     
     try:
@@ -394,6 +412,7 @@ async def list_patients(
                 "medications": patient.get("medications", []),
                 "encounters": patient.get("encounters", []),
                 "notes": patient.get("notes", []),
+                "source": patient.get("source", "unknown"),
                 "age": calculate_age(patient.get("date_of_birth")),
                 "stats": {
                     "notes": len(patient.get("notes", [])),
@@ -412,6 +431,7 @@ async def list_patients(
             detail=f"Failed to retrieve patients: {str(e)}"
         )
 
+
 @router.get("/patients/{patient_id}", response_model=dict)
 async def get_patient(patient_id: str):
     logger.info(f"Retrieving patient: {patient_id}")