build.rb 6.88 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
# == 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
Kamil Trzcinski's avatar
Kamil Trzcinski committed
27
  class Build < CommitStatus
Douwe Maan's avatar
Douwe Maan committed
28
29
30
31
32
33
34
35
    LAZY_ATTRIBUTES = ['trace']

    belongs_to :runner, class_name: 'Ci::Runner'
    belongs_to :trigger_request, class_name: 'Ci::TriggerRequest'

    serialize :options

    validates :coverage, numericality: true, allow_blank: true
Kamil Trzcinski's avatar
Kamil Trzcinski committed
36
    validates_presence_of :ref
Douwe Maan's avatar
Douwe Maan committed
37
38

    scope :unstarted, ->() { where(runner_id: nil) }
Kamil Trzcinski's avatar
Kamil Trzcinski committed
39
    scope :ignore_failures, ->() { where(allow_failure: false) }
Kamil Trzcinski's avatar
Kamil Trzcinski committed
40
    scope :similar, ->(build) { where(ref: build.ref, tag: build.tag, trigger_request_id: build.trigger_request_id) }
Douwe Maan's avatar
Douwe Maan committed
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63

    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
Kamil Trzcinski's avatar
Kamil Trzcinski committed
64
        new_build.status = 'pending'
Douwe Maan's avatar
Douwe Maan committed
65
        new_build.runner_id = nil
Kamil Trzcinski's avatar
Kamil Trzcinski committed
66
        new_build.trigger_request_id = nil
Douwe Maan's avatar
Douwe Maan committed
67
68
69
70
        new_build.save
      end

      def retry(build)
Kamil Trzcinski's avatar
Kamil Trzcinski committed
71
        new_build = Ci::Build.new(status: 'pending')
Kamil Trzcinski's avatar
Kamil Trzcinski committed
72
73
        new_build.ref = build.ref
        new_build.tag = build.tag
Douwe Maan's avatar
Douwe Maan committed
74
75
76
77
78
79
80
        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
81
        new_build.stage_idx = build.stage_idx
Douwe Maan's avatar
Douwe Maan committed
82
83
84
85
86
87
88
89
90
91
92
93
94
95
        new_build.trigger_request = build.trigger_request
        new_build.save
        new_build
      end
    end

    state_machine :status, initial: :pending do
      after_transition any => [:success, :failed, :canceled] do |build, transition|
        project = build.project

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

96
        build.commit.create_next_builds(build)
Douwe Maan's avatar
Douwe Maan committed
97
98
99
100
101
102
103
104
        project.execute_services(build)

        if project.coverage_enabled?
          build.update_coverage
        end
      end
    end

Kamil Trzcinski's avatar
Kamil Trzcinski committed
105
106
    def ignored?
      failed? && allow_failure?
Kamil Trzcinski's avatar
Kamil Trzcinski committed
107
108
    end

Douwe Maan's avatar
Douwe Maan committed
109
110
    def trace_html
      html = Ci::Ansi2html::convert(trace) if trace.present?
111
      html || ''
Douwe Maan's avatar
Douwe Maan committed
112
113
114
115
116
117
118
    end

    def timeout
      project.timeout
    end

    def variables
119
      predefined_variables + yaml_variables + project_variables + trigger_variables
Douwe Maan's avatar
Douwe Maan committed
120
121
122
123
124
125
126
    end

    def project
      commit.project
    end

    def project_id
Kamil Trzcinski's avatar
Kamil Trzcinski committed
127
      commit.project.id
Douwe Maan's avatar
Douwe Maan committed
128
129
130
131
132
133
    end

    def project_name
      project.name
    end

Kamil Trzcinski's avatar
Kamil Trzcinski committed
134
135
136
    def project_recipients
      recipients = project.email_recipients.split(' ')

137
138
      if project.email_add_pusher? && user.present? && user.notification_email.present?
        recipients << user.notification_email
Kamil Trzcinski's avatar
Kamil Trzcinski committed
139
140
141
142
143
      end

      recipients.uniq
    end

Douwe Maan's avatar
Douwe Maan committed
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
    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
168
      rescue
Douwe Maan's avatar
Douwe Maan committed
169
170
171
172
173
        # if bad regex or something goes wrong we dont want to interrupt transition
        # so we just silentrly ignore error for now
      end
    end

174
    def raw_trace
Douwe Maan's avatar
Douwe Maan committed
175
176
177
178
179
180
181
      if File.exist?(path_to_trace)
        File.read(path_to_trace)
      else
        # backward compatibility
        read_attribute :trace
      end
    end
182
183
184
185
186
187
188
189
190

    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
191
192
193
194
195
196
197
198
199
200
201

    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
202
        Settings.gitlab_ci.builds_path,
Douwe Maan's avatar
Douwe Maan committed
203
204
205
206
207
208
209
210
211
        created_at.utc.strftime("%Y_%m"),
        project.id.to_s
      )
    end

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

Kamil Trzcinski's avatar
Kamil Trzcinski committed
212
213
214
215
216
    def target_url
      Gitlab::Application.routes.url_helpers.
        namespace_project_build_url(gl_project.namespace, gl_project, self)
    end

Kamil Trzcinski's avatar
Kamil Trzcinski committed
217
218
    def cancel_url
      if active?
Kamil Trzcinski's avatar
Kamil Trzcinski committed
219
        Gitlab::Application.routes.url_helpers.
220
          cancel_namespace_project_build_path(gl_project.namespace, gl_project, self)
Kamil Trzcinski's avatar
Kamil Trzcinski committed
221
222
223
224
225
      end
    end

    def retry_url
      if commands.present?
Kamil Trzcinski's avatar
Kamil Trzcinski committed
226
        Gitlab::Application.routes.url_helpers.
227
          retry_namespace_project_build_path(gl_project.namespace, gl_project, self)
Kamil Trzcinski's avatar
Kamil Trzcinski committed
228
229
230
      end
    end

231
232
233
234
235
236
237
238
239
240
241
242
    def can_be_served?(runner)
      (tag_list - runner.tag_list).empty?
    end

    def any_runners_online?
      project.any_runners? { |runner| runner.active? && runner.online? && can_be_served?(runner) }
    end

    def show_warning?
      pending? && !any_runners_online?
    end

Douwe Maan's avatar
Douwe Maan committed
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
    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
270
271
272

    def predefined_variables
      variables = []
273
      variables << { key: :CI_BUILD_TAG, value: ref, public: true } if tag?
274
275
276
277
278
      variables << { key: :CI_BUILD_NAME, value: name, public: true }
      variables << { key: :CI_BUILD_STAGE, value: stage, public: true }
      variables << { key: :CI_BUILD_TRIGGERED, value: 'true', public: true } if trigger_request
      variables
    end
Douwe Maan's avatar
Douwe Maan committed
279
280
  end
end