debian-mirror-gitlab/lib/ci/gitlab_ci_yaml_processor.rb

331 lines
11 KiB
Ruby
Raw Normal View History

2015-09-25 12:07:36 +05:30
module Ci
class GitlabCiYamlProcessor
class ValidationError < StandardError; end
2016-08-24 12:49:21 +05:30
include Gitlab::Ci::Config::Node::LegacyValidationHelpers
2015-09-25 12:07:36 +05:30
DEFAULT_STAGE = 'test'
2016-06-02 11:05:42 +05:30
ALLOWED_YAML_KEYS = [:before_script, :after_script, :image, :services, :types, :stages, :variables, :cache]
ALLOWED_JOB_KEYS = [:tags, :script, :only, :except, :type, :image, :services,
:allow_failure, :type, :stage, :when, :artifacts, :cache,
:dependencies, :before_script, :after_script, :variables,
:environment]
ALLOWED_CACHE_KEYS = [:key, :untracked, :paths]
ALLOWED_ARTIFACTS_KEYS = [:name, :untracked, :paths, :when, :expire_in]
2015-09-25 12:07:36 +05:30
2016-08-24 12:49:21 +05:30
attr_reader :path, :cache, :stages
2015-09-25 12:07:36 +05:30
2015-11-26 14:37:03 +05:30
def initialize(config, path = nil)
@ci_config = Gitlab::Ci::Config.new(config)
@config = @ci_config.to_hash
2015-09-25 12:07:36 +05:30
@path = path
2015-09-25 12:07:36 +05:30
2016-08-24 12:49:21 +05:30
unless @ci_config.valid?
raise ValidationError, @ci_config.errors.first
end
2015-09-25 12:07:36 +05:30
2016-08-24 12:49:21 +05:30
initial_parsing
2015-09-25 12:07:36 +05:30
validate!
rescue Gitlab::Ci::Config::Loader::FormatError => e
raise ValidationError, e.message
2015-09-25 12:07:36 +05:30
end
2016-08-24 12:49:21 +05:30
def jobs_for_ref(ref, tag = false, trigger_request = nil)
@jobs.select do |_, job|
process?(job[:only], job[:except], ref, tag, trigger_request)
2016-06-22 15:30:34 +05:30
end
2015-09-25 12:07:36 +05:30
end
2016-08-24 12:49:21 +05:30
def jobs_for_stage_and_ref(stage, ref, tag = false, trigger_request = nil)
jobs_for_ref(ref, tag, trigger_request).select do |_, job|
job[:stage] == stage
2015-09-25 12:07:36 +05:30
end
end
2016-08-24 12:49:21 +05:30
def builds_for_ref(ref, tag = false, trigger_request = nil)
jobs_for_ref(ref, tag, trigger_request).map do |name, _|
build_attributes(name)
end
2016-06-02 11:05:42 +05:30
end
2016-08-24 12:49:21 +05:30
def builds_for_stage_and_ref(stage, ref, tag = false, trigger_request = nil)
jobs_for_stage_and_ref(stage, ref, tag, trigger_request).map do |name, _|
build_attributes(name)
end
2016-06-02 11:05:42 +05:30
end
2015-09-25 12:07:36 +05:30
2016-08-24 12:49:21 +05:30
def builds
@jobs.map do |name, _|
build_attributes(name)
end
2015-09-25 12:07:36 +05:30
end
2016-08-24 12:49:21 +05:30
def build_attributes(name)
job = @jobs[name.to_sym] || {}
2015-09-25 12:07:36 +05:30
{
2016-08-24 12:49:21 +05:30
stage_idx: @stages.index(job[:stage]),
2015-09-25 12:07:36 +05:30
stage: job[:stage],
2016-08-24 12:49:21 +05:30
##
# Refactoring note:
# - before script behaves differently than after script
# - after script returns an array of commands
# - before script should be a concatenated command
commands: [job[:before_script] || @before_script, job[:script]].flatten.compact.join("\n"),
2015-10-24 18:46:33 +05:30
tag_list: job[:tags] || [],
2015-09-25 12:07:36 +05:30
name: name,
allow_failure: job[:allow_failure] || false,
2015-10-24 18:46:33 +05:30
when: job[:when] || 'on_success',
environment: job[:environment],
2016-08-24 12:49:21 +05:30
yaml_variables: yaml_variables(name),
2015-09-25 12:07:36 +05:30
options: {
image: job[:image] || @image,
2015-11-26 14:37:03 +05:30
services: job[:services] || @services,
artifacts: job[:artifacts],
cache: job[:cache] || @cache,
2016-06-02 11:05:42 +05:30
dependencies: job[:dependencies],
after_script: job[:after_script] || @after_script,
2015-09-25 12:07:36 +05:30
}.compact
}
end
2016-08-24 12:49:21 +05:30
private
2016-08-24 12:49:21 +05:30
def initial_parsing
@before_script = @ci_config.before_script
@image = @ci_config.image
@after_script = @ci_config.after_script
@services = @ci_config.services
@variables = @ci_config.variables
@stages = @ci_config.stages
@cache = @ci_config.cache
2016-06-02 11:05:42 +05:30
2016-08-24 12:49:21 +05:30
@jobs = {}
2016-06-02 11:05:42 +05:30
2016-08-24 12:49:21 +05:30
@config.except!(*ALLOWED_YAML_KEYS)
@config.each { |name, param| add_job(name, param) }
2015-09-25 12:07:36 +05:30
2016-08-24 12:49:21 +05:30
raise ValidationError, "Please define at least one job" if @jobs.none?
end
2016-06-02 11:05:42 +05:30
2016-08-24 12:49:21 +05:30
def add_job(name, job)
return if name.to_s.start_with?('.')
2015-09-25 12:07:36 +05:30
2016-08-24 12:49:21 +05:30
raise ValidationError, "Unknown parameter: #{name}" unless job.is_a?(Hash) && job.has_key?(:script)
2015-09-25 12:07:36 +05:30
2016-08-24 12:49:21 +05:30
stage = job[:stage] || job[:type] || DEFAULT_STAGE
@jobs[name] = { stage: stage }.merge(job)
end
2015-09-25 12:07:36 +05:30
2016-08-24 12:49:21 +05:30
def yaml_variables(name)
variables = global_variables.merge(job_variables(name))
variables.map do |key, value|
{ key: key, value: value, public: true }
2015-09-25 12:07:36 +05:30
end
2016-08-24 12:49:21 +05:30
end
2015-09-25 12:07:36 +05:30
2016-08-24 12:49:21 +05:30
def global_variables
@variables || {}
2016-06-02 11:05:42 +05:30
end
2015-11-26 14:37:03 +05:30
2016-08-24 12:49:21 +05:30
def job_variables(name)
job = @jobs[name.to_sym]
return {} unless job
2016-08-24 12:49:21 +05:30
job[:variables] || {}
end
2015-11-26 14:37:03 +05:30
2016-08-24 12:49:21 +05:30
def validate!
@jobs.each do |name, job|
validate_job!(name, job)
2015-09-25 12:07:36 +05:30
end
2016-08-24 12:49:21 +05:30
true
2015-09-25 12:07:36 +05:30
end
def validate_job!(name, job)
2015-12-23 02:04:40 +05:30
validate_job_name!(name)
validate_job_keys!(name, job)
validate_job_types!(name, job)
2016-06-02 11:05:42 +05:30
validate_job_script!(name, job)
2015-12-23 02:04:40 +05:30
validate_job_stage!(name, job) if job[:stage]
2016-06-02 11:05:42 +05:30
validate_job_variables!(name, job) if job[:variables]
2015-12-23 02:04:40 +05:30
validate_job_cache!(name, job) if job[:cache]
validate_job_artifacts!(name, job) if job[:artifacts]
2016-06-02 11:05:42 +05:30
validate_job_dependencies!(name, job) if job[:dependencies]
2015-12-23 02:04:40 +05:30
end
def validate_job_name!(name)
2015-11-26 14:37:03 +05:30
if name.blank? || !validate_string(name)
raise ValidationError, "job name should be non-empty string"
end
2015-12-23 02:04:40 +05:30
end
2015-11-26 14:37:03 +05:30
2015-12-23 02:04:40 +05:30
def validate_job_keys!(name, job)
2015-09-25 12:07:36 +05:30
job.keys.each do |key|
unless ALLOWED_JOB_KEYS.include? key
2015-11-26 14:37:03 +05:30
raise ValidationError, "#{name} job: unknown parameter #{key}"
2015-09-25 12:07:36 +05:30
end
end
2015-12-23 02:04:40 +05:30
end
2015-09-25 12:07:36 +05:30
2015-12-23 02:04:40 +05:30
def validate_job_types!(name, job)
2015-11-26 14:37:03 +05:30
if job[:image] && !validate_string(job[:image])
raise ValidationError, "#{name} job: image should be a string"
2015-09-25 12:07:36 +05:30
end
if job[:services] && !validate_array_of_strings(job[:services])
2015-11-26 14:37:03 +05:30
raise ValidationError, "#{name} job: services should be an array of strings"
2015-09-25 12:07:36 +05:30
end
if job[:tags] && !validate_array_of_strings(job[:tags])
2015-11-26 14:37:03 +05:30
raise ValidationError, "#{name} job: tags parameter should be an array of strings"
2015-09-25 12:07:36 +05:30
end
2016-06-22 15:30:34 +05:30
if job[:only] && !validate_array_of_strings_or_regexps(job[:only])
raise ValidationError, "#{name} job: only parameter should be an array of strings or regexps"
2015-09-25 12:07:36 +05:30
end
2016-06-22 15:30:34 +05:30
if job[:except] && !validate_array_of_strings_or_regexps(job[:except])
raise ValidationError, "#{name} job: except parameter should be an array of strings or regexps"
2015-09-25 12:07:36 +05:30
end
2015-12-23 02:04:40 +05:30
if job[:allow_failure] && !validate_boolean(job[:allow_failure])
raise ValidationError, "#{name} job: allow_failure parameter should be an boolean"
2015-11-26 14:37:03 +05:30
end
2016-08-24 12:49:21 +05:30
if job[:when] && !job[:when].in?(%w[on_success on_failure always manual])
raise ValidationError, "#{name} job: when parameter should be on_success, on_failure, always or manual"
2015-12-23 02:04:40 +05:30
end
if job[:environment] && !validate_environment(job[:environment])
raise ValidationError, "#{name} job: environment parameter #{Gitlab::Regex.environment_name_regex_message}"
end
2015-12-23 02:04:40 +05:30
end
2015-11-26 14:37:03 +05:30
2016-06-02 11:05:42 +05:30
def validate_job_script!(name, job)
if !validate_string(job[:script]) && !validate_array_of_strings(job[:script])
raise ValidationError, "#{name} job: script should be a string or an array of a strings"
end
if job[:before_script] && !validate_array_of_strings(job[:before_script])
raise ValidationError, "#{name} job: before_script should be an array of strings"
end
if job[:after_script] && !validate_array_of_strings(job[:after_script])
raise ValidationError, "#{name} job: after_script should be an array of strings"
end
end
2015-12-23 02:04:40 +05:30
def validate_job_stage!(name, job)
2016-08-24 12:49:21 +05:30
unless job[:stage].is_a?(String) && job[:stage].in?(@stages)
raise ValidationError, "#{name} job: stage parameter should be #{@stages.join(", ")}"
2015-11-26 14:37:03 +05:30
end
2015-12-23 02:04:40 +05:30
end
2015-11-26 14:37:03 +05:30
2016-06-02 11:05:42 +05:30
def validate_job_variables!(name, job)
unless validate_variables(job[:variables])
raise ValidationError,
"#{name} job: variables should be a map of key-value strings"
end
end
2015-12-23 02:04:40 +05:30
def validate_job_cache!(name, job)
job[:cache].keys.each do |key|
unless ALLOWED_CACHE_KEYS.include? key
raise ValidationError, "#{name} job: cache unknown parameter #{key}"
end
end
2016-01-29 22:53:50 +05:30
if job[:cache][:key] && !validate_string(job[:cache][:key])
raise ValidationError, "#{name} job: cache:key parameter should be a string"
end
2015-12-23 02:04:40 +05:30
if job[:cache][:untracked] && !validate_boolean(job[:cache][:untracked])
raise ValidationError, "#{name} job: cache:untracked parameter should be an boolean"
2015-09-25 12:07:36 +05:30
end
2015-10-24 18:46:33 +05:30
2015-12-23 02:04:40 +05:30
if job[:cache][:paths] && !validate_array_of_strings(job[:cache][:paths])
raise ValidationError, "#{name} job: cache:paths parameter should be an array of strings"
2015-10-24 18:46:33 +05:30
end
2015-09-25 12:07:36 +05:30
end
2015-12-23 02:04:40 +05:30
def validate_job_artifacts!(name, job)
job[:artifacts].keys.each do |key|
unless ALLOWED_ARTIFACTS_KEYS.include? key
raise ValidationError, "#{name} job: artifacts unknown parameter #{key}"
end
end
2016-06-02 11:05:42 +05:30
if job[:artifacts][:name] && !validate_string(job[:artifacts][:name])
raise ValidationError, "#{name} job: artifacts:name parameter should be a string"
end
2015-12-23 02:04:40 +05:30
if job[:artifacts][:untracked] && !validate_boolean(job[:artifacts][:untracked])
raise ValidationError, "#{name} job: artifacts:untracked parameter should be an boolean"
end
if job[:artifacts][:paths] && !validate_array_of_strings(job[:artifacts][:paths])
raise ValidationError, "#{name} job: artifacts:paths parameter should be an array of strings"
end
if job[:artifacts][:when] && !job[:artifacts][:when].in?(%w[on_success on_failure always])
raise ValidationError, "#{name} job: artifacts:when parameter should be on_success, on_failure or always"
end
if job[:artifacts][:expire_in] && !validate_duration(job[:artifacts][:expire_in])
raise ValidationError, "#{name} job: artifacts:expire_in parameter should be a duration"
end
2015-12-23 02:04:40 +05:30
end
2015-09-25 12:07:36 +05:30
2016-06-02 11:05:42 +05:30
def validate_job_dependencies!(name, job)
unless validate_array_of_strings(job[:dependencies])
2016-06-02 11:05:42 +05:30
raise ValidationError, "#{name} job: dependencies parameter should be an array of strings"
end
2016-08-24 12:49:21 +05:30
stage_index = @stages.index(job[:stage])
2016-06-02 11:05:42 +05:30
job[:dependencies].each do |dependency|
raise ValidationError, "#{name} job: undefined dependency: #{dependency}" unless @jobs[dependency.to_sym]
2016-08-24 12:49:21 +05:30
unless @stages.index(@jobs[dependency.to_sym][:stage]) < stage_index
2016-06-02 11:05:42 +05:30
raise ValidationError, "#{name} job: dependency #{dependency} is not defined in prior stages"
end
end
end
def process?(only_params, except_params, ref, tag, trigger_request)
2015-11-26 14:37:03 +05:30
if only_params.present?
2016-06-02 11:05:42 +05:30
return false unless matching?(only_params, ref, tag, trigger_request)
2015-11-26 14:37:03 +05:30
end
if except_params.present?
2016-06-02 11:05:42 +05:30
return false if matching?(except_params, ref, tag, trigger_request)
2015-11-26 14:37:03 +05:30
end
true
end
2016-06-02 11:05:42 +05:30
def matching?(patterns, ref, tag, trigger_request)
2015-11-26 14:37:03 +05:30
patterns.any? do |pattern|
2016-06-02 11:05:42 +05:30
match_ref?(pattern, ref, tag, trigger_request)
2015-11-26 14:37:03 +05:30
end
end
2016-06-02 11:05:42 +05:30
def match_ref?(pattern, ref, tag, trigger_request)
2015-11-26 14:37:03 +05:30
pattern, path = pattern.split('@', 2)
return false if path && path != self.path
return true if tag && pattern == 'tags'
return true if !tag && pattern == 'branches'
2016-06-02 11:05:42 +05:30
return true if trigger_request.present? && pattern == 'triggers'
2015-11-26 14:37:03 +05:30
if pattern.first == "/" && pattern.last == "/"
Regexp.new(pattern[1...-1]) =~ ref
else
pattern == ref
end
2015-09-25 12:07:36 +05:30
end
end
end