3 deletion::{receive_delete_action, verify_delete_activity, DeletableObjects},
7 objects::person::ApubPerson,
8 protocol::activities::deletion::{delete::Delete, undo_delete::UndoDelete},
10 use activitypub_federation::{config::Data, kinds::activity::UndoType, traits::ActivityHandler};
11 use lemmy_api_common::{
12 context::LemmyContext,
14 send::{send_comment_ws_message_simple, send_community_ws_message, send_post_ws_message},
18 use lemmy_db_schema::{
20 comment::{Comment, CommentUpdateForm},
21 community::{Community, CommunityUpdateForm},
26 ModRemoveCommunityForm,
30 post::{Post, PostUpdateForm},
34 use lemmy_utils::error::LemmyError;
37 #[async_trait::async_trait]
38 impl ActivityHandler for UndoDelete {
39 type DataType = LemmyContext;
40 type Error = LemmyError;
42 fn id(&self) -> &Url {
46 fn actor(&self) -> &Url {
50 async fn verify(&self, data: &Data<Self::DataType>) -> Result<(), Self::Error> {
51 self.object.verify(data).await?;
52 verify_delete_activity(&self.object, self.object.summary.is_some(), data).await?;
56 #[tracing::instrument(skip_all)]
57 async fn receive(self, context: &Data<LemmyContext>) -> Result<(), LemmyError> {
58 insert_activity(&self.id, &self, false, false, context).await?;
59 if self.object.summary.is_some() {
60 UndoDelete::receive_undo_remove_action(
61 &self.actor.dereference(context).await?,
62 self.object.object.id(),
67 receive_delete_action(self.object.object.id(), &self.actor, false, context).await
73 #[tracing::instrument(skip_all)]
74 pub(in crate::activities::deletion) fn new(
76 object: DeletableObjects,
78 community: Option<&Community>,
79 summary: Option<String>,
80 context: &Data<LemmyContext>,
81 ) -> Result<UndoDelete, LemmyError> {
82 let object = Delete::new(actor, object, to.clone(), community, summary, context)?;
84 let id = generate_activity_id(
86 &context.settings().get_protocol_and_hostname(),
88 let cc: Option<Url> = community.map(|c| c.actor_id.clone().into());
90 actor: actor.actor_id.clone().into(),
93 cc: cc.into_iter().collect(),
96 audience: community.map(|c| c.actor_id.clone().into()),
100 #[tracing::instrument(skip_all)]
101 pub(in crate::activities) async fn receive_undo_remove_action(
104 context: &Data<LemmyContext>,
105 ) -> Result<(), LemmyError> {
106 use UserOperationCrud::*;
107 match DeletableObjects::read_from_db(object, context).await? {
108 DeletableObjects::Community(community) => {
110 return Err(LemmyError::from_message(
111 "Only local admin can restore community",
114 let form = ModRemoveCommunityForm {
115 mod_person_id: actor.id,
116 community_id: community.id,
117 removed: Some(false),
121 ModRemoveCommunity::create(context.pool(), &form).await?;
122 let deleted_community = Community::update(
125 &CommunityUpdateForm::builder().removed(Some(false)).build(),
128 send_community_ws_message(deleted_community.id, EditCommunity, None, None, context).await?;
130 DeletableObjects::Post(post) => {
131 let form = ModRemovePostForm {
132 mod_person_id: actor.id,
134 removed: Some(false),
137 ModRemovePost::create(context.pool(), &form).await?;
138 let removed_post = Post::update(
141 &PostUpdateForm::builder().removed(Some(false)).build(),
144 send_post_ws_message(removed_post.id, EditPost, None, None, context).await?;
146 DeletableObjects::Comment(comment) => {
147 let form = ModRemoveCommentForm {
148 mod_person_id: actor.id,
149 comment_id: comment.id,
150 removed: Some(false),
153 ModRemoveComment::create(context.pool(), &form).await?;
154 let removed_comment = Comment::update(
157 &CommentUpdateForm::builder().removed(Some(false)).build(),
160 send_comment_ws_message_simple(removed_comment.id, EditComment, context).await?;
162 DeletableObjects::PrivateMessage(_) => unimplemented!(),