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