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.
52 lines
1.6 KiB
52 lines
1.6 KiB
# frozen_string_literal: true |
|
|
|
class ActivityPub::Activity::Delete < ActivityPub::Activity |
|
def perform |
|
if @account.uri == object_uri |
|
delete_person |
|
else |
|
delete_note |
|
end |
|
end |
|
|
|
private |
|
|
|
def delete_person |
|
with_lock("delete_in_progress:#{@account.id}", autorelease: 2.hours, raise_on_failure: false) do |
|
DeleteAccountService.new.call(@account, reserve_username: false, skip_activitypub: true) |
|
end |
|
end |
|
|
|
def delete_note |
|
return if object_uri.nil? |
|
|
|
with_lock("delete_status_in_progress:#{object_uri}", raise_on_failure: false) do |
|
unless non_matching_uri_hosts?(@account.uri, object_uri) |
|
# This lock ensures a concurrent `ActivityPub::Activity::Create` either |
|
# does not create a status at all, or has finished saving it to the |
|
# database before we try to load it. |
|
# Without the lock, `delete_later!` could be called after `delete_arrived_first?` |
|
# and `Status.find` before `Status.create!` |
|
with_lock("create:#{object_uri}") { delete_later!(object_uri) } |
|
|
|
Tombstone.find_or_create_by(uri: object_uri, account: @account) |
|
end |
|
|
|
@status = Status.find_by(uri: object_uri, account: @account) |
|
@status ||= Status.find_by(uri: @object['atomUri'], account: @account) if @object.is_a?(Hash) && @object['atomUri'].present? |
|
|
|
return if @status.nil? |
|
|
|
forwarder.forward! if forwarder.forwardable? |
|
delete_now! |
|
end |
|
end |
|
|
|
def forwarder |
|
@forwarder ||= ActivityPub::Forwarder.new(@account, @json, @status) |
|
end |
|
|
|
def delete_now! |
|
RemoveStatusService.new.call(@status, redraft: false) |
|
end |
|
end
|
|
|