2 activities::{generate_activity_id, send_lemmy_activity, verify_is_public, verify_person},
3 insert_received_activity,
4 objects::{instance::remote_instance_inboxes, person::ApubPerson},
5 protocol::activities::deletion::delete_user::DeleteUser,
8 use activitypub_federation::{
10 kinds::{activity::DeleteType, public},
11 protocol::verification::verify_urls_match,
12 traits::{ActivityHandler, Actor},
14 use lemmy_api_common::{
15 context::LemmyContext,
16 person::{DeleteAccount, DeleteAccountResponse},
17 utils::{delete_user_account, local_user_view_from_jwt},
19 use lemmy_utils::error::LemmyError;
22 #[async_trait::async_trait]
23 impl SendActivity for DeleteAccount {
24 type Response = DeleteAccountResponse;
26 async fn send_activity(
28 _response: &Self::Response,
29 context: &Data<LemmyContext>,
30 ) -> Result<(), LemmyError> {
31 let local_user_view = local_user_view_from_jwt(&request.auth, context).await?;
32 let actor: ApubPerson = local_user_view.person.into();
41 let id = generate_activity_id(
43 &context.settings().get_protocol_and_hostname(),
45 let delete = DeleteUser {
46 actor: actor.id().into(),
48 object: actor.id().into(),
49 kind: DeleteType::Delete,
54 let inboxes = remote_instance_inboxes(&mut context.pool()).await?;
55 send_lemmy_activity(context, delete, &actor, inboxes, true).await?;
60 /// This can be separate from Delete activity because it doesn't need to be handled in shared inbox
61 /// (cause instance actor doesn't have shared inbox).
62 #[async_trait::async_trait]
63 impl ActivityHandler for DeleteUser {
64 type DataType = LemmyContext;
65 type Error = LemmyError;
67 fn id(&self) -> &Url {
71 fn actor(&self) -> &Url {
75 async fn verify(&self, context: &Data<Self::DataType>) -> Result<(), LemmyError> {
76 insert_received_activity(&self.id, context).await?;
77 verify_is_public(&self.to, &[])?;
78 verify_person(&self.actor, context).await?;
79 verify_urls_match(self.actor.inner(), self.object.inner())?;
83 async fn receive(self, context: &Data<Self::DataType>) -> Result<(), LemmyError> {
84 let actor = self.actor.dereference(context).await?;