2 activities::{generate_activity_id, send_lemmy_activity, verify_is_public, verify_person},
3 objects::person::ApubPerson,
4 protocol::activities::deletion::delete_user::DeleteUser,
6 use activitystreams_kinds::{activity::DeleteType, public};
7 use lemmy_api_common::utils::{blocking, delete_user_account};
11 traits::ActivityHandler,
12 verify::verify_urls_match,
14 use lemmy_db_schema::source::site::Site;
15 use lemmy_utils::LemmyError;
16 use lemmy_websocket::LemmyContext;
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;
26 context: &Data<LemmyContext>,
27 request_counter: &mut i32,
28 ) -> Result<(), LemmyError> {
29 verify_is_public(&self.to, &[])?;
30 verify_person(&self.actor, context, request_counter).await?;
31 verify_urls_match(self.actor.inner(), self.object.inner())?;
37 context: &Data<LemmyContext>,
38 request_counter: &mut i32,
39 ) -> Result<(), LemmyError> {
42 .dereference(context, context.client(), request_counter)
44 delete_user_account(actor.id, context.pool()).await?;
50 #[tracing::instrument(skip_all)]
51 pub async fn send(actor: &ApubPerson, context: &LemmyContext) -> Result<(), LemmyError> {
52 let actor_id = ObjectId::new(actor.actor_id.clone());
53 let id = generate_activity_id(
55 &context.settings().get_protocol_and_hostname(),
57 let delete = DeleteUser {
58 actor: actor_id.clone(),
61 kind: DeleteType::Delete,
66 let remote_sites = blocking(context.pool(), Site::read_remote_sites).await??;
67 let inboxes = remote_sites
69 .map(|s| s.inbox_url.into())
71 send_lemmy_activity(context, &delete, &id, actor, inboxes, true).await?;