use crate::{ activities::{ community::announce::AnnouncableActivities, deletion::{delete::receive_remove_action, verify_delete_activity}, generate_activity_id, verify_activity, verify_add_remove_moderator_target, verify_mod_action, verify_person_in_community, }, activity_queue::send_to_community_new, extensions::context::lemmy_context, fetcher::object_id::ObjectId, generate_moderators_url, ActorType, }; use activitystreams::{ activity::kind::RemoveType, base::AnyBase, primitives::OneOrMany, unparsed::Unparsed, }; use lemmy_api_common::blocking; use lemmy_apub_lib::{values::PublicUrl, ActivityFields, ActivityHandler}; use lemmy_db_queries::Joinable; use lemmy_db_schema::source::{ community::{Community, CommunityModerator, CommunityModeratorForm}, person::Person, }; use lemmy_utils::LemmyError; use lemmy_websocket::LemmyContext; use serde::{Deserialize, Serialize}; use url::Url; #[derive(Clone, Debug, Deserialize, Serialize, ActivityFields)] #[serde(rename_all = "camelCase")] pub struct RemoveMod { actor: ObjectId, to: [PublicUrl; 1], pub(in crate::activities) object: ObjectId, cc: [ObjectId; 1], #[serde(rename = "type")] kind: RemoveType, // if target is set, this is means remove mod from community pub(in crate::activities) target: Option, id: Url, #[serde(rename = "@context")] context: OneOrMany, #[serde(flatten)] unparsed: Unparsed, } impl RemoveMod { pub async fn send( community: &Community, removed_mod: &Person, actor: &Person, context: &LemmyContext, ) -> Result<(), LemmyError> { let id = generate_activity_id(RemoveType::Remove)?; let remove = RemoveMod { actor: ObjectId::new(actor.actor_id()), to: [PublicUrl::Public], object: ObjectId::new(removed_mod.actor_id()), target: Some(generate_moderators_url(&community.actor_id)?.into()), id: id.clone(), context: lemmy_context(), cc: [ObjectId::new(community.actor_id())], kind: RemoveType::Remove, unparsed: Default::default(), }; let activity = AnnouncableActivities::RemoveMod(remove); let inboxes = vec![removed_mod.get_shared_inbox_or_inbox_url()]; send_to_community_new(activity, &id, actor, community, inboxes, context).await } } #[async_trait::async_trait(?Send)] impl ActivityHandler for RemoveMod { async fn verify( &self, context: &LemmyContext, request_counter: &mut i32, ) -> Result<(), LemmyError> { verify_activity(self)?; if let Some(target) = &self.target { verify_person_in_community(&self.actor, &self.cc[0], context, request_counter).await?; verify_mod_action(&self.actor, self.cc[0].clone(), context).await?; verify_add_remove_moderator_target(target, &self.cc[0])?; } else { verify_delete_activity( self.object.inner(), self, &self.cc[0], true, context, request_counter, ) .await?; } Ok(()) } async fn receive( self, context: &LemmyContext, request_counter: &mut i32, ) -> Result<(), LemmyError> { if self.target.is_some() { let community = self.cc[0].dereference(context, request_counter).await?; let remove_mod = self.object.dereference(context, request_counter).await?; let form = CommunityModeratorForm { community_id: community.id, person_id: remove_mod.id, }; blocking(context.pool(), move |conn| { CommunityModerator::leave(conn, &form) }) .await??; // TODO: send websocket notification about removed mod Ok(()) } else { receive_remove_action( &self.actor, self.object.inner(), None, context, request_counter, ) .await } } }