1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
|
# frozen_string_literal: true
RSpec.shared_examples Gitlab::BitbucketServerImport::ObjectImporter do
include AfterNextHelpers
describe '.sidekiq_retries_exhausted' do
let(:job) { { 'args' => [1, {}, 'key'], 'jid' => 'jid' } }
it 'notifies the waiter' do
expect(Gitlab::JobWaiter).to receive(:notify).with('key', 'jid')
described_class.sidekiq_retries_exhausted_block.call(job, StandardError.new)
end
end
describe '#perform' do
let_it_be(:import_started_project) { create(:project, :import_started) }
let(:project_id) { project_id }
let(:waiter_key) { 'key' }
shared_examples 'notifies the waiter' do
specify do
allow_next(worker.importer_class).to receive(:execute)
expect(Gitlab::JobWaiter).to receive(:notify).with(waiter_key, anything)
worker.perform(project_id, {}, waiter_key)
end
end
context 'when project does not exist' do
let(:project_id) { non_existing_record_id }
it_behaves_like 'notifies the waiter'
end
context 'when project has import started' do
let_it_be(:project) do
create(:project, :import_started, import_data_attributes: {
data: { 'project_key' => 'key', 'repo_slug' => 'slug' },
credentials: { 'token' => 'token' }
})
end
let(:project_id) { project.id }
it 'calls the importer' do
expect_next(worker.importer_class, project, kind_of(Hash)).to receive(:execute)
worker.perform(project_id, {}, waiter_key)
end
it_behaves_like 'notifies the waiter'
end
context 'when project import has been cancelled' do
let_it_be(:project_id) { create(:project, :import_canceled).id }
it 'does not call the importer' do
expect_next(worker.importer_class).not_to receive(:execute)
worker.perform(project_id, {}, waiter_key)
end
it_behaves_like 'notifies the waiter'
end
end
end
|
