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
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
require 'licensee'
module GitalyServer
class RepositoryService < Gitaly::RepositoryService::Service
include Utils
def create_repository(_request, call)
repo_path = GitalyServer.repo_path(call)
Gitlab::Git::Repository.create(repo_path)
Gitaly::CreateRepositoryResponse.new
end
def fetch_source_branch(request, call)
source_repository = Gitlab::Git::GitalyRemoteRepository.new(request.source_repository, call)
repository = Gitlab::Git::Repository.from_gitaly(request.repository, call)
result = repository.fetch_source_branch!(source_repository, request.source_branch, request.target_ref)
Gitaly::FetchSourceBranchResponse.new(result: result)
end
def fetch_remote(request, call)
gitlab_projects = Gitlab::Git::GitlabProjects.from_gitaly(request.repository, call)
remote_name = request.remote
repository = nil
if request.remote_params
params = request.remote_params
repository = Gitlab::Git::Repository.from_gitaly(request.repository, call)
mirror_refmaps = parse_refmaps(params.mirror_refmaps)
repository.add_remote(params.name, params.url, mirror_refmap: mirror_refmaps)
remote_name = params.name
end
success = Gitlab::Git::SshAuth.from_gitaly(request).setup do |env|
Gitlab::Git::HttpAuth.from_gitaly(request, call) do
gitlab_projects.fetch_remote(
remote_name,
request.timeout,
force: request.force,
tags: !request.no_tags,
env: env
)
end
end
raise GRPC::Unknown.new("Fetching remote #{request.remote} failed: #{gitlab_projects.output}") unless success
Gitaly::FetchRemoteResponse.new
ensure
repository&.remove_remote(remote_name)
end
def write_config(request, call)
repo = Gitlab::Git::Repository.from_gitaly(request.repository, call)
repo.write_config(full_path: request.full_path)
Gitaly::WriteConfigResponse.new
rescue Rugged::Error => ex
Gitaly::WriteConfigResponse.new(error: ex.message.b)
end
def set_config(request, call)
repo = Gitlab::Git::Repository.from_gitaly(request.repository, call)
request.entries.each do |entry|
key = entry.key
value = case entry.value
when :value_str
entry.value_str
when :value_int32
entry.value_int32
when :value_bool
entry.value_bool
else
raise GRPC::InvalidArgument, "unknown entry type: #{entry.value}"
end
repo.rugged.config[key] = value
end
Gitaly::SetConfigResponse.new
end
def find_license(request, call)
repo = Gitlab::Git::Repository.from_gitaly(request.repository, call)
short_name = begin
::Licensee.license(repo.path).try(:key)
rescue Rugged::Error
end
Gitaly::FindLicenseResponse.new(license_short_name: short_name || "")
end
private
OPERATION_MAP = {
added: Gitaly::GetRawChangesResponse::RawChange::Operation::ADDED,
copied: Gitaly::GetRawChangesResponse::RawChange::Operation::COPIED,
deleted: Gitaly::GetRawChangesResponse::RawChange::Operation::DELETED,
modified: Gitaly::GetRawChangesResponse::RawChange::Operation::MODIFIED,
renamed: Gitaly::GetRawChangesResponse::RawChange::Operation::RENAMED,
type_changed: Gitaly::GetRawChangesResponse::RawChange::Operation::TYPE_CHANGED
}.freeze
def to_proto_raw_change(change)
operation = OPERATION_MAP[change.operation] || Gitaly::GetRawChangesResponse::RawChange::Operation::UNKNOWN
# Protobuf doesn't even try to call `to_s` or `to_i` where it might be needed.
Gitaly::GetRawChangesResponse::RawChange.new(
blob_id: change.blob_id.to_s,
size: change.blob_size.to_i,
new_path: change.new_path.to_s,
old_path: change.old_path.to_s,
operation: operation,
old_mode: change.old_mode.to_i(8),
new_mode: change.new_mode.to_i(8)
)
end
end
end
|
