build.rb 7.5 KB
Newer Older
Douwe Maan's avatar
Douwe Maan committed
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
# == Schema Information
#
# Table name: builds
#
#  id                 :integer          not null, primary key
#  project_id         :integer
#  status             :string(255)
#  finished_at        :datetime
#  trace              :text
#  created_at         :datetime
#  updated_at         :datetime
#  started_at         :datetime
#  runner_id          :integer
#  commit_id          :integer
#  coverage           :float
#  commands           :text
#  job_id             :integer
#  name               :string(255)
#  options            :text
#  allow_failure      :boolean          default(FALSE), not null
#  stage              :string(255)
#  deploy             :boolean          default(FALSE)
#  trigger_request_id :integer
#

module Ci
  class Build < ActiveRecord::Base
    extend Ci::Model
29

Douwe Maan's avatar
Douwe Maan committed
30
31
32
33
34
    LAZY_ATTRIBUTES = ['trace']

    belongs_to :commit, class_name: 'Ci::Commit'
    belongs_to :runner, class_name: 'Ci::Runner'
    belongs_to :trigger_request, class_name: 'Ci::TriggerRequest'
35
    belongs_to :user
Douwe Maan's avatar
Douwe Maan committed
36
37
38
39
40
41

    serialize :options

    validates :commit, presence: true
    validates :status, presence: true
    validates :coverage, numericality: true, allow_blank: true
Kamil Trzcinski's avatar
Kamil Trzcinski committed
42
    validates_presence_of :ref
Douwe Maan's avatar
Douwe Maan committed
43
44
45
46
47
48
49

    scope :running, ->() { where(status: "running") }
    scope :pending, ->() { where(status: "pending") }
    scope :success, ->() { where(status: "success") }
    scope :failed, ->() { where(status: "failed")  }
    scope :unstarted, ->() { where(runner_id: nil) }
    scope :running_or_pending, ->() { where(status:[:running, :pending]) }
50
    scope :latest, ->() { where(id: unscope(:select).select('max(id)').group(:name, :ref)).order(stage_idx: :asc) }
Kamil Trzcinski's avatar
Kamil Trzcinski committed
51
52
    scope :ignore_failures, ->() { where(allow_failure: false) }
    scope :for_ref, ->(ref) { where(ref: ref) }
Kamil Trzcinski's avatar
Kamil Trzcinski committed
53
    scope :similar, ->(build) { where(ref: build.ref, tag: build.tag, trigger_request_id: build.trigger_request_id) }
Douwe Maan's avatar
Douwe Maan committed
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83

    acts_as_taggable

    # To prevent db load megabytes of data from trace
    default_scope -> { select(Ci::Build.columns_without_lazy) }

    class << self
      def columns_without_lazy
        (column_names - LAZY_ATTRIBUTES).map do |column_name|
          "#{table_name}.#{column_name}"
        end
      end

      def last_month
        where('created_at > ?', Date.today - 1.month)
      end

      def first_pending
        pending.unstarted.order('created_at ASC').first
      end

      def create_from(build)
        new_build = build.dup
        new_build.status = :pending
        new_build.runner_id = nil
        new_build.save
      end

      def retry(build)
        new_build = Ci::Build.new(status: :pending)
Kamil Trzcinski's avatar
Kamil Trzcinski committed
84
85
        new_build.ref = build.ref
        new_build.tag = build.tag
Douwe Maan's avatar
Douwe Maan committed
86
87
88
89
90
91
92
        new_build.options = build.options
        new_build.commands = build.commands
        new_build.tag_list = build.tag_list
        new_build.commit_id = build.commit_id
        new_build.name = build.name
        new_build.allow_failure = build.allow_failure
        new_build.stage = build.stage
Kamil Trzcinski's avatar
Kamil Trzcinski committed
93
        new_build.stage_idx = build.stage_idx
Douwe Maan's avatar
Douwe Maan committed
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
        new_build.trigger_request = build.trigger_request
        new_build.save
        new_build
      end
    end

    state_machine :status, initial: :pending do
      event :run do
        transition pending: :running
      end

      event :drop do
        transition running: :failed
      end

      event :success do
        transition running: :success
      end

      event :cancel do
        transition [:pending, :running] => :canceled
      end

      after_transition pending: :running do |build, transition|
        build.update_attributes started_at: Time.now
      end

      after_transition any => [:success, :failed, :canceled] do |build, transition|
        build.update_attributes finished_at: Time.now
        project = build.project

        if project.web_hooks?
          Ci::WebHookService.new.build_end(build)
        end

