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.
		
		
		
		
		
			
		
			
				
					
					
						
							52 lines
						
					
					
						
							1.8 KiB
						
					
					
				
			
		
		
	
	
							52 lines
						
					
					
						
							1.8 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
 | |
|     config = Accounts.load_webhook_config(submitter.submission.account)
 | |
|     url = config&.value.presence
 | |
| 
 | |
|     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,
 | |
|                    **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
 | |
|       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
 |