From 47eeba4a4a7302662f4c39ebcc8e15a7876f8227 Mon Sep 17 00:00:00 2001 From: Paul Cristian Sarbu Date: Mon, 9 Oct 2023 15:30:31 +0200 Subject: 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 --- .../serve_api/remote/source_tree_client.cpp | 50 ++++++++++++++++++++++ 1 file changed, 50 insertions(+) create mode 100644 src/buildtool/serve_api/remote/source_tree_client.cpp (limited to 'src/buildtool/serve_api/remote/source_tree_client.cpp') 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 { + 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(response.status())); + return std::nullopt; + } + return response.tree(); +} -- cgit v1.2.3