gitlab-org--gitlab-foss/app/models/ci/commit.rb

216 lines
5 KiB
Ruby
Raw Normal View History

2015-08-25 21:42:46 -04:00
# == Schema Information
#
# Table name: ci_commits
2015-08-25 21:42:46 -04:00
#
# id :integer not null, primary key
# project_id :integer
# ref :string(255)
# sha :string(255)
# before_sha :string(255)
# push_data :text
# created_at :datetime
# updated_at :datetime
# tag :boolean default(FALSE)
# yaml_errors :text
# committed_at :datetime
# gl_project_id :integer
2015-08-25 21:42:46 -04:00
#
module Ci
class Commit < ActiveRecord::Base
extend Ci::Model
2015-09-24 11:09:33 -04:00
2015-12-04 06:55:23 -05:00
belongs_to :project, class_name: '::Project', foreign_key: :gl_project_id
has_many :statuses, class_name: 'CommitStatus'
2015-10-06 06:01:16 -04:00
has_many :builds, class_name: 'Ci::Build'
2015-08-25 21:42:46 -04:00
has_many :trigger_requests, dependent: :destroy, class_name: 'Ci::TriggerRequest'
2015-10-02 07:46:38 -04:00
validates_presence_of :sha
2015-08-25 21:42:46 -04:00
validate :valid_commit_sha
def self.truncate_sha(sha)
sha[0...8]
end
def to_param
sha
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
2015-10-02 07:46:38 -04:00
commit_data.author_name if commit_data
2015-08-25 21:42:46 -04:00
end
def git_author_email
2015-10-02 07:46:38 -04:00
commit_data.author_email if commit_data
2015-08-25 21:42:46 -04:00
end
def git_commit_message
2015-10-02 07:46:38 -04:00
commit_data.message if commit_data
2015-08-25 21:42:46 -04:00
end
def short_sha
Ci::Commit.truncate_sha(sha)
end
def commit_data
2015-12-04 06:55:23 -05:00
@commit ||= project.commit(sha)
2015-08-25 21:42:46 -04:00
rescue
nil
end
def stage
2015-10-12 15:35:52 -04:00
running_or_pending = statuses.latest.running_or_pending.ordered
2015-10-06 06:01:16 -04:00
running_or_pending.first.try(:stage)
2015-08-25 21:42:46 -04:00
end
def create_builds(ref, tag, user, trigger_request = nil)
2015-08-25 21:42:46 -04:00
return unless config_processor
2015-10-05 06:02:26 -04:00
config_processor.stages.any? do |stage|
CreateBuildsService.new.execute(self, stage, ref, tag, user, trigger_request, 'success').present?
2015-10-05 06:02:26 -04:00
end
end
def create_next_builds(build)
2015-10-05 06:02:26 -04:00
return unless config_processor
# don't create other builds if this one is retried
latest_builds = builds.similar(build).latest
return unless latest_builds.exists?(build.id)
2015-10-05 06:02:26 -04:00
# get list of stages after this build
next_stages = config_processor.stages.drop_while { |stage| stage != build.stage }
next_stages.delete(build.stage)
# get status for all prior builds
prior_builds = latest_builds.reject { |other_build| next_stages.include?(other_build.stage) }
status = Ci::Status.get_status(prior_builds)
# create builds for next stages based
next_stages.any? do |stage|
CreateBuildsService.new.execute(self, stage, build.ref, build.tag, build.user, build.trigger_request, status).present?
2015-10-05 06:02:26 -04:00
end
2015-08-25 21:42:46 -04:00
end
2015-10-02 07:46:38 -04:00
def refs
2015-10-12 10:32:58 -04:00
statuses.order(:ref).pluck(:ref).uniq
2015-08-25 21:42:46 -04:00
end
2015-10-12 10:32:58 -04:00
def latest_statuses
@latest_statuses ||= statuses.latest.to_a
2015-10-05 06:38:00 -04:00
end
def latest_statuses_for_ref(ref)
latest_statuses.select { |status| status.ref == ref }
2015-08-25 21:42:46 -04:00
end
def matrix_builds(build = nil)
matrix_builds = builds.latest.ordered
matrix_builds = matrix_builds.similar(build) if build
matrix_builds.to_a
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
2015-10-12 10:32:58 -04:00
def status
2015-10-06 06:01:16 -04:00
if yaml_errors.present?
2015-08-25 21:42:46 -04:00
return 'failed'
2015-10-06 06:01:16 -04:00
end
@status ||= Ci::Status.get_status(latest_statuses)
2015-08-25 21:42:46 -04:00
end
def pending?
2015-10-06 06:01:16 -04:00
status == 'pending'
2015-08-25 21:42:46 -04:00
end
def running?
2015-10-06 06:01:16 -04:00
status == 'running'
2015-08-25 21:42:46 -04:00
end
def success?
2015-10-06 06:01:16 -04:00
status == 'success'
2015-08-25 21:42:46 -04:00
end
def failed?
status == 'failed'
end
def canceled?
2015-10-06 06:01:16 -04:00
status == 'canceled'
2015-08-25 21:42:46 -04:00
end
2015-11-02 11:27:38 -05:00
def active?
running? || pending?
end
def complete?
canceled? || success? || failed?
end
2015-10-12 10:32:58 -04:00
def duration
duration_array = statuses.map(&:duration).compact
2015-10-12 10:32:58 -04:00
duration_array.reduce(:+).to_i
2015-10-02 07:46:38 -04:00
end
def started_at
@started_at ||= statuses.order('started_at ASC').first.try(:started_at)
end
2015-08-25 21:42:46 -04:00
def finished_at
2015-10-06 06:01:16 -04:00
@finished_at ||= statuses.order('finished_at DESC').first.try(:finished_at)
2015-08-25 21:42:46 -04:00
end
def coverage
coverage_array = latest_statuses.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
def config_processor
return nil unless ci_yaml_file
2015-12-04 06:55:23 -05:00
@config_processor ||= Ci::GitlabCiYamlProcessor.new(ci_yaml_file, project.path_with_namespace)
rescue Ci::GitlabCiYamlProcessor::ValidationError, Psych::SyntaxError => e
2015-08-25 21:42:46 -04:00
save_yaml_error(e.message)
nil
rescue
save_yaml_error("Undefined error")
2015-08-25 21:42:46 -04:00
nil
end
2015-10-02 07:46:38 -04:00
def 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
end
2015-10-02 07:46:38 -04:00
rescue
nil
end
2015-08-25 21:42:46 -04:00
def skip_ci?
2015-10-02 07:46:38 -04:00
git_commit_message =~ /(\[ci skip\])/ if git_commit_message
2015-08-25 21:42:46 -04:00
end
private
def save_yaml_error(error)
return if self.yaml_errors?
self.yaml_errors = error
save
end
end
end