2 apub::{activity_queue::send_activity, community::do_announce, insert_activity},
6 base::{Extends, ExtendsExt},
9 use lemmy_db::{community::Community, user::User_};
10 use lemmy_utils::{apub::get_apub_protocol_string, settings::Settings, LemmyError};
11 use serde::{export::fmt::Debug, Serialize};
12 use url::{ParseError, Url};
15 pub async fn send_activity_to_community<T, Kind>(
17 community: &Community,
20 context: &LemmyContext,
21 ) -> Result<(), LemmyError>
23 T: AsObject<Kind> + Extends<Kind> + Serialize + Debug + Send + Clone + 'static,
25 <T as Extends<Kind>>::Error: From<serde_json::Error> + Send + Sync + 'static,
27 // TODO: looks like call this sometimes with activity, and sometimes with any_base
28 insert_activity(creator.id, activity.clone(), true, context.pool()).await?;
30 // if this is a local community, we need to do an announce from the community instead
32 do_announce(activity.into_any_base()?, &community, creator, context).await?;
34 send_activity(context.activity_queue(), activity, creator, to)?;
40 pub(in crate::apub) fn generate_activity_id<T>(kind: T) -> Result<Url, ParseError>
45 "{}://{}/activities/{}/{}",
46 get_apub_protocol_string(),
47 Settings::get().hostname,
48 kind.to_string().to_lowercase(),