6cf57c6765
* Refactor how Redis locks are created * Fix autorelease duration on account deletion lock
52 lines
1.6 KiB
Ruby
52 lines
1.6 KiB
Ruby
# 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 invalid_origin?(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
|