Add callback_url/acct information for Sidekiq PuSH workers Exception. (#4281)
* Add destination informations to exception on SubscribeWorker and DeliveryWorker. * Simplify delivery error message. * Prevent changing Exception type... * fix typo.pull/111/head
parent
f5e228ad2e
commit
994d948c39
|
@ -8,11 +8,11 @@ module Mastodon
|
||||||
|
|
||||||
class UnexpectedResponseError < Error
|
class UnexpectedResponseError < Error
|
||||||
def initialize(response = nil)
|
def initialize(response = nil)
|
||||||
@response = response
|
if response.respond_to? :uri
|
||||||
|
super("#{response.uri} returned code #{response.code}")
|
||||||
|
else
|
||||||
|
super
|
||||||
end
|
end
|
||||||
|
|
||||||
def to_s
|
|
||||||
"#{@response.uri} returned code #{@response.code}"
|
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
|
@ -16,6 +16,8 @@ class Pubsubhubbub::DeliveryWorker
|
||||||
@subscription = Subscription.find(subscription_id)
|
@subscription = Subscription.find(subscription_id)
|
||||||
@payload = payload
|
@payload = payload
|
||||||
process_delivery unless blocked_domain?
|
process_delivery unless blocked_domain?
|
||||||
|
rescue => e
|
||||||
|
raise e.class, "Delivery failed for #{subscription&.callback_url}: #{e.message}"
|
||||||
end
|
end
|
||||||
|
|
||||||
private
|
private
|
||||||
|
|
|
@ -22,5 +22,7 @@ class Pubsubhubbub::SubscribeWorker
|
||||||
account = Account.find(account_id)
|
account = Account.find(account_id)
|
||||||
logger.debug "PuSH re-subscribing to #{account.acct}"
|
logger.debug "PuSH re-subscribing to #{account.acct}"
|
||||||
::SubscribeService.new.call(account)
|
::SubscribeService.new.call(account)
|
||||||
|
rescue => e
|
||||||
|
raise e.class, "Subscribe failed for #{account&.acct}: #{e.message}"
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
Loading…
Reference in New Issue