add webhook secret

This commit is contained in:
Pete Matsyburka
2024-08-05 13:30:04 +03:00
parent 6b1c3bba19
commit 478167ea4f
12 changed files with 93 additions and 12 deletions
@@ -14,7 +14,7 @@ class SendFormCompletedWebhookRequestJob
attempt = params['attempt'].to_i
url = load_url(submitter, params)
url, secret = load_url_and_secret(submitter, params)
return if url.blank?
@@ -29,6 +29,7 @@ class SendFormCompletedWebhookRequestJob
timestamp: Time.current,
data: Submitters::SerializeForWebhook.call(submitter)
}.to_json,
**secret.to_h,
'Content-Type' => 'application/json',
'User-Agent' => USER_AGENT)
rescue Faraday::Error
@@ -45,9 +46,11 @@ class SendFormCompletedWebhookRequestJob
end
end
def load_url(submitter, params)
def load_url_and_secret(submitter, params)
if params['encrypted_config_id']
url = EncryptedConfig.find(params['encrypted_config_id']).value
config = EncryptedConfig.find(params['encrypted_config_id'])
url = config.value
return if url.blank?
@@ -55,7 +58,10 @@ class SendFormCompletedWebhookRequestJob
return if preferences['form.completed'] == false
url
secret = EncryptedConfig.find_or_initialize_by(account_id: config.account_id,
key: EncryptedConfig::WEBHOOK_SECRET_KEY)&.value.to_h
[url, secret]
elsif params['webhook_url_id']
webhook_url = submitter.account.webhook_urls.find(params['webhook_url_id'])
@@ -13,7 +13,8 @@ class SendFormStartedWebhookRequestJob
submitter = Submitter.find(params['submitter_id'])
attempt = params['attempt'].to_i
url = Accounts.load_webhook_url(submitter.submission.account)
config = Accounts.load_webhook_config(submitter.submission.account)
url = config&.value.presence
return if url.blank?
@@ -30,6 +31,8 @@ class SendFormStartedWebhookRequestJob
timestamp: Time.current,
data: Submitters::SerializeForWebhook.call(submitter)
}.to_json,
**EncryptedConfig.find_or_initialize_by(account_id: config.account_id,
key: EncryptedConfig::WEBHOOK_SECRET_KEY)&.value.to_h,
'Content-Type' => 'application/json',
'User-Agent' => USER_AGENT)
rescue Faraday::Error
@@ -13,7 +13,8 @@ class SendFormViewedWebhookRequestJob
submitter = Submitter.find(params['submitter_id'])
attempt = params['attempt'].to_i
url = Accounts.load_webhook_url(submitter.submission.account)
config = Accounts.load_webhook_config(submitter.submission.account)
url = config&.value.presence
return if url.blank?
@@ -30,6 +31,8 @@ class SendFormViewedWebhookRequestJob
timestamp: Time.current,
data: Submitters::SerializeForWebhook.call(submitter)
}.to_json,
**EncryptedConfig.find_or_initialize_by(account_id: config.account_id,
key: EncryptedConfig::WEBHOOK_SECRET_KEY)&.value.to_h,
'Content-Type' => 'application/json',
'User-Agent' => USER_AGENT)
rescue Faraday::Error
@@ -13,7 +13,9 @@ class SendSubmissionArchivedWebhookRequestJob
submission = Submission.find(params['submission_id'])
attempt = params['attempt'].to_i
url = Accounts.load_webhook_url(submission.account)
config = Accounts.load_webhook_config(submission.account)
url = config&.value.presence
return if url.blank?
@@ -28,6 +30,8 @@ class SendSubmissionArchivedWebhookRequestJob
timestamp: Time.current,
data: submission.as_json(only: %i[id archived_at])
}.to_json,
**EncryptedConfig.find_or_initialize_by(account_id: config.account_id,
key: EncryptedConfig::WEBHOOK_SECRET_KEY)&.value.to_h,
'Content-Type' => 'application/json',
'User-Agent' => USER_AGENT)
rescue Faraday::Error
@@ -13,7 +13,9 @@ class SendSubmissionCreatedWebhookRequestJob
submission = Submission.find(params['submission_id'])
attempt = params['attempt'].to_i
url = Accounts.load_webhook_url(submission.account)
config = Accounts.load_webhook_config(submission.account)
url = config&.value.presence
return if url.blank?
@@ -28,6 +30,8 @@ class SendSubmissionCreatedWebhookRequestJob
timestamp: Time.current,
data: Submissions::SerializeForApi.call(submission)
}.to_json,
**EncryptedConfig.find_or_initialize_by(account_id: config.account_id,
key: EncryptedConfig::WEBHOOK_SECRET_KEY)&.value.to_h,
'Content-Type' => 'application/json',
'User-Agent' => USER_AGENT)
rescue Faraday::Error
@@ -13,7 +13,9 @@ class SendTemplateCreatedWebhookRequestJob
template = Template.find(params['template_id'])
attempt = params['attempt'].to_i
url = Accounts.load_webhook_url(template.account)
config = Accounts.load_webhook_config(template.account)
url = config&.value.presence
return if url.blank?
@@ -28,6 +30,8 @@ class SendTemplateCreatedWebhookRequestJob
timestamp: Time.current,
data: Templates::SerializeForApi.call(template)
}.to_json,
**EncryptedConfig.find_or_initialize_by(account_id: config.account_id,
key: EncryptedConfig::WEBHOOK_SECRET_KEY)&.value.to_h,
'Content-Type' => 'application/json',
'User-Agent' => USER_AGENT)
rescue Faraday::Error
@@ -13,7 +13,9 @@ class SendTemplateUpdatedWebhookRequestJob
template = Template.find(params['template_id'])
attempt = params['attempt'].to_i
url = Accounts.load_webhook_url(template.account)
config = Accounts.load_webhook_config(template.account)
url = config&.value.presence
return if url.blank?
@@ -28,6 +30,8 @@ class SendTemplateUpdatedWebhookRequestJob
timestamp: Time.current,
data: Templates::SerializeForApi.call(template)
}.to_json,
**EncryptedConfig.find_or_initialize_by(account_id: config.account_id,
key: EncryptedConfig::WEBHOOK_SECRET_KEY)&.value.to_h,
'Content-Type' => 'application/json',
'User-Agent' => USER_AGENT)
rescue Faraday::Error