deletion::{receive_delete_action, verify_delete_activity, DeletableObjects},
generate_activity_id,
},
- insert_activity,
+ insert_received_activity,
objects::person::ApubPerson,
protocol::activities::deletion::{delete::Delete, undo_delete::UndoDelete},
};
use activitypub_federation::{config::Data, kinds::activity::UndoType, traits::ActivityHandler};
-use lemmy_api_common::{context::LemmyContext, websocket::UserOperationCrud};
+use lemmy_api_common::context::LemmyContext;
use lemmy_db_schema::{
source::{
comment::{Comment, CommentUpdateForm},
},
traits::Crud,
};
-use lemmy_utils::error::LemmyError;
+use lemmy_utils::error::{LemmyError, LemmyErrorType};
use url::Url;
#[async_trait::async_trait]
}
async fn verify(&self, data: &Data<Self::DataType>) -> Result<(), Self::Error> {
+ insert_received_activity(&self.id, data).await?;
self.object.verify(data).await?;
verify_delete_activity(&self.object, self.object.summary.is_some(), data).await?;
Ok(())
#[tracing::instrument(skip_all)]
async fn receive(self, context: &Data<LemmyContext>) -> Result<(), LemmyError> {
- insert_activity(&self.id, &self, false, false, context).await?;
if self.object.summary.is_some() {
UndoDelete::receive_undo_remove_action(
&self.actor.dereference(context).await?,
object: &Url,
context: &Data<LemmyContext>,
) -> Result<(), LemmyError> {
- use UserOperationCrud::*;
match DeletableObjects::read_from_db(object, context).await? {
DeletableObjects::Community(community) => {
if community.local {
- return Err(LemmyError::from_message(
- "Only local admin can restore community",
- ));
+ return Err(LemmyErrorType::OnlyLocalAdminCanRestoreCommunity)?;
}
let form = ModRemoveCommunityForm {
mod_person_id: actor.id,
reason: None,
expires: None,
};
- ModRemoveCommunity::create(context.pool(), &form).await?;
- let deleted_community = Community::update(
- context.pool(),
+ ModRemoveCommunity::create(&mut context.pool(), &form).await?;
+ Community::update(
+ &mut context.pool(),
community.id,
&CommunityUpdateForm::builder().removed(Some(false)).build(),
)
.await?;
- context
- .send_community_ws_message(&EditCommunity, deleted_community.id, None, None)
- .await?;
}
DeletableObjects::Post(post) => {
let form = ModRemovePostForm {
removed: Some(false),
reason: None,
};
- ModRemovePost::create(context.pool(), &form).await?;
- let removed_post = Post::update(
- context.pool(),
+ ModRemovePost::create(&mut context.pool(), &form).await?;
+ Post::update(
+ &mut context.pool(),
post.id,
&PostUpdateForm::builder().removed(Some(false)).build(),
)
.await?;
- context
- .send_post_ws_message(&EditPost, removed_post.id, None, None)
- .await?;
}
DeletableObjects::Comment(comment) => {
let form = ModRemoveCommentForm {
removed: Some(false),
reason: None,
};
- ModRemoveComment::create(context.pool(), &form).await?;
- let removed_comment = Comment::update(
- context.pool(),
+ ModRemoveComment::create(&mut context.pool(), &form).await?;
+ Comment::update(
+ &mut context.pool(),
comment.id,
&CommentUpdateForm::builder().removed(Some(false)).build(),
)
.await?;
- context
- .send_comment_ws_message_simple(&EditComment, removed_comment.id)
- .await?;
}
DeletableObjects::PrivateMessage(_) => unimplemented!(),
}