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

   1 use itertools::Itertools;
   2 use url::Url;
   3
   4 use lemmy_apub_lib::traits::ActorType;
   5 use lemmy_utils::LemmyError;
   6 use lemmy_websocket::LemmyContext;
   7
   8 use crate::{
   9   activities::send_lemmy_activity,
  10   activity_lists::AnnouncableActivities,
  11   check_is_apub_id_valid,
  12   fetcher::object_id::ObjectId,
  13   insert_activity,
  14   objects::community::ApubCommunity,
  15   protocol::activities::community::announce::AnnounceActivity,
  16 };
  17
  18 pub mod add_mod;
  19 pub mod announce;
  20 pub mod block_user;
  21 pub mod remove_mod;
  22 pub mod report;
  23 pub mod undo_block_user;
  24 pub mod update;
  25
  26 async fn list_community_follower_inboxes(
  27   community: &ApubCommunity,
  28   additional_inboxes: Vec<Url>,
  29   context: &LemmyContext,
  30 ) -> Result<Vec<Url>, LemmyError> {
  31   Ok(
  32     vec![
  33       community
  34         .get_follower_inboxes(context.pool(), &context.settings())
  35         .await?,
  36       additional_inboxes,
  37     ]
  38     .iter()
  39     .flatten()
  40     .unique()
  41     .filter(|inbox| inbox.host_str() != Some(&context.settings().hostname))
  42     .filter(|inbox| check_is_apub_id_valid(inbox, false, &context.settings()).is_ok())
  43     .map(|inbox| inbox.to_owned())
  44     .collect(),
  45   )
  46 }
  47
  48 pub(crate) async fn send_to_community<T: ActorType>(
  49   activity: AnnouncableActivities,
  50   activity_id: &Url,
  51   actor: &T,
  52   community: &ApubCommunity,
  53   additional_inboxes: Vec<Url>,
  54   context: &LemmyContext,
  55 ) -> Result<(), LemmyError> {
  56   // if this is a local community, we need to do an announce from the community instead
  57   if community.local {
  58     insert_activity(activity_id, activity.clone(), true, false, context.pool()).await?;
  59     AnnounceActivity::send(activity, community, additional_inboxes, context).await?;
  60   } else {
  61     let mut inboxes = additional_inboxes;
  62     inboxes.push(community.shared_inbox_or_inbox_url());
  63     send_lemmy_activity(context, &activity, activity_id, actor, inboxes, false).await?;
  64   }
  65
  66   Ok(())
  67 }
  68
  69 async fn get_community_from_moderators_url(
  70   moderators: &Url,
  71   context: &LemmyContext,
  72   request_counter: &mut i32,
  73 ) -> Result<ApubCommunity, LemmyError> {
  74   let community_id = Url::parse(&moderators.to_string().replace("/moderators", ""))?;
  75   ObjectId::new(community_id)
  76     .dereference(context, request_counter)
  77     .await
  78 }