342 lines
		
	
	
		
			7.7 KiB
		
	
	
	
		
			Ruby
		
	
	
	
			
		
		
	
	
			342 lines
		
	
	
		
			7.7 KiB
		
	
	
	
		
			Ruby
		
	
	
	
| class Commit
 | |
|   extend ActiveModel::Naming
 | |
| 
 | |
|   include ActiveModel::Conversion
 | |
|   include Participable
 | |
|   include Mentionable
 | |
|   include Referable
 | |
|   include StaticModel
 | |
| 
 | |
|   attr_mentionable :safe_message, pipeline: :single_line
 | |
| 
 | |
|   participant :author
 | |
|   participant :committer
 | |
|   participant :notes_with_associations
 | |
| 
 | |
|   attr_accessor :project
 | |
| 
 | |
|   DIFF_SAFE_LINES = Gitlab::Git::DiffCollection::DEFAULT_LIMITS[:max_lines]
 | |
| 
 | |
|   # Commits above this size will not be rendered in HTML
 | |
|   DIFF_HARD_LIMIT_FILES = 1000
 | |
|   DIFF_HARD_LIMIT_LINES = 50000
 | |
| 
 | |
|   class << self
 | |
|     def decorate(commits, project)
 | |
|       commits.map do |commit|
 | |
|         if commit.kind_of?(Commit)
 | |
|           commit
 | |
|         else
 | |
|           self.new(commit, project)
 | |
|         end
 | |
|       end
 | |
|     end
 | |
| 
 | |
|     # Calculate number of lines to render for diffs
 | |
|     def diff_line_count(diffs)
 | |
|       diffs.reduce(0) { |sum, d| sum + Gitlab::Git::Util.count_lines(d.diff) }
 | |
|     end
 | |
| 
 | |
|     # Truncate sha to 8 characters
 | |
|     def truncate_sha(sha)
 | |
|       sha[0..7]
 | |
|     end
 | |
| 
 | |
|     def max_diff_options
 | |
|       {
 | |
|         max_files: DIFF_HARD_LIMIT_FILES,
 | |
|         max_lines: DIFF_HARD_LIMIT_LINES,
 | |
|       }
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   attr_accessor :raw
 | |
| 
 | |
|   def initialize(raw_commit, project)
 | |
|     raise "Nil as raw commit passed" unless raw_commit
 | |
| 
 | |
|     @raw = raw_commit
 | |
|     @project = project
 | |
|   end
 | |
| 
 | |
|   def id
 | |
|     @raw.id
 | |
|   end
 | |
| 
 | |
|   def ==(other)
 | |
|     (self.class === other) && (raw == other.raw)
 | |
|   end
 | |
| 
 | |
|   def self.reference_prefix
 | |
|     '@'
 | |
|   end
 | |
| 
 | |
|   # Pattern used to extract commit references from text
 | |
|   #
 | |
|   # The SHA can be between 7 and 40 hex characters.
 | |
|   #
 | |
|   # This pattern supports cross-project references.
 | |
|   def self.reference_pattern
 | |
