repository.rb 25.3 KB
Newer Older
1 2
require 'securerandom'

3
class Repository
L
Lin Jen-Shin 已提交
4 5 6
  REF_MERGE_REQUEST = 'merge-requests'.freeze
  REF_KEEP_AROUND = 'keep-around'.freeze
  REF_ENVIRONMENTS = 'environments'.freeze
7
  MAX_DIVERGING_COUNT = 1000
8 9 10 11

  RESERVED_REFS_NAMES = %W[
    heads
    tags
12
    replace
13 14 15 16 17
    #{REF_ENVIRONMENTS}
    #{REF_KEEP_AROUND}
    #{REF_ENVIRONMENTS}
  ].freeze

18
  include Gitlab::ShellAdapter
19
  include Gitlab::RepositoryCacheAdapter
20

21
  attr_accessor :full_path, :disk_path, :project, :is_wiki
22

23
  delegate :ref_name_for_sha, to: :raw_repository
24
  delegate :bundle_to_disk, :create_from_bundle, to: :raw_repository
25

26
  CreateTreeError = Class.new(StandardError)
27

28 29 30 31 32 33
  # Methods that cache data from the Git repository.
  #
  # Each entry in this Array should have a corresponding method with the exact
  # same name. The cache key used by those methods must also match method's
  # name.
  #
34 35 36
  # For example, for entry `:commit_count` there's a method called `commit_count` which
  # stores its data in the `commit_count` cache key.
  CACHED_METHODS = %i(size commit_count rendered_readme contribution_guide
37 38
                      changelog license_blob license_key gitignore koding_yml
                      gitlab_ci_yml branch_names tag_names branch_count
39
                      tag_count avatar exists? root_ref has_visible_content?
S
Sean McGivern 已提交
40
                      issue_template_names merge_request_template_names).freeze
41 42

  # Methods that use cache_method but only memoize the value
43
  MEMOIZED_CACHED_METHODS = %i(license).freeze
44 45 46 47 48

  # Certain method caches should be refreshed when certain types of files are
  # changed. This Hash maps file types (as returned by Gitlab::FileDetector) to
  # the corresponding methods to call for refreshing caches.
  METHOD_CACHES_FOR_FILE_TYPES = {
49
    readme: :rendered_readme,
50
    changelog: :changelog,
51
    license: %i(license_blob license_key license),
52 53 54 55
    contributing: :contribution_guide,
    gitignore: :gitignore,
    koding: :koding_yml,
    gitlab_ci: :gitlab_ci_yml,
S
Sean McGivern 已提交
56 57 58
    avatar: :avatar,
    issue_template: :issue_template_names,
    merge_request_template: :merge_request_template_names
D
Douwe Maan 已提交
59
  }.freeze
60

61
  def initialize(full_path, project, disk_path: nil, is_wiki: false)
62
    @full_path = full_path
63
    @disk_path = disk_path || full_path
64
    @project = project
65
    @commit_cache = {}
66
    @is_wiki = is_wiki
67
  end
68

69
  def ==(other)
H
http://jneen.net/ 已提交
70 71 72
    @disk_path == other.disk_path
  end

73
  def raw_repository
74
    return nil unless full_path
75

76
    @raw_repository ||= initialize_raw_repository
77 78
  end

79 80
  alias_method :raw, :raw_repository

81 82 83 84
  def cleanup
    @raw_repository&.cleanup
  end

85
  # Return absolute path to repository
86
  def path_to_repo
87
    @path_to_repo ||= File.expand_path(
88
      File.join(repository_storage_path, disk_path + '.git')
89
    )
90 91
  end

92 93 94 95
  def inspect
    "#<#{self.class.name}:#{@disk_path}>"
  end

L
Lin Jen-Shin 已提交
96
  def commit(ref = 'HEAD')
97
    return nil unless exists?
98
    return ref if ref.is_a?(::Commit)
99

100 101
    find_commit(ref)
  end
102

103 104 105 106 107 108
  # Finding a commit by the passed SHA
  # Also takes care of caching, based on the SHA
  def commit_by(oid:)
    return @commit_cache[oid] if @commit_cache.key?(oid)

    @commit_cache[oid] = find_commit(oid)
109 110
  end

