return user hospital

Author: cjustinobi

src/docs.rs

@@ -22,6 +22,7 @@ use crate::handlers::{auth, hospitals, patients, appointments, specialists, admi
         patients::delete_account,
         patients::update_medical_info,
         hospitals::get_hospitals,
+        hospitals::get_user_hospitals,
         hospitals::get_hospital_by_id,
         hospitals::create_hospital,
         hospitals::update_hospital,

src/handlers/hospitals.rs

@@ -495,6 +495,56 @@ pub async fn get_hospitals(
     ))
 }
 
+/// Get user's hospitals
+#[utoipa::path(
+    get,
+    path = "/api/hospitals/me",
+    responses(
+        (status = 200, body = ApiResponse<Vec<HospitalResponse>>),
+        (status = 401),
+        (status = 500)
+    ),
+    tag = "hospitals",
+    security(("bearer_auth" = []))
+)]
+pub async fn get_user_hospitals(
+    State(state): State<AppState>,
+    Extension(user): Extension<User>,
+) -> Result<ApiResponse<Vec<HospitalResponse>>, AppError> {
+    let mut conn = state.pool.get()?;
+    let my_hospitals = hospitals::service::get_user_hospitals(&mut conn, user.id)?;
+
+    let mut response = Vec::new();
+    for hospital in my_hospitals {
+        let inventory = hospitals::service::get_hospital_inventory(&mut conn, hospital.id)?;
+        response.push(HospitalResponse {
+            id: hospital.id,
+            name: hospital.name,
+            hospital_type: hospital.hospital_type,
+            address: hospital.address,
+            city: hospital.city,
+            state: hospital.state,
+            country: hospital.country,
+            primary_phone: hospital.primary_phone,
+            emergency_phone: hospital.emergency_phone,
+            email: hospital.email,
+            license_number: hospital.license_number,
+            accreditation_doc_url: hospital.accreditation_doc_url,
+            license_status: hospital.license_status,
+            has_blood_bank: hospital.has_blood_bank,
+            accepting_donors: hospital.accepting_donors,
+            donating_operating_hours: hospital.donating_operating_hours,
+            created_at: hospital.created_at,
+            blood_inventory: inventory,
+        });
+    }
+
+    Ok(ApiResponse::success_with_message(
+        "User hospitals retrieved successfully",
+        response,
+    ))
+}
+
 /// Get hospital by ID
 #[utoipa::path(
     get,

src/hospitals/service.rs

@@ -291,6 +291,16 @@ pub fn get_hospitals(conn: &mut PgConnection) -> Result<Vec<Hospital>, AppError>
         .map_err(AppError::from)
 }
 
+/// Get user's hospitals
+pub fn get_user_hospitals(conn: &mut PgConnection, uid: Uuid) -> Result<Vec<Hospital>, AppError> {
+    hospitals
+        .filter(user_id.eq(uid))
+        .filter(deleted_at.is_null())
+        .select(Hospital::as_select())
+        .load(conn)
+        .map_err(AppError::from)
+}
+
 /// Get hospital by ID
 pub fn get_hospital_by_id(
     conn: &mut PgConnection,

src/routes/hospitals.rs

@@ -14,6 +14,7 @@ pub fn protected_router() -> Router<AppState> {
     Router::new()
         .route("/{hospital_id}", delete(hospitals::delete_hospital))
         .route("/create", post(hospitals::create_hospital))
+        .route("/me", get(hospitals::get_user_hospitals))
         .route("/update/{hospital_id}", put(hospitals::update_hospital))
         .route("/blood-request", get(hospitals::get_blood_requests))
         .route("/blood-request", post(hospitals::create_blood_request))