44 lines
1.3 KiB
Ruby
44 lines
1.3 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class ActivityPub::Activity::Flag < ActivityPub::Activity
|
|
def perform
|
|
return if skip_reports?
|
|
|
|
target_accounts = object_uris.filter_map { |uri| account_from_uri(uri) }
|
|
target_statuses_by_account = object_uris.filter_map { |uri| status_from_uri(uri) }.group_by(&:account_id)
|
|
|
|
target_accounts.each do |target_account|
|
|
target_statuses = target_statuses_by_account[target_account.id]
|
|
replied_to_accounts = target_statuses.nil? ? [] : Account.local.where(id: target_statuses.filter_map(&:in_reply_to_account_id))
|
|
|
|
next if target_account.suspended? || (!target_account.local? && replied_to_accounts.none?)
|
|
|
|
ReportService.new.call(
|
|
@account,
|
|
target_account,
|
|
status_ids: target_statuses.nil? ? [] : target_statuses.map(&:id),
|
|
comment: report_comment,
|
|
uri: report_uri
|
|
)
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
def skip_reports?
|
|
DomainBlock.reject_reports?(@account.domain)
|
|
end
|
|
|
|
def object_uris
|
|
@object_uris ||= Array(@object.is_a?(Array) ? @object.map { |item| value_or_id(item) } : value_or_id(@object))
|
|
end
|
|
|
|
def report_uri
|
|
@json['id'] unless @json['id'].nil? || non_matching_uri_hosts?(@account.uri, @json['id'])
|
|
end
|
|
|
|
def report_comment
|
|
(@json['content'] || '')[0...5000]
|
|
end
|
|
end
|