2 activities::{generate_activity_id, send_lemmy_activity, verify_activity, verify_is_public},
3 activity_lists::AnnouncableActivities,
4 http::{is_activity_already_known, ActivityCommonFields},
6 objects::community::ApubCommunity,
7 protocol::activities::community::announce::AnnounceActivity,
9 use activitystreams::{activity::kind::AnnounceType, public};
13 traits::{ActivityHandler, ActorType},
15 use lemmy_utils::LemmyError;
16 use lemmy_websocket::LemmyContext;
19 #[async_trait::async_trait(?Send)]
20 pub(crate) trait GetCommunity {
21 async fn get_community(
23 context: &LemmyContext,
24 request_counter: &mut i32,
25 ) -> Result<ApubCommunity, LemmyError>;
28 impl AnnounceActivity {
30 object: AnnouncableActivities,
31 community: &ApubCommunity,
32 context: &LemmyContext,
33 ) -> Result<AnnounceActivity, LemmyError> {
35 actor: ObjectId::new(community.actor_id()),
38 cc: vec![community.followers_url.clone().into()],
39 kind: AnnounceType::Announce,
40 id: generate_activity_id(
41 &AnnounceType::Announce,
42 &context.settings().get_protocol_and_hostname(),
44 unparsed: Default::default(),
49 object: AnnouncableActivities,
50 community: &ApubCommunity,
51 additional_inboxes: Vec<Url>,
52 context: &LemmyContext,
53 ) -> Result<(), LemmyError> {
54 let announce = AnnounceActivity::new(object.clone(), community, context)?;
55 let inboxes = community
56 .get_follower_inboxes(additional_inboxes.clone(), context)
68 // Pleroma (and likely Mastodon) can't handle activities like Announce/Create/Page, so for
69 // compatibility, we also send Announce/Page and Announce/Note (for new and updated
71 use AnnouncableActivities::*;
72 let object = match object {
73 CreateOrUpdatePost(c) => Page(c.object),
74 CreateOrUpdateComment(c) => Note(c.object),
77 let announce_compat = AnnounceActivity::new(object, community, context)?;
91 #[async_trait::async_trait(?Send)]
92 impl ActivityHandler for AnnounceActivity {
93 type DataType = LemmyContext;
96 context: &Data<LemmyContext>,
97 request_counter: &mut i32,
98 ) -> Result<(), LemmyError> {
99 verify_is_public(&self.to, &self.cc)?;
100 verify_activity(&self.id, self.actor.inner(), &context.settings())?;
101 self.object.verify(context, request_counter).await?;
107 context: &Data<LemmyContext>,
108 request_counter: &mut i32,
109 ) -> Result<(), LemmyError> {
110 // TODO: this is pretty ugly, but i cant think of a much better way
111 let object = serde_json::to_string(&self.object)?;
112 let object_data: ActivityCommonFields = serde_json::from_str(&object)?;
114 if is_activity_already_known(context.pool(), &object_data.id).await? {
117 insert_activity(&object_data.id, &self.object, false, true, context.pool()).await?;
118 self.object.receive(context, request_counter).await