use crate::{ activities::{ generate_activity_id, send_lemmy_activity, verify_activity, verify_person_in_community, }, objects::{community::ApubCommunity, person::ApubPerson}, protocol::activities::community::report::Report, PostOrComment, }; use activitystreams_kinds::activity::FlagType; use lemmy_api_common::{blocking, comment::CommentReportResponse, post::PostReportResponse}; use lemmy_apub_lib::{ data::Data, object_id::ObjectId, traits::{ActivityHandler, ActorType}, }; use lemmy_db_schema::{ source::{ comment_report::{CommentReport, CommentReportForm}, post_report::{PostReport, PostReportForm}, }, traits::Reportable, }; use lemmy_db_views::{comment_report_view::CommentReportView, post_report_view::PostReportView}; use lemmy_utils::LemmyError; use lemmy_websocket::{messages::SendModRoomMessage, LemmyContext, UserOperation}; impl Report { #[tracing::instrument(skip_all)] pub async fn send( object_id: ObjectId, actor: &ApubPerson, community_id: ObjectId, reason: String, context: &LemmyContext, ) -> Result<(), LemmyError> { let community = community_id.dereference_local(context).await?; let kind = FlagType::Flag; let id = generate_activity_id( kind.clone(), &context.settings().get_protocol_and_hostname(), )?; let report = Report { actor: ObjectId::new(actor.actor_id()), to: [ObjectId::new(community.actor_id())], object: object_id, summary: reason, kind, id: id.clone(), unparsed: Default::default(), }; send_lemmy_activity( context, &report, &id, actor, vec![community.shared_inbox_or_inbox_url()], false, ) .await } } #[async_trait::async_trait(?Send)] impl ActivityHandler for Report { type DataType = LemmyContext; #[tracing::instrument(skip_all)] async fn verify( &self, context: &Data, request_counter: &mut i32, ) -> Result<(), LemmyError> { verify_activity(&self.id, self.actor.inner(), &context.settings())?; let community = self.to[0].dereference(context, request_counter).await?; verify_person_in_community(&self.actor, &community, context, request_counter).await?; Ok(()) } #[tracing::instrument(skip_all)] async fn receive( self, context: &Data, request_counter: &mut i32, ) -> Result<(), LemmyError> { let actor = self.actor.dereference(context, request_counter).await?; match self.object.dereference(context, request_counter).await? { PostOrComment::Post(post) => { let report_form = PostReportForm { creator_id: actor.id, post_id: post.id, original_post_name: post.name.clone(), original_post_url: post.url.clone(), reason: self.summary, original_post_body: post.body.clone(), }; let report = blocking(context.pool(), move |conn| { PostReport::report(conn, &report_form) }) .await??; let post_report_view = blocking(context.pool(), move |conn| { PostReportView::read(conn, report.id, actor.id) }) .await??; context.chat_server().do_send(SendModRoomMessage { op: UserOperation::CreateCommentReport, response: PostReportResponse { post_report_view }, community_id: post.community_id, websocket_id: None, }); } PostOrComment::Comment(comment) => { let report_form = CommentReportForm { creator_id: actor.id, comment_id: comment.id, original_comment_text: comment.content.clone(), reason: self.summary, }; let report = blocking(context.pool(), move |conn| { CommentReport::report(conn, &report_form) }) .await??; let comment_report_view = blocking(context.pool(), move |conn| { CommentReportView::read(conn, report.id, actor.id) }) .await??; let community_id = comment_report_view.community.id; context.chat_server().do_send(SendModRoomMessage { op: UserOperation::CreateCommentReport, response: CommentReportResponse { comment_report_view, }, community_id, websocket_id: None, }); } }; Ok(()) } }