2021-03-25 19:19:40 +00:00
|
|
|
use crate::PerformCrud;
|
|
|
|
use actix_web::web::Data;
|
|
|
|
use lemmy_api_common::{
|
|
|
|
blocking,
|
|
|
|
check_community_ban,
|
|
|
|
get_local_user_view_from_jwt,
|
|
|
|
is_mod_or_admin,
|
|
|
|
post::*,
|
|
|
|
};
|
2021-08-17 18:04:58 +00:00
|
|
|
use lemmy_apub::activities::deletion::{send_apub_delete, send_apub_remove};
|
|
|
|
use lemmy_db_queries::{source::post::Post_, Crud};
|
|
|
|
use lemmy_db_schema::source::{community::Community, moderator::*, post::*};
|
2021-03-25 19:19:40 +00:00
|
|
|
use lemmy_utils::{ApiError, ConnectionId, LemmyError};
|
2021-08-17 18:04:58 +00:00
|
|
|
use lemmy_websocket::{send::send_post_ws_message, LemmyContext, UserOperationCrud};
|
2021-03-25 19:19:40 +00:00
|
|
|
|
|
|
|
#[async_trait::async_trait(?Send)]
|
|
|
|
impl PerformCrud for DeletePost {
|
|
|
|
type Response = PostResponse;
|
|
|
|
|
|
|
|
async fn perform(
|
|
|
|
&self,
|
|
|
|
context: &Data<LemmyContext>,
|
|
|
|
websocket_id: Option<ConnectionId>,
|
|
|
|
) -> Result<PostResponse, LemmyError> {
|
2021-07-05 16:07:26 +00:00
|
|
|
let data: &DeletePost = self;
|
2021-09-22 15:57:09 +00:00
|
|
|
let local_user_view =
|
|
|
|
get_local_user_view_from_jwt(&data.auth, context.pool(), context.secret()).await?;
|
2021-03-25 19:19:40 +00:00
|
|
|
|
|
|
|
let post_id = data.post_id;
|
|
|
|
let orig_post = blocking(context.pool(), move |conn| Post::read(conn, post_id)).await??;
|
|
|
|
|
|
|
|
check_community_ban(
|
|
|
|
local_user_view.person.id,
|
|
|
|
orig_post.community_id,
|
|
|
|
context.pool(),
|
|
|
|
)
|
|
|
|
.await?;
|
|
|
|
|
|
|
|
// Verify that only the creator can delete
|
|
|
|
if !Post::is_post_creator(local_user_view.person.id, orig_post.creator_id) {
|
2021-10-13 19:50:21 +00:00
|
|
|
return Err(ApiError::err_plain("no_post_edit_allowed").into());
|
2021-03-25 19:19:40 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
// Update the post
|
|
|
|
let post_id = data.post_id;
|
|
|
|
let deleted = data.deleted;
|
|
|
|
let updated_post = blocking(context.pool(), move |conn| {
|
|
|
|
Post::update_deleted(conn, post_id, deleted)
|
|
|
|
})
|
|
|
|
.await??;
|
|
|
|
|
|
|
|
// apub updates
|
2021-08-17 18:04:58 +00:00
|
|
|
let community = blocking(context.pool(), move |conn| {
|
|
|
|
Community::read(conn, orig_post.community_id)
|
2021-03-25 19:19:40 +00:00
|
|
|
})
|
|
|
|
.await??;
|
2021-08-17 18:04:58 +00:00
|
|
|
send_apub_delete(
|
|
|
|
&local_user_view.person,
|
|
|
|
&community,
|
|
|
|
updated_post.ap_id.into(),
|
|
|
|
deleted,
|
|
|
|
context,
|
|
|
|
)
|
|
|
|
.await?;
|
2021-03-25 19:19:40 +00:00
|
|
|
|
2021-08-17 18:04:58 +00:00
|
|
|
send_post_ws_message(
|
|
|
|
data.post_id,
|
|
|
|
UserOperationCrud::DeletePost,
|
2021-03-25 19:19:40 +00:00
|
|
|
websocket_id,
|
2021-08-17 18:04:58 +00:00
|
|
|
Some(local_user_view.person.id),
|
|
|
|
context,
|
|
|
|
)
|
|
|
|
.await
|
2021-03-25 19:19:40 +00:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
#[async_trait::async_trait(?Send)]
|
|
|
|
impl PerformCrud for RemovePost {
|
|
|
|
type Response = PostResponse;
|
|
|
|
|
|
|
|
async fn perform(
|
|
|
|
&self,
|
|
|
|
context: &Data<LemmyContext>,
|
|
|
|
websocket_id: Option<ConnectionId>,
|
|
|
|
) -> Result<PostResponse, LemmyError> {
|
2021-07-05 16:07:26 +00:00
|
|
|
let data: &RemovePost = self;
|
2021-09-22 15:57:09 +00:00
|
|
|
let local_user_view =
|
|
|
|
get_local_user_view_from_jwt(&data.auth, context.pool(), context.secret()).await?;
|
2021-03-25 19:19:40 +00:00
|
|
|
|
|
|
|
let post_id = data.post_id;
|
|
|
|
let orig_post = blocking(context.pool(), move |conn| Post::read(conn, post_id)).await??;
|
|
|
|
|
|
|
|
check_community_ban(
|
|
|
|
local_user_view.person.id,
|
|
|
|
orig_post.community_id,
|
|
|
|
context.pool(),
|
|
|
|
)
|
|
|
|
.await?;
|
|
|
|
|
|
|
|
// Verify that only the mods can remove
|
|
|
|
is_mod_or_admin(
|
|
|
|
context.pool(),
|
|
|
|
local_user_view.person.id,
|
|
|
|
orig_post.community_id,
|
|
|
|
)
|
|
|
|
.await?;
|
|
|
|
|
|
|
|
// Update the post
|
|
|
|
let post_id = data.post_id;
|
|
|
|
let removed = data.removed;
|
|
|
|
let updated_post = blocking(context.pool(), move |conn| {
|
|
|
|
Post::update_removed(conn, post_id, removed)
|
|
|
|
})
|
|
|
|
.await??;
|
|
|
|
|
|
|
|
// Mod tables
|
|
|
|
let form = ModRemovePostForm {
|
|
|
|
mod_person_id: local_user_view.person.id,
|
|
|
|
post_id: data.post_id,
|
|
|
|
removed: Some(removed),
|
|
|
|
reason: data.reason.to_owned(),
|
|
|
|
};
|
|
|
|
blocking(context.pool(), move |conn| {
|
|
|
|
ModRemovePost::create(conn, &form)
|
|
|
|
})
|
|
|
|
.await??;
|
|
|
|
|
|
|
|
// apub updates
|
2021-08-17 18:04:58 +00:00
|
|
|
let community = blocking(context.pool(), move |conn| {
|
|
|
|
Community::read(conn, orig_post.community_id)
|
2021-03-25 19:19:40 +00:00
|
|
|
})
|
|
|
|
.await??;
|
2021-08-17 18:04:58 +00:00
|
|
|
send_apub_remove(
|
|
|
|
&local_user_view.person,
|
|
|
|
&community,
|
|
|
|
updated_post.ap_id.into(),
|
|
|
|
data.reason.clone().unwrap_or_else(|| "".to_string()),
|
|
|
|
removed,
|
|
|
|
context,
|
|
|
|
)
|
|
|
|
.await?;
|
2021-03-25 19:19:40 +00:00
|
|
|
|
2021-08-17 18:04:58 +00:00
|
|
|
send_post_ws_message(
|
|
|
|
data.post_id,
|
|
|
|
UserOperationCrud::RemovePost,
|
2021-03-25 19:19:40 +00:00
|
|
|
websocket_id,
|
2021-08-17 18:04:58 +00:00
|
|
|
Some(local_user_view.person.id),
|
|
|
|
context,
|
|
|
|
)
|
|
|
|
.await
|
2021-03-25 19:19:40 +00:00
|
|
|
}
|
|
|
|
}
|