2015-08-25 21:42:46 -04:00
|
|
|
module Ci
|
2016-06-02 10:19:18 -04:00
|
|
|
class Pipeline < ActiveRecord::Base
|
2015-08-25 21:42:46 -04:00
|
|
|
extend Ci::Model
|
2016-04-16 15:46:26 -04:00
|
|
|
include Statuseable
|
2015-09-24 11:09:33 -04:00
|
|
|
|
2016-06-03 06:00:16 -04:00
|
|
|
self.table_name = 'ci_commits'
|
|
|
|
|
2015-12-04 06:55:23 -05:00
|
|
|
belongs_to :project, class_name: '::Project', foreign_key: :gl_project_id
|
2016-07-15 09:42:29 -04:00
|
|
|
belongs_to :user
|
|
|
|
|
2016-06-03 07:58:35 -04:00
|
|
|
has_many :statuses, class_name: 'CommitStatus', foreign_key: :commit_id
|
|
|
|
has_many :builds, class_name: 'Ci::Build', foreign_key: :commit_id
|
2016-06-03 08:46:17 -04:00
|
|
|
has_many :trigger_requests, dependent: :destroy, class_name: 'Ci::TriggerRequest', foreign_key: :commit_id
|
2015-08-25 21:42:46 -04:00
|
|
|
|
2015-10-02 07:46:38 -04:00
|
|
|
validates_presence_of :sha
|
2016-08-11 09:22:35 -04:00
|
|
|
validates_presence_of :ref
|
2016-04-16 16:43:40 -04:00
|
|
|
validates_presence_of :status
|
2015-08-25 21:42:46 -04:00
|
|
|
validate :valid_commit_sha
|
|
|
|
|
2016-07-03 19:58:58 -04:00
|
|
|
after_save :keep_around_commits
|
2016-04-11 10:55:40 -04:00
|
|
|
|
2016-08-11 11:23:07 -04:00
|
|
|
delegate :stages, to: :statuses
|
|
|
|
|
2016-08-11 14:54:02 -04:00
|
|
|
state_machine :status, initial: :created do
|
2016-08-12 05:36:51 -04:00
|
|
|
event :queue do
|
2016-08-12 06:23:47 -04:00
|
|
|
transition created: :pending
|
2016-08-12 05:53:27 -04:00
|
|
|
transition any - [:created, :pending] => :running
|
2016-08-12 05:36:51 -04:00
|
|
|
end
|
|
|
|
|
|
|
|
event :run do
|
2016-08-12 05:53:27 -04:00
|
|
|
transition any => :running
|
2016-08-12 05:36:51 -04:00
|
|
|
end
|
|
|
|
|
2016-08-11 14:54:02 -04:00
|
|
|
event :skip do
|
|
|
|
transition any => :skipped
|
|
|
|
end
|
|
|
|
|
|
|
|
event :drop do
|
|
|
|
transition any => :failed
|
|
|
|
end
|
|
|
|
|
2016-08-12 05:36:51 -04:00
|
|
|
event :succeed do
|
|
|
|
transition any => :success
|
|
|
|
end
|
|
|
|
|
|
|
|
event :cancel do
|
|
|
|
transition any => :canceled
|
2016-08-11 14:54:02 -04:00
|
|
|
end
|
|
|
|
|
2016-08-12 05:53:27 -04:00
|
|
|
before_transition [:created, :pending] => :running do |pipeline|
|
|
|
|
pipeline.started_at = Time.now
|
2016-08-11 14:54:02 -04:00
|
|
|
end
|
|
|
|
|
2016-08-12 05:53:27 -04:00
|
|
|
before_transition any => [:success, :failed, :canceled] do |pipeline|
|
|
|
|
pipeline.finished_at = Time.now
|
2016-08-11 14:54:02 -04:00
|
|
|
end
|
|
|
|
|
2016-08-12 05:53:27 -04:00
|
|
|
before_transition do |pipeline|
|
2016-08-11 14:54:02 -04:00
|
|
|
pipeline.update_duration
|
|
|
|
end
|
2016-08-12 06:03:30 -04:00
|
|
|
|
|
|
|
after_transition do |pipeline, transition|
|
|
|
|
pipeline.execute_hooks unless transition.loopback?
|
|
|
|
end
|
2016-08-11 14:54:02 -04:00
|
|
|
end
|
|
|
|
|
2016-07-19 10:08:16 -04:00
|
|
|
# ref can't be HEAD or SHA, can only be branch/tag name
|
2016-07-19 12:52:16 -04:00
|
|
|
scope :latest_successful_for, ->(ref = default_branch) do
|
2016-07-20 09:46:46 -04:00
|
|
|
where(ref: ref).success.order(id: :desc).limit(1)
|
2016-07-19 08:59:38 -04:00
|
|
|
end
|
|
|
|
|
2015-08-25 21:42:46 -04:00
|
|
|
def self.truncate_sha(sha)
|
|
|
|
sha[0...8]
|
|
|
|
end
|
|
|
|
|
2016-04-12 13:57:54 -04:00
|
|
|
def self.stages
|
2016-05-14 15:47:47 -04:00
|
|
|
# We use pluck here due to problems with MySQL which doesn't allow LIMIT/OFFSET in queries
|
2016-06-03 09:35:16 -04:00
|
|
|
CommitStatus.where(pipeline: pluck(:id)).stages
|
2016-04-12 13:57:54 -04:00
|
|
|
end
|
|
|
|
|
2016-08-10 10:45:30 -04:00
|
|
|
def self.duration
|
|
|
|
where.not(duration: nil).pluck(:duration).inject(0, &:+)
|
|
|
|
end
|
|
|
|
|
2015-09-28 07:35:26 -04:00
|
|
|
def project_id
|
|
|
|
project.id
|
2015-09-28 07:14:34 -04:00
|
|
|
end
|
|
|
|
|
2015-08-25 21:42:46 -04:00
|
|
|
def valid_commit_sha
|
2015-12-11 11:57:04 -05:00
|
|
|
if self.sha == Gitlab::Git::BLANK_SHA
|
2015-08-25 21:42:46 -04:00
|
|
|
self.errors.add(:sha, " cant be 00000000 (branch removal)")
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
def git_author_name
|
2016-06-21 08:43:37 -04:00
|
|
|
commit.try(:author_name)
|
2015-08-25 21:42:46 -04:00
|
|
|
end
|
|
|
|
|
|
|
|
def git_author_email
|
2016-06-21 08:43:37 -04:00
|
|
|
commit.try(:author_email)
|
2015-08-25 21:42:46 -04:00
|
|
|
end
|
|
|
|
|
|
|
|
def git_commit_message
|
2016-06-21 08:43:37 -04:00
|
|
|
commit.try(:message)
|
2015-08-25 21:42:46 -04:00
|
|
|
end
|
|
|
|
|
2016-07-11 03:11:20 -04:00
|
|
|
def git_commit_title
|
|
|
|
commit.try(:title)
|
|
|
|
end
|
|
|
|
|
2015-08-25 21:42:46 -04:00
|
|
|
def short_sha
|
2016-06-02 10:19:18 -04:00
|
|
|
Ci::Pipeline.truncate_sha(sha)
|
2015-08-25 21:42:46 -04:00
|
|
|
end
|
|
|
|
|
2016-06-21 08:43:37 -04:00
|
|
|
def commit
|
2015-12-04 06:55:23 -05:00
|
|
|
@commit ||= project.commit(sha)
|
2015-08-25 21:42:46 -04:00
|
|
|
rescue
|
|
|
|
nil
|
|
|
|
end
|
|
|
|
|
2016-03-31 13:51:28 -04:00
|
|
|
def branch?
|
|
|
|
!tag?
|
|
|
|
end
|
|
|
|
|
2016-07-16 17:06:34 -04:00
|
|
|
def manual_actions
|
|
|
|
builds.latest.manual_actions
|
2016-07-16 12:39:58 -04:00
|
|
|
end
|
|
|
|
|
2016-03-31 13:51:28 -04:00
|
|
|
def retryable?
|
|
|
|
builds.latest.any? do |build|
|
2016-04-16 16:43:40 -04:00
|
|
|
build.failed? && build.retryable?
|
2016-03-31 13:51:28 -04:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2016-05-31 09:26:00 -04:00
|
|
|
def cancelable?
|
|
|
|
builds.running_or_pending.any?
|
|
|
|
end
|
|
|
|
|
2016-05-09 19:26:13 -04:00
|
|
|
def cancel_running
|
|
|
|
builds.running_or_pending.each(&:cancel)
|
|
|
|
end
|
|
|
|
|
2016-06-14 07:04:10 -04:00
|
|
|
def retry_failed(user)
|
|
|
|
builds.latest.failed.select(&:retryable?).each do |build|
|
|
|
|
Ci::Build.retry(build, user)
|
|
|
|
end
|
2016-05-09 19:26:13 -04:00
|
|
|
end
|
|
|
|
|
2016-04-13 07:01:08 -04:00
|
|
|
def latest?
|
|
|
|
return false unless ref
|
|
|
|
commit = project.commit(ref)
|
|
|
|
return false unless commit
|
|
|
|
commit.sha == sha
|
|
|
|
end
|
|
|
|
|
2016-04-12 13:57:22 -04:00
|
|
|
def triggered?
|
|
|
|
trigger_requests.any?
|
|
|
|
end
|
|
|
|
|
2015-10-06 06:01:16 -04:00
|
|
|
def retried
|
|
|
|
@retried ||= (statuses.order(id: :desc) - statuses.latest)
|
2015-08-25 21:42:46 -04:00
|
|
|
end
|
|
|
|
|
|
|
|
def coverage
|
2016-04-13 14:51:03 -04:00
|
|
|
coverage_array = statuses.latest.map(&:coverage).compact
|
2015-12-04 06:55:23 -05:00
|
|
|
if coverage_array.size >= 1
|
|
|
|
'%.2f' % (coverage_array.reduce(:+) / coverage_array.size)
|
2015-08-25 21:42:46 -04:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2016-08-11 09:22:35 -04:00
|
|
|
def config_builds_attributes
|
|
|
|
return [] unless config_processor
|
|
|
|
|
|
|
|
config_processor.
|
|
|
|
builds_for_ref(ref, tag?, trigger_requests.first).
|
|
|
|
sort_by { |build| build[:stage_idx] }
|
|
|
|
end
|
|
|
|
|
2016-07-14 10:58:05 -04:00
|
|
|
def has_warnings?
|
|
|
|
builds.latest.ignored.any?
|
2016-07-12 13:05:48 -04:00
|
|
|
end
|
|
|
|
|
2015-08-25 21:42:46 -04:00
|
|
|
def config_processor
|
2015-11-18 10:32:00 -05:00
|
|
|
return nil unless ci_yaml_file
|
2016-04-13 14:54:21 -04:00
|
|
|
return @config_processor if defined?(@config_processor)
|
|
|
|
|
|
|
|
@config_processor ||= begin
|
|
|
|
Ci::GitlabCiYamlProcessor.new(ci_yaml_file, project.path_with_namespace)
|
|
|
|
rescue Ci::GitlabCiYamlProcessor::ValidationError, Psych::SyntaxError => e
|
2016-06-02 07:52:19 -04:00
|
|
|
self.yaml_errors = e.message
|
2016-04-13 14:54:21 -04:00
|
|
|
nil
|
|
|
|
rescue
|
2016-06-02 06:39:15 -04:00
|
|
|
self.yaml_errors = 'Undefined error'
|
2016-04-13 14:54:21 -04:00
|
|
|
nil
|
|
|
|
end
|
2015-08-25 21:42:46 -04:00
|
|
|
end
|
|
|
|
|
2015-10-02 07:46:38 -04:00
|
|
|
def ci_yaml_file
|
2016-04-13 14:54:21 -04:00
|
|
|
return @ci_yaml_file if defined?(@ci_yaml_file)
|
|
|
|
|
2016-02-02 08:35:09 -05:00
|
|
|
@ci_yaml_file ||= begin
|
|
|
|
blob = project.repository.blob_at(sha, '.gitlab-ci.yml')
|
|
|
|
blob.load_all_data!(project.repository)
|
|
|
|
blob.data
|
2016-04-13 14:54:21 -04:00
|
|
|
rescue
|
|
|
|
nil
|
2016-02-02 08:35:09 -05:00
|
|
|
end
|
2015-10-02 07:46:38 -04:00
|
|
|
end
|
|
|
|
|
2016-04-29 09:14:38 -04:00
|
|
|
def environments
|
|
|
|
builds.where.not(environment: nil).success.pluck(:environment).uniq
|
|
|
|
end
|
|
|
|
|
2016-06-23 06:29:11 -04:00
|
|
|
# Manually set the notes for a Ci::Pipeline
|
|
|
|
# There is no ActiveRecord relation between Ci::Pipeline and notes
|
|
|
|
# as they are related to a commit sha. This method helps importing
|
|
|
|
# them using the +Gitlab::ImportExport::RelationFactory+ class.
|
|
|
|
def notes=(notes)
|
|
|
|
notes.each do |note|
|
|
|
|
note[:id] = nil
|
|
|
|
note[:commit_id] = sha
|
|
|
|
note[:noteable_id] = self['id']
|
|
|
|
note.save!
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2016-06-13 04:55:54 -04:00
|
|
|
def notes
|
|
|
|
Note.for_commit_id(sha)
|
|
|
|
end
|
|
|
|
|
2016-08-11 09:22:35 -04:00
|
|
|
def process!
|
|
|
|
Ci::ProcessPipelineService.new(project, user).execute(self)
|
|
|
|
end
|
2016-08-11 12:37:36 -04:00
|
|
|
|
2016-08-12 05:36:51 -04:00
|
|
|
def build_updated
|
|
|
|
case latest_builds_status
|
|
|
|
when 'pending'
|
|
|
|
queue
|
|
|
|
when 'running'
|
|
|
|
run
|
|
|
|
when 'success'
|
|
|
|
succeed
|
|
|
|
when 'failed'
|
|
|
|
drop
|
|
|
|
when 'canceled'
|
|
|
|
cancel
|
|
|
|
when 'skipped'
|
|
|
|
skip
|
|
|
|
end
|
2016-08-11 09:22:35 -04:00
|
|
|
end
|
|
|
|
|
2016-07-20 07:17:21 -04:00
|
|
|
def predefined_variables
|
|
|
|
[
|
|
|
|
{ key: 'CI_PIPELINE_ID', value: id.to_s, public: true }
|
|
|
|
]
|
|
|
|
end
|
|
|
|
|
2016-08-11 14:54:02 -04:00
|
|
|
def update_duration
|
2016-04-13 14:51:03 -04:00
|
|
|
self.duration = statuses.latest.duration
|
2016-08-02 06:06:31 -04:00
|
|
|
end
|
|
|
|
|
|
|
|
def execute_hooks
|
|
|
|
project.execute_hooks(pipeline_data, :pipeline_hooks)
|
2016-08-04 12:43:16 -04:00
|
|
|
project.execute_services(pipeline_data, :pipeline_hooks)
|
|
|
|
end
|
|
|
|
|
2016-06-02 11:17:23 -04:00
|
|
|
private
|
|
|
|
|
2016-08-04 12:43:16 -04:00
|
|
|
def pipeline_data
|
2016-08-12 04:09:29 -04:00
|
|
|
Gitlab::DataBuilder::Pipeline.build(self)
|
2016-04-11 10:55:40 -04:00
|
|
|
end
|
2016-07-03 19:58:58 -04:00
|
|
|
|
2016-08-12 05:36:51 -04:00
|
|
|
def latest_builds_status
|
2016-08-11 14:54:02 -04:00
|
|
|
return 'failed' unless yaml_errors.blank?
|
|
|
|
|
|
|
|
statuses.latest.status || 'skipped'
|
2016-04-11 10:55:40 -04:00
|
|
|
end
|
2016-07-03 19:58:58 -04:00
|
|
|
|
|
|
|
def keep_around_commits
|
2016-07-15 18:33:30 -04:00
|
|
|
return unless project
|
2016-07-19 08:59:38 -04:00
|
|
|
|
2016-07-03 19:58:58 -04:00
|
|
|
project.repository.keep_around(self.sha)
|
|
|
|
project.repository.keep_around(self.before_sha)
|
|
|
|
end
|
2015-08-25 21:42:46 -04:00
|
|
|
end
|
|
|
|
end
|