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

   1 use crate::Perform;
   2 use actix_web::web::Data;
   3 use lemmy_api_common::{
   4   request::purge_image_from_pictrs,
   5   site::{PurgeItemResponse, PurgePerson},
   6   utils::{get_local_user_view_from_jwt, is_admin, purge_image_posts_for_person},
   7 };
   8 use lemmy_db_schema::{
   9   source::{
  10     moderator::{AdminPurgePerson, AdminPurgePersonForm},
  11     person::Person,
  12   },
  13   traits::Crud,
  14 };
  15 use lemmy_utils::{error::LemmyError, ConnectionId};
  16 use lemmy_websocket::LemmyContext;
  17
  18 #[async_trait::async_trait(?Send)]
  19 impl Perform for PurgePerson {
  20   type Response = PurgeItemResponse;
  21
  22   #[tracing::instrument(skip(context, _websocket_id))]
  23   async fn perform(
  24     &self,
  25     context: &Data<LemmyContext>,
  26     _websocket_id: Option<ConnectionId>,
  27   ) -> Result<Self::Response, LemmyError> {
  28     let data: &Self = self;
  29     let local_user_view =
  30       get_local_user_view_from_jwt(&data.auth, context.pool(), context.secret()).await?;
  31
  32     // Only let admins purge an item
  33     is_admin(&local_user_view)?;
  34
  35     // Read the person to get their images
  36     let person_id = data.person_id;
  37     let person = Person::read(context.pool(), person_id).await?;
  38
  39     if let Some(banner) = person.banner {
  40       purge_image_from_pictrs(context.client(), context.settings(), &banner)
  41         .await
  42         .ok();
  43     }
  44
  45     if let Some(avatar) = person.avatar {
  46       purge_image_from_pictrs(context.client(), context.settings(), &avatar)
  47         .await
  48         .ok();
  49     }
  50
  51     purge_image_posts_for_person(
  52       person_id,
  53       context.pool(),
  54       context.settings(),
  55       context.client(),
  56     )
  57     .await?;
  58
  59     Person::delete(context.pool(), person_id).await?;
  60
  61     // Mod tables
  62     let reason = data.reason.to_owned();
  63     let form = AdminPurgePersonForm {
  64       admin_person_id: local_user_view.person.id,
  65       reason,
  66     };
  67
  68     AdminPurgePerson::create(context.pool(), &form).await?;
  69
  70     Ok(PurgeItemResponse { success: true })
  71   }
  72 }