Lowkiq::Testing.inline! needed

[solutus]

It would be useful to have an inline mode that runs the job immediately instead of enqueuing it.
Something like Sidekiq::Testing.inline!

[solutus]

Solution for rspec may look like this:

Rspec.configure do |config
  Lowkiq::Testing.inline!(config)
end

#--------------------------------------------
# frozen_string_literal: true

module Lowkiq
  module Testing
    def self.inline!(context)
      workers = modules_extending_module(Lowkiq::Worker)
      context.before do
        workers.each do |worker|
          worker.singleton_class.class_eval do
            alias_method(:orig_perform_async, :perform_async)
            define_method(:perform_async) do |jobs|
              payloads_by_id = jobs
                .group_by { |job| job[:id] }
                .transform_values { |group| group.map { |job| job[:payload] } }
              perform(payloads_by_id)
            end
          end
        end
      end

      context.after do
        workers.each do |worker|
          worker.singleton_class.class_eval do
            alias_method(:perform_async, :orig_perform_async)
          end
        end
      end
    end

    def self.modules_extending_module(target_module)
      extending_classes = []
      ObjectSpace.each_object(Module) do |klass|
        if klass.singleton_class.ancestors.include?(target_module)
          extending_classes << klass
        end
      end
      extending_classes
    end
  end
end