main
use ::session::AuthedUser;
use api::http::{Path, Query, State};
use api::rest::AppResponseData;
use crate::errors::ApiError;
use crate::services::inbox::{InboxPage, InboxQuery};
use crate::services::service::PullService;
#[derive(Debug, serde::Deserialize, utoipa::IntoParams)]
pub struct InboxPath {
/// created | review-requested | reviewed
pub scope: String,
}
#[utoipa::path(
get,
path = "/pulls/@me/{scope}",
tag = "pulls",
description = "跨仓库的个人合并请求收件箱：我创建的、待我评审的、我评审过的。",
params(InboxPath, InboxQuery),
responses(
(status = 200, description = "inbox", body = AppResponseData<api::pagination::Page<crate::services::pulls::PullDto>>)
)
)]
pub async fn list_my_pulls(
State(service): State<PullService>,
AuthedUser(uid): AuthedUser,
Path(path): Path<InboxPath>,
Query(query): Query<InboxQuery>,
) -> Result<AppResponseData<InboxPage>, ApiError> {
let caller = uid;
let scope = match path.scope.as_str() {
"created" => crate::services::inbox::InboxScope::Created,
"review-requested" => crate::services::inbox::InboxScope::ReviewRequested,
"reviewed" => crate::services::inbox::InboxScope::Reviewed,
other => {
return Err(ApiError::from(crate::errors::PullError::BadRequest(
format!("unknown inbox scope `{other}`"),
)));
}
};
let page = service.list_inbox(caller, scope, query).await?;
Ok(AppResponseData::ok(page))
}