use crate::{ activities::{ community::{ announce::GetCommunity, get_community_from_moderators_url, send_activity_in_community, }, generate_activity_id, verify_activity, verify_add_remove_moderator_target, verify_is_public, verify_mod_action, verify_person_in_community, }, activity_lists::AnnouncableActivities, generate_moderators_url, objects::{community::ApubCommunity, person::ApubPerson}, protocol::activities::community::remove_mod::RemoveMod, }; use activitystreams_kinds::{activity::RemoveType, public}; use lemmy_api_common::blocking; use lemmy_apub_lib::{ data::Data, object_id::ObjectId, traits::{ActivityHandler, ActorType}, }; use lemmy_db_schema::{ source::community::{CommunityModerator, CommunityModeratorForm}, traits::Joinable, }; use lemmy_utils::LemmyError; use lemmy_websocket::LemmyContext; impl RemoveMod { #[tracing::instrument(skip_all)] pub async fn send( community: &ApubCommunity, removed_mod: &ApubPerson, actor: &ApubPerson, context: &LemmyContext, ) -> Result<(), LemmyError> { let id = generate_activity_id( RemoveType::Remove, &context.settings().get_protocol_and_hostname(), )?; let remove = RemoveMod { actor: ObjectId::new(actor.actor_id()), to: vec![public()], object: ObjectId::new(removed_mod.actor_id()), target: generate_moderators_url(&community.actor_id)?.into(), id: id.clone(), cc: vec![community.actor_id()], kind: RemoveType::Remove, unparsed: Default::default(), }; let activity = AnnouncableActivities::RemoveMod(remove); let inboxes = vec![removed_mod.shared_inbox_or_inbox_url()]; send_activity_in_community(activity, &id, actor, community, inboxes, context).await } } #[async_trait::async_trait(?Send)] impl ActivityHandler for RemoveMod { type DataType = LemmyContext; #[tracing::instrument(skip_all)] async fn verify( &self, context: &Data, request_counter: &mut i32, ) -> Result<(), LemmyError> { verify_is_public(&self.to, &self.cc)?; verify_activity(&self.id, self.actor.inner(), &context.settings())?; let community = self.get_community(context, request_counter).await?; verify_person_in_community(&self.actor, &community, context, request_counter).await?; verify_mod_action(&self.actor, &community, context, request_counter).await?; verify_add_remove_moderator_target(&self.target, &community)?; Ok(()) } #[tracing::instrument(skip_all)] async fn receive( self, context: &Data, request_counter: &mut i32, ) -> Result<(), LemmyError> { let community = self.get_community(context, request_counter).await?; let remove_mod = self .object .dereference(context, context.client(), 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(()) } } #[async_trait::async_trait(?Send)] impl GetCommunity for RemoveMod { #[tracing::instrument(skip_all)] async fn get_community( &self, context: &LemmyContext, request_counter: &mut i32, ) -> Result { get_community_from_moderators_url(&self.target, context, request_counter).await } }