2023-08-05 15:25:16 +03:00
|
|
|
# frozen_string_literal: true
|
|
|
|
|
|
2024-06-18 16:51:42 +03:00
|
|
|
class SendFormStartedWebhookRequestJob
|
|
|
|
|
include Sidekiq::Job
|
|
|
|
|
|
|
|
|
|
sidekiq_options queue: :webhooks
|
2024-05-27 14:35:19 +03:00
|
|
|
|
2024-02-16 18:41:58 +02:00
|
|
|
MAX_ATTEMPTS = 10
|
2024-02-09 23:04:42 +02:00
|
|
|
|
2024-06-22 10:36:32 +03:00
|
|
|
def perform(params = {})
|
2025-12-03 13:20:52 +02:00
|
|
|
submitter = Submitter.find_by(id: params['submitter_id'])
|
|
|
|
|
|
|
|
|
|
return unless submitter
|
|
|
|
|
|
|
|
|
|
webhook_url = WebhookUrl.find_by(id: params['webhook_url_id'])
|
|
|
|
|
|
|
|
|
|
return unless webhook_url
|
2024-06-22 10:36:32 +03:00
|
|
|
|
|
|
|
|
attempt = params['attempt'].to_i
|
2023-08-05 15:25:16 +03:00
|
|
|
|
2024-10-28 20:39:09 +02:00
|
|
|
return if webhook_url.url.blank? || webhook_url.events.exclude?('form.started')
|
2023-08-05 15:25:16 +03:00
|
|
|
|
|
|
|
|
ActiveStorage::Current.url_options = Docuseal.default_url_options
|
|
|
|
|
|
2025-01-22 20:58:47 +02:00
|
|
|
resp = SendWebhookRequest.call(webhook_url, event_type: 'form.started',
|
2025-07-04 21:11:08 +03:00
|
|
|
event_uuid: params['event_uuid'],
|
|
|
|
|
record: submitter,
|
|
|
|
|
attempt:,
|
2025-01-22 20:58:47 +02:00
|
|
|
data: Submitters::SerializeForWebhook.call(submitter))
|
2024-02-09 23:04:42 +02:00
|
|
|
|
2026-05-06 19:09:35 +03:00
|
|
|
return if attempt > MAX_ATTEMPTS || (resp && resp.status.to_i < 400)
|
|
|
|
|
|
|
|
|
|
SendFormStartedWebhookRequestJob.perform_in((2**attempt).minutes, {
|
|
|
|
|
**params,
|
|
|
|
|
'attempt' => attempt + 1,
|
|
|
|
|
'last_status' => resp&.status.to_i
|
|
|
|
|
})
|
2023-08-05 15:25:16 +03:00
|
|
|
end
|
|
|
|
|
end
|