crates/api_crud/src/community/remove.rs

   1 use crate::PerformCrud;
   2 use actix_web::web::Data;
   3 use lemmy_api_common::{
   4   community::{CommunityResponse, RemoveCommunity},
   5   utils::{get_local_user_view_from_jwt, is_admin},
   6 };
   7 use lemmy_apub::activities::deletion::{send_apub_delete_in_community, DeletableObjects};
   8 use lemmy_db_schema::{
   9   source::{
  10     community::{Community, CommunityUpdateForm},
  11     moderator::{ModRemoveCommunity, ModRemoveCommunityForm},
  12   },
  13   traits::Crud,
  14 };
  15 use lemmy_utils::{error::LemmyError, utils::naive_from_unix, ConnectionId};
  16 use lemmy_websocket::{send::send_community_ws_message, LemmyContext, UserOperationCrud};
  17
  18 #[async_trait::async_trait(?Send)]
  19 impl PerformCrud for RemoveCommunity {
  20   type Response = CommunityResponse;
  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<CommunityResponse, LemmyError> {
  28     let data: &RemoveCommunity = self;
  29     let local_user_view =
  30       get_local_user_view_from_jwt(&data.auth, context.pool(), context.secret()).await?;
  31
  32     // Verify its an admin (only an admin can remove a community)
  33     is_admin(&local_user_view)?;
  34
  35     // Do the remove
  36     let community_id = data.community_id;
  37     let removed = data.removed;
  38     let updated_community = Community::update(
  39       context.pool(),
  40       community_id,
  41       &CommunityUpdateForm::builder()
  42         .removed(Some(removed))
  43         .build(),
  44     )
  45     .await
  46     .map_err(|e| LemmyError::from_error_message(e, "couldnt_update_community"))?;
  47
  48     // Mod tables
  49     let expires = data.expires.map(naive_from_unix);
  50     let form = ModRemoveCommunityForm {
  51       mod_person_id: local_user_view.person.id,
  52       community_id: data.community_id,
  53       removed: Some(removed),
  54       reason: data.reason.clone(),
  55       expires,
  56     };
  57     ModRemoveCommunity::create(context.pool(), &form).await?;
  58
  59     let res = send_community_ws_message(
  60       data.community_id,
  61       UserOperationCrud::RemoveCommunity,
  62       websocket_id,
  63       Some(local_user_view.person.id),
  64       context,
  65     )
  66     .await?;
  67
  68     // Apub messages
  69     let deletable = DeletableObjects::Community(Box::new(updated_community.clone().into()));
  70     send_apub_delete_in_community(
  71       local_user_view.person,
  72       updated_community,
  73       deletable,
  74       data.reason.clone().or_else(|| Some(String::new())),
  75       removed,
  76       context,
  77     )
  78     .await?;
  79     Ok(res)
  80   }
  81 }