Ожидайте, что несколько активных заданий Rails одного класса будут поставлены в очередь с разными параметрами - PullRequest
Новая
       49

Ожидайте, что несколько активных заданий Rails одного класса будут поставлены в очередь с разными параметрами

1 голос
/ 28 апреля 2020

У меня есть активное задание Rails, которое создает несколько других заданий одного типа с разными параметрами. Я хочу проверить, что эта работа ставит другую работу в очередь с правильными параметрами.

Это в основном то, чего я пытаюсь достичь: 

require 'rails_helper'

RSpec.describe TriggerJob, type: :job do
  include ActiveJob::TestHelper

  after do
    clear_enqueued_jobs
  end

  it 'enqueues jobs for all model instances' do
    model1 = create(:model)
    model2 = create(:model)
    model3 = create(:model)

    expect { described_class.perform_now }
      .to(have_enqueued_job(ModelJob).with { |arg| expect(arg.id).to be == model1.id }.exactly(:once))
      .and(have_enqueued_job(ModelJob).with { |arg| expect(arg.id).to be == model2.id }.exactly(:once))
      .and(have_enqueued_job(ModelJob).with { |arg| expect(arg.id).to be == model3.id }.exactly(:once))
  end
end

Это не работает, потому что RSpe c кажется, просто соответствует типу класса задания, а затем пытается сравнить первые аргументы заданий с моим блоком. В зависимости от порядка в очереди это не удается. Мне бы хотелось, чтобы RSpe c совпадал с ЛЮБЫМИ заданиями в очереди ModelJob и не выполнялся, если не удалось найти совпадения в очереди.

Кроме того, я хотел бы проверить, что других заданий ModelJob не существует. с другими параметрами, но это не обязательно.

1 Ответ

0 голосов
/ 05 мая 2020

Вы можете проверить enqueued_jobs напрямую. Это не так красиво, хотя. 

  it 'enqueues jobs for all model instances' do
    model1 = create(:model)
    model2 = create(:model)
    model3 = create(:model)

    described_class.perform_now

    job_classes = enqueued_jobs.map { |enqueued_job| enqueued_job[:job] }
    expect(job_classes).to eq([ModelJob] * 3)

    job_args = enqueued_jobs.map do |enqueued_job|
      ::ActiveJob::Arguments.deserialize(enqueued_job[:args])
    end
    expect(job_args.one? { |arg| arg.id == model1.id }).to eq(true)
    expect(job_args.one? { |arg| arg.id == model2.id }).to eq(true)
    expect(job_args.one? { |arg| arg.id == model3.id }).to eq(true)
  end
...