111 112 113 114 115 116 117 118 119 120 121 122
  def commits_by(oids:)
    return [] unless oids.present?

    commits = Gitlab::Git::Commit.batch_by_oid(raw_repository, oids)

    if commits.present?
      Commit.decorate(commits, @project)
    else
      []
    end
  end

123
  def commits(ref = nil, path: nil, limit: nil, offset: nil, skip_merges: false, after: nil, before: nil, all: nil)
124
    options = {
125 126 127 128 129
      repo: raw_repository,
      ref: ref,
      path: path,
      limit: limit,
      offset: offset,
130 131
      after: after,
      before: before,
132
      follow: Array(path).length == 1,
133 134
      skip_merges: skip_merges,
      all: all
135 136 137
    }

    commits = Gitlab::Git::Commit.where(options)
138
    commits = Commit.decorate(commits, @project) if commits.present?
139 140

    CommitCollection.new(project, commits, ref)
141 142
  end

143 144
  def commits_between(from, to)
    commits = Gitlab::Git::Commit.between(raw_repository, from, to)
145
    commits = Commit.decorate(commits, @project) if commits.present?
146 147 148
    commits
  end

149 150 151 152 153 154 155
  # Returns a list of commits that are not present in any reference
  def new_commits(newrev)
    refs = ::Gitlab::Git::RevList.new(raw, newrev: newrev).new_refs

    refs.map { |sha| commit(sha.strip) }
  end

J
Jacob Vosmaer 已提交
156
  # Gitaly migration: https://gitlab.com/gitlab-org/gitaly/issues/384
157
  def find_commits_by_message(query, ref = nil, path = nil, limit = 1000, offset = 0)
158 159 160 161
    unless exists? && has_visible_content? && query.present?
      return []
    end

162 163
    commits = raw_repository.find_commits_by_message(query, ref, path, limit, offset).map do |c|
      commit(c)
164
    end
165
    CommitCollection.new(project, commits, ref)
166 167
  end

168
  def find_branch(name, fresh_repo: true)
169
    raw_repository.find_branch(name, fresh_repo)
170 171 172
  end

  def find_tag(name)
173
    tags.find { |tag| tag.name == name }
174 175
  end

176
  def add_branch(user, branch_name, ref)
177
    branch = raw_repository.add_branch(branch_name, user: user, target: ref)
178

179
    after_create_branch
180 181 182 183

    branch
  rescue Gitlab::Git::Repository::InvalidRef
    false
184 185
  end

186
  def add_tag(user, tag_name, target, message = nil)
187
    raw_repository.add_tag(tag_name, user: user, target: target, message: message)
188 189
  rescue Gitlab::Git::Repository::InvalidRef
    false
190 191
  end

192
  def rm_branch(user, branch_name)
193
    before_remove_branch
194

195
    raw_repository.rm_branch(branch_name, user: user)
196

197
    after_remove_branch
198
    true
199 200
  end

L
Lin Jen-Shin 已提交
201
  def rm_tag(user, tag_name)
Y
Yorick Peterse 已提交
202
    before_remove_tag
203

204
    raw_repository.rm_tag(tag_name, user: user)
L
Lin Jen-Shin 已提交
205 206 207

    after_remove_tag
    true
208 209
  end

210 211 212 213
  def ref_names
    branch_names + tag_names
  end

214
  def branch_exists?(branch_name)
215 216
    return false unless raw_repository

217
    branch_names.include?(branch_name)
218 219
  end

220 221 222 223 224 225
  def tag_exists?(tag_name)
    return false unless raw_repository

    tag_names.include?(tag_name)
  end

226
  def ref_exists?(ref)
227 228
    !!raw_repository&.ref_exists?(ref)
  rescue ArgumentError
229
    false
230 231
  end

D
Douwe Maan 已提交
232 233 234 235
  # Makes sure a commit is kept around when Git garbage collection runs.
  # Git GC will delete commits from the repository that are no longer in any
  # branches or tags, but we want to keep some of these commits around, for
  # example if they have comments or CI builds.
236
  def keep_around(sha)
237
    return unless sha.present? && commit_by(oid: sha)
238 239 240

    return if kept_around?(sha)

241
    # This will still fail if the file is corrupted (e.g. 0 bytes)
242
    raw_repository.write_ref(keep_around_ref_name(sha), sha, shell: false)
243 244
  rescue Gitlab::Git::CommandError => ex
    Rails.logger.error "Unable to create keep-around reference for repository #{path}: #{ex}"
