Function admin_delete_comment_task

crates/backend/src/handlers.rs:2556–2605

(
    State(state): State<AppState>,
    headers: HeaderMap,
    Path(task_id): Path<String>,
    Json(request): Json<AdminTaskActionRequest>,
)

}

pub async fn admin_delete_comment_task(
    State(state): State<AppState>,
    headers: HeaderMap,
    Path(task_id): Path<String>,
    Json(request): Json<AdminTaskActionRequest>,
) -> Result<Json<serde_json::Value>, (StatusCode, Json<ErrorResponse>)> {
    ensure_admin_access(&state, &headers)?;

    let before = state
        .comment_store
        .get_comment_task(&task_id)
        .await
        .map_err(|e| internal_error("Failed to fetch comment task", e))?;
    let Some(before_task) = before else {
        return Err((
            StatusCode::NOT_FOUND,
            Json(ErrorResponse {
                error: "Comment task not found".to_string(),
                code: 404,
            }),
        ));
    };
    if before_task.status == COMMENT_STATUS_RUNNING {
        return Err(conflict_error("Running comment task cannot be deleted"));
    }

    state
        .comment_store
        .delete_comment_task(&task_id)
        .await
        .map_err(|e| internal_error("Failed to delete comment task", e))?;

    let operator = request.operator.unwrap_or_else(|| "admin".to_string());
    let _ = state
        .comment_store
        .append_audit_log(NewCommentAuditInput {
            log_id: generate_task_id("audit"),
            task_id: task_id.clone(),
            action: "task_deleted".to_string(),
            operator,
            before_json: serde_json::to_string(&before_task).ok(),
            after_json: Some("{\"deleted\":true}".to_string()),
        })
        .await;

    Ok(Json(serde_json::json!({
        "task_id": task_id,
        "deleted": true
    })))
}

pub async fn admin_list_comment_audit_logs(
    State(state): State<AppState>,