X-Git-Url: http://these/git/?a=blobdiff_plain;f=crates%2Fapi%2Fsrc%2Fsite%2Fpurge%2Fcomment.rs;h=bfaf9cbb0772e9614fe33cd163828a2af35f895a;hb=3471f3533cb724b2cf6953d563aadfcc9f66c1d2;hp=54f3c0edf9eba6c960a8d96c65dae41d0d0149b0;hpb=030afbc2e78a91b1a302ca59c4ea0ccef9057019;p=lemmy.git diff --git a/crates/api/src/site/purge/comment.rs b/crates/api/src/site/purge/comment.rs index 54f3c0ed..bfaf9cbb 100644 --- a/crates/api/src/site/purge/comment.rs +++ b/crates/api/src/site/purge/comment.rs @@ -1,9 +1,9 @@ use crate::Perform; use actix_web::web::Data; use lemmy_api_common::{ + context::LemmyContext, site::{PurgeComment, PurgeItemResponse}, - utils::{get_local_user_view_from_jwt, is_admin}, - LemmyContext, + utils::{is_admin, local_user_view_from_jwt, sanitize_html_opt}, }; use lemmy_db_schema::{ source::{ @@ -12,45 +12,40 @@ use lemmy_db_schema::{ }, traits::Crud, }; -use lemmy_utils::{error::LemmyError, ConnectionId}; +use lemmy_utils::error::LemmyError; #[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 { + #[tracing::instrument(skip(context))] + async fn perform(&self, context: &Data) -> Result { let data: &Self = self; - let local_user_view = - get_local_user_view_from_jwt(&data.auth, context.pool(), context.secret()).await?; + let local_user_view = local_user_view_from_jwt(&data.auth, context).await?; - // Only let admins purge an item + // Only let admin 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 comment = Comment::read(&mut 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?; + Comment::delete(&mut context.pool(), comment_id).await?; // Mod tables - let reason = data.reason.clone(); + let reason = sanitize_html_opt(&data.reason); let form = AdminPurgeCommentForm { admin_person_id: local_user_view.person.id, reason, post_id, }; - AdminPurgeComment::create(context.pool(), &form).await?; + AdminPurgeComment::create(&mut context.pool(), &form).await?; Ok(PurgeItemResponse { success: true }) }