2 use actix_web::web::Data;
3 use lemmy_api_common::{
5 post::{PostReportResponse, ResolvePostReport},
6 utils::{get_local_user_view_from_jwt, is_mod_or_admin},
7 websocket::{messages::SendModRoomMessage, UserOperation},
9 use lemmy_db_schema::{source::post_report::PostReport, traits::Reportable};
10 use lemmy_db_views::structs::PostReportView;
11 use lemmy_utils::{error::LemmyError, ConnectionId};
13 /// Resolves or unresolves a post report and notifies the moderators of the community
14 #[async_trait::async_trait(?Send)]
15 impl Perform for ResolvePostReport {
16 type Response = PostReportResponse;
18 #[tracing::instrument(skip(context, websocket_id))]
21 context: &Data<LemmyContext>,
22 websocket_id: Option<ConnectionId>,
23 ) -> Result<PostReportResponse, LemmyError> {
24 let data: &ResolvePostReport = self;
26 get_local_user_view_from_jwt(&data.auth, context.pool(), context.secret()).await?;
28 let report_id = data.report_id;
29 let person_id = local_user_view.person.id;
30 let report = PostReportView::read(context.pool(), report_id, person_id).await?;
32 let person_id = local_user_view.person.id;
33 is_mod_or_admin(context.pool(), person_id, report.community.id).await?;
36 PostReport::resolve(context.pool(), report_id, person_id)
38 .map_err(|e| LemmyError::from_error_message(e, "couldnt_resolve_report"))?;
40 PostReport::unresolve(context.pool(), report_id, person_id)
42 .map_err(|e| LemmyError::from_error_message(e, "couldnt_resolve_report"))?;
45 let post_report_view = PostReportView::read(context.pool(), report_id, person_id).await?;
47 let res = PostReportResponse { post_report_view };
49 context.chat_server().do_send(SendModRoomMessage {
50 op: UserOperation::ResolvePostReport,
51 response: res.clone(),
52 community_id: report.community.id,