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
129
130
|
// Copyright 2022 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_BUILD_ENGINE_BASE_MAPS_JSON_FILE_MAP_HPP
#define INCLUDED_SRC_BUILDTOOL_BUILD_ENGINE_BASE_MAPS_JSON_FILE_MAP_HPP
#include <cstddef>
#include <exception>
#include <filesystem>
#include <string>
#include <utility> // std::move
#include "fmt/core.h"
#include "gsl/gsl"
#include "nlohmann/json.hpp"
#include "src/buildtool/build_engine/base_maps/module_name.hpp"
#include "src/buildtool/common/repository_config.hpp"
#include "src/buildtool/file_system/file_root.hpp"
#include "src/buildtool/multithreading/async_map_consumer.hpp"
namespace BuildMaps::Base {
using JsonFileMap = AsyncMapConsumer<ModuleName, nlohmann::json>;
// function pointer type for specifying which root to get from global config
using RootGetter = auto (RepositoryConfig::*)(std::string const&) const
-> FileRoot const*;
// function pointer type for specifying the file name from the global config
using FileNameGetter = auto (RepositoryConfig::*)(std::string const&) const
-> std::string const*;
template <RootGetter kGetRoot, FileNameGetter kGetName, bool kMandatory = true>
auto CreateJsonFileMap(
gsl::not_null<const RepositoryConfig*> const& repo_config,
std::size_t jobs) -> JsonFileMap {
auto json_file_reader = [repo_config](auto /* unused */,
auto setter,
auto logger,
auto /* unused */,
auto const& key) {
auto const* root = ((*repo_config).*kGetRoot)(key.repository);
auto const* json_file_name = ((*repo_config).*kGetName)(key.repository);
if (root == nullptr or json_file_name == nullptr) {
(*logger)(fmt::format("Cannot determine root or JSON file name for "
"repository {}.",
key.repository),
true);
return;
}
auto module = std::filesystem::path{key.module}.lexically_normal();
if (module.is_absolute() or *module.begin() == "..") {
(*logger)(fmt::format("Modules have to live inside their "
"repository, but found {}.",
key.module),
true);
return;
}
auto json_file_path = module / *json_file_name;
if (root->IsAbsent()) {
std::string missing_root = "[unknown]";
auto absent_tree = root->GetAbsentTreeId();
if (absent_tree) {
missing_root = *absent_tree;
}
(*logger)(fmt::format(
"Would have to read JSON file {} of absent root {}.",
json_file_path.string(),
missing_root),
true);
return;
}
if (not root->IsFile(json_file_path)) {
if constexpr (kMandatory) {
(*logger)(fmt::format("JSON file {} does not exist.",
json_file_path.string()),
true);
}
else {
(*setter)(nlohmann::json::object());
}
return;
}
auto const file_content = root->ReadContent(json_file_path);
if (not file_content) {
(*logger)(fmt::format("cannot read JSON file {}.",
json_file_path.string()),
true);
return;
}
auto json = nlohmann::json();
try {
json = nlohmann::json::parse(*file_content);
} catch (std::exception const& e) {
(*logger)(
fmt::format("JSON file {} does not contain valid JSON:\n{}",
json_file_path.string(),
e.what()),
true);
return;
}
if (not json.is_object()) {
(*logger)(fmt::format("JSON in {} is not an object.",
json_file_path.string()),
true);
return;
}
(*setter)(std::move(json));
};
return AsyncMapConsumer<ModuleName, nlohmann::json>{json_file_reader, jobs};
}
} // namespace BuildMaps::Base
#endif // INCLUDED_SRC_BUILDTOOL_BUILD_ENGINE_BASE_MAPS_JSON_FILE_MAP_HPP
|
