summaryrefslogtreecommitdiffstats
path: root/aclk/schema-wrappers/connection.cc
diff options
context:
space:
mode:
Diffstat (limited to 'aclk/schema-wrappers/connection.cc')
-rw-r--r--aclk/schema-wrappers/connection.cc72
1 files changed, 0 insertions, 72 deletions
diff --git a/aclk/schema-wrappers/connection.cc b/aclk/schema-wrappers/connection.cc
deleted file mode 100644
index 20b40ece2..000000000
--- a/aclk/schema-wrappers/connection.cc
+++ /dev/null
@@ -1,72 +0,0 @@
-// SPDX-License-Identifier: GPL-3.0-or-later
-
-#include "proto/agent/v1/connection.pb.h"
-#include "proto/agent/v1/disconnect.pb.h"
-#include "connection.h"
-
-#include "schema_wrapper_utils.h"
-
-#include <sys/time.h>
-#include <stdlib.h>
-
-using namespace agent::v1;
-
-char *generate_update_agent_connection(size_t *len, const update_agent_connection_t *data)
-{
- UpdateAgentConnection connupd;
-
- connupd.set_claim_id(data->claim_id);
- connupd.set_reachable(data->reachable);
- connupd.set_session_id(data->session_id);
-
- connupd.set_update_source((data->lwt) ? CONNECTION_UPDATE_SOURCE_LWT : CONNECTION_UPDATE_SOURCE_AGENT);
-
- struct timeval tv;
- gettimeofday(&tv, NULL);
-
- google::protobuf::Timestamp *timestamp = connupd.mutable_updated_at();
- timestamp->set_seconds(tv.tv_sec);
- timestamp->set_nanos(tv.tv_usec * 1000);
-
- if (data->capabilities) {
- const struct capability *capa = data->capabilities;
- while (capa->name) {
- aclk_lib::v1::Capability *proto_capa = connupd.add_capabilities();
- capability_set(proto_capa, capa);
- capa++;
- }
- }
-
- *len = PROTO_COMPAT_MSG_SIZE(connupd);
- char *msg = (char*)mallocz(*len);
- if (msg)
- connupd.SerializeToArray(msg, *len);
-
- return msg;
-}
-
-struct disconnect_cmd *parse_disconnect_cmd(const char *data, size_t len) {
- DisconnectReq req;
- struct disconnect_cmd *res;
-
- if (!req.ParseFromArray(data, len))
- return NULL;
-
- res = (struct disconnect_cmd *)callocz(1, sizeof(struct disconnect_cmd));
-
- if (!res)
- return NULL;
-
- res->reconnect_after_s = req.reconnect_after_seconds();
- res->permaban = req.permaban();
- res->error_code = req.error_code();
- if (req.error_description().c_str()) {
- res->error_description = strdupz(req.error_description().c_str());
- if (!res->error_description) {
- freez(res);
- return NULL;
- }
- }
-
- return res;
-}