merge_request.rb 5.2 KB
Newer Older
D
Dmitriy Zaporozhets 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
# == Schema Information
#
# Table name: merge_requests
#
#  id            :integer          not null, primary key
#  target_branch :string(255)      not null
#  source_branch :string(255)      not null
#  project_id    :integer          not null
#  author_id     :integer
#  assignee_id   :integer
#  title         :string(255)
#  closed        :boolean          default(FALSE), not null
#  created_at    :datetime         not null
#  updated_at    :datetime         not null
#  st_commits    :text(2147483647)
#  st_diffs      :text(2147483647)
#  merged        :boolean          default(FALSE), not null
#  state         :integer          default(1), not null
#  milestone_id  :integer
#

22
require Rails.root.join("app/models/commit")
R
randx 已提交
23
require Rails.root.join("app/roles/static_model")
24

D
Dmitriy Zaporozhets 已提交
25
class MergeRequest < ActiveRecord::Base
26
  include IssueCommonality
R
Riyad Preukschas 已提交
27
  include Votes
28

29
  attr_accessible :title, :assignee_id, :closed, :target_branch, :source_branch, :milestone_id,
30 31
                  :author_id_of_changes

A
Andrey Kumanyaev 已提交
32 33
  attr_accessor :should_remove_source_branch

34 35
  BROKEN_DIFF = "--broken-diff"

36 37 38 39
  UNCHECKED = 1
  CAN_BE_MERGED = 2
  CANNOT_BE_MERGED = 3

40 41 42
  serialize :st_commits
  serialize :st_diffs

A
Andrey Kumanyaev 已提交
43 44
  validates :source_branch, presence: true
  validates :target_branch, presence: true
45
  validate :validate_branches
D
Dmitriy Zaporozhets 已提交
46

47
  def self.find_all_by_branch(branch_name)
V
Valeriy Sizov 已提交
48
    where("source_branch LIKE :branch OR target_branch LIKE :branch", branch: branch_name)
49 50
  end

51 52 53 54
  def self.find_all_by_milestone(milestone)
    where("milestone_id = :milestone_id", milestone_id: milestone)
  end

V
Valery Sizov 已提交
55 56 57 58 59 60 61 62 63
  def human_state
    states = {
      CAN_BE_MERGED =>  "can_be_merged",
      CANNOT_BE_MERGED => "cannot_be_merged",
      UNCHECKED => "unchecked"
    }
    states[self.state]
  end

64
  def validate_branches
65
    if target_branch == source_branch
66 67 68 69
      errors.add :base, "You can not use same branch for source and target branches"
    end
  end

70 71 72 73 74
  def reload_code
    self.reloaded_commits
    self.reloaded_diffs
  end

75 76 77 78
  def unchecked?
    state == UNCHECKED
  end

79
  def mark_as_unchecked
80 81
    self.state = UNCHECKED
    self.save
82 83
  end

84
  def can_be_merged?
85 86 87 88
    state == CAN_BE_MERGED
  end

  def check_if_can_be_merged
89
    self.state = if Gitlab::Satellite::MergeAction.new(self.author, self).can_be_merged?
90 91 92 93 94
                   CAN_BE_MERGED
                 else
                   CANNOT_BE_MERGED
                 end
    self.save
95 96
  end

D
Dmitriy Zaporozhets 已提交
97
  def diffs
98 99 100 101 102 103
    st_diffs || []
  end

  def reloaded_diffs
    if open? && unmerged_diffs.any?
      self.st_diffs = unmerged_diffs
104
      self.save
105
    end
106 107 108 109 110 111 112 113 114 115 116 117

  rescue Grit::Git::GitTimeout
    self.st_diffs = [BROKEN_DIFF]
    self.save
  end

  def broken_diffs?
    diffs == [BROKEN_DIFF]
  end

  def valid_diffs?
    !broken_diffs?
118 119 120
  end

  def unmerged_diffs
121 122 123 124 125
    # Only show what is new in the source branch compared to the target branch, not the other way around.
    # The linex below with merge_base is equivalent to diff with three dots (git diff branch1...branch2)
    # From the git documentation: "git diff A...B" is equivalent to "git diff $(git-merge-base A B) B"
    common_commit = project.repo.git.native(:merge_base, {}, [target_branch, source_branch]).strip
    diffs = project.repo.diff(common_commit, source_branch)
D
Dmitriy Zaporozhets 已提交
126 127 128
  end

  def last_commit
129
    commits.first
D
Dmitriy Zaporozhets 已提交
130
  end
131

132
  def merged?
133 134 135
    merged && merge_event
  end

D
Dmitriy Zaporozhets 已提交
136
  def merge_event
137
    self.project.events.where(target_id: self.id, target_type: "MergeRequest", action: Event::Merged).last
D
Dmitriy Zaporozhets 已提交
138 139
  end

140
  def closed_event
141
    self.project.events.where(target_id: self.id, target_type: "MergeRequest", action: Event::Closed).last
142 143
  end

144 145 146 147 148
  def commits
    st_commits || []
  end

  def probably_merged?
149
    unmerged_commits.empty? &&
150 151 152 153 154 155 156 157 158 159 160
      commits.any? && open?
  end

  def open?
    !closed
  end

  def mark_as_merged!
    self.merged = true
    self.closed = true
    save
161 162 163
  end

  def mark_as_unmergable
164 165
    self.state = CANNOT_BE_MERGED
    self.save
166 167
  end

168 169
  def reloaded_commits
    if open? && unmerged_commits.any?
170 171 172 173 174 175 176 177 178 179 180 181 182
      self.st_commits = unmerged_commits
      save
    end
    commits
  end

  def unmerged_commits
    self.project.repo.
      commits_between(self.target_branch, self.source_branch).
      map {|c| Commit.new(c)}.
      sort_by(&:created_at).
      reverse
  end
183 184 185 186

  def merge!(user_id)
    self.mark_as_merged!
    Event.create(
187 188 189 190 191
      project: self.project,
      action: Event::Merged,
      target_id: self.id,
      target_type: "MergeRequest",
      author_id: user_id
192 193
    )
  end
194

195
  def automerge!(current_user)
196
    if Gitlab::Satellite::MergeAction.new(current_user, self).merge! && self.unmerged_commits.empty?
197 198 199
      self.merge!(current_user.id)
      true
    end
Z
Zevs 已提交
200
  rescue
201 202 203
    self.mark_as_unmergable
    false
  end
R
randx 已提交
204 205 206 207 208 209 210 211 212 213 214 215

  def to_raw
    FileUtils.mkdir_p(Rails.root.join("tmp", "patches"))
    patch_path = Rails.root.join("tmp", "patches", "merge_request_#{self.id}.patch")

    from = commits.last.id
    to = source_branch

    project.repo.git.run('', "format-patch" , " > #{patch_path.to_s}", {}, ["#{from}..#{to}", "--stdout"])

    patch_path
  end
216 217 218 219 220

  def mr_and_commit_notes
    commit_ids = commits.map(&:id)
    Note.where("(noteable_type = 'MergeRequest' AND noteable_id = :mr_id) OR (noteable_type = 'Commit' AND noteable_id IN (:commit_ids))", mr_id: id, commit_ids: commit_ids)
  end
D
Dmitriy Zaporozhets 已提交
221
end