You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
99 lines
3.6 KiB
99 lines
3.6 KiB
# frozen_string_literal: true |
|
|
|
class ReportService < BaseService |
|
include Payloadable |
|
|
|
def call(source_account, target_account, options = {}) |
|
@source_account = source_account |
|
@target_account = target_account |
|
@status_ids = options.delete(:status_ids).presence || [] |
|
@comment = options.delete(:comment).presence || '' |
|
@category = options[:rule_ids].present? ? 'violation' : (options.delete(:category).presence || 'other') |
|
@rule_ids = options.delete(:rule_ids).presence |
|
@options = options |
|
|
|
raise ActiveRecord::RecordNotFound if @target_account.unavailable? |
|
|
|
create_report! |
|
notify_staff! |
|
|
|
if forward? |
|
forward_to_origin! |
|
forward_to_replied_to! |
|
end |
|
|
|
@report |
|
end |
|
|
|
private |
|
|
|
def create_report! |
|
@report = @source_account.reports.create!( |
|
target_account: @target_account, |
|
status_ids: reported_status_ids, |
|
comment: @comment, |
|
uri: @options[:uri], |
|
forwarded: forward_to_origin?, |
|
category: @category, |
|
rule_ids: @rule_ids |
|
) |
|
end |
|
|
|
def notify_staff! |
|
return if @report.unresolved_siblings? |
|
|
|
User.those_who_can(:manage_reports).includes(:account).find_each do |u| |
|
LocalNotificationWorker.perform_async(u.account_id, @report.id, 'Report', 'admin.report') |
|
AdminMailer.with(recipient: u.account).new_report(@report).deliver_later if u.allows_report_emails? |
|
end |
|
end |
|
|
|
def forward_to_origin! |
|
return unless forward_to_origin? |
|
|
|
# Send report to the server where the account originates from |
|
ActivityPub::DeliveryWorker.perform_async(payload, some_local_account.id, @target_account.inbox_url) |
|
end |
|
|
|
def forward_to_replied_to! |
|
# Send report to servers to which the account was replying to, so they also have a chance to act |
|
inbox_urls = Account.remote.where(domain: forward_to_domains).where(id: Status.where(id: reported_status_ids).where.not(in_reply_to_account_id: nil).select(:in_reply_to_account_id)).inboxes - [@target_account.inbox_url, @target_account.shared_inbox_url] |
|
|
|
inbox_urls.each do |inbox_url| |
|
ActivityPub::DeliveryWorker.perform_async(payload, some_local_account.id, inbox_url) |
|
end |
|
end |
|
|
|
def forward? |
|
!@target_account.local? && ActiveModel::Type::Boolean.new.cast(@options[:forward]) |
|
end |
|
|
|
def forward_to_origin? |
|
forward? && forward_to_domains.include?(@target_account.domain) |
|
end |
|
|
|
def forward_to_domains |
|
@forward_to_domains ||= (@options[:forward_to_domains] || [@target_account.domain]).filter_map { |domain| TagManager.instance.normalize_domain(domain&.strip) }.uniq |
|
end |
|
|
|
def reported_status_ids |
|
return AccountStatusesFilter.new(@target_account, @source_account).results.with_discarded.find(Array(@status_ids)).pluck(:id) if @source_account.local? |
|
|
|
# If the account making reports is remote, it is likely anonymized so we have to relax the requirements for attaching statuses. |
|
domain = @source_account.domain.to_s.downcase |
|
has_followers = @target_account.followers.with_domain(domain).exists? |
|
visibility = has_followers ? %i(public unlisted private) : %i(public unlisted) |
|
scope = @target_account.statuses.with_discarded |
|
scope.merge!(scope.where(visibility: visibility).or(scope.where('EXISTS (SELECT 1 FROM mentions m JOIN accounts a ON m.account_id = a.id WHERE lower(a.domain) = ?)', domain))) |
|
# Allow missing posts to not drop reports that include e.g. a deleted post |
|
scope.where(id: Array(@status_ids)).pluck(:id) |
|
end |
|
|
|
def payload |
|
Oj.dump(serialize_payload(@report, ActivityPub::FlagSerializer, account: some_local_account)) |
|
end |
|
|
|
def some_local_account |
|
@some_local_account ||= Account.representative |
|
end |
|
end
|
|
|