Class: WebhookInbox::ProcessJob

Inherits:
ActiveJob::Base
  • Object
show all
Defined in:
app/jobs/webhook_inbox/process_job.rb

Instance Method Summary collapse

Instance Method Details

#perform(event_id) ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
 
# File 'app/jobs/webhook_inbox/process_job.rb', line 9

def perform(event_id)
  event = WebhookInbox::Event.find_by(id: event_id)
  unless event
    logger.warn "[WebhookInbox] ProcessJob: event #{event_id} not found — skipping"
    return
  end

  return unless event.status.in?(%w[pending])

  event.update!(status: "processing", attempts: event.attempts + 1)

  handlers = WebhookInbox.configuration.handlers_for(event.provider, event.event_type)

  if handlers.empty?
    logger.info "[WebhookInbox] No handlers registered for #{event.provider}:#{event.event_type}"
  else
    handlers.each { |handler| handler.call(event) }
  end

  event.update!(status: "processed", processed_at: Time.current, error_message: nil)
rescue StandardError => e
  event&.update!(
    status: "failed",
    error_message: "#{e.class}: #{e.message}\n#{e.backtrace&.first(5)&.join("\n")}"
  )
  raise # let ActiveJob retry_on handle re-enqueueing
end