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 pub(crate) async fn send_activity_in_community<T: ActorType>(
  21   activity: AnnouncableActivities,
  22   activity_id: &Url,
  23   actor: &T,
  24   community: &ApubCommunity,
  25   mut inboxes: Vec<Url>,
  26   context: &LemmyContext,
  27 ) -> Result<(), LemmyError> {
  28   inboxes.push(community.shared_inbox_or_inbox_url());
  29   send_lemmy_activity(context, &activity, activity_id, actor, inboxes, false).await?;
  30
  31   if community.local {
  32     AnnounceActivity::send(activity, community, context).await?;
  33   }
  34
  35   Ok(())
  36 }
  37
  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, request_counter)
  46     .await
  47 }