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 remove_mod;
  15 pub mod report;
  16 pub mod update;
  17
  18 #[tracing::instrument(skip_all)]
  19 pub(crate) async fn send_activity_in_community<T: ActorType>(
  20   activity: AnnouncableActivities,
  21   activity_id: &Url,
  22   actor: &T,
  23   community: &ApubCommunity,
  24   mut inboxes: Vec<Url>,
  25   context: &LemmyContext,
  26 ) -> Result<(), LemmyError> {
  27   inboxes.push(community.shared_inbox_or_inbox_url());
  28   send_lemmy_activity(context, &activity, activity_id, actor, inboxes, false).await?;
  29
  30   if community.local {
  31     AnnounceActivity::send(activity, community, context).await?;
  32   }
  33
  34   Ok(())
  35 }
  36
  37 #[tracing::instrument(skip_all)]
  38 async fn get_community_from_moderators_url(
  39   moderators: &Url,
  40   context: &LemmyContext,
  41   request_counter: &mut i32,
  42 ) -> Result<ApubCommunity, LemmyError> {
  43   let community_id = Url::parse(&moderators.to_string().replace("/moderators", ""))?;
  44   ObjectId::new(community_id)
  45     .dereference(context, context.client(), request_counter)
  46     .await
  47 }