mirror of https://github.com/docusealco/docuseal
				
				
				
			
			You can not select more than 25 topics
			Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
		
		
		
		
		
			
		
			
				
					
					
						
							49 lines
						
					
					
						
							1.5 KiB
						
					
					
				
			
		
		
	
	
							49 lines
						
					
					
						
							1.5 KiB
						
					
					
				# frozen_string_literal: true
 | 
						|
 | 
						|
class SendFormViewedWebhookRequestJob
 | 
						|
  include Sidekiq::Job
 | 
						|
 | 
						|
  sidekiq_options queue: :webhooks
 | 
						|
 | 
						|
  USER_AGENT = 'DocuSeal.co Webhook'
 | 
						|
 | 
						|
  MAX_ATTEMPTS = 10
 | 
						|
 | 
						|
  def perform(params = {})
 | 
						|
    submitter = Submitter.find(params['submitter_id'])
 | 
						|
 | 
						|
    attempt = params['attempt'].to_i
 | 
						|
    url = Accounts.load_webhook_url(submitter.submission.account)
 | 
						|
 | 
						|
    return if url.blank?
 | 
						|
 | 
						|
    preferences = Accounts.load_webhook_preferences(submitter.submission.account)
 | 
						|
 | 
						|
    return if preferences['form.viewed'] == false
 | 
						|
 | 
						|
    ActiveStorage::Current.url_options = Docuseal.default_url_options
 | 
						|
 | 
						|
    resp = begin
 | 
						|
      Faraday.post(url,
 | 
						|
                   {
 | 
						|
                     event_type: 'form.viewed',
 | 
						|
                     timestamp: Time.current,
 | 
						|
                     data: Submitters::SerializeForWebhook.call(submitter)
 | 
						|
                   }.to_json,
 | 
						|
                   'Content-Type' => 'application/json',
 | 
						|
                   'User-Agent' => USER_AGENT)
 | 
						|
    rescue Faraday::Error
 | 
						|
      nil
 | 
						|
    end
 | 
						|
 | 
						|
    if (resp.nil? || resp.status.to_i >= 400) && attempt <= MAX_ATTEMPTS &&
 | 
						|
       (!Docuseal.multitenant? || submitter.account.account_configs.exists?(key: :plan))
 | 
						|
      SendFormViewedWebhookRequestJob.perform_in((2**attempt).minutes, {
 | 
						|
                                                   'submitter_id' => submitter.id,
 | 
						|
                                                   'attempt' => attempt + 1,
 | 
						|
                                                   'last_status' => resp&.status.to_i
 | 
						|
                                                 })
 | 
						|
    end
 | 
						|
  end
 | 
						|
end
 |