use crate::Perform; use actix_web::web::Data; use lemmy_api_common::{ site::{PurgeComment, PurgeItemResponse}, utils::{get_local_user_view_from_jwt, is_admin}, LemmyContext, }; use lemmy_db_schema::{ source::{ comment::Comment, moderator::{AdminPurgeComment, AdminPurgeCommentForm}, }, traits::Crud, }; use lemmy_utils::{error::LemmyError, ConnectionId}; #[async_trait::async_trait(?Send)] impl Perform for PurgeComment { type Response = PurgeItemResponse; #[tracing::instrument(skip(context, _websocket_id))] async fn perform( &self, context: &Data, _websocket_id: Option, ) -> Result { let data: &Self = self; let local_user_view = get_local_user_view_from_jwt(&data.auth, context.pool(), context.secret()).await?; // Only let admins purge an item is_admin(&local_user_view)?; let comment_id = data.comment_id; // Read the comment to get the post_id let comment = Comment::read(context.pool(), comment_id).await?; let post_id = comment.post_id; // TODO read comments for pictrs images and purge them Comment::delete(context.pool(), comment_id).await?; // Mod tables let reason = data.reason.clone(); let form = AdminPurgeCommentForm { admin_person_id: local_user_view.person.id, reason, post_id, }; AdminPurgeComment::create(context.pool(), &form).await?; Ok(PurgeItemResponse { success: true }) } }