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
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
|
# frozen_string_literal: true
require 'spec_helper'
RSpec.describe BulkImports::Tracker, type: :model, feature_category: :importers do
describe 'associations' do
it do
is_expected.to belong_to(:entity).required.class_name('BulkImports::Entity')
.with_foreign_key(:bulk_import_entity_id).inverse_of(:trackers)
end
end
describe 'validations' do
before do
create(:bulk_import_tracker)
end
it { is_expected.to validate_presence_of(:relation) }
it { is_expected.to validate_uniqueness_of(:relation).scoped_to(:bulk_import_entity_id) }
it { is_expected.to validate_presence_of(:stage) }
context 'when has_next_page is true' do
it "validates presence of `next_page`" do
tracker = build(:bulk_import_tracker, has_next_page: true)
expect(tracker).not_to be_valid
expect(tracker.errors).to include(:next_page)
end
end
end
describe '.running_trackers' do
it 'returns trackers that are running for a given entity' do
entity = create(:bulk_import_entity)
BulkImports::Tracker.state_machines[:status].states.map(&:value).each do |status|
create(:bulk_import_tracker, status: status, entity: entity)
end
expect(described_class.running_trackers(entity.id).pluck(:status)).to include(1, 3)
end
end
describe '.next_pipeline_trackers_for' do
let_it_be(:entity) { create(:bulk_import_entity) }
let_it_be(:stage_0_tracker) { create(:bulk_import_tracker, :finished, entity: entity) }
it 'returns empty when all the stages pipelines are finished' do
expect(described_class.next_pipeline_trackers_for(entity.id))
.to eq([])
end
it 'returns the not started pipeline trackers from the minimum stage number' do
stage_1_tracker = create(:bulk_import_tracker, entity: entity, stage: 1)
stage_1_finished_tracker = create(:bulk_import_tracker, :finished, entity: entity, stage: 1)
stage_1_failed_tracker = create(:bulk_import_tracker, :failed, entity: entity, stage: 1)
stage_1_skipped_tracker = create(:bulk_import_tracker, :skipped, entity: entity, stage: 1)
stage_2_tracker = create(:bulk_import_tracker, entity: entity, stage: 2)
expect(described_class.next_pipeline_trackers_for(entity.id))
.to include(stage_1_tracker)
expect(described_class.next_pipeline_trackers_for(entity.id))
.not_to include(stage_2_tracker, stage_1_finished_tracker, stage_1_failed_tracker, stage_1_skipped_tracker)
end
end
describe '#pipeline_class' do
it 'returns the pipeline class' do
entity = create(:bulk_import_entity)
pipeline_class = BulkImports::Groups::Stage.new(entity).pipelines.first[:pipeline]
tracker = create(:bulk_import_tracker, pipeline_name: pipeline_class)
expect(tracker.pipeline_class).to eq(pipeline_class)
end
it 'raises an error when the pipeline is not valid' do
tracker = create(:bulk_import_tracker, pipeline_name: 'InexistingPipeline')
expect { tracker.pipeline_class }
.to raise_error(
BulkImports::Error,
"'InexistingPipeline' is not a valid BulkImport Pipeline"
)
end
context 'when using delegation methods' do
context 'with group pipelines' do
let(:entity) { create(:bulk_import_entity) }
it 'does not raise' do
entity.pipelines.each do |pipeline|
tracker = create(:bulk_import_tracker, entity: entity, pipeline_name: pipeline[:pipeline])
expect { tracker.abort_on_failure? }.not_to raise_error
expect { tracker.file_extraction_pipeline? }.not_to raise_error
end
end
end
context 'with project pipelines' do
let(:entity) { create(:bulk_import_entity, :project_entity) }
it 'does not raise' do
entity.pipelines.each do |pipeline|
tracker = create(:bulk_import_tracker, entity: entity, pipeline_name: pipeline[:pipeline])
expect { tracker.abort_on_failure? }.not_to raise_error
expect { tracker.file_extraction_pipeline? }.not_to raise_error
end
end
end
end
end
end
|
