Also send reports to user's home instance (fixes #4286) (#4305)

reduce-pool-size^2
Nutomic 5 months ago committed by GitHub
parent 35db0dc8e7
commit abe8b18ea8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -1,7 +1,7 @@
use crate::{ use crate::{
activities::{generate_activity_id, send_lemmy_activity, verify_person_in_community}, activities::{generate_activity_id, send_lemmy_activity, verify_person_in_community},
insert_received_activity, insert_received_activity,
objects::{community::ApubCommunity, person::ApubPerson}, objects::{community::ApubCommunity, instance::ApubSite, person::ApubPerson},
protocol::{activities::community::report::Report, InCommunity}, protocol::{activities::community::report::Report, InCommunity},
PostOrComment, PostOrComment,
}; };
@ -19,8 +19,9 @@ use lemmy_db_schema::{
community::Community, community::Community,
person::Person, person::Person,
post_report::{PostReport, PostReportForm}, post_report::{PostReport, PostReportForm},
site::Site,
}, },
traits::Reportable, traits::{Crud, Reportable},
}; };
use lemmy_utils::error::LemmyError; use lemmy_utils::error::LemmyError;
use url::Url; use url::Url;
@ -44,18 +45,31 @@ impl Report {
let report = Report { let report = Report {
actor: actor.id().into(), actor: actor.id().into(),
to: [community.id().into()], to: [community.id().into()],
object: object_id, object: object_id.clone(),
summary: reason, summary: reason,
kind, kind,
id: id.clone(), id: id.clone(),
audience: Some(community.id().into()), audience: Some(community.id().into()),
}; };
let inbox = if community.local {
ActivitySendTargets::empty() // send report to the community where object was posted
} else { let mut inboxes = ActivitySendTargets::to_inbox(community.shared_inbox_or_inbox());
ActivitySendTargets::to_inbox(community.shared_inbox_or_inbox())
// also send report to user's home instance if possible
let object_creator_id = match object_id.dereference_local(&context).await? {
PostOrComment::Post(p) => p.creator_id,
PostOrComment::Comment(c) => c.creator_id,
}; };
send_lemmy_activity(&context, report, &actor, inbox, false).await let object_creator = Person::read(&mut context.pool(), object_creator_id).await?;
let object_creator_site: Option<ApubSite> =
Site::read_from_instance_id(&mut context.pool(), object_creator.instance_id)
.await?
.map(Into::into);
if let Some(inbox) = object_creator_site.map(|s| s.shared_inbox_or_inbox()) {
inboxes.add_inbox(inbox);
}
send_lemmy_activity(&context, report, &actor, inboxes, false).await
} }
} }

Loading…
Cancel
Save