245 246 247
  end

  def kept_around?(sha)
248
    ref_exists?(keep_around_ref_name(sha))
249
  end
250

251
  def diverging_commit_counts(branch)
252
    @root_ref_hash ||= raw_repository.commit(root_ref).id
J
Jeff Stubler 已提交
253
    cache.fetch(:"diverging_commit_counts_#{branch.name}") do
254 255
      # Rugged seems to throw a `ReferenceError` when given branch_names rather
      # than SHA-1 hashes
256 257
      number_commits_behind, number_commits_ahead =
        raw_repository.count_commits_between(
258
          @root_ref_hash,
259 260 261
          branch.dereferenced_target.sha,
          left_right: true,
          max_count: MAX_DIVERGING_COUNT)
262

263 264 265
      { behind: number_commits_behind, ahead: number_commits_ahead }
    end
  end
266

267 268 269
  def expire_tags_cache
    expire_method_caches(%i(tag_names tag_count))
    @tags = nil
270
  end
271

272
  def expire_branches_cache
273
    expire_method_caches(%i(branch_names branch_count has_visible_content?))
274
    @local_branches = nil
275
    @branch_exists_memo = nil
276 277
  end

278 279
  def expire_statistics_caches
    expire_method_caches(%i(size commit_count))
280 281
  end

282 283
  def expire_all_method_caches
    expire_method_caches(CACHED_METHODS)
D
Douwe Maan 已提交
284 285
  end

286 287 288 289 290 291 292 293 294 295 296 297 298 299 300
  def expire_avatar_cache
    expire_method_caches(%i(avatar))
  end

  # Refreshes the method caches of this repository.
  #
  # types - An Array of file types (e.g. `:readme`) used to refresh extra
  #         caches.
  def refresh_method_caches(types)
    to_refresh = []

    types.each do |type|
      methods = METHOD_CACHES_FOR_FILE_TYPES[type.to_sym]

      to_refresh.concat(Array(methods)) if methods
301
    end
302

303
    expire_method_caches(to_refresh)
304

305
    to_refresh.each { |method| send(method) } # rubocop:disable GitlabSecurity/PublicSend
306
  end
307

308 309 310 311 312 313 314
  def expire_branch_cache(branch_name = nil)
    # When we push to the root branch we have to flush the cache for all other
    # branches as their statistics are based on the commits relative to the
    # root branch.
    if !branch_name || branch_name == root_ref
      branches.each do |branch|
        cache.expire(:"diverging_commit_counts_#{branch.name}")
315
        cache.expire(:"commit_count_#{branch.name}")
316 317 318 319 320
      end
    # In case a commit is pushed to a non-root branch we only have to flush the
    # cache for said branch.
    else
      cache.expire(:"diverging_commit_counts_#{branch_name}")
321
      cache.expire(:"commit_count_#{branch_name}")
322
    end
D
Dmitriy Zaporozhets 已提交
323 324
  end

325
  def expire_root_ref_cache
326
    expire_method_caches(%i(root_ref))
327 328
  end

329 330
  # Expires the cache(s) used to determine if a repository is empty or not.
  def expire_emptiness_caches
331
    return unless empty?
332

333
    expire_method_caches(%i(has_visible_content?))
334
    raw_repository.expire_has_local_branches_cache
Y
Yorick Peterse 已提交
335 336
  end

337 338 339 340
  def lookup_cache
    @lookup_cache ||= {}
  end

341
  def expire_exists_cache
342
    expire_method_caches(%i(exists?))
343 344
  end

345 346 347 348 349 350 351
  # expire cache that doesn't depend on repository data (when expiring)
  def expire_content_cache
    expire_tags_cache
    expire_branches_cache
    expire_root_ref_cache
    expire_emptiness_caches
    expire_exists_cache
352
    expire_statistics_caches
353 354 355 356 357
  end

  # Runs code after a repository has been created.
  def after_create
    expire_exists_cache
358 359
    expire_root_ref_cache
    expire_emptiness_caches
Y
Yorick Peterse 已提交
360 361

    repository_event(:create_repository)
362 363
  end

364 365
  # Runs code just before a repository is deleted.
  def before_delete
366
    expire_exists_cache
367 368
    expire_all_method_caches
    expire_branch_cache if exists?
369
    expire_content_cache
