diff options
Diffstat (limited to 'src/buildtool/main/serve.cpp')
| -rw-r--r-- | src/buildtool/main/serve.cpp | 276 |
1 files changed, 276 insertions, 0 deletions
diff --git a/src/buildtool/main/serve.cpp b/src/buildtool/main/serve.cpp new file mode 100644 index 00000000..da7ed62a --- /dev/null +++ b/src/buildtool/main/serve.cpp @@ -0,0 +1,276 @@ +// 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/main/serve.hpp" + +#ifndef BOOTSTRAP_BUILD_TOOL + +#include <fstream> + +#include "nlohmann/json.hpp" +#include "src/buildtool/build_engine/expression/configuration.hpp" +#include "src/buildtool/build_engine/expression/expression.hpp" +#include "src/buildtool/file_system/file_system_manager.hpp" +#include "src/buildtool/logging/log_level.hpp" +#include "src/buildtool/logging/logger.hpp" +#include "src/buildtool/main/exit_codes.hpp" + +void ReadJustServeConfig(gsl::not_null<CommandLineArguments*> const& clargs) { + Configuration serve_config{}; + if (FileSystemManager::IsFile(clargs->serve.config)) { + // json::parse may throw + try { + std::ifstream fs(clargs->serve.config); + auto map = Expression::FromJson(nlohmann::json::parse(fs)); + if (not map->IsMap()) { + Logger::Log(LogLevel::Error, + "In just-serve config file {}: expected an object " + "but found:\n{}", + clargs->serve.config.string(), + map->ToString()); + std::exit(kExitFailure); + } + serve_config = Configuration{map}; + } catch (std::exception const& e) { + Logger::Log(LogLevel::Error, + "Parsing just-serve config file {} as JSON failed with " + "error:\n{}", + clargs->serve.config.string(), + e.what()); + std::exit(kExitFailure); + } + } + else { + Logger::Log(LogLevel::Error, + "Cannot read just-serve config file {}", + clargs->serve.config.string()); + std::exit(kExitFailure); + } + // read paths of additional lookup repositories + auto repositories = serve_config["repositories"]; + if (repositories.IsNotNull()) { + if (not repositories->IsList()) { + Logger::Log( + LogLevel::Error, + "just-serve: configuration-file provided repositories has " + "to be a list of strings, but found {}", + repositories->ToString()); + std::exit(kExitFailure); + } + auto const& repos_list = repositories->List(); + clargs->serve.repositories.reserve(clargs->serve.repositories.size() + + repos_list.size()); + for (auto const& repo : repos_list) { + if (not repo->IsString()) { + Logger::Log(LogLevel::Error, + "just-serve: expected each repository path to be a " + "string, but found {}", + repo->ToString()); + std::exit(kExitFailure); + } + clargs->serve.repositories.emplace_back(repo->String()); + } + } + // read logging arguments + auto logging = serve_config["logging"]; + if (logging.IsNotNull()) { + if (not logging->IsMap()) { + Logger::Log( + LogLevel::Error, + "just-serve: configuration-file provided logging arguments has " + "to be a map, but found {}", + logging->ToString()); + std::exit(kExitFailure); + } + // read in first the append flag + auto append = logging->Get("append", Expression::none_t{}); + if (append.IsNotNull()) { + if (not append->IsBool()) { + Logger::Log(LogLevel::Error, + "Configuration-provided log append has to be a " + "flag, but found {}", + append->ToString()); + std::exit(kExitFailure); + } + clargs->log.log_append = append->Bool(); + } + // read in the plain flag + auto plain = logging->Get("plain", Expression::none_t{}); + if (plain.IsNotNull()) { + if (not plain->IsBool()) { + Logger::Log(LogLevel::Error, + "Configuration-provided plain log has to be a " + "flag, but found {}", + plain->ToString()); + std::exit(kExitFailure); + } + clargs->log.plain_log = plain->Bool(); + } + // read in files field + auto files = logging->Get("files", Expression::none_t{}); + if (files.IsNotNull()) { + if (not files->IsList()) { + Logger::Log(LogLevel::Error, + "Configuration-provided log files has to be a " + "list, but found {}", + files->ToString()); + std::exit(kExitFailure); + } + auto const& files_list = files->List(); + clargs->log.log_files.reserve(clargs->log.log_files.size() + + files_list.size()); + for (auto const& file : files_list) { + if (not file->IsString()) { + Logger::Log(LogLevel::Error, + "just-serve: expected each log file path to be " + "a string, but found {}", + file->ToString()); + std::exit(kExitFailure); + } + clargs->log.log_files.emplace_back(file->String()); + } + } + // read in limit field + auto limit = logging->Get("limit", Expression::none_t{}); + if (limit.IsNotNull()) { + if (not limit->IsNumber()) { + Logger::Log(LogLevel::Error, + "Configuration-provided log limit has to be " + "numeric, but found {}", + limit->ToString()); + std::exit(kExitFailure); + } + clargs->log.log_limit = ToLogLevel(limit->Number()); + } + } + // read client TLS authentication arguments + auto auth_args = serve_config["authentication"]; + if (auth_args.IsNotNull()) { + if (not auth_args->IsMap()) { + Logger::Log(LogLevel::Error, + "just-serve: configuration-file provided " + "authentication has to be a map, but found {}", + auth_args->ToString()); + std::exit(kExitFailure); + } + // read the TLS CA certificate + auto cacert = auth_args->Get("ca cert", Expression::none_t{}); + if (cacert.IsNotNull()) { + if (not cacert->IsString()) { + Logger::Log(LogLevel::Error, + "Configuration-provided TLS CA certificate has to " + "be a string, but found {}", + cacert->ToString()); + std::exit(kExitFailure); + } + clargs->auth.tls_ca_cert = cacert->String(); + } + } + // read remote service arguments + auto remote_service = serve_config["remote service"]; + if (remote_service.IsNotNull()) { + if (not remote_service->IsMap()) { + Logger::Log(LogLevel::Error, + "just-serve: configuration-file provided remote " + "service has to be a map, but found {}", + remote_service->ToString()); + std::exit(kExitFailure); + } + // read the interface + auto interface = remote_service->Get("interface", Expression::none_t{}); + if (interface.IsNotNull()) { + if (not interface->IsString()) { + Logger::Log(LogLevel::Error, + "Configuration-provided remote service interface " + "has to be a string, but found {}", + interface->ToString()); + std::exit(kExitFailure); + } + clargs->service.interface = interface->String(); + } + // read the port + auto port = remote_service->Get("port", Expression::none_t{}); + if (port.IsNotNull()) { + if (not port->IsNumber()) { + Logger::Log(LogLevel::Error, + "Configuration-provided remote service port has to " + "be numeric, but found {}", + port->ToString()); + std::exit(kExitFailure); + } + double val{}; + if (std::modf(port->Number(), &val) != 0.0) { + Logger::Log(LogLevel::Error, + "Configuration-provided remote service port has to " + "be an integer, but found {}", + interface->ToString()); + std::exit(kExitFailure); + } + // we are sure now that the port is an integer + clargs->service.port = std::nearbyint(val); + } + // read the pid file + auto pid_file = remote_service->Get("pid file", Expression::none_t{}); + if (pid_file.IsNotNull()) { + if (not pid_file->IsString()) { + Logger::Log(LogLevel::Error, + "Configuration-provided remote service pid file " + "has to be a string, but found {}", + pid_file->ToString()); + std::exit(kExitFailure); + } + clargs->service.pid_file = pid_file->String(); + } + // read the info file + auto info_file = remote_service->Get("info file", Expression::none_t{}); + if (info_file.IsNotNull()) { + if (not info_file->IsString()) { + Logger::Log(LogLevel::Error, + "Configuration-provided remote service info file " + "has to be a string, but found {}", + info_file->ToString()); + std::exit(kExitFailure); + } + clargs->service.info_file = info_file->String(); + } + // read the TLS server certificate + auto server_cert = + remote_service->Get("server cert", Expression::none_t{}); + if (server_cert.IsNotNull()) { + if (not server_cert->IsString()) { + Logger::Log(LogLevel::Error, + "Configuration-provided TLS server certificate has " + "to be a string, but found {}", + server_cert->ToString()); + std::exit(kExitFailure); + } + clargs->sauth.tls_server_cert = server_cert->String(); + } + // read the TLS server key + auto server_key = + remote_service->Get("server key", Expression::none_t{}); + if (server_key.IsNotNull()) { + if (not server_key->IsString()) { + Logger::Log(LogLevel::Error, + "Configuration-provided TLS server key has to be a " + "string, but found {}", + server_key->ToString()); + std::exit(kExitFailure); + } + clargs->sauth.tls_server_key = server_key->String(); + } + } +} + +#endif // BOOTSTRAP_BUILD_TOOL |