summaryrefslogtreecommitdiff
path: root/src/buildtool/serve_api/remote/source_tree_client.cpp
diff options
context:
space:
mode:
authorPaul Cristian Sarbu <paul.cristian.sarbu@huawei.com>2023-10-09 15:30:31 +0200
committerPaul Cristian Sarbu <paul.cristian.sarbu@huawei.com>2023-11-02 12:06:50 +0100
commit47eeba4a4a7302662f4c39ebcc8e15a7876f8227 (patch)
tree03a261af2d0ca532607c1e949a344799bee1d02a /src/buildtool/serve_api/remote/source_tree_client.cpp
parentc1a58d73d2fa21f9c692bbe3895443d3afc43d1d (diff)
downloadjustbuild-47eeba4a4a7302662f4c39ebcc8e15a7876f8227.tar.gz
just serve: Fix inconsistencies
- add missing serve_api TARGETS file - rename service client to align with server naming scheme - fix inconsistencies in comments between implementation and protocol
Diffstat (limited to 'src/buildtool/serve_api/remote/source_tree_client.cpp')
-rw-r--r--src/buildtool/serve_api/remote/source_tree_client.cpp50
1 files changed, 50 insertions, 0 deletions
diff --git a/src/buildtool/serve_api/remote/source_tree_client.cpp b/src/buildtool/serve_api/remote/source_tree_client.cpp
new file mode 100644
index 00000000..2026d80d
--- /dev/null
+++ b/src/buildtool/serve_api/remote/source_tree_client.cpp
@@ -0,0 +1,50 @@
+// Copyright 2023 Huawei Cloud Computing Technology Co., Ltd.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+#include "src/buildtool/serve_api/remote/source_tree_client.hpp"
+
+#include "src/buildtool/common/remote/client_common.hpp"
+
+SourceTreeClient::SourceTreeClient(std::string const& server,
+ Port port) noexcept {
+ stub_ = justbuild::just_serve::SourceTree::NewStub(
+ CreateChannelWithCredentials(server, port));
+}
+
+auto SourceTreeClient::ServeCommitTree(std::string const& commit_id,
+ std::string const& subdir,
+ bool sync_tree)
+ -> std::optional<std::string> {
+ justbuild::just_serve::ServeCommitTreeRequest request{};
+ request.set_commit(commit_id);
+ request.set_subdir(subdir);
+ request.set_sync_tree(sync_tree);
+
+ grpc::ClientContext context;
+ justbuild::just_serve::ServeCommitTreeResponse response;
+ grpc::Status status = stub_->ServeCommitTree(&context, request, &response);
+
+ if (not status.ok()) {
+ LogStatus(&logger_, LogLevel::Debug, status);
+ return std::nullopt;
+ }
+ if (response.status() !=
+ ::justbuild::just_serve::ServeCommitTreeResponse::OK) {
+ logger_.Emit(LogLevel::Debug,
+ "ServeCommitTree response returned with {}",
+ static_cast<int>(response.status()));
+ return std::nullopt;
+ }
+ return response.tree();
+}