|     @reference_pattern ||= %r{
 | |
|       (?:#{Project.reference_pattern}#{reference_prefix})?
 | |
|       (?<commit>\h{7,40})
 | |
|     }x
 | |
|   end
 | |
| 
 | |
|   def self.link_reference_pattern
 | |
|     @link_reference_pattern ||= super("commit", /(?<commit>\h{7,40})/)
 | |
|   end
 | |
| 
 | |
|   def to_reference(from_project = nil)
 | |
|     if cross_project_reference?(from_project)
 | |
|       project.to_reference + self.class.reference_prefix + self.id
 | |
|     else
 | |
|       self.id
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   def reference_link_text(from_project = nil)
 | |
|     if cross_project_reference?(from_project)
 | |
|       project.to_reference + self.class.reference_prefix + self.short_id
 | |
|     else
 | |
|       self.short_id
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   def diff_line_count
 | |
|     @diff_line_count ||= Commit::diff_line_count(self.diffs)
 | |
|     @diff_line_count
 | |
|   end
 | |
| 
 | |
|   # Returns a string describing the commit for use in a link title
 | |
|   #
 | |
|   # Example
 | |
|   #
 | |
|   #   "Commit: Alex Denisov - Project git clone panel"
 | |
|   def link_title
 | |
|     "Commit: #{author_name} - #{title}"
 | |
|   end
 | |
| 
 | |
|   # Returns the commits title.
 | |
|   #
 | |
|   # Usually, the commit title is the first line of the commit message.
 | |
|   # In case this first line is longer than 100 characters, it is cut off
 | |
|   # after 80 characters and ellipses (`&hellp;`) are appended.
 | |
|   def title
 | |
|     full_title.length > 100 ? full_title[0..79] << "…" : full_title
 | |
|   end
 | |
| 
 | |
|   # Returns the full commits title
 | |
|   def full_title
 | |
|     return @full_title if @full_title
 | |
| 
 | |
|     if safe_message.blank?
 | |
|       @full_title = no_commit_message
 | |
|     else
 | |
|       @full_title = safe_message.split("\n", 2).first
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   # Returns the commits description
 | |
|   #
 | |
|   # cut off, ellipses (`&hellp;`) are prepended to the commit message.
 | |
|   def description
 | |
|     title_end = safe_message.index("\n")
 | |
|     @description ||=
 | |
|       if (!title_end && safe_message.length > 100) || (title_end && title_end > 100)
 | |
|         "…" << safe_message[80..-1]
 | |
|       else
 | |
|         safe_message.split("\n", 2)[1].try(:chomp)
 | |
|       end
 | |
|   end
 | |
| 
 | |
|   def description?
 | |
|     description.present?
 | |
|   end
 | |
| 
 | |
|   def hook_attrs(with_changed_files: false)
 | |
|     data = {
 | |
|       id: id,
 | |
|       message: safe_message,
 | |
|       timestamp: committed_date.xmlschema,
 | |
|       url: Gitlab::UrlBuilder.build(self),
 | |
|       author: {
 | |
|         name: author_name,
 | |
|         email: author_email
 | |
|       }
 | |
|     }
 | |
| 
 | |
|     if with_changed_files
 | |
|       data.merge!(repo_changes)
 | |
|     end
 | |
| 
 | |
|     data
 | |
|   end
 | |
| 
 | |
|   # Discover issues should be closed when this commit is pushed to a project's
 | |
|   # default branch.
 | |
|   def closes_issues(current_user = self.committer)
 | |
|     Gitlab::ClosingIssueExtractor.new(project, current_user).closed_by_message(safe_message)
 | |
|   end
 | |
| 
 | |
|   def author
 | |
|     if RequestStore.active?
 | |
|       key = "commit_author:#{author_email.downcase}"
 | |
|       # nil is a valid value since no author may exist in the system
 | |
|       if RequestStore.store.has_key?(key)
 | |
|         @author = RequestStore.store[key]
 | |
|       else
 | |
|         @author = find_author_by_any_email
 | |
|         RequestStore.store[key] = @author
 | |
|       end
 | |
|     else
 | |
|       @author ||= find_author_by_any_email
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   def committer
 | |
|     @committer ||= User.find_by_any_email(committer_email.downcase)
 | |
|   end
 | |
| 
 | |
|   def parents
 | |
|     @parents ||= parent_ids.map { |id| project.commit(id) }
 | |
|   end
 | |
| 
 | |
|   def parent
 | |
|     @parent ||= project.commit(self.parent_id) if self.parent_id
 | |
|   end
 | |
| 
 | |
|   def notes
 | |
|     project.notes.for_commit_id(self.id)
 | |
|   end
 | |
| 
 | |
|   def notes_with_associations
 | |
|     notes.includes(:author)
 | |
|   end
 | |
| 
 | |
|   def method_missing(m, *args, &block)
 | |
|     @raw.send(m, *args, &block)
 | |
|   end
 | |
| 
 | |
|   def respond_to_missing?(method, include_private = false)
 | |
|     @raw.respond_to?(method, include_private) || super
 | |
|   end
 | |
| 
 | |
|   # Truncate sha to 8 characters
 | |
|   def short_id
 | |
|     @raw.short_id(7)
 | |
|   end
 | |
| 
 | |
|   def diff_refs
 | |
|     Gitlab::Diff::DiffRefs.new(
 | |
|       base_sha: self.parent_id || self.sha,
 | |
|       head_sha: self.sha
 | |
|     )
 | |
|   end
 | |
| 
 | |
|   def pipelines
 | |
|     @pipeline ||= project.pipelines.where(sha: sha)
 | |
|   end
 | |
| 
 | |
|   def status
 | |
|     return @status if defined?(@status)
 | |
|     @status ||= pipelines.status
 | |
|   end
 | |
| 
 | |
|   def revert_branch_name
 | |
|     "revert-#{short_id}"
 | |
|   end
 | |
| 
 | |
|   def cherry_pick_branch_name
 | |
|     project.repository.next_branch("cherry-pick-#{short_id}", mild: true)
 | |
|   end
 | |
| 
 | |
|   def revert_description
 | |
|     if merged_merge_request
 | |
|       "This reverts merge request #{merged_merge_request.to_reference}"
 | |
|     else
 | |
|       "This reverts commit #{sha}"
 | |
|     end
 | |
|   end
 | |
| 
 | |
|   def revert_message
 | |
|     %Q{Revert "#{title.strip}"\n\n#{revert_description}}
 | |
|   end
 | |
| 
 | |
|   def reverts_commit?(commit)
 | |
|     description? && description.include?(commit.revert_description)
 | |
|   end
 | |
| 
 | |
|   def merge_commit?
 | |
|     parents.size > 1
 | |
|   end
 | |
| 
 | |
|   def merged_merge_request
 | |
|     return @merged_merge_request if defined?(@merged_merge_request)
 | |
| 
 | |
|     @merged_merge_request = project.merge_requests.find_by(merge_commit_sha: id) if merge_commit?
 | |
|   end
 | |
| 
 | |
|   def has_been_reverted?(current_user = nil, noteable = self)
 | |
|     ext = all_references(current_user)
 | |
| 
 | |
|     noteable.notes_with_associations.system.each do |note|
 | |
|       note.all_references(current_user, extractor: ext)
 | |
|     end
 | |
| 
 | |
|     ext.commits.any? { |commit_ref| commit_ref.reverts_commit?(self) }
 | |
|   end
 | |
| 
 | |
|   def change_type_title
 | |
|     merged_merge_request ? 'merge request' : 'commit'
 | |
|   end
 | |
| 
 | |
|   # Get the URI type of the given path
 | |
|   #
 | |
|   # Used to build URLs to files in the repository in GFM.
 | |
|   #
 | |
|   # path - String path to check
 | |
|   #
 | |
|   # Examples:
 | |
|   #
 | |
|   #   uri_type('doc/README.md') # => :blob
 | |
|   #   uri_type('doc/logo.png')  # => :raw
 | |
|   #   uri_type('doc/api')       # => :tree
 | |
|   #   uri_type('not/found')     # => :nil
 | |
|   #
 | |
|   # Returns a symbol
 | |
|   def uri_type(path)
 | |
|     entry = @raw.tree.path(path)
 | |
|     if entry[:type] == :blob
 | |
|       blob = ::Blob.decorate(Gitlab::Git::Blob.new(name: entry[:name]))
 | |
|       blob.image? || blob.video? ? :raw : :blob
 | |
|     else
 | |
|       entry[:type]
 | |
|     end
 | |
|   rescue Rugged::TreeError
 | |
|     nil
 | |
|   end
 | |
| 
 | |
|   private
 | |
| 
 | |
|   def find_author_by_any_email
 | |
|     User.find_by_any_email(author_email.downcase)
 | |
|   end
 | |
| 
 | |
|   def repo_changes
 | |
|     changes = { added: [], modified: [], removed: [] }
 | |
| 
 | |
|     diffs.each do |diff|
 | |
|       if diff.deleted_file
 | |
|         changes[:removed] << diff.old_path
 | |
|       elsif diff.renamed_file || diff.new_file
 | |
|         changes[:added] << diff.new_path
 | |
|       else
 | |
|         changes[:modified] << diff.new_path
 | |
|       end
 | |
|     end
 | |
| 
 | |
|     changes
 | |
|   end
 | |
| end
 |