Contents

require 'sidekiq'

module Inboxable
  class PollingReceiverWorker
    include Sidekiq::Job

    def perform
      Inboxable.configuration.orm == :activerecord ? perform_activerecord : perform_mongoid
    end

    def perform_activerecord
      Inboxable.inbox_model.pending
           .where(last_attempted_at: [..Time.zone.now, nil])
           .find_in_batches(batch_size: ENV.fetch('INBOXABLE__BATCH_SIZE', 100).to_i)
           .each do |batch|
        batch.each do |inbox|
          inbox.processor_class_name.constantize.perform_async(inbox.id)
          inbox.update(last_attempted_at: 1.minute.from_now, status: :processed, allow_processing: false)
        end
      end
    end

    def perform_mongoid
      batch_size = ENV.fetch('INBOXABLE__BATCH_SIZE', 100).to_i
      Inboxable.inbox_model.pending
           .any_of({ last_attempted_at: ..Time.zone.now }, { last_attempted_at: nil })
           .each_slice(batch_size) do |batch|
        batch.each do |inbox|
          inbox.processor_class_name.constantize.perform_async(inbox.id.to_s)
          inbox.update(last_attempted_at: 1.minute.from_now, status: :processed, allow_processing: false)
        end
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
inboxable-0.1.1	lib/inboxable/polling_receiver_worker.rb