Y
Yorick Peterse 已提交
370 371

    repository_event(:remove_repository)
372 373 374 375 376 377 378
  end

  # Runs code just before the HEAD of a repository is changed.
  def before_change_head
    # Cached divergent commit counts are based on repository head
    expire_branch_cache
    expire_root_ref_cache
Y
Yorick Peterse 已提交
379 380

    repository_event(:change_default_branch)
381 382
  end

Y
Yorick Peterse 已提交
383 384
  # Runs code before pushing (= creating or removing) a tag.
  def before_push_tag
385 386
    expire_statistics_caches
    expire_emptiness_caches
387
    expire_tags_cache
Y
Yorick Peterse 已提交
388 389

    repository_event(:push_tag)
Y
Yorick Peterse 已提交
390 391 392 393 394
  end

  # Runs code before removing a tag.
  def before_remove_tag
    expire_tags_cache
395
    expire_statistics_caches
Y
Yorick Peterse 已提交
396 397

    repository_event(:remove_tag)
398 399
  end

L
Lin Jen-Shin 已提交
400 401 402 403 404
  # Runs code after removing a tag.
  def after_remove_tag
    expire_tags_cache
  end

405 406 407
  # Runs code after the HEAD of a repository is changed.
  def after_change_head
    expire_method_caches(METHOD_CACHES_FOR_FILE_TYPES.keys)
408 409
  end

410 411
  # Runs code after a repository has been forked/imported.
  def after_import
412
    expire_content_cache
413 414 415
  end

  # Runs code after a new commit has been pushed.
416 417 418
  def after_push_commit(branch_name)
    expire_statistics_caches
    expire_branch_cache(branch_name)
Y
Yorick Peterse 已提交
419 420

    repository_event(:push_commit, branch: branch_name)
421 422 423 424
  end

  # Runs code after a new branch has been created.
  def after_create_branch
425
    expire_branches_cache
Y
Yorick Peterse 已提交
426 427

    repository_event(:push_branch)
428 429
  end

430 431 432
  # Runs code before removing an existing branch.
  def before_remove_branch
    expire_branches_cache
Y
Yorick Peterse 已提交
433 434

    repository_event(:remove_branch)
435 436
  end

437 438
  # Runs code after an existing branch has been removed.
  def after_remove_branch
439
    expire_branches_cache
440 441
  end

442
  def method_missing(m, *args, &block)
443 444
    if m == :lookup && !block_given?
      lookup_cache[m] ||= {}
445
      lookup_cache[m][args.join(":")] ||= raw_repository.__send__(m, *args, &block) # rubocop:disable GitlabSecurity/PublicSend
446
    else
447
      raw_repository.__send__(m, *args, &block) # rubocop:disable GitlabSecurity/PublicSend
448
    end
449 450
  end

451 452
  def respond_to_missing?(method, include_private = false)
    raw_repository.respond_to?(method, include_private) || super
453
  end
D
Dmitriy Zaporozhets 已提交
454 455

  def blob_at(sha, path)
456
    Blob.decorate(raw_repository.blob_at(sha, path), project)
D
Douwe Maan 已提交
457 458
  rescue Gitlab::Git::Repository::NoRepository
    nil
D
Dmitriy Zaporozhets 已提交
459
  end
460

461 462 463 464 465
  # items is an Array like: [[oid, path], [oid1, path1]]
  def blobs_at(items)
    raw_repository.batch_blobs(items).map { |blob| Blob.decorate(blob, project) }
  end

466
  def root_ref
467 468
    # When the repo does not exist, or there is no root ref, we raise this error so no data is cached.
    raw_repository&.root_ref or raise Gitlab::Git::Repository::NoRepository # rubocop:disable Style/AndOr
469
  end
470
  cache_method :root_ref
471

472
  # Gitaly migration: https://gitlab.com/gitlab-org/gitaly/issues/314
473
  def exists?
474
    return false unless full_path
475

476
    raw_repository.exists?
477 478 479
  end
  cache_method :exists?

480 481 482
  # We don't need to cache the output of this method because both exists? and
  # has_visible_content? are already memoized and cached. There's no guarantee
  # that the values are expired and loaded atomically.
483 484 485 486 487
  def empty?
    return true unless exists?

    !has_visible_content?
  end
488 489 490 491 492 493 494 495 496 497 498 499

  # The size of this repository in megabytes.
  def size
    exists? ? raw_repository.size : 0.0
  end
  cache_method :size, fallback: 0.0

  def commit_count
    root_ref ? raw_repository.commit_count(root_ref) : 0
  end
  cache_method :commit_count, fallback: 0

500
  def commit_count_for_ref(ref)
501
    return 0 unless exists?
502

503
    cache.fetch(:"commit_count_#{ref}") { raw_repository.commit_count(ref) }
504 505
  end

506
  delegate :branch_names, to: :raw_repository
507 508
  cache_method :branch_names, fallback: []

D
Douwe Maan 已提交
509
  delegate :tag_names, to: :raw_repository
510 511
  cache_method :tag_names, fallback: []

512
  delegate :branch_count, :tag_count, :has_visible_content?, to: :raw_repository
513 514
  cache_method :branch_count, fallback: 0
  cache_method :tag_count, fallback: 0
515
  cache_method :has_visible_content?, fallback: false
516 517

  def avatar
518 519 520 521 522
    # n+1: https://gitlab.com/gitlab-org/gitlab-ce/issues/38327
    Gitlab::GitalyClient.allow_n_plus_1_calls do
      if tree = file_on_head(:avatar)
        tree.path
      end
523 524
    end
  end
525
  cache_method :avatar
526

S
Sean McGivern 已提交
527 528 529 530 531 532 533 534 535 536
  def issue_template_names
    Gitlab::Template::IssueTemplate.dropdown_names(project)
  end
  cache_method :issue_template_names, fallback: []

  def merge_request_template_names
    Gitlab::Template::MergeRequestTemplate.dropdown_names(project)
  end
  cache_method :merge_request_template_names, fallback: []

537
  def readme
538 539
    if readme = tree(:head)&.readme
      ReadmeBlob.new(readme, self)
540
    end
541 542
  end

543
  def rendered_readme
T
Toon Claes 已提交
544
    MarkupHelper.markup_unsafe(readme.name, readme.data, project: project) if readme
545 546
  end
  cache_method :rendered_readme
547

548
  def contribution_guide
549
    file_on_head(:contributing)
550
  end
551
  cache_method :contribution_guide
552 553

  def changelog
554
    file_on_head(:changelog)
555
  end
556
  cache_method :changelog
557

558
  def license_blob
559
    file_on_head(:license)
560
  end
561
  cache_method :license_blob
Z
Zeger-Jan van de Weg 已提交
562

563
  def license_key
564
    return unless exists?
565

566
    raw_repository.license_short_name
567
  end
568
  cache_method :license_key
569

D
Douwe Maan 已提交
570 571
  def license
    return unless license_key
572

573
    Licensee::License.new(license_key)
574
  end
575
  cache_method :license, memoize_only: true
576 577

  def gitignore
578
    file_on_head(:gitignore)
579
  end
580
  cache_method :gitignore
581 582

  def koding_yml
583
    file_on_head(:koding)
584
  end
585
  cache_method :koding_yml
586

587
  def gitlab_ci_yml
588
    file_on_head(:gitlab_ci)
589
  end
590
  cache_method :gitlab_ci_yml
591

592
  def head_commit
593 594 595 596
    @head_commit ||= commit(self.root_ref)
  end

  def head_tree
597 598 599
    if head_commit
      @head_tree ||= Tree.new(self, head_commit.sha, nil)
    end
600 601
  end

602
  def tree(sha = :head, path = nil, recursive: false)
603
    if sha == :head
604 605
      return unless head_commit

606 607 608 609 610
      if path.nil?
        return head_tree
      else
        sha = head_commit.sha
      end
611 612
    end

613
    Tree.new(self, sha, path, recursive: recursive)
614
  end
D
Dmitriy Zaporozhets 已提交
615 616

  def blob_at_branch(branch_name, path)
D
Dmitriy Zaporozhets 已提交
617
    last_commit = commit(branch_name)
D
Dmitriy Zaporozhets 已提交
618

D
Dmitriy Zaporozhets 已提交
619 620 621 622 623
    if last_commit
      blob_at(last_commit.sha, path)
    else
      nil
    end
D
Dmitriy Zaporozhets 已提交
624
  end
D
Dmitriy Zaporozhets 已提交
625

626
  def last_commit_for_path(sha, path)
627 628
    commit = raw_repository.last_commit_for_path(sha, path)
    ::Commit.new(commit, @project) if commit
629
  end
630

H
Hiroyuki Sato 已提交
631 632
  def last_commit_id_for_path(sha, path)
    key = path.blank? ? "last_commit_id_for_path:#{sha}" : "last_commit_id_for_path:#{sha}:#{Digest::SHA1.hexdigest(path)}"
H
Hiroyuki Sato 已提交
633

H
Hiroyuki Sato 已提交
634
    cache.fetch(key) do
635
      last_commit_for_path(sha, path)&.id
H
Hiroyuki Sato 已提交
636 637 638
    end
  end

639
  def next_branch(name, opts = {})
P
P.S.V.R 已提交
640 641
    branch_ids = self.branch_names.map do |n|
      next 1 if n == name
642

P
P.S.V.R 已提交
643
      result = n.match(/\A#{name}-([0-9]+)\z/)
644 645 646
      result[1].to_i if result
    end.compact

P
P.S.V.R 已提交
647
    highest_branch_id = branch_ids.max || 0
648

P
P.S.V.R 已提交
649 650 651
    return name if opts[:mild] && 0 == highest_branch_id

    "#{name}-#{highest_branch_id + 1}"
652 653
  end

654
  def branches_sorted_by(value)
655
    raw_repository.local_branches(sort_by: value)
656
  end
657

658 659
  def tags_sorted_by(value)
    case value
H
haseeb 已提交
660 661 662
    when 'name_asc'
      VersionSorter.sort(tags) { |tag| tag.name }
    when 'name_desc'
663
      VersionSorter.rsort(tags) { |tag| tag.name }
664 665 666 667 668 669 670 671 672
    when 'updated_desc'
      tags_sorted_by_committed_date.reverse
    when 'updated_asc'
      tags_sorted_by_committed_date
    else
      tags
    end
  end

673 674 675 676 677
  # Params:
  #
  # order_by: name|email|commits
  # sort: asc|desc default: 'asc'
  def contributors(order_by: nil, sort: 'asc')
678
    commits = self.commits(nil, limit: 2000, offset: 0, skip_merges: true)
679

680
    commits = commits.group_by(&:author_email).map do |email, commits|
681 682
      contributor = Gitlab::Contributor.new
      contributor.email = email
683

D
Dmitriy Zaporozhets 已提交
684
      commits.each do |commit|
685
        if contributor.name.blank?
D
Dmitriy Zaporozhets 已提交
686
          contributor.name = commit.author_name
687 688
        end

689
        contributor.commits += 1
690 691
      end

692 693
      contributor
    end
694
    Commit.order_by(collection: commits, order_by: order_by, sort: sort)
695
  end
D
Dmitriy Zaporozhets 已提交
696

697
  def branch_names_contains(sha)
698
    raw_repository.branch_names_contains_sha(sha)
699
  end
H
Hannes Rosenögger 已提交
700

701
  def tag_names_contains(sha)
702
    raw_repository.tag_names_contains_sha(sha)
H
Hannes Rosenögger 已提交
703
  end
704

705
  def local_branches
706
    @local_branches ||= raw_repository.local_branches
707 708
  end

709 710
  alias_method :branches, :local_branches

711 712 713 714
  def tags
    @tags ||= raw_repository.tags
  end

D
Douwe Maan 已提交
715 716
  def create_dir(user, path, **options)
    options[:actions] = [{ action: :create_dir, file_path: path }]
717

718
    multi_action(user, **options)
S
Stan Hu 已提交
719 720
  end

D
Douwe Maan 已提交
721 722
  def create_file(user, path, content, **options)
    options[:actions] = [{ action: :create, file_path: path, content: content }]
723

724
    multi_action(user, **options)
S
Stan Hu 已提交
725
  end
726

D
Douwe Maan 已提交
727 728 729
  def update_file(user, path, content, **options)
    previous_path = options.delete(:previous_path)
    action = previous_path && previous_path != path ? :move : :update
730

D
Douwe Maan 已提交
731
    options[:actions] = [{ action: action, file_path: path, previous_path: previous_path, content: content }]
732

733
    multi_action(user, **options)
734 735
  end

D
Douwe Maan 已提交
736 737
  def delete_file(user, path, **options)
    options[:actions] = [{ action: :delete, file_path: path }]
738

739
    multi_action(user, **options)
740 741
  end

742 743
  def with_cache_hooks
    result = yield
744

745
    return unless result
746

747 748
    after_create if result.repo_created?
    after_create_branch if result.branch_created?
749

750 751 752
    result.newrev
  end

753 754
  def multi_action(user, **options)
    start_project = options.delete(:start_project)
M
Marc Siegfriedt 已提交
755

756 757
    if start_project
      options[:start_repository] = start_project.repository.raw_repository
M
Marc Siegfriedt 已提交
758 759
    end

760
    with_cache_hooks { raw.multi_action(user, **options) }
761 762
  end

763 764 765 766 767 768
  def merge(user, source_sha, merge_request, message)
    with_cache_hooks do
      raw_repository.merge(user, source_sha, merge_request.target_branch, message) do |commit_id|
        merge_request.update(in_progress_merge_commit_sha: commit_id)
        nil # Return value does not matter.
      end
769
    end
770 771
  end

772
  def ff_merge(user, source, target_branch, merge_request: nil)
773 774
    their_commit_id = commit(source)&.id
    raise 'Invalid merge source' if their_commit_id.nil?
775

776
    merge_request&.update(in_progress_merge_commit_sha: their_commit_id)
777

778
    with_cache_hooks { raw.ff_merge(user, their_commit_id, target_branch) }
779 780
  end

781
  def revert(
782
    user, commit, branch_name, message,
783
    start_branch_name: nil, start_project: project)
784

785 786 787 788 789 790 791 792 793
    with_cache_hooks do
      raw_repository.revert(
        user: user,
        commit: commit.raw,
        branch_name: branch_name,
        message: message,
        start_branch_name: start_branch_name,
        start_repository: start_project.repository.raw_repository
      )
794
    end
795 796
  end

797
  def cherry_pick(
798
    user, commit, branch_name, message,
799
    start_branch_name: nil, start_project: project)
P
P.S.V.R 已提交
800

801 802 803 804 805 806 807 808 809
    with_cache_hooks do
      raw_repository.cherry_pick(
        user: user,
        commit: commit.raw,
        branch_name: branch_name,
        message: message,
        start_branch_name: start_branch_name,
        start_repository: start_project.repository.raw_repository
      )
P
P.S.V.R 已提交
810 811 812
    end
  end

813
  def merged_to_root_ref?(branch_or_name)
814 815 816
    branch = Gitlab::Git::Branch.find(self, branch_or_name)

    if branch
817 818
      same_head = branch.target == root_ref_sha
      merged = ancestor?(branch.target, root_ref_sha)
819
      !same_head && merged
F
Florent (HP) 已提交
820 821 822 823 824
    else
      nil
    end
  end

825 826 827 828
  def root_ref_sha
    @root_ref_sha ||= commit(root_ref).sha
  end

829
  delegate :merged_branch_names, :can_be_merged?, to: :raw_repository
830

S
Stan Hu 已提交
831
  def merge_base(first_commit_id, second_commit_id)
832 833
    first_commit_id = commit(first_commit_id).try(:id) || first_commit_id
    second_commit_id = commit(second_commit_id).try(:id) || second_commit_id
834
    raw_repository.merge_base(first_commit_id, second_commit_id)
S
Stan Hu 已提交
835 836
  end

837
  def ancestor?(ancestor_id, descendant_id)
838
    return false if ancestor_id.nil? || descendant_id.nil?
839

840
    raw_repository.ancestor?(ancestor_id, descendant_id)
841 842
  end

843
  def fetch_as_mirror(url, forced: false, refmap: :all_refs, remote_name: nil, prune: true)
844 845 846 847 848
    unless remote_name
      remote_name = "tmp-#{SecureRandom.hex}"
      tmp_remote_name = true
    end

849
    add_remote(remote_name, url, mirror_refmap: refmap)
850
    fetch_remote(remote_name, forced: forced, prune: prune)
851 852 853 854
  ensure
    remove_remote(remote_name) if tmp_remote_name
  end

855 856
  def fetch_remote(remote, forced: false, ssh_auth: nil, no_tags: false, prune: true)
    gitlab_shell.fetch_remote(raw_repository, remote, ssh_auth: ssh_auth, forced: forced, no_tags: no_tags, prune: prune)
857 858
  end

859 860
  def fetch_source_branch!(source_repository, source_branch, local_ref)
    raw_repository.fetch_source_branch!(source_repository.raw_repository, source_branch, local_ref)
861
  end
862

863 864
  def compare_source_branch(target_branch_name, source_repository, source_branch_name, straight:)
    raw_repository.compare_source_branch(target_branch_name, source_repository.raw_repository, source_branch_name, straight: straight)
865
  end
866

867
  def create_ref(ref, ref_path)
868
    raw_repository.write_ref(ref_path, ref)
869 870
  end

871 872 873 874 875
  def ls_files(ref)
    actual_ref = ref || root_ref
    raw_repository.ls_files(actual_ref)
  end

876 877 878 879 880 881 882 883 884 885 886 887
  def search_files_by_content(query, ref)
    return [] if empty? || query.blank?

    raw_repository.search_files_by_content(query, ref)
  end

  def search_files_by_name(query, ref)
    return [] if empty?

    raw_repository.search_files_by_name(query, ref)
  end

888 889 890 891 892 893 894 895 896 897
  def copy_gitattributes(ref)
    actual_ref = ref || root_ref
    begin
      raw_repository.copy_gitattributes(actual_ref)
      true
    rescue Gitlab::Git::Repository::InvalidRef
      false
    end
  end

898 899
  def file_on_head(type)
    if head = tree(:head)
D
Douwe Maan 已提交
900 901
      head.blobs.find do |blob|
        Gitlab::FileDetector.type_of(blob.path) == type
902 903 904 905
      end
    end
  end

D
Douwe Maan 已提交
906 907 908 909
  def route_map_for(sha)
    blob_data_at(sha, '.gitlab/route-map.yml')
  end

910 911
  def gitlab_ci_yml_for(sha, path = '.gitlab-ci.yml')
    blob_data_at(sha, path)
D
Douwe Maan 已提交
912 913
  end

914 915 916 917
  def fetch_ref(source_repository, source_ref:, target_ref:)
    raw_repository.fetch_ref(source_repository.raw_repository, source_ref: source_ref, target_ref: target_ref)
  end

918 919 920 921
  def repository_storage_path
    @project.repository_storage_path
  end

922 923 924 925 926 927 928
  def rebase(user, merge_request)
    raw.rebase(user, merge_request.id, branch: merge_request.source_branch,
                                       branch_sha: merge_request.source_branch_sha,
                                       remote_repository: merge_request.target_project.repository.raw,
                                       remote_branch: merge_request.target_branch)
  end

929 930
  private

931 932 933 934 935 936 937 938 939 940 941 942
  # TODO Generice finder, later split this on finders by Ref or Oid
  # gitlab-org/gitlab-ce#39239
  def find_commit(oid_or_ref)
    commit = if oid_or_ref.is_a?(Gitlab::Git::Commit)
               oid_or_ref
             else
               Gitlab::Git::Commit.find(raw_repository, oid_or_ref)
             end

    ::Commit.new(commit, @project) if commit
  end

D
Douwe Maan 已提交
943 944
  def blob_data_at(sha, path)
    blob = blob_at(sha, path)
945
    return unless blob
946

947
    blob.load_all_data!
948
    blob.data
949
  end
950

951
  def cache
952
    @cache ||= Gitlab::RepositoryCache.new(self)
953
  end
954 955

  def tags_sorted_by_committed_date
956 957 958 959 960 961 962 963 964 965 966 967
    tags.sort_by do |tag|
      # Annotated tags can point to any object (e.g. a blob), but generally
      # tags point to a commit. If we don't have a commit, then just default
      # to putting the tag at the end of the list.
      target = tag.dereferenced_target

      if target
        target.committed_date
      else
        Time.now
      end
    end
968
  end
D
Douwe Maan 已提交
969 970

  def keep_around_ref_name(sha)
971
    "refs/#{REF_KEEP_AROUND}/#{sha}"
D
Douwe Maan 已提交
972
  end
Y
Yorick Peterse 已提交
973 974

  def repository_event(event, tags = {})
975
    Gitlab::Metrics.add_event(event, { path: full_path }.merge(tags))
Y
Yorick Peterse 已提交
976
  end
977

978
  def initialize_raw_repository
979
    Gitlab::Git::Repository.new(project.repository_storage, disk_path + '.git', Gitlab::GlRepository.gl_repository(project, is_wiki))
980
  end
981
end