Update api/routes.py

api/routes.py

@@ -191,23 +191,29 @@ async def list_doctor_appointments(current_user: dict = Depends(get_current_user
     if current_user.get("role") != "doctor":
         raise HTTPException(status_code=403, detail="Only doctors can view this")
 
-    cursor = appointments_collection.find({"doctor_id": {"$exists": True}})
+    cursor = appointments_collection.find({"doctor_id": ObjectId(current_user["_id"])})
     appointments = []
 
     async for a in cursor:
-        patient = await users_collection.find_one({"_id": a["patient_id"]})
-        patient_info = {
-            "full_name": patient.get("full_name", ""),
-            "email": patient.get("email", ""),
-        } if patient else {}
+        try:
+            patient_id = a.get("patient_id")
+            if not isinstance(patient_id, ObjectId):
+                patient_id = ObjectId(patient_id)
+
+            patient = await users_collection.find_one({"_id": patient_id})
+        except Exception:
+            patient = None
 
         appointments.append({
             "_id": str(a["_id"]),
             "doctor_id": str(a["doctor_id"]),
-            "patient": patient_info,
-            "date": a["date"].strftime("%Y-%m-%d") if isinstance(a["date"], datetime) else a["date"],
-            "time": a["time"],
-            "reason": a["reason"]
+            "patient": {
+                "full_name": patient.get("full_name", "Unknown") if patient else "Unknown",
+                "email": patient.get("email", "") if patient else "",
+            },
+            "date": a.get("date").strftime("%Y-%m-%d") if isinstance(a.get("date"), datetime) else a.get("date"),
+            "time": a.get("time", ""),
+            "reason": a.get("reason", "")
         })
 
     return appointments