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

websocket: send node configuration as metadata to the relay

Browse source
This commit is contained in:
Steffen Vogel 2021-03-19 08:30:22 -04:00
parent 65e26e31b9
commit 3b84db26c6
1 changed files with 32 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
lib/nodes/websocket.cpp
View file

@ -26,6 +26,7 @@
#include <cstring>
#include <signal.h>
#include <curl/curl.h>
#include <libwebsockets.h>
#include <villas/timing.h>
@ -81,6 +82,34 @@ static void websocket_destination_destroy(struct websocket_destination *d)
free((char *) d->info.address);
}
static void websocket_connection_send_metadata(struct websocket_connection *c)
{
json_t *json = node_to_json(c->node);
CURL *handle = curl_easy_init();
curl_easy_setopt(handle, CURLOPT_TIMEOUT, 3L);
curl_easy_setopt(handle, CURLOPT_URL, c->destination->uri);
curl_easy_setopt(handle, CURLOPT_FOLLOWLOCATION, 1L);
curl_easy_setopt(handle, CURLOPT_POSTFIELDS, json_dumps(json, 0));
CURLcode ret = curl_easy_perform(handle);
if (ret) {
logger->warn("Failed to update metadata of node {}: {}", node_name(c->node), curl_easy_strerror(ret));
goto out;
}
long code;
curl_easy_getinfo(handle, CURLINFO_RESPONSE_CODE, &code);
if (ret)
logger->warn("Failed to update metadata of node {}: Received HTTP code {}", node_name(c->node), code);
out: curl_easy_cleanup(handle);
return;
}
static int websocket_connection_init(struct websocket_connection *c)
{
int ret;
@ -101,6 +130,9 @@ static int websocket_connection_init(struct websocket_connection *c)
if (!c->buffers.recv || !c->buffers.send)
throw MemoryAllocationError();
if (c->mode == websocket_connection::Mode::CLIENT)
websocket_connection_send_metadata(c);
c->state = websocket_connection::State::INITIALIZED;
return 0;