use crate::{
    entities::trash::{RepeatedTrash, RepeatedTrashId, TrashId},
    errors::FlowyError,
    services::TrashController,
};
use lib_dispatch::prelude::{data_result, Data, DataResult, Unit};
use std::sync::Arc;

#[tracing::instrument(skip(controller), err)]
pub(crate) async fn read_trash_handler(
    controller: Unit<Arc<TrashController>>,
) -> DataResult<RepeatedTrash, FlowyError> {
    let repeated_trash = controller.read_trash().await?;
    data_result(repeated_trash)
}

#[tracing::instrument(skip(identifier, controller), err)]
pub(crate) async fn putback_trash_handler(
    identifier: Data<TrashId>,
    controller: Unit<Arc<TrashController>>,
) -> Result<(), FlowyError> {
    let _ = controller.putback(&identifier.id).await?;
    Ok(())
}

#[tracing::instrument(skip(identifiers, controller), err)]
pub(crate) async fn delete_trash_handler(
    identifiers: Data<RepeatedTrashId>,
    controller: Unit<Arc<TrashController>>,
) -> Result<(), FlowyError> {
    let _ = controller.delete(identifiers.into_inner()).await?;
    Ok(())
}

#[tracing::instrument(skip(controller), err)]
pub(crate) async fn restore_all_trash_handler(controller: Unit<Arc<TrashController>>) -> Result<(), FlowyError> {
    let _ = controller.restore_all_trash().await?;
    Ok(())
}

#[tracing::instrument(skip(controller), err)]
pub(crate) async fn delete_all_trash_handler(controller: Unit<Arc<TrashController>>) -> Result<(), FlowyError> {
    let _ = controller.delete_all_trash().await?;
    Ok(())
}