Update api/routes.py

api/routes.py

@@ -271,3 +271,39 @@ async def get_synthea_patient(id: str):
         return patient
     except Exception:
         raise HTTPException(status_code=400, detail="Invalid patient ID")
+
+
+        
+@router.post("/ehr/auto-import")
+async def auto_import_synthea_patients():
+    csv_path = Path("data/synthea/patients.csv")
+
+    if not csv_path.exists():
+        raise HTTPException(status_code=404, detail="Synthea patients.csv not found.")
+
+    try:
+        with open(csv_path, "r", encoding="utf-8") as f:
+            reader = csv.DictReader(f)
+            patients = []
+
+            for row in reader:
+                patients.append({
+                    "synthea_id": row.get("Id"),
+                    "full_name": f"{row.get('FIRST', '')} {row.get('LAST', '')}".strip(),
+                    "gender": row.get("GENDER"),
+                    "date_of_birth": datetime.strptime(row.get("BIRTHDATE"), "%Y-%m-%dT%H:%M:%SZ"),
+                    "address": row.get("ADDRESS"),
+                    "city": row.get("CITY"),
+                    "state": row.get("STATE"),
+                    "zip": row.get("ZIP"),
+                    "created_at": datetime.utcnow()
+                })
+
+        if not patients:
+            raise HTTPException(status_code=400, detail="No patients found in CSV.")
+
+        result = await patients_collection.insert_many(patients)
+        return {"message": "Imported successfully", "count": len(result.inserted_ids)}
+
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))