summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorShinya Maeda <gitlab.shinyamaeda@gmail.com>2017-04-01 00:19:46 +0900
committerShinya Maeda <gitlab.shinyamaeda@gmail.com>2017-04-06 23:46:58 +0900
commit21cabf381b55ab2747d773ae1eeb70d2bb40e9a5 (patch)
treeacc2037bde1711fbdbc9ef46e1b0d334ba273feb
parent5720919cd0cd457aa83fa3e3c36e34867b0eed60 (diff)
downloadgitlab-ce-21cabf381b55ab2747d773ae1eeb70d2bb40e9a5.tar.gz
Move real_next_run to helper
-rw-r--r--app/helpers/triggers_helper.rb13
-rw-r--r--app/models/ci/trigger_schedule.rb13
-rw-r--r--spec/helpers/triggers_helper_spec.rb27
-rw-r--r--spec/models/ci/trigger_schedule_spec.rb24
4 files changed, 40 insertions, 37 deletions
diff --git a/app/helpers/triggers_helper.rb b/app/helpers/triggers_helper.rb
index a48d4475e97..be5cce9aea0 100644
--- a/app/helpers/triggers_helper.rb
+++ b/app/helpers/triggers_helper.rb
@@ -10,4 +10,17 @@ module TriggersHelper
def service_trigger_url(service)
"#{Settings.gitlab.url}/api/v3/projects/#{service.project_id}/services/#{service.to_param}/trigger"
end
+
+ def real_next_run(trigger_schedule, worker_cron: nil, worker_time_zone: nil)
+ worker_cron = Settings.cron_jobs['trigger_schedule_worker']['cron'] unless worker_cron.present?
+ worker_time_zone = Time.zone.name unless worker_time_zone.present?
+
+ worker_next_time = Ci::CronParser.new(worker_cron, worker_time_zone).next_time_from(Time.now)
+
+ if trigger_schedule.next_run_at > worker_next_time
+ trigger_schedule.next_run_at
+ else
+ worker_next_time
+ end
+ end
end
diff --git a/app/models/ci/trigger_schedule.rb b/app/models/ci/trigger_schedule.rb
index b861f41fed1..aedba8bdf54 100644
--- a/app/models/ci/trigger_schedule.rb
+++ b/app/models/ci/trigger_schedule.rb
@@ -25,19 +25,6 @@ module Ci
end
end
- def real_next_run(worker_cron: nil, worker_time_zone: nil)
- worker_cron = Settings.cron_jobs['trigger_schedule_worker']['cron'] unless worker_cron.present?
- worker_time_zone = Time.zone.name unless worker_time_zone.present?
-
- worker_next_time = Ci::CronParser.new(worker_cron, worker_time_zone).next_time_from(Time.now)
-
- if next_run_at > worker_next_time
- next_run_at
- else
- worker_next_time
- end
- end
-
private
def less_than_1_hour_from_now?(time)
diff --git a/spec/helpers/triggers_helper_spec.rb b/spec/helpers/triggers_helper_spec.rb
new file mode 100644
index 00000000000..ce17f4442ab
--- /dev/null
+++ b/spec/helpers/triggers_helper_spec.rb
@@ -0,0 +1,27 @@
+require 'rails_helper'
+
+describe TriggersHelper do
+ describe '#real_next_run' do
+ let(:trigger_schedule) { create(:ci_trigger_schedule, cron: user_cron, cron_time_zone: 'UTC') }
+
+ subject { helper.real_next_run(trigger_schedule, worker_cron: worker_cron, worker_time_zone: 'UTC') }
+
+ context 'when next_run_at > worker_next_time' do
+ let(:worker_cron) { '* * * * *' } # every minutes
+ let(:user_cron) { '0 0 1 1 *' } # every 00:00, January 1st
+
+ it 'returns next_run_at' do
+ is_expected.to eq(trigger_schedule.next_run_at)
+ end
+ end
+
+ context 'when worker_next_time > next_run_at' do
+ let(:worker_cron) { '0 0 1 1 *' } # every 00:00, January 1st
+ let(:user_cron) { '0 */6 * * *' } # each six hours
+
+ it 'returns worker_next_time' do
+ is_expected.to eq(Ci::CronParser.new(worker_cron, 'UTC').next_time_from(Time.now))
+ end
+ end
+ end
+end
diff --git a/spec/models/ci/trigger_schedule_spec.rb b/spec/models/ci/trigger_schedule_spec.rb
index da23611f1a0..6a586a4e9b1 100644
--- a/spec/models/ci/trigger_schedule_spec.rb
+++ b/spec/models/ci/trigger_schedule_spec.rb
@@ -54,28 +54,4 @@ describe Ci::TriggerSchedule, models: true do
end
end
end
-
- describe '#real_next_run' do
- let(:trigger_schedule) { create(:ci_trigger_schedule, cron: user_cron, cron_time_zone: 'UTC') }
-
- subject { trigger_schedule.real_next_run(worker_cron: worker_cron, worker_time_zone: 'UTC') }
-
- context 'when next_run_at > worker_next_time' do
- let(:worker_cron) { '* * * * *' } # every minutes
- let(:user_cron) { '0 0 1 1 *' } # every 00:00, January 1st
-
- it 'returns next_run_at' do
- is_expected.to eq(trigger_schedule.next_run_at)
- end
- end
-
- context 'when worker_next_time > next_run_at' do
- let(:worker_cron) { '0 0 1 1 *' } # every 00:00, January 1st
- let(:user_cron) { '0 */6 * * *' } # each six hours
-
- it 'returns worker_next_time' do
- is_expected.to eq(Ci::CronParser.new(worker_cron, 'UTC').next_time_from(Time.now))
- end
- end
- end
end