Mirrors/VILLASnode
1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/node/ synced 2025-03-09 00:00:00 +01:00
Code Issues Releases Wiki Activity

api: allow passing configuration via API during restart

Browse source
This commit is contained in:
Steffen Vogel 2020-10-16 11:38:58 +02:00
parent 1bd4d8b2d4
commit d79fd3de6d
1 changed files with 23 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
lib/api/requests/restart.cpp
View file

@ -66,18 +66,35 @@ public:
if (method != Session::Method::POST)
throw InvalidMethod(this);
const char *cfg = nullptr;
json_t *json_config = nullptr;
if (body) {
ret = json_unpack_ex(body, &err, 0, "{ s?: s }", "config", &cfg);
ret = json_unpack_ex(body, &err, 0, "{ s?: o }",
"config", &json_config
);
if (ret < 0)
throw BadRequest("Failed to parse request body");
}
/* If no config is provided via request, we will use the previous one */
configUri = cfg
? cfg
: session->getSuperNode()->getConfigUri();
if (json_config) {
if (json_is_string(json_config))
configUri = json_string_value(json_config);
else if (json_is_object(json_config)) {
configUri = tmpnam(nullptr);
FILE *configFile = fopen(configUri.c_str(), "w");
ret = json_dumpf(json_config, configFile, JSON_INDENT(4));
if (ret < 0)
throw Error(HTTP_STATUS_INTERNAL_SERVER_ERROR, "Failed to create temporary config file");
fclose(configFile);
}
elif (json_config != nullptr)
throw BadRequest("Parameter 'config' must be either a URL (string) or a configuration (object)");
}
else /* If no config is provided via request, we will use the previous one */
configUri = session->getSuperNode()->getConfigUri();
logger->info("Restarting to {}", configUri.c_str());