adminbruno
/
docuseal
mirror of https://github.com/docusealco/docuseal
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

retry webhooks on timeout

Browse Source
pull/220/head^2
Pete Matsyburka 2 years ago
parent b9a906b569
commit ab56e8be20
3 changed files with 43 additions and 31 deletions
Show Stats Download Patch File Download Diff File

26
app/jobs/send_form_completed_webhook_request_job.rb
Unescape View File

@ -15,21 +15,25 @@ class SendFormCompletedWebhookRequestJob < ApplicationJob
ActiveStorage::Current.url_options = Docuseal.default_url_options ActiveStorage::Current.url_options = Docuseal.default_url_options
resp = Faraday.post(config.value, resp = begin
{ Faraday.post(config.value,
event_type: 'form.completed', {
timestamp: Time.current, event_type: 'form.completed',
data: Submitters::SerializeForWebhook.call(submitter) timestamp: Time.current,
}.to_json, data: Submitters::SerializeForWebhook.call(submitter)
'Content-Type' => 'application/json', }.to_json,
'User-Agent' => USER_AGENT) 'Content-Type' => 'application/json',
'User-Agent' => USER_AGENT)
if resp.status.to_i >= 400 && attempt <= MAX_ATTEMPTS && rescue Faraday::TimeoutError
nil
end
if (resp.nil? || resp.status.to_i >= 400) && attempt <= MAX_ATTEMPTS &&
(!Docuseal.multitenant? || submitter.account.account_configs.exists?(key: :plan)) (!Docuseal.multitenant? || submitter.account.account_configs.exists?(key: :plan))
SendFormCompletedWebhookRequestJob.set(wait: (2**attempt).minutes) SendFormCompletedWebhookRequestJob.set(wait: (2**attempt).minutes)
.perform_later(submitter, { .perform_later(submitter, {
attempt: attempt + 1, attempt: attempt + 1,
last_status: resp.status.to_i last_status: resp&.status.to_i
}) })
end end
end end

24
app/jobs/send_form_started_webhook_request_job.rb
Unescape View File

@ -13,21 +13,25 @@ class SendFormStartedWebhookRequestJob < ApplicationJob
ActiveStorage::Current.url_options = Docuseal.default_url_options ActiveStorage::Current.url_options = Docuseal.default_url_options
resp = Faraday.post(config.value, resp = begin
{ Faraday.post(config.value,
event_type: 'form.started', {
timestamp: Time.current, event_type: 'form.started',
data: Submitters::SerializeForWebhook.call(submitter) timestamp: Time.current,
}.to_json, data: Submitters::SerializeForWebhook.call(submitter)
'Content-Type' => 'application/json', }.to_json,
'User-Agent' => USER_AGENT) 'Content-Type' => 'application/json',
'User-Agent' => USER_AGENT)
rescue Faraday::TimeoutError
nil
end
if resp.status.to_i >= 400 && attempt <= MAX_ATTEMPTS && if (resp.nil? || resp.status.to_i >= 400) && attempt <= MAX_ATTEMPTS &&
(!Docuseal.multitenant? || submitter.account.account_configs.exists?(key: :plan)) (!Docuseal.multitenant? || submitter.account.account_configs.exists?(key: :plan))
SendFormStartedWebhookRequestJob.set(wait: (2**attempt).minutes) SendFormStartedWebhookRequestJob.set(wait: (2**attempt).minutes)
.perform_later(submitter, { .perform_later(submitter, {
attempt: attempt + 1, attempt: attempt + 1,
last_status: resp.status.to_i last_status: resp&.status.to_i
}) })
end end
end end

24
app/jobs/send_form_viewed_webhook_request_job.rb
Unescape View File

@ -13,21 +13,25 @@ class SendFormViewedWebhookRequestJob < ApplicationJob
ActiveStorage::Current.url_options = Docuseal.default_url_options ActiveStorage::Current.url_options = Docuseal.default_url_options
resp = Faraday.post(config.value, resp = begin
{ Faraday.post(config.value,
event_type: 'form.viewed', {
timestamp: Time.current, event_type: 'form.viewed',
data: Submitters::SerializeForWebhook.call(submitter) timestamp: Time.current,
}.to_json, data: Submitters::SerializeForWebhook.call(submitter)
'Content-Type' => 'application/json', }.to_json,
'User-Agent' => USER_AGENT) 'Content-Type' => 'application/json',
'User-Agent' => USER_AGENT)
rescue Faraday::TimeoutError
nil
end
if resp.status.to_i >= 400 && attempt <= MAX_ATTEMPTS && if (resp.nil? || resp.status.to_i >= 400) && attempt <= MAX_ATTEMPTS &&
(!Docuseal.multitenant? || submitter.account.account_configs.exists?(key: :plan)) (!Docuseal.multitenant? || submitter.account.account_configs.exists?(key: :plan))
SendFormViewedWebhookRequestJob.set(wait: (2**attempt).minutes) SendFormViewedWebhookRequestJob.set(wait: (2**attempt).minutes)
.perform_later(submitter, { .perform_later(submitter, {
attempt: attempt + 1, attempt: attempt + 1,
last_status: resp.status.to_i last_status: resp&.status.to_i
}) })
end end
end end

Write Preview
Loading…
Cancel
Save