133 lines
4.3 KiB
Ruby
133 lines
4.3 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
module Gitlab
|
|
module Ci
|
|
module Status
|
|
class Composite
|
|
include Gitlab::Utils::StrongMemoize
|
|
|
|
# This class accepts an array of arrays/hashes/or objects
|
|
def initialize(all_statuses, with_allow_failure: true, dag: false)
|
|
unless all_statuses.respond_to?(:pluck)
|
|
raise ArgumentError, "all_statuses needs to respond to `.pluck`"
|
|
end
|
|
|
|
@status_set = Set.new
|
|
@status_key = 0
|
|
@allow_failure_key = 1 if with_allow_failure
|
|
@dag = dag
|
|
|
|
consume_all_statuses(all_statuses)
|
|
end
|
|
|
|
# The status calculation is order dependent,
|
|
# 1. In some cases we assume that that status is exact
|
|
# if the we only have given statues,
|
|
# 2. In other cases we assume that status is of that type
|
|
# based on what statuses are no longer valid based on the
|
|
# data set that we have
|
|
# rubocop: disable Metrics/CyclomaticComplexity
|
|
# rubocop: disable Metrics/PerceivedComplexity
|
|
def status
|
|
return if none?
|
|
|
|
strong_memoize(:status) do
|
|
if @dag && any_of?(:skipped)
|
|
# The DAG job is skipped if one of the needs does not run at all.
|
|
'skipped'
|
|
elsif @dag && !only_of?(:success, :failed, :canceled, :skipped, :success_with_warnings)
|
|
# DAG is blocked from executing if a dependent is not "complete"
|
|
'pending'
|
|
elsif only_of?(:skipped, :ignored)
|
|
'skipped'
|
|
elsif only_of?(:success, :skipped, :success_with_warnings, :ignored)
|
|
'success'
|
|
elsif only_of?(:created, :success_with_warnings, :ignored)
|
|
'created'
|
|
elsif only_of?(:preparing, :success_with_warnings, :ignored)
|
|
'preparing'
|
|
elsif only_of?(:canceled, :success, :skipped, :success_with_warnings, :ignored)
|
|
'canceled'
|
|
elsif only_of?(:pending, :created, :skipped, :success_with_warnings, :ignored)
|
|
'pending'
|
|
elsif any_of?(:running, :pending)
|
|
'running'
|
|
elsif any_of?(:waiting_for_resource)
|
|
'waiting_for_resource'
|
|
elsif any_of?(:manual)
|
|
'manual'
|
|
elsif any_of?(:scheduled)
|
|
'scheduled'
|
|
elsif any_of?(:preparing)
|
|
'preparing'
|
|
elsif any_of?(:created)
|
|
'running'
|
|
else
|
|
'failed'
|
|
end
|
|
end
|
|
end
|
|
# rubocop: enable Metrics/CyclomaticComplexity
|
|
# rubocop: enable Metrics/PerceivedComplexity
|
|
|
|
def warnings?
|
|
@status_set.include?(:success_with_warnings)
|
|
end
|
|
|
|
private
|
|
|
|
def none?
|
|
@status_set.empty?
|
|
end
|
|
|
|
def any_of?(*names)
|
|
names.any? { |name| @status_set.include?(name) }
|
|
end
|
|
|
|
def only_of?(*names)
|
|
matching = names.count { |name| @status_set.include?(name) }
|
|
matching > 0 &&
|
|
matching == @status_set.size
|
|
end
|
|
|
|
def consume_all_statuses(all_statuses)
|
|
columns = []
|
|
columns[@status_key] = :status
|
|
columns[@allow_failure_key] = :allow_failure if @allow_failure_key
|
|
|
|
all_statuses
|
|
.pluck(*columns) # rubocop: disable CodeReuse/ActiveRecord
|
|
.each(&method(:consume_status))
|
|
end
|
|
|
|
def consume_status(description)
|
|
# convert `"status"` into `["status"]`
|
|
description = Array(description)
|
|
|
|
status =
|
|
if success_with_warnings?(description)
|
|
:success_with_warnings
|
|
elsif ignored_status?(description)
|
|
:ignored
|
|
else
|
|
description[@status_key].to_sym
|
|
end
|
|
|
|
@status_set.add(status)
|
|
end
|
|
|
|
def success_with_warnings?(status)
|
|
@allow_failure_key &&
|
|
status[@allow_failure_key] &&
|
|
::Ci::HasStatus::PASSED_WITH_WARNINGS_STATUSES.include?(status[@status_key])
|
|
end
|
|
|
|
def ignored_status?(status)
|
|
@allow_failure_key &&
|
|
status[@allow_failure_key] &&
|
|
::Ci::HasStatus::EXCLUDE_IGNORED_STATUSES.include?(status[@status_key])
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|