Sojan Jose
9638163b6f
- Auto-fixed 143 code style violations using rubocop -A - Fixed RuboCop configuration: moved rubocop-rspec_rails to plugins - Removed redundant || 0 patterns after .to_i calls - Fixed RSpec describe class format - Added remaining naming violations to exclude list for future cleanup - Reduced violations from 100 to 0 offenses
62 lines
1.3 KiB
Ruby
62 lines
1.3 KiB
Ruby
class Webhooks::Trigger
|
|
SUPPORTED_ERROR_HANDLE_EVENTS = %w[message_created message_updated].freeze
|
|
|
|
def initialize(url, payload, webhook_type)
|
|
@url = url
|
|
@payload = payload
|
|
@webhook_type = webhook_type
|
|
end
|
|
|
|
def self.execute(url, payload, webhook_type)
|
|
new(url, payload, webhook_type).execute
|
|
end
|
|
|
|
def execute
|
|
perform_request
|
|
rescue StandardError => e
|
|
handle_error(e)
|
|
Rails.logger.warn "Exception: Invalid webhook URL #{@url} : #{e.message}"
|
|
end
|
|
|
|
private
|
|
|
|
def perform_request
|
|
RestClient::Request.execute(
|
|
method: :post,
|
|
url: @url,
|
|
payload: @payload.to_json,
|
|
headers: { content_type: :json, accept: :json },
|
|
timeout: 5
|
|
)
|
|
end
|
|
|
|
def handle_error(error)
|
|
return unless should_handle_error?
|
|
return unless message
|
|
|
|
update_message_status(error)
|
|
end
|
|
|
|
def should_handle_error?
|
|
@webhook_type == :api_inbox_webhook && SUPPORTED_ERROR_HANDLE_EVENTS.include?(@payload[:event])
|
|
end
|
|
|
|
def update_message_status(error)
|
|
Messages::StatusUpdateService.new(message, 'failed', error.message).perform
|
|
end
|
|
|
|
def message
|
|
return if message_id.blank?
|
|
|
|
if instance_variable_defined?(:@message)
|
|
@message
|
|
else
|
|
@message = Message.find_by(id: message_id)
|
|
end
|
|
end
|
|
|
|
def message_id
|
|
@payload[:id]
|
|
end
|
|
end
|