build.rb 7.18 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]) }
Kamil Trzcinski's avatar
Kamil Trzcinski committed
50
51
52
    scope :latest, ->() { group(:name).order(stage_idx: :asc, created_at: :desc) }
    scope :ignore_failures, ->() { where(allow_failure: false) }
    scope :for_ref, ->(ref) { where(ref: ref) }
Douwe Maan's avatar
Douwe Maan committed
53
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
84
85
86
87
88
89

    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)
        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
90
        new_build.stage_idx = build.stage_idx
Douwe Maan's avatar
Douwe Maan committed
91
92
93
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
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
        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

        if build.commit.success?
          build.commit.create_next_builds(build.trigger_request)
        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

Kamil Trzcinski's avatar
WIP    
Kamil Trzcinski committed
144
    delegate :sha, :short_sha, :before_sha, :ref, :project,
Douwe Maan's avatar
Douwe Maan committed
145
146
147
148
      to: :commit, prefix: false

    def trace_html
      html = Ci::Ansi2html::convert(trace) if trace.present?
149
      html || ''
Douwe Maan's avatar
Douwe Maan committed
150
151
152
153
154
155
156
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
    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
189
      commit.project.id
Douwe Maan's avatar
Douwe Maan committed
190
191
192
193
194
195
    end

    def project_name
      project.name
    end

Kamil Trzcinski's avatar
Kamil Trzcinski committed
196
197
198
    def project_recipients
      recipients = project.email_recipients.split(' ')

199
200
      if project.email_add_pusher? && user.present? && user.notification_email.present?
        recipients << user.notification_email
Kamil Trzcinski's avatar
Kamil Trzcinski committed
201
202
203
204
205
      end

      recipients.uniq
    end

Douwe Maan's avatar
Douwe Maan committed
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
    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
230
      rescue
Douwe Maan's avatar
Douwe Maan committed
231
232
233
234
235
        # if bad regex or something goes wrong we dont want to interrupt transition
        # so we just silentrly ignore error for now
      end
    end

236
    def raw_trace
Douwe Maan's avatar
Douwe Maan committed
237
238
239
240
241
242
243
      if File.exist?(path_to_trace)
        File.read(path_to_trace)
      else
        # backward compatibility
        read_attribute :trace
      end
    end
244
245
246
247
248
249
250
251
252

    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
253
254
255
256
257
258
259
260
261
262
263

    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
264
        Settings.gitlab_ci.builds_path,
Douwe Maan's avatar
Douwe Maan committed
265
266
267
268
269
270
271
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
        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