diff options
author | Paul Cristian Sarbu <paul.cristian.sarbu@huawei.com> | 2023-10-09 15:30:31 +0200 |
---|---|---|
committer | Paul Cristian Sarbu <paul.cristian.sarbu@huawei.com> | 2023-11-02 12:06:50 +0100 |
commit | 47eeba4a4a7302662f4c39ebcc8e15a7876f8227 (patch) | |
tree | 03a261af2d0ca532607c1e949a344799bee1d02a /src/buildtool/serve_api/remote/source_tree_client.cpp | |
parent | c1a58d73d2fa21f9c692bbe3895443d3afc43d1d (diff) | |
download | justbuild-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.cpp | 50 |
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(); +} |