6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
|
# File 'app/jobs/rails_webhook_outbox/delivery_job.rb', line 6
def perform(delivery)
return skip_disabled_subscription(delivery) unless delivery.subscription.active?
if RailsWebhookOutbox.config.test_mode
delivery.update!(status: :delivered, attempts: delivery.attempts + 1, delivered_at: Time.current)
delivery.subscription.record_delivery_success!
notify("webhook.delivered.rails_webhook_outbox", delivery, 0)
return
end
start = Process.clock_gettime(Process::CLOCK_MONOTONIC)
response = Sender.call(delivery)
duration_ms = elapsed_ms(start)
delivery.update!(
status: :delivered,
response_code: response.code.to_i,
response_body: response.body.truncate(1000),
delivered_at: Time.current,
attempts: delivery.attempts + 1
)
delivery.subscription.record_delivery_success!
Rails.logger.info { "[RailsWebhookOutbox] delivered event=#{delivery.event} delivery_id=#{delivery.id} subscription_id=#{delivery.subscription_id} status=#{response.code} duration=#{duration_ms}ms" }
notify("webhook.delivered.rails_webhook_outbox", delivery, duration_ms)
rescue DeliveryError => e
duration_ms = elapsed_ms(start)
max_retries = RailsWebhookOutbox.config.max_retries
final = executions >= max_retries
delivery.update!(
response_code: e.response_code,
response_body: e.response_body&.truncate(1000),
attempts: delivery.attempts + 1,
status: final ? :failed : :pending,
next_retry_at: final ? nil : Time.current + ((executions**4) + 2).seconds
)
if final
Rails.logger.error { "[RailsWebhookOutbox] failed event=#{delivery.event} delivery_id=#{delivery.id} subscription_id=#{delivery.subscription_id} status=#{e.response_code} attempts=#{delivery.attempts}" }
notify("webhook.failed.rails_webhook_outbox", delivery, duration_ms)
record_failure_and_notify_if_tripped(delivery)
else
Rails.logger.warn { "[RailsWebhookOutbox] retry event=#{delivery.event} delivery_id=#{delivery.id} subscription_id=#{delivery.subscription_id} status=#{e.response_code} attempt=#{delivery.attempts} next_retry_at=#{delivery.next_retry_at.utc.iso8601}" }
raise
end
end
|