crates/api/src/site/purge/comment.rs

   1 use crate::Perform;
   2 use actix_web::web::Data;
   3 use lemmy_api_common::{
   4   context::LemmyContext,
   5   site::{PurgeComment, PurgeItemResponse},
   6   utils::{get_local_user_view_from_jwt, is_top_admin},
   7 };
   8 use lemmy_db_schema::{
   9   source::{
  10     comment::Comment,
  11     moderator::{AdminPurgeComment, AdminPurgeCommentForm},
  12   },
  13   traits::Crud,
  14 };
  15 use lemmy_utils::{error::LemmyError, ConnectionId};
  16
  17 #[async_trait::async_trait(?Send)]
  18 impl Perform for PurgeComment {
  19   type Response = PurgeItemResponse;
  20
  21   #[tracing::instrument(skip(context, _websocket_id))]
  22   async fn perform(
  23     &self,
  24     context: &Data<LemmyContext>,
  25     _websocket_id: Option<ConnectionId>,
  26   ) -> Result<Self::Response, LemmyError> {
  27     let data: &Self = self;
  28     let local_user_view =
  29       get_local_user_view_from_jwt(&data.auth, context.pool(), context.secret()).await?;
  30
  31     // Only let the top admin purge an item
  32     is_top_admin(context.pool(), local_user_view.person.id).await?;
  33
  34     let comment_id = data.comment_id;
  35
  36     // Read the comment to get the post_id
  37     let comment = Comment::read(context.pool(), comment_id).await?;
  38
  39     let post_id = comment.post_id;
  40
  41     // TODO read comments for pictrs images and purge them
  42
  43     Comment::delete(context.pool(), comment_id).await?;
  44
  45     // Mod tables
  46     let reason = data.reason.clone();
  47     let form = AdminPurgeCommentForm {
  48       admin_person_id: local_user_view.person.id,
  49       reason,
  50       post_id,
  51     };
  52
  53     AdminPurgeComment::create(context.pool(), &form).await?;
  54
  55     Ok(PurgeItemResponse { success: true })
  56   }
  57 }