diff options
Diffstat (limited to 'spec/workers/jira_connect/sync_merge_request_worker_spec.rb')
-rw-r--r-- | spec/workers/jira_connect/sync_merge_request_worker_spec.rb | 47 |
1 files changed, 15 insertions, 32 deletions
diff --git a/spec/workers/jira_connect/sync_merge_request_worker_spec.rb b/spec/workers/jira_connect/sync_merge_request_worker_spec.rb index 1a40aa2b3ad..6a0a0744f6f 100644 --- a/spec/workers/jira_connect/sync_merge_request_worker_spec.rb +++ b/spec/workers/jira_connect/sync_merge_request_worker_spec.rb @@ -12,48 +12,31 @@ RSpec.describe JiraConnect::SyncMergeRequestWorker do let_it_be(:merge_request) { create(:merge_request, source_project: project) } let(:merge_request_id) { merge_request.id } + let(:update_sequence_id) { 1 } - subject { described_class.new.perform(merge_request_id) } + it_behaves_like 'an idempotent worker' do + let(:job_args) { [merge_request_id, update_sequence_id] } - it 'calls JiraConnect::SyncService#execute' do - expect_next_instance_of(JiraConnect::SyncService) do |service| - expect(service).to receive(:execute).with(merge_requests: [merge_request], update_sequence_id: nil) + before do + stub_request(:post, 'https://sample.atlassian.net/rest/devinfo/0.10/bulk').to_return(status: 200, body: '', headers: {}) end - subject - end - - context 'when MR no longer exists' do - let(:merge_request_id) { non_existing_record_id } - - it 'does not call JiraConnect::SyncService' do - expect(JiraConnect::SyncService).not_to receive(:new) + it 'calls JiraConnect::SyncService#execute' do + expect_next_instances_of(JiraConnect::SyncService, IdempotentWorkerHelper::WORKER_EXEC_TIMES) do |service| + expect(service).to receive(:execute).with(merge_requests: [merge_request], update_sequence_id: update_sequence_id) + end subject end - end - context 'with update_sequence_id' do - let(:update_sequence_id) { 1 } - let(:request_path) { '/rest/devinfo/0.10/bulk' } - let(:request_body) do - { - repositories: [ - Atlassian::JiraConnect::Serializers::RepositoryEntity.represent( - project, - merge_requests: [merge_request], - update_sequence_id: update_sequence_id - ) - ] - } - end - - subject { described_class.new.perform(merge_request_id, update_sequence_id) } + context 'when MR no longer exists' do + let(:merge_request_id) { non_existing_record_id } - it 'sends the request with custom update_sequence_id' do - expect_next(Atlassian::JiraConnect::Client).to receive(:post).with(request_path, request_body) + it 'does not call JiraConnect::SyncService' do + expect(JiraConnect::SyncService).not_to receive(:new) - subject + subject + end end end end |