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

   1 use crate::{
   2   activities::send_lemmy_activity,
   3   activity_lists::AnnouncableActivities,
   4   insert_activity,
   5   objects::community::ApubCommunity,
   6   protocol::activities::community::announce::AnnounceActivity,
   7 };
   8 use lemmy_apub_lib::{object_id::ObjectId, traits::ActorType};
   9 use lemmy_utils::LemmyError;
  10 use lemmy_websocket::LemmyContext;
  11 use url::Url;
  12
  13 pub mod add_mod;
  14 pub mod announce;
  15 pub mod block_user;
  16 pub mod remove_mod;
  17 pub mod report;
  18 pub mod undo_block_user;
  19 pub mod update;
  20
  21 pub(crate) async fn send_to_community<T: ActorType>(
  22   activity: AnnouncableActivities,
  23   activity_id: &Url,
  24   actor: &T,
  25   community: &ApubCommunity,
  26   additional_inboxes: Vec<Url>,
  27   context: &LemmyContext,
  28 ) -> Result<(), LemmyError> {
  29   // if this is a local community, we need to do an announce from the community instead
  30   let object_value = serde_json::to_value(&activity)?;
  31   if community.local {
  32     insert_activity(activity_id, object_value, 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 }