mirror of
https://github.com/diaspora/diaspora.git
synced 2026-01-10 07:38:10 -05:00
16 lines
519 B
Ruby
16 lines
519 B
Ruby
# frozen_string_literal: true
|
|
|
|
module Workers
|
|
class SendPrivate < SendBase
|
|
def perform(sender_id, obj_str, targets, retry_count=0)
|
|
targets_to_retry = DiasporaFederation::Federation::Sender.private(sender_id, obj_str, targets)
|
|
|
|
return if targets_to_retry.empty?
|
|
|
|
schedule_retry(retry_count + 1, sender_id, obj_str, targets_to_retry.keys) do |delay, new_retry_count|
|
|
Workers::SendPrivate.perform_in(delay, sender_id, obj_str, targets_to_retry, new_retry_count)
|
|
end
|
|
end
|
|
end
|
|
end
|