use ::session::AuthedUser;
use api::http::{Json, Path, Query, State};
use api::rest::{AppResponseData, NoData};
use uuid::Uuid;

use crate::errors::ApiError;
use crate::services::drafts::{DraftDto, UpsertDraftCmd};
use crate::services::service::ChatService;

#[derive(Debug, Clone, serde::Deserialize, utoipa::IntoParams, utoipa::ToSchema)]
pub struct DraftQuery {
    pub thread_id: Option<Uuid>,
}

#[utoipa::path(
    put,
    path = "/chat/rooms/{room_id}/draft",
    tag = "chat",
    description = "保存房间或话题输入草稿；提交空内容会清除对应草稿。",
    params(("room_id" = Uuid, Path, description = "room id")),
    request_body = UpsertDraftCmd,
    responses(
        (status = 200, description = "draft saved", body = AppResponseData<DraftDto>),
        (status = 400, description = "bad request", body = AppResponseData<NoData>),
        (status = 401, description = "authentication required", body = AppResponseData<NoData>)
    )
)]
pub async fn upsert_draft(
    State(service): State<ChatService>,
    AuthedUser(uid): AuthedUser,
    Path(room_id): Path<Uuid>,
    Json(cmd): Json<UpsertDraftCmd>,
) -> Result<AppResponseData<DraftDto>, ApiError> {
    let dto = service.upsert_draft(uid, room_id, cmd).await?;
    Ok(AppResponseData::ok(dto))
}

#[utoipa::path(
    get,
    path = "/chat/rooms/{room_id}/draft",
    tag = "chat",
    description = "读取当前用户在指定房间或话题中的输入草稿。",
    params(("room_id" = Uuid, Path, description = "room id"), DraftQuery),
    responses(
        (status = 200, description = "draft", body = AppResponseData<Option<DraftDto>>),
        (status = 404, description = "not found", body = AppResponseData<NoData>),
        (status = 401, description = "authentication required", body = AppResponseData<NoData>)
    )
)]
pub async fn get_draft(
    State(service): State<ChatService>,
    AuthedUser(uid): AuthedUser,
    Path(room_id): Path<Uuid>,
    Query(q): Query<DraftQuery>,
) -> Result<AppResponseData<Option<DraftDto>>, ApiError> {
    let dto = service.get_draft(uid, room_id, q.thread_id).await?;
    Ok(AppResponseData::ok(dto))
}

#[utoipa::path(
    get,
    path = "/chat/drafts",
    tag = "chat",
    description = "分页列出当前用户保存的全部聊天草稿。",
    responses(
        (status = 200, description = "my drafts", body = AppResponseData<api::pagination::Page<DraftDto>>),
        (status = 401, description = "unauthorized", body = AppResponseData<NoData>),
        (status = 404, description = "resource not found", body = AppResponseData<NoData>)
    )
)]
pub async fn list_my_drafts(
    State(service): State<ChatService>,
    AuthedUser(uid): AuthedUser,
    Query(page): Query<api::pagination::PageQuery>,
) -> Result<AppResponseData<api::pagination::Page<DraftDto>>, ApiError> {
    let drafts = service.list_my_drafts(uid).await?;
    Ok(AppResponseData::ok(api::pagination::paginate(
        drafts, &page,
    )?))
}

#[utoipa::path(
    delete,
    path = "/chat/rooms/{room_id}/draft",
    tag = "chat",
    description = "删除当前用户在指定房间或话题中的输入草稿。",
    params(("room_id" = Uuid, Path), ("thread_id" = Option<Uuid>, Query, description = "thread scope")),
    responses(
        (status = 200, description = "draft deleted", body = AppResponseData<NoData>),
        (status = 404, description = "no draft", body = AppResponseData<NoData>),
        (status = 401, description = "authentication required", body = AppResponseData<NoData>)
    )
)]
pub async fn delete_draft(
    State(service): State<ChatService>,
    AuthedUser(uid): AuthedUser,
    Path(room_id): Path<Uuid>,
    Query(q): Query<DraftQuery>,
) -> Result<AppResponseData<NoData>, ApiError> {
    service.delete_draft(uid, room_id, q.thread_id).await?;
    Ok(AppResponseData::empty())
}