Kamil Trzcinski's avatar
Kamil Trzcinski committed
129
130
        if build.commit.should_create_next_builds?(build)
          build.commit.create_next_builds(build.ref, build.tag, build.user, build.trigger_request)
Douwe Maan's avatar
Douwe Maan committed
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
        end

        project.execute_services(build)

        if project.coverage_enabled?
          build.update_coverage
        end
      end

      state :pending, value: 'pending'
      state :running, value: 'running'
      state :failed, value: 'failed'
      state :success, value: 'success'
      state :canceled, value: 'canceled'
    end

147
    delegate :sha, :short_sha, :project, :gl_project,
Douwe Maan's avatar
Douwe Maan committed
148
149
      to: :commit, prefix: false

Kamil Trzcinski's avatar
Kamil Trzcinski committed
150
151
152
153
    def before_sha
      Gitlab::Git::BLANK_SHA
    end

Douwe Maan's avatar
Douwe Maan committed
154
155
    def trace_html
      html = Ci::Ansi2html::convert(trace) if trace.present?
156
      html || ''
Douwe Maan's avatar
Douwe Maan committed
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
    end

    def started?
      !pending? && !canceled? && started_at
    end

    def active?
      running? || pending?
    end

    def complete?
      canceled? || success? || failed?
    end

    def ignored?
      failed? && allow_failure?
    end

    def timeout
      project.timeout
    end

    def variables
      yaml_variables + project_variables + trigger_variables
    end

    def duration
      if started_at && finished_at
        finished_at - started_at
      elsif started_at
        Time.now - started_at
      end
    end

    def project
      commit.project
    end

    def project_id
Kamil Trzcinski's avatar
Kamil Trzcinski committed
196
      commit.project.id
Douwe Maan's avatar
Douwe Maan committed
197
198
199
200
201
202
    end

    def project_name
      project.name
    end

Kamil Trzcinski's avatar
Kamil Trzcinski committed
203
204
205
    def project_recipients
      recipients = project.email_recipients.split(' ')

206
207
      if project.email_add_pusher? && user.present? && user.notification_email.present?
        recipients << user.notification_email
Kamil Trzcinski's avatar
Kamil Trzcinski committed
208
209
210
211
212
      end

      recipients.uniq
    end

Douwe Maan's avatar
Douwe Maan committed
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
    def repo_url
      project.repo_url_with_auth
    end

    def allow_git_fetch
      project.allow_git_fetch
    end

    def update_coverage
      coverage = extract_coverage(trace, project.coverage_regex)

      if coverage.is_a? Numeric
        update_attributes(coverage: coverage)
      end
    end

    def extract_coverage(text, regex)
      begin
        matches = text.gsub(Regexp.new(regex)).to_a.last
        coverage = matches.gsub(/\d+(\.\d+)?/).first

        if coverage.present?
          coverage.to_f
        end
237
      rescue
Douwe Maan's avatar
Douwe Maan committed
238
239
240
241
242
        # if bad regex or something goes wrong we dont want to interrupt transition
        # so we just silentrly ignore error for now
      end
    end

243
    def raw_trace
Douwe Maan's avatar
Douwe Maan committed
244
245
246
247
248
249
250
      if File.exist?(path_to_trace)
        File.read(path_to_trace)
      else
        # backward compatibility
        read_attribute :trace
      end
    end
251
252
253
254
255
256
257
258
259

    def trace
      trace = raw_trace
      if project && trace.present?
        trace.gsub(project.token, 'xxxxxx')
      else
        trace
      end
    end
Douwe Maan's avatar
Douwe Maan committed
260
261
262
263
264
265
266
267
268
269
270

    def trace=(trace)
      unless Dir.exists? dir_to_trace
        FileUtils.mkdir_p dir_to_trace
      end

      File.write(path_to_trace, trace)
    end

    def dir_to_trace
      File.join(
Valery Sizov's avatar
Valery Sizov committed
271
        Settings.gitlab_ci.builds_path,
Douwe Maan's avatar
Douwe Maan committed
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
        created_at.utc.strftime("%Y_%m"),
        project.id.to_s
      )
    end

    def path_to_trace
      "#{dir_to_trace}/#{id}.log"
    end

    private

    def yaml_variables
      if commit.config_processor
        commit.config_processor.variables.map do |key, value|
          { key: key, value: value, public: true }
        end
      else
        []
      end
    end

    def project_variables
      project.variables.map do |variable|
        { key: variable.key, value: variable.value, public: false }
      end
    end

    def trigger_variables
      if trigger_request && trigger_request.variables
        trigger_request.variables.map do |key, value|
          { key: key, value: value, public: false }
        end
      else
        []
      end
    end
  end
end