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::{blocking, 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,
  11     moderator::{ModRemoveCommunity, ModRemoveCommunityForm},
  12   },
  13   traits::Crud,
  14 };
  15 use lemmy_utils::{utils::naive_from_unix, ConnectionId, LemmyError};
  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 = blocking(context.pool(), move |conn| {
  39       Community::update_removed(conn, community_id, removed)
  40     })
  41     .await?
  42     .map_err(|e| LemmyError::from_error_message(e, "couldnt_update_community"))?;
  43
  44     // Mod tables
  45     let expires = data.expires.map(naive_from_unix);
  46     let form = ModRemoveCommunityForm {
  47       mod_person_id: local_user_view.person.id,
  48       community_id: data.community_id,
  49       removed: Some(removed),
  50       reason: data.reason.to_owned(),
  51       expires,
  52     };
  53     blocking(context.pool(), move |conn| {
  54       ModRemoveCommunity::create(conn, &form)
  55     })
  56     .await??;
  57
  58     let res = send_community_ws_message(
  59       data.community_id,
  60       UserOperationCrud::RemoveCommunity,
  61       websocket_id,
  62       Some(local_user_view.person.id),
  63       context,
  64     )
  65     .await?;
  66
  67     // Apub messages
  68     let deletable = DeletableObjects::Community(Box::new(updated_community.clone().into()));
  69     send_apub_delete_in_community(
  70       local_user_view.person,
  71       updated_community,
  72       deletable,
  73       data.reason.clone().or_else(|| Some("".to_string())),
  74       removed,
  75       context,
  76     )
  77     .await?;
  78     Ok(res)
  79   }
  80 }