138 lines
4 KiB
Ruby
138 lines
4 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require 'spec_helper'
|
|
|
|
describe Ci::PipelineSchedule do
|
|
it { is_expected.to belong_to(:project) }
|
|
it { is_expected.to belong_to(:owner) }
|
|
|
|
it { is_expected.to have_many(:pipelines) }
|
|
it { is_expected.to have_many(:variables) }
|
|
|
|
it { is_expected.to respond_to(:ref) }
|
|
it { is_expected.to respond_to(:cron) }
|
|
it { is_expected.to respond_to(:cron_timezone) }
|
|
it { is_expected.to respond_to(:description) }
|
|
it { is_expected.to respond_to(:next_run_at) }
|
|
|
|
describe 'validations' do
|
|
it 'does not allow invalid cron patters' do
|
|
pipeline_schedule = build(:ci_pipeline_schedule, cron: '0 0 0 * *')
|
|
|
|
expect(pipeline_schedule).not_to be_valid
|
|
end
|
|
|
|
it 'does not allow invalid cron patters' do
|
|
pipeline_schedule = build(:ci_pipeline_schedule, cron_timezone: 'invalid')
|
|
|
|
expect(pipeline_schedule).not_to be_valid
|
|
end
|
|
|
|
context 'when active is false' do
|
|
it 'does not allow nullified ref' do
|
|
pipeline_schedule = build(:ci_pipeline_schedule, :inactive, ref: nil)
|
|
|
|
expect(pipeline_schedule).not_to be_valid
|
|
end
|
|
end
|
|
end
|
|
|
|
describe '#set_next_run_at' do
|
|
let!(:pipeline_schedule) { create(:ci_pipeline_schedule, :nightly) }
|
|
|
|
context 'when creates new pipeline schedule' do
|
|
let(:expected_next_run_at) do
|
|
Gitlab::Ci::CronParser.new(pipeline_schedule.cron, pipeline_schedule.cron_timezone)
|
|
.next_time_from(Time.now)
|
|
end
|
|
|
|
it 'updates next_run_at automatically' do
|
|
expect(described_class.last.next_run_at).to eq(expected_next_run_at)
|
|
end
|
|
end
|
|
|
|
context 'when updates cron of exsisted pipeline schedule' do
|
|
let(:new_cron) { '0 0 1 1 *' }
|
|
|
|
let(:expected_next_run_at) do
|
|
Gitlab::Ci::CronParser.new(new_cron, pipeline_schedule.cron_timezone)
|
|
.next_time_from(Time.now)
|
|
end
|
|
|
|
it 'updates next_run_at automatically' do
|
|
pipeline_schedule.update!(cron: new_cron)
|
|
|
|
expect(described_class.last.next_run_at).to eq(expected_next_run_at)
|
|
end
|
|
end
|
|
end
|
|
|
|
describe '#schedule_next_run!' do
|
|
let!(:pipeline_schedule) { create(:ci_pipeline_schedule, :nightly) }
|
|
|
|
context 'when reschedules after 10 days from now' do
|
|
let(:future_time) { 10.days.from_now }
|
|
|
|
let(:expected_next_run_at) do
|
|
Gitlab::Ci::CronParser.new(pipeline_schedule.cron, pipeline_schedule.cron_timezone)
|
|
.next_time_from(future_time)
|
|
end
|
|
|
|
it 'points to proper next_run_at' do
|
|
Timecop.freeze(future_time) do
|
|
pipeline_schedule.schedule_next_run!
|
|
|
|
expect(pipeline_schedule.next_run_at).to eq(expected_next_run_at)
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
describe '#real_next_run' do
|
|
subject do
|
|
described_class.last.real_next_run(worker_cron: worker_cron,
|
|
worker_time_zone: worker_time_zone)
|
|
end
|
|
|
|
context 'when GitLab time_zone is UTC' do
|
|
before do
|
|
allow(Time).to receive(:zone)
|
|
.and_return(ActiveSupport::TimeZone[worker_time_zone])
|
|
end
|
|
|
|
let(:worker_time_zone) { 'UTC' }
|
|
|
|
context 'when cron_timezone is Eastern Time (US & Canada)' do
|
|
before do
|
|
create(:ci_pipeline_schedule, :nightly,
|
|
cron_timezone: 'Eastern Time (US & Canada)')
|
|
end
|
|
|
|
let(:worker_cron) { '0 1 2 3 *' }
|
|
|
|
it 'returns the next time worker executes' do
|
|
expect(subject.min).to eq(0)
|
|
expect(subject.hour).to eq(1)
|
|
expect(subject.day).to eq(2)
|
|
expect(subject.month).to eq(3)
|
|
end
|
|
end
|
|
end
|
|
end
|
|
|
|
describe '#job_variables' do
|
|
let!(:pipeline_schedule) { create(:ci_pipeline_schedule) }
|
|
|
|
let!(:pipeline_schedule_variables) do
|
|
create_list(:ci_pipeline_schedule_variable, 2, pipeline_schedule: pipeline_schedule)
|
|
end
|
|
|
|
subject { pipeline_schedule.job_variables }
|
|
|
|
before do
|
|
pipeline_schedule.reload
|
|
end
|
|
|
|
it { is_expected.to contain_exactly(*pipeline_schedule_variables.map(&:to_runner_variable)) }
|
|
end
|
|
end
|