|
1
|
module Actions
|
|
2
|
module ForemanPipeline
|
|
3
|
module Job
|
|
4
|
class CvPublishJobHook < JobHook
|
|
5
|
|
|
6
|
def self.subscribe
|
|
7
|
Katello::ContentView::Publish
|
|
8
|
end
|
|
9
|
|
|
10
|
def plan(content_view, descripton)
|
|
11
|
valid_jobs = content_view.jobs.select { |job| job.is_valid? }
|
|
12
|
jobs_to_run = valid_jobs.select { |job| job.environment.library? }
|
|
13
|
allowed_jobs = jobs_to_run.select { |job| job.levelup_trigger && job.not_yet_promoted? }
|
|
14
|
|
|
15
|
plan_self(:trigger => trigger.output,
|
|
16
|
:job_ids => allowed_jobs.map(&:id),
|
|
17
|
:job_names => allowed_jobs.map(&:name))
|
|
18
|
end
|
|
19
|
end
|
|
20
|
end
|
|
21
|
end
|
|
22
|
end
|
