36 lines
1.1 KiB
Ruby
36 lines
1.1 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
class SubscribeService < BaseService
|
|
def call(account)
|
|
account.secret = SecureRandom.hex
|
|
|
|
subscription = account.subscription(api_subscription_url(account.id))
|
|
response = subscription.subscribe
|
|
|
|
if response_failed_permanently?(response)
|
|
# We're not allowed to subscribe. Fail and move on.
|
|
account.secret = ''
|
|
account.save!
|
|
elsif response_successful?(response)
|
|
# The subscription will be confirmed asynchronously.
|
|
account.save!
|
|
else
|
|
# The response was either a 429 rate limit, or a 5xx error.
|
|
# We need to retry at a later time. Fail loudly!
|
|
raise "Subscription attempt failed for #{account.acct} (#{account.hub_url}): HTTP #{response.code}"
|
|
end
|
|
end
|
|
|
|
private
|
|
|
|
# Any response in the 3xx or 4xx range, except for 429 (rate limit)
|
|
def response_failed_permanently?(response)
|
|
(response.status.redirect? || response.status.client_error?) && !response.status.too_many_requests?
|
|
end
|
|
|
|
# Any response in the 2xx range
|
|
def response_successful?(response)
|
|
response.status.success?
|
|
end
|
|
end
|