2 activities::{generate_activity_id, send_lemmy_activity, verify_is_public, verify_person},
4 objects::{instance::remote_instance_inboxes, person::ApubPerson},
5 protocol::activities::deletion::delete_user::DeleteUser,
7 use activitypub_federation::{
8 core::object_id::ObjectId,
10 traits::ActivityHandler,
11 utils::verify_urls_match,
13 use activitystreams_kinds::{activity::DeleteType, public};
14 use lemmy_api_common::{utils::delete_user_account, LemmyContext};
15 use lemmy_utils::error::LemmyError;
18 /// This can be separate from Delete activity because it doesn't need to be handled in shared inbox
19 /// (cause instance actor doesn't have shared inbox).
20 #[async_trait::async_trait(?Send)]
21 impl ActivityHandler for DeleteUser {
22 type DataType = LemmyContext;
23 type Error = LemmyError;
25 fn id(&self) -> &Url {
29 fn actor(&self) -> &Url {
35 context: &Data<LemmyContext>,
36 request_counter: &mut i32,
37 ) -> Result<(), LemmyError> {
38 verify_is_public(&self.to, &[])?;
39 verify_person(&self.actor, context, request_counter).await?;
40 verify_urls_match(self.actor.inner(), self.object.inner())?;
46 context: &Data<LemmyContext>,
47 request_counter: &mut i32,
48 ) -> Result<(), LemmyError> {
51 .dereference(context, local_instance(context).await, request_counter)
65 #[tracing::instrument(skip_all)]
66 pub async fn send(actor: &ApubPerson, context: &LemmyContext) -> Result<(), LemmyError> {
67 let actor_id = ObjectId::new(actor.actor_id.clone());
68 let id = generate_activity_id(
70 &context.settings().get_protocol_and_hostname(),
72 let delete = DeleteUser {
73 actor: actor_id.clone(),
76 kind: DeleteType::Delete,
81 let inboxes = remote_instance_inboxes(context.pool()).await?;
82 send_lemmy_activity(context, delete, actor, inboxes, true).await?;