skip webhook not found

pull/402/head^2^2
Pete Matsyburka 2 weeks ago
parent e92fc0d3e1
commit cba2d02990

@ -4,7 +4,9 @@ class ProcessSubmissionExpiredJob
include Sidekiq::Job include Sidekiq::Job
def perform(params = {}) def perform(params = {})
submission = Submission.find(params['submission_id']) submission = Submission.find_by(id: params['submission_id'])
return unless submission
return if submission.archived_at? return if submission.archived_at?
return if submission.template&.archived_at? return if submission.template&.archived_at?

@ -8,8 +8,13 @@ class SendFormCompletedWebhookRequestJob
MAX_ATTEMPTS = 12 MAX_ATTEMPTS = 12
def perform(params = {}) def perform(params = {})
submitter = Submitter.find(params['submitter_id']) submitter = Submitter.find_by(id: params['submitter_id'])
webhook_url = WebhookUrl.find(params['webhook_url_id'])
return unless submitter
webhook_url = WebhookUrl.find_by(id: params['webhook_url_id'])
return unless webhook_url
attempt = params['attempt'].to_i attempt = params['attempt'].to_i

@ -8,8 +8,13 @@ class SendFormDeclinedWebhookRequestJob
MAX_ATTEMPTS = 10 MAX_ATTEMPTS = 10
def perform(params = {}) def perform(params = {})
submitter = Submitter.find(params['submitter_id']) submitter = Submitter.find_by(id: params['submitter_id'])
webhook_url = WebhookUrl.find(params['webhook_url_id'])
return unless submitter
webhook_url = WebhookUrl.find_by(id: params['webhook_url_id'])
return unless webhook_url
attempt = params['attempt'].to_i attempt = params['attempt'].to_i

@ -8,8 +8,13 @@ class SendFormStartedWebhookRequestJob
MAX_ATTEMPTS = 10 MAX_ATTEMPTS = 10
def perform(params = {}) def perform(params = {})
submitter = Submitter.find(params['submitter_id']) submitter = Submitter.find_by(id: params['submitter_id'])
webhook_url = WebhookUrl.find(params['webhook_url_id'])
return unless submitter
webhook_url = WebhookUrl.find_by(id: params['webhook_url_id'])
return unless webhook_url
attempt = params['attempt'].to_i attempt = params['attempt'].to_i

@ -8,8 +8,13 @@ class SendFormViewedWebhookRequestJob
MAX_ATTEMPTS = 10 MAX_ATTEMPTS = 10
def perform(params = {}) def perform(params = {})
submitter = Submitter.find(params['submitter_id']) submitter = Submitter.find_by(id: params['submitter_id'])
webhook_url = WebhookUrl.find(params['webhook_url_id'])
return unless submitter
webhook_url = WebhookUrl.find_by(id: params['webhook_url_id'])
return unless webhook_url
attempt = params['attempt'].to_i attempt = params['attempt'].to_i

@ -8,8 +8,13 @@ class SendSubmissionArchivedWebhookRequestJob
MAX_ATTEMPTS = 10 MAX_ATTEMPTS = 10
def perform(params = {}) def perform(params = {})
submission = Submission.find(params['submission_id']) submission = Submission.find_by(id: params['submission_id'])
webhook_url = WebhookUrl.find(params['webhook_url_id'])
return unless submission
webhook_url = WebhookUrl.find_by(id: params['webhook_url_id'])
return unless webhook_url
attempt = params['attempt'].to_i attempt = params['attempt'].to_i

@ -8,8 +8,13 @@ class SendSubmissionCompletedWebhookRequestJob
MAX_ATTEMPTS = 10 MAX_ATTEMPTS = 10
def perform(params = {}) def perform(params = {})
submission = Submission.find(params['submission_id']) submission = Submission.find_by(id: params['submission_id'])
webhook_url = WebhookUrl.find(params['webhook_url_id'])
return unless submission
webhook_url = WebhookUrl.find_by(id: params['webhook_url_id'])
return unless webhook_url
attempt = params['attempt'].to_i attempt = params['attempt'].to_i

@ -8,8 +8,13 @@ class SendSubmissionCreatedWebhookRequestJob
MAX_ATTEMPTS = 10 MAX_ATTEMPTS = 10
def perform(params = {}) def perform(params = {})
submission = Submission.find(params['submission_id']) submission = Submission.find_by(id: params['submission_id'])
webhook_url = WebhookUrl.find(params['webhook_url_id'])
return unless submission
webhook_url = WebhookUrl.find_by(id: params['webhook_url_id'])
return unless webhook_url
attempt = params['attempt'].to_i attempt = params['attempt'].to_i

@ -8,8 +8,13 @@ class SendSubmissionExpiredWebhookRequestJob
MAX_ATTEMPTS = 10 MAX_ATTEMPTS = 10
def perform(params = {}) def perform(params = {})
submission = Submission.find(params['submission_id']) submission = Submission.find_by(id: params['submission_id'])
webhook_url = WebhookUrl.find(params['webhook_url_id'])
return unless submission
webhook_url = WebhookUrl.find_by(id: params['webhook_url_id'])
return unless webhook_url
attempt = params['attempt'].to_i attempt = params['attempt'].to_i

@ -8,8 +8,13 @@ class SendTemplateCreatedWebhookRequestJob
MAX_ATTEMPTS = 10 MAX_ATTEMPTS = 10
def perform(params = {}) def perform(params = {})
template = Template.find(params['template_id']) template = Template.find_by(id: params['template_id'])
webhook_url = WebhookUrl.find(params['webhook_url_id'])
return unless template
webhook_url = WebhookUrl.find_by(id: params['webhook_url_id'])
return unless webhook_url
attempt = params['attempt'].to_i attempt = params['attempt'].to_i

@ -8,8 +8,13 @@ class SendTemplateUpdatedWebhookRequestJob
MAX_ATTEMPTS = 10 MAX_ATTEMPTS = 10
def perform(params = {}) def perform(params = {})
template = Template.find(params['template_id']) template = Template.find_by(id: params['template_id'])
webhook_url = WebhookUrl.find(params['webhook_url_id'])
return unless template
webhook_url = WebhookUrl.find_by(id: params['webhook_url_id'])
return unless webhook_url
attempt = params['attempt'].to_i attempt = params['attempt'].to_i

@ -8,10 +8,13 @@ class SendTestWebhookRequestJob
USER_AGENT = 'DocuSeal.com Webhook' USER_AGENT = 'DocuSeal.com Webhook'
def perform(params = {}) def perform(params = {})
submitter = Submitter.find(params['submitter_id']) submitter = Submitter.find_by(id: params['submitter_id'])
webhook_url = WebhookUrl.find(params['webhook_url_id'])
return unless webhook_url && submitter return unless submitter
webhook_url = WebhookUrl.find_by(id: params['webhook_url_id'])
return unless webhook_url
Faraday.post(webhook_url.url, Faraday.post(webhook_url.url,
{ {

Loading…
Cancel
Save