crates/apub/src/activities/community/undo_block_user.rs

   1 use crate::{
   2   activities::{
   3     community::{announce::GetCommunity, send_activity_in_community},
   4     generate_activity_id,
   5     verify_activity,
   6     verify_is_public,
   7     verify_mod_action,
   8     verify_person_in_community,
   9   },
  10   activity_lists::AnnouncableActivities,
  11   objects::{community::ApubCommunity, person::ApubPerson},
  12   protocol::activities::community::{
  13     block_user::BlockUserFromCommunity,
  14     undo_block_user::UndoBlockUserFromCommunity,
  15   },
  16 };
  17 use activitystreams_kinds::{activity::UndoType, public};
  18 use lemmy_api_common::blocking;
  19 use lemmy_apub_lib::{
  20   data::Data,
  21   object_id::ObjectId,
  22   traits::{ActivityHandler, ActorType},
  23 };
  24 use lemmy_db_schema::{
  25   source::community::{CommunityPersonBan, CommunityPersonBanForm},
  26   traits::Bannable,
  27 };
  28 use lemmy_utils::LemmyError;
  29 use lemmy_websocket::LemmyContext;
  30
  31 impl UndoBlockUserFromCommunity {
  32   #[tracing::instrument(skip_all)]
  33   pub async fn send(
  34     community: &ApubCommunity,
  35     target: &ApubPerson,
  36     actor: &ApubPerson,
  37     context: &LemmyContext,
  38   ) -> Result<(), LemmyError> {
  39     let block = BlockUserFromCommunity::new(community, target, actor, None, context)?;
  40
  41     let id = generate_activity_id(
  42       UndoType::Undo,
  43       &context.settings().get_protocol_and_hostname(),
  44     )?;
  45     let undo = UndoBlockUserFromCommunity {
  46       actor: ObjectId::new(actor.actor_id()),
  47       to: vec![public()],
  48       object: block,
  49       cc: vec![community.actor_id()],
  50       kind: UndoType::Undo,
  51       id: id.clone(),
  52       unparsed: Default::default(),
  53     };
  54
  55     let activity = AnnouncableActivities::UndoBlockUserFromCommunity(undo);
  56     let inboxes = vec![target.shared_inbox_or_inbox_url()];
  57     send_activity_in_community(activity, &id, actor, community, inboxes, context).await
  58   }
  59 }
  60
  61 #[async_trait::async_trait(?Send)]
  62 impl ActivityHandler for UndoBlockUserFromCommunity {
  63   type DataType = LemmyContext;
  64
  65   #[tracing::instrument(skip_all)]
  66   async fn verify(
  67     &self,
  68     context: &Data<LemmyContext>,
  69     request_counter: &mut i32,
  70   ) -> Result<(), LemmyError> {
  71     verify_is_public(&self.to, &self.cc)?;
  72     verify_activity(&self.id, self.actor.inner(), &context.settings())?;
  73     let community = self.get_community(context, request_counter).await?;
  74     verify_person_in_community(&self.actor, &community, context, request_counter).await?;
  75     verify_mod_action(&self.actor, &community, context, request_counter).await?;
  76     self.object.verify(context, request_counter).await?;
  77     Ok(())
  78   }
  79
  80   #[tracing::instrument(skip_all)]
  81   async fn receive(
  82     self,
  83     context: &Data<LemmyContext>,
  84     request_counter: &mut i32,
  85   ) -> Result<(), LemmyError> {
  86     let community = self.get_community(context, request_counter).await?;
  87     let blocked_user = self
  88       .object
  89       .object
  90       .dereference(context, context.client(), request_counter)
  91       .await?;
  92
  93     let community_user_ban_form = CommunityPersonBanForm {
  94       community_id: community.id,
  95       person_id: blocked_user.id,
  96       expires: None,
  97     };
  98
  99     blocking(context.pool(), move |conn: &'_ _| {
 100       CommunityPersonBan::unban(conn, &community_user_ban_form)
 101     })
 102     .await??;
 103
 104     Ok(())
 105   }
 106 }
 107
 108 #[async_trait::async_trait(?Send)]
 109 impl GetCommunity for UndoBlockUserFromCommunity {
 110   #[tracing::instrument(skip_all)]
 111   async fn get_community(
 112     &self,
 113     context: &LemmyContext,
 114     request_counter: &mut i32,
 115   ) -> Result<ApubCommunity, LemmyError> {
 116     self.object.get_community(context, request_counter).await
 117   }
 118 }