use axum::{extract::Query, extract::State, http::StatusCode};
use metrics::counter;
use serde::Deserialize;
use tracing::{error, instrument};

use crate::{
    handlers::{ErrorResponse, ErrorResponseStatus, RespExt},
    router::{AppState, UserAuth},
};
use atuin_server_database::Database;

#[derive(Deserialize)]
pub struct DeleteParams {}

#[instrument(skip_all, fields(user.id = user.id))]
pub async fn delete<DB: Database>(
    _params: Query<DeleteParams>,
    UserAuth(user): UserAuth,
    state: State<AppState<DB>>,
) -> Result<(), ErrorResponseStatus<'static>> {
    let State(AppState {
        database,
        settings: _,
    }) = state;

    if let Err(e) = database.delete_store(&user).await {
        counter!("atuin_store_delete_failed", 1);
        error!("failed to delete store {e:?}");

        return Err(ErrorResponse::reply("failed to delete store")
            .with_status(StatusCode::INTERNAL_SERVER_ERROR));
    }

    counter!("atuin_store_deleted", 1);

    Ok(())
}