class ActiveJob::QueueAdapters::SidekiqAdapter

def enqueue(job)
  job.provider_job_id = Sidekiq::ActiveJob::Wrapper.set(
    wrapped: job.class,
    queue: job.queue_name
  ).perform_async(job.serialize)
end

def enqueue_after_transaction_commit?
  true
end

def enqueue_all(jobs)
  enqueued_count = 0
  jobs.group_by(&:class).each do |job_class, same_class_jobs|
    same_class_jobs.group_by(&:queue_name).each do |queue, same_class_and_queue_jobs|
      immediate_jobs, scheduled_jobs = same_class_and_queue_jobs.partition { |job| job.scheduled_at.nil? }
      if immediate_jobs.any?
        jids = Sidekiq::Client.push_bulk(
          "class" => Sidekiq::ActiveJob::Wrapper,
          "wrapped" => job_class,
          "queue" => queue,
          "args" => immediate_jobs.map { |job| [job.serialize] }
        )
        enqueued_count += jids.compact.size
      end
      if scheduled_jobs.any?
        jids = Sidekiq::Client.push_bulk(
          "class" => Sidekiq::ActiveJob::Wrapper,
          "wrapped" => job_class,
          "queue" => queue,
          "args" => scheduled_jobs.map { |job| [job.serialize] },
          "at" => scheduled_jobs.map { |job| job.scheduled_at&.to_f }
        )
        enqueued_count += jids.compact.size
      end
    end
  end
  enqueued_count
end

def enqueue_at(job, timestamp)
  job.provider_job_id = Sidekiq::ActiveJob::Wrapper.set(
    wrapped: job.class,
    queue: job.queue_name
  ).perform_at(timestamp, job.serialize)
end

def stopping? = !!@@stopping