3 following::follow::FollowCommunity,
8 context::lemmy_context,
9 fetcher::object_id::ObjectId,
10 objects::{community::ApubCommunity, person::ApubPerson},
13 use activitystreams::{
14 activity::kind::AcceptType,
16 primitives::OneOrMany,
19 use lemmy_api_common::blocking;
22 traits::{ActivityFields, ActivityHandler, ActorType},
23 verify::verify_urls_match,
25 use lemmy_db_schema::{source::community::CommunityFollower, traits::Followable};
26 use lemmy_utils::LemmyError;
27 use lemmy_websocket::LemmyContext;
28 use serde::{Deserialize, Serialize};
31 #[derive(Clone, Debug, Deserialize, Serialize, ActivityFields)]
32 #[serde(rename_all = "camelCase")]
33 pub struct AcceptFollowCommunity {
34 actor: ObjectId<ApubCommunity>,
35 to: ObjectId<ApubPerson>,
36 object: FollowCommunity,
37 #[serde(rename = "type")]
40 #[serde(rename = "@context")]
41 context: OneOrMany<AnyBase>,
46 impl AcceptFollowCommunity {
48 follow: FollowCommunity,
49 context: &LemmyContext,
50 request_counter: &mut i32,
51 ) -> Result<(), LemmyError> {
52 let community = follow.object.dereference_local(context).await?;
56 .dereference(context, request_counter)
58 let accept = AcceptFollowCommunity {
59 actor: ObjectId::new(community.actor_id()),
60 to: ObjectId::new(person.actor_id()),
62 kind: AcceptType::Accept,
63 id: generate_activity_id(
65 &context.settings().get_protocol_and_hostname(),
67 context: lemmy_context(),
68 unparsed: Default::default(),
70 let inbox = vec![person.inbox_url()];
71 send_lemmy_activity(context, &accept, &accept.id, &community, inbox, true).await
75 /// Handle accepted follows
76 #[async_trait::async_trait(?Send)]
77 impl ActivityHandler for AcceptFollowCommunity {
78 type DataType = LemmyContext;
81 context: &Data<LemmyContext>,
82 request_counter: &mut i32,
83 ) -> Result<(), LemmyError> {
84 verify_activity(self, &context.settings())?;
85 verify_urls_match(self.to.inner(), self.object.actor())?;
86 verify_urls_match(self.actor(), self.object.to.inner())?;
87 verify_community(&self.actor, context, request_counter).await?;
88 self.object.verify(context, request_counter).await?;
94 context: &Data<LemmyContext>,
95 request_counter: &mut i32,
96 ) -> Result<(), LemmyError> {
97 let actor = self.actor.dereference(context, request_counter).await?;
98 let to = self.to.dereference(context, request_counter).await?;
99 // This will throw an error if no follow was requested
100 blocking(context.pool(), move |conn| {
101 CommunityFollower::follow_accepted(conn, actor.id, to.id)