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

   1 use crate::{
   2   activities::send_lemmy_activity,
   3   activity_lists::AnnouncableActivities,
   4   objects::community::ApubCommunity,
   5   protocol::activities::community::announce::AnnounceActivity,
   6 };
   7 use lemmy_apub_lib::{object_id::ObjectId, traits::ActorType};
   8 use lemmy_utils::LemmyError;
   9 use lemmy_websocket::LemmyContext;
  10 use url::Url;
  11
  12 pub mod add_mod;
  13 pub mod announce;
  14 pub mod block_user;
  15 pub mod remove_mod;
  16 pub mod report;
  17 pub mod undo_block_user;
  18 pub mod update;
  19
  20 #[tracing::instrument(skip_all)]
  21 pub(crate) async fn send_activity_in_community<T: ActorType>(
  22   activity: AnnouncableActivities,
  23   activity_id: &Url,
  24   actor: &T,
  25   community: &ApubCommunity,
  26   mut inboxes: Vec<Url>,
  27   context: &LemmyContext,
  28 ) -> Result<(), LemmyError> {
  29   inboxes.push(community.shared_inbox_or_inbox_url());
  30   send_lemmy_activity(context, &activity, activity_id, actor, inboxes, false).await?;
  31
  32   if community.local {
  33     AnnounceActivity::send(activity, community, context).await?;
  34   }
  35
  36   Ok(())
  37 }
  38
  39 #[tracing::instrument(skip_all)]
  40 async fn get_community_from_moderators_url(
  41   moderators: &Url,
  42   context: &LemmyContext,
  43   request_counter: &mut i32,
  44 ) -> Result<ApubCommunity, LemmyError> {
  45   let community_id = Url::parse(&moderators.to_string().replace("/moderators", ""))?;
  46   ObjectId::new(community_id)
  47     .dereference(context, context.client(), request_counter)
  48     .await
  49 }