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

   1 use crate::Perform;
   2 use actix_web::web::Data;
   3 use lemmy_api_common::{
   4   site::{PurgeComment, PurgeItemResponse},
   5   utils::{get_local_user_view_from_jwt, is_admin},
   6 };
   7 use lemmy_db_schema::{
   8   source::{
   9     comment::Comment,
  10     moderator::{AdminPurgeComment, AdminPurgeCommentForm},
  11   },
  12   traits::Crud,
  13 };
  14 use lemmy_utils::{error::LemmyError, ConnectionId};
  15 use lemmy_websocket::LemmyContext;
  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 admins purge an item
  32     is_admin(&local_user_view)?;
  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.to_owned();
  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 }