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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
|
module Gitlab
module Git
class GitalyRemoteRepository < RemoteRepository
CLIENT_NAME = 'gitaly-ruby'.freeze
attr_reader :gitaly_client
def initialize(gitaly_repository, call)
@gitaly_repository = gitaly_repository
@storage = gitaly_repository.storage_name
@gitaly_client = GitalyServer.client(call)
end
def path
raise 'gitaly-ruby cannot access remote repositories by path'
end
def empty?
!exists? || !has_visible_content?
end
def branch_exists?(branch_name)
request = Gitaly::RefExistsRequest.new(repository: @gitaly_repository, ref: "refs/heads/#{branch_name}".b)
stub = Gitaly::RefService::Stub.new(address, credentials)
stub.ref_exists(request, request_kwargs).value
end
def commit_id(revision)
request = Gitaly::FindCommitRequest.new(repository: @gitaly_repository, revision: revision.b)
stub = Gitaly::CommitService::Stub.new(address, credentials)
stub.find_commit(request, request_kwargs)&.commit&.id.presence
end
private
def exists?
request = Gitaly::RepositoryExistsRequest.new(repository: @gitaly_repository)
stub = Gitaly::RepositoryService::Stub.new(address, credentials)
stub.repository_exists(request, request_kwargs).exists
end
def has_visible_content?
request = Gitaly::HasLocalBranchesRequest.new(repository: @gitaly_repository)
stub = Gitaly::RepositoryService::Stub.new(address, credentials)
stub.has_local_branches(request, request_kwargs).value
end
def address
addr = gitaly_client.address(storage)
addr = addr.sub(%r{^tcp://}, '') if URI(addr).scheme == 'tcp'
addr
end
def credentials
:this_channel_is_insecure
end
def token
gitaly_client.token(storage).to_s
end
def request_kwargs
@request_kwargs ||= begin
metadata = {
'authorization' => "Bearer #{auhtorization_token}",
'client_name' => CLIENT_NAME
}
{ metadata: metadata }
end
end
def auhtorization_token
issued_at = Time.now.to_i.to_s
hmac = OpenSSL::HMAC.hexdigest(OpenSSL::Digest::SHA256.new, token, issued_at)
"v2.#{hmac}.#{issued_at}"
end
end
end
end
|
