3 community::announce::AnnouncableActivities,
7 verify_person_in_community,
9 activity_queue::send_to_community_new,
10 extensions::context::lemmy_context,
11 fetcher::object_id::ObjectId,
14 use activitystreams::{
15 activity::kind::BlockType,
17 primitives::OneOrMany,
20 use lemmy_api_common::blocking;
21 use lemmy_apub_lib::{values::PublicUrl, ActivityFields, ActivityHandler};
22 use lemmy_db_queries::{Bannable, Followable};
23 use lemmy_db_schema::source::{
27 CommunityFollowerForm,
29 CommunityPersonBanForm,
33 use lemmy_utils::LemmyError;
34 use lemmy_websocket::LemmyContext;
35 use serde::{Deserialize, Serialize};
38 #[derive(Clone, Debug, Deserialize, Serialize, ActivityFields)]
39 #[serde(rename_all = "camelCase")]
40 pub struct BlockUserFromCommunity {
41 actor: ObjectId<Person>,
43 pub(in crate::activities::community) object: ObjectId<Person>,
44 cc: [ObjectId<Community>; 1],
45 #[serde(rename = "type")]
48 #[serde(rename = "@context")]
49 context: OneOrMany<AnyBase>,
54 impl BlockUserFromCommunity {
55 pub(in crate::activities::community) fn new(
56 community: &Community,
59 context: &LemmyContext,
60 ) -> Result<BlockUserFromCommunity, LemmyError> {
61 Ok(BlockUserFromCommunity {
62 actor: ObjectId::new(actor.actor_id()),
63 to: [PublicUrl::Public],
64 object: ObjectId::new(target.actor_id()),
65 cc: [ObjectId::new(community.actor_id())],
66 kind: BlockType::Block,
67 id: generate_activity_id(
69 &context.settings().get_protocol_and_hostname(),
71 context: lemmy_context(),
72 unparsed: Default::default(),
77 community: &Community,
80 context: &LemmyContext,
81 ) -> Result<(), LemmyError> {
82 let block = BlockUserFromCommunity::new(community, target, actor, context)?;
83 let block_id = block.id.clone();
85 let activity = AnnouncableActivities::BlockUserFromCommunity(block);
86 let inboxes = vec![target.get_shared_inbox_or_inbox_url()];
87 send_to_community_new(activity, &block_id, actor, community, inboxes, context).await
91 #[async_trait::async_trait(?Send)]
92 impl ActivityHandler for BlockUserFromCommunity {
95 context: &LemmyContext,
96 request_counter: &mut i32,
97 ) -> Result<(), LemmyError> {
98 verify_activity(self, &context.settings())?;
99 verify_person_in_community(&self.actor, &self.cc[0], context, request_counter).await?;
100 verify_mod_action(&self.actor, self.cc[0].clone(), context).await?;
106 context: &LemmyContext,
107 request_counter: &mut i32,
108 ) -> Result<(), LemmyError> {
109 let community = self.cc[0].dereference(context, request_counter).await?;
110 let blocked_user = self.object.dereference(context, request_counter).await?;
112 let community_user_ban_form = CommunityPersonBanForm {
113 community_id: community.id,
114 person_id: blocked_user.id,
117 blocking(context.pool(), move |conn: &'_ _| {
118 CommunityPersonBan::ban(conn, &community_user_ban_form)
122 // Also unsubscribe them from the community, if they are subscribed
123 let community_follower_form = CommunityFollowerForm {
124 community_id: community.id,
125 person_id: blocked_user.id,
128 blocking(context.pool(), move |conn: &'_ _| {
129 CommunityFollower::unfollow(conn, &community_follower_form)