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

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