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
|
// 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.
#ifndef INCLUDED_SRC_BUILDTOOL_SERVE_API_REMOTE_SERVE_API_HPP
#define INCLUDED_SRC_BUILDTOOL_SERVE_API_REMOTE_SERVE_API_HPP
#include <memory>
#include <optional>
#include <string>
#include "src/buildtool/common/remote/port.hpp"
#include "src/buildtool/file_system/symlinks_map/pragma_special.hpp"
#include "src/buildtool/serve_api/remote/config.hpp"
#include "src/buildtool/serve_api/remote/configuration_client.hpp"
#include "src/buildtool/serve_api/remote/source_tree_client.hpp"
#include "src/buildtool/serve_api/remote/target_client.hpp"
class ServeApi final {
public:
ServeApi(ServeApi const&) = delete;
~ServeApi() = default;
auto operator=(ServeApi const&) -> ServeApi& = delete;
auto operator=(ServeApi&&) -> ServeApi& = delete;
[[nodiscard]] static auto Instance() noexcept -> ServeApi& {
static ServeApi instance = ServeApi::init();
return instance;
}
[[nodiscard]] static auto RetrieveTreeFromCommit(
std::string const& commit,
std::string const& subdir = ".",
bool sync_tree = false) -> std::optional<std::string> {
return Instance().stc_->ServeCommitTree(commit, subdir, sync_tree);
}
[[nodiscard]] static auto RetrieveTreeFromArchive(
std::string const& content,
std::string const& archive_type = "archive",
std::string const& subdir = ".",
std::optional<PragmaSpecial> const& resolve_symlinks = std::nullopt,
bool sync_tree = false) -> std::optional<std::string> {
return Instance().stc_->ServeArchiveTree(
content, archive_type, subdir, resolve_symlinks, sync_tree);
}
[[nodiscard]] static auto ContentInRemoteCAS(std::string const& content)
-> bool {
return Instance().stc_->ServeContent(content);
}
[[nodiscard]] static auto ServeTargetVariables(
std::string const& target_root_id,
std::string const& target_file,
std::string const& target) -> std::optional<std::vector<std::string>> {
return Instance().tc_->ServeTargetVariables(
target_root_id, target_file, target);
}
[[nodiscard]] static auto ServeTarget(const TargetCacheKey& key)
-> std::optional<std::pair<TargetCacheEntry, Artifact::ObjectInfo>> {
return Instance().tc_->ServeTarget(key);
}
[[nodiscard]] static auto CheckServeRemoteExecution() -> bool {
return Instance().cc_->CheckServeRemoteExecution();
}
private:
ServeApi(std::string const& host, Port port) noexcept
: stc_{std::make_unique<SourceTreeClient>(host, port)},
tc_{std::make_unique<TargetClient>(host, port)},
cc_{std::make_unique<ConfigurationClient>(host, port)} {}
ServeApi(ServeApi&& other) noexcept = default;
[[nodiscard]] static auto init() noexcept -> ServeApi {
auto sadd = RemoteServeConfig::RemoteAddress();
return ServeApi{sadd->host, sadd->port};
}
// source tree service client
std::unique_ptr<SourceTreeClient> stc_;
// target service client
std::unique_ptr<TargetClient> tc_;
// configuration service client
std::unique_ptr<ConfigurationClient> cc_;
};
#endif // INCLUDED_SRC_BUILDTOOL_SERVE_API_REMOTE_SERVE_API_HPP
|
