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

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