Sha256: e7fc67016014ae5c4e314e8c73204fb1cc56e20786f568c25b9f64e214a8fee2

Contents?: true

Size: 649 Bytes

Versions: 16

Compression:

Stored size: 649 Bytes

Contents

# frozen_string_literal: true

# legacy worker for backwards compatibility when upgrading from Eventsimple <= 1.0.0
module Eventsimple
  class ReactorWorker
    include Sidekiq::Worker

    def perform(event_global_id, reactor_class)
      gid = GlobalID.parse(event_global_id)

      event = Retriable.with_context(:reactor) do
        gid.model_class.uncached { GlobalID::Locator.locate event_global_id }
      end
    rescue ActiveRecord::RecordNotFound
      Rails.logger.error("Event #{event_global_id} not found for reactor: #{reactor_class}")
    else
      reactor = reactor_class.constantize
      reactor.new.call(event)
    end
  end
end

Version data entries

16 entries across 16 versions & 1 rubygems

Version Path
eventsimple-1.5.6 lib/eventsimple/reactor_worker.rb
eventsimple-1.5.5 lib/eventsimple/reactor_worker.rb
eventsimple-1.5.4 lib/eventsimple/reactor_worker.rb
eventsimple-1.5.3 lib/eventsimple/reactor_worker.rb
eventsimple-1.4.3 lib/eventsimple/reactor_worker.rb
eventsimple-1.4.2 lib/eventsimple/reactor_worker.rb
eventsimple-1.4.1 lib/eventsimple/reactor_worker.rb
eventsimple-1.4.0 lib/eventsimple/reactor_worker.rb
eventsimple-1.3.3 lib/eventsimple/reactor_worker.rb
eventsimple-1.3.2 lib/eventsimple/reactor_worker.rb
eventsimple-1.3.1 lib/eventsimple/reactor_worker.rb
eventsimple-1.3.0 lib/eventsimple/reactor_worker.rb
eventsimple-1.2.3 lib/eventsimple/reactor_worker.rb
eventsimple-1.2.2 lib/eventsimple/reactor_worker.rb
eventsimple-1.2.1 lib/eventsimple/reactor_worker.rb
eventsimple-1.2.0 lib/eventsimple/reactor_worker.rb