ruby/lib/gitaly_server/remote_service.rb


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
29
30
31
32
33
34
35
36
37
38
39
40

module GitalyServer
  class RemoteService < Gitaly::RemoteService::Service
    include Utils

    # Maximum number of divergent refs to return in UpdateRemoteMirrorResponse
    DIVERGENT_REF_LIMIT = 100

    def add_remote(request, call)
      repo = Gitlab::Git::Repository.from_gitaly(request.repository, call)

      mirror_refmap = parse_refmaps(request.mirror_refmaps)

      repo.add_remote(request.name, request.url, mirror_refmap: mirror_refmap)

      Gitaly::AddRemoteResponse.new
    end

    def update_remote_mirror(call)
      request_enum = call.each_remote_read
      first_request = request_enum.next

      only_branches_matching = first_request.only_branches_matching.to_a
      only_branches_matching += request_enum.flat_map(&:only_branches_matching)

      remote_mirror = Gitlab::Git::RemoteMirror.new(
        Gitlab::Git::Repository.from_gitaly(first_request.repository, call),
        first_request.ref_name,
        ssh_auth: Gitlab::Git::SshAuth.from_gitaly(first_request),
        only_branches_matching: only_branches_matching,
        keep_divergent_refs: first_request.keep_divergent_refs
      )

      remote_mirror.update

      Gitaly::UpdateRemoteMirrorResponse.new(
        divergent_refs: remote_mirror.divergent_refs.take(DIVERGENT_REF_LIMIT)
      )
    end
  end
end