mattyr/sidecloq

module Sidecloq
  class JobEnqueuer
    attr_reader :spec

    def initialize(spec)
      # Dup to prevent JID reuse in subsequent enqueue's
      @spec = spec.dup
      @spec['class'] = Object.const_get(spec['class'])
    end

    def enqueue
      if active_job_class?
        initialize_active_job_class.enqueue(queue: spec['queue'])
      else
        Sidekiq::Client.push(spec)
      end
    end

    private unless $TESTING

    def klass
      spec['class']
    end

    def active_job_class?
      defined?(ActiveJob::Base) && klass < ActiveJob::Base
    end

    def initialize_active_job_class
      args = spec['args']

      if args.is_a?(Array)
        klass.new(*args)
      else
        klass.new(args)
      end
    end
  end
end