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;
18 #[async_trait::async_trait(?Send)]
19 pub(crate) trait GetCommunity {
20 async fn get_community(
22 context: &LemmyContext,
23 request_counter: &mut i32,
24 ) -> Result<ApubCommunity, LemmyError>;
27 impl AnnounceActivity {
29 object: AnnouncableActivities,
30 community: &ApubCommunity,
31 context: &LemmyContext,
32 ) -> Result<AnnounceActivity, LemmyError> {
34 actor: ObjectId::new(community.actor_id()),
37 cc: vec![community.followers_url.clone().into()],
38 kind: AnnounceType::Announce,
39 id: generate_activity_id(
40 &AnnounceType::Announce,
41 &context.settings().get_protocol_and_hostname(),
43 unparsed: Default::default(),
48 object: AnnouncableActivities,
49 community: &ApubCommunity,
50 context: &LemmyContext,
51 ) -> Result<(), LemmyError> {
52 let announce = AnnounceActivity::new(object.clone(), community, context)?;
53 let inboxes = community.get_follower_inboxes(context).await?;
64 // Pleroma (and likely Mastodon) can't handle activities like Announce/Create/Page. So for
65 // compatibility to allow them to follow Lemmy communities, we also send Announce/Page and
66 // Announce/Note (for new and updated posts/comments).
67 use AnnouncableActivities::*;
68 let object = match object {
69 CreateOrUpdatePost(c) => Page(c.object),
70 CreateOrUpdateComment(c) => Note(c.object),
73 let announce_compat = AnnounceActivity::new(object, community, context)?;
87 #[async_trait::async_trait(?Send)]
88 impl ActivityHandler for AnnounceActivity {
89 type DataType = LemmyContext;
92 context: &Data<LemmyContext>,
93 request_counter: &mut i32,
94 ) -> Result<(), LemmyError> {
95 verify_is_public(&self.to, &self.cc)?;
96 verify_activity(&self.id, self.actor.inner(), &context.settings())?;
97 self.object.verify(context, request_counter).await?;
103 context: &Data<LemmyContext>,
104 request_counter: &mut i32,
105 ) -> Result<(), LemmyError> {
106 // TODO: this can probably be implemented in a cleaner way
108 // Dont insert these into activities table, as they are not activities.
109 AnnouncableActivities::Page(_) | AnnouncableActivities::Note(_) => {}
111 let object_value = serde_json::to_value(&self.object)?;
112 let object_data: ActivityCommonFields = serde_json::from_value(object_value.to_owned())?;
114 if is_activity_already_known(context.pool(), &object_data.id).await? {
117 insert_activity(&object_data.id, object_value, false, true, context.pool()).await?;
120 self.object.receive(context, request_counter).await