summaryrefslogtreecommitdiffstats
path: root/aclk/schema-wrappers/proto_2_json.cc
diff options
context:
space:
mode:
Diffstat (limited to 'aclk/schema-wrappers/proto_2_json.cc')
-rw-r--r--aclk/schema-wrappers/proto_2_json.cc88
1 files changed, 0 insertions, 88 deletions
diff --git a/aclk/schema-wrappers/proto_2_json.cc b/aclk/schema-wrappers/proto_2_json.cc
deleted file mode 100644
index 854396510..000000000
--- a/aclk/schema-wrappers/proto_2_json.cc
+++ /dev/null
@@ -1,88 +0,0 @@
-#include <google/protobuf/message.h>
-#include <google/protobuf/util/json_util.h>
-
-#include "proto/alarm/v1/config.pb.h"
-#include "proto/alarm/v1/stream.pb.h"
-#include "proto/aclk/v1/lib.pb.h"
-#include "proto/agent/v1/connection.pb.h"
-#include "proto/agent/v1/disconnect.pb.h"
-#include "proto/nodeinstance/connection/v1/connection.pb.h"
-#include "proto/nodeinstance/create/v1/creation.pb.h"
-#include "proto/nodeinstance/info/v1/info.pb.h"
-#include "proto/context/v1/stream.pb.h"
-#include "proto/context/v1/context.pb.h"
-#include "proto/agent/v1/cmds.pb.h"
-
-#include "libnetdata/libnetdata.h"
-
-#include "proto_2_json.h"
-
-using namespace google::protobuf::util;
-
-static google::protobuf::Message *msg_name_to_protomsg(const char *msgname)
-{
-//tx side
- if (!strcmp(msgname, "UpdateAgentConnection"))
- return new agent::v1::UpdateAgentConnection;
- if (!strcmp(msgname, "UpdateNodeInstanceConnection"))
- return new nodeinstance::v1::UpdateNodeInstanceConnection;
- if (!strcmp(msgname, "CreateNodeInstance"))
- return new nodeinstance::create::v1::CreateNodeInstance;
- if (!strcmp(msgname, "UpdateNodeInfo"))
- return new nodeinstance::info::v1::UpdateNodeInfo;
- if (!strcmp(msgname, "AlarmCheckpoint"))
- return new alarms::v1::AlarmCheckpoint;
- if (!strcmp(msgname, "ProvideAlarmConfiguration"))
- return new alarms::v1::ProvideAlarmConfiguration;
- if (!strcmp(msgname, "AlarmSnapshot"))
- return new alarms::v1::AlarmSnapshot;
- if (!strcmp(msgname, "AlarmLogEntry"))
- return new alarms::v1::AlarmLogEntry;
- if (!strcmp(msgname, "UpdateNodeCollectors"))
- return new nodeinstance::info::v1::UpdateNodeCollectors;
- if (!strcmp(msgname, "ContextsUpdated"))
- return new context::v1::ContextsUpdated;
- if (!strcmp(msgname, "ContextsSnapshot"))
- return new context::v1::ContextsSnapshot;
-
-//rx side
- if (!strcmp(msgname, "CreateNodeInstanceResult"))
- return new nodeinstance::create::v1::CreateNodeInstanceResult;
- if (!strcmp(msgname, "SendNodeInstances"))
- return new agent::v1::SendNodeInstances;
- if (!strcmp(msgname, "StartAlarmStreaming"))
- return new alarms::v1::StartAlarmStreaming;
- if (!strcmp(msgname, "SendAlarmCheckpoint"))
- return new alarms::v1::SendAlarmCheckpoint;
- if (!strcmp(msgname, "SendAlarmConfiguration"))
- return new alarms::v1::SendAlarmConfiguration;
- if (!strcmp(msgname, "SendAlarmSnapshot"))
- return new alarms::v1::SendAlarmSnapshot;
- if (!strcmp(msgname, "DisconnectReq"))
- return new agent::v1::DisconnectReq;
- if (!strcmp(msgname, "ContextsCheckpoint"))
- return new context::v1::ContextsCheckpoint;
- if (!strcmp(msgname, "StopStreamingContexts"))
- return new context::v1::StopStreamingContexts;
- if (!strcmp(msgname, "CancelPendingRequest"))
- return new agent::v1::CancelPendingRequest;
-
- return NULL;
-}
-
-char *protomsg_to_json(const void *protobin, size_t len, const char *msgname)
-{
- google::protobuf::Message *msg = msg_name_to_protomsg(msgname);
- if (msg == NULL)
- return strdupz("Don't know this message type by name.");
-
- if (!msg->ParseFromArray(protobin, len))
- return strdupz("Can't parse this message. Malformed or wrong parser used.");
-
- JsonPrintOptions options;
-
- std::string output;
- google::protobuf::util::MessageToJsonString(*msg, &output, options);
- delete msg;
- return strdupz(output.c_str());
-}