mirror of https://github.com/docusealco/docuseal
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
52 lines
1.9 KiB
52 lines
1.9 KiB
# frozen_string_literal: true
|
|
|
|
RSpec.describe ProcessSubmissionExpiredJob do
|
|
let(:account) { create(:account) }
|
|
let(:user) { create(:user, account:) }
|
|
let(:template) { create(:template, account:, author: user) }
|
|
let(:expire_at) { 2.days.from_now.change(usec: 0) }
|
|
let(:submission) do
|
|
create(:submission, :with_submitters, template:, created_by_user: user, expire_at:)
|
|
end
|
|
|
|
before { allow(WebhookUrls).to receive(:enqueue_events) }
|
|
|
|
describe '#perform' do
|
|
it 'enqueues the expired event when the scheduled expire_at still matches' do
|
|
described_class.new.perform('submission_id' => submission.id, 'expire_at' => expire_at.to_i)
|
|
|
|
expect(WebhookUrls).to have_received(:enqueue_events).with(submission, 'submission.expired')
|
|
end
|
|
|
|
it 'enqueues the expired event for legacy jobs scheduled without an expire_at param' do
|
|
described_class.new.perform('submission_id' => submission.id)
|
|
|
|
expect(WebhookUrls).to have_received(:enqueue_events).with(submission, 'submission.expired')
|
|
end
|
|
|
|
it 'skips a stale job scheduled for an earlier expire_at that was extended' do
|
|
submission.update!(expire_at: 3.days.from_now)
|
|
|
|
described_class.new.perform('submission_id' => submission.id, 'expire_at' => expire_at.to_i)
|
|
|
|
expect(WebhookUrls).not_to have_received(:enqueue_events)
|
|
end
|
|
|
|
it 'skips a stale job scheduled for a later expire_at that was shortened' do
|
|
submission.update!(expire_at: 1.day.from_now)
|
|
|
|
described_class.new.perform('submission_id' => submission.id, 'expire_at' => expire_at.to_i)
|
|
|
|
expect(WebhookUrls).not_to have_received(:enqueue_events)
|
|
end
|
|
|
|
it 'skips a stale job when the expiration has been cleared' do
|
|
submission.update!(expire_at: nil)
|
|
|
|
described_class.new.perform('submission_id' => submission.id, 'expire_at' => expire_at.to_i)
|
|
|
|
expect(WebhookUrls).not_to have_received(:enqueue_events)
|
|
end
|
|
end
|
|
end
|