1 files changed, 173 insertions, 0 deletions
diff --git a/veslibrary/ves_cpplibrary/src/lib/encode/XSyslogFieldsImp.cpp b/veslibrary/ves_cpplibrary/src/lib/encode/XSyslogFieldsImp.cpp
new file mode 100755
index 0000000..d7baefd
--- /dev/null
+++ b/veslibrary/ves_cpplibrary/src/lib/encode/XSyslogFieldsImp.cpp
@@ -0,0 +1,173 @@
+#include "XSyslogFieldsImp.h"
+
+const std::string XEnumSyslogFieldsEventSourceTypeMapping[] = {
+    "other",
+    "router",
+    "switch",
+    "host",
+    "card",
+    "port",
+    "slotThreshold",
+    "portThreshold",
+    "virtualMachine",
+    "virtualNetworkFunction"
+};
+
+const std::string XEnumSyslogFieldsSyslogSevMapping[] = {
+    "Alert",
+    "Critical",
+    "Debug",
+    "Emergency",
+    "Error",
+    "Info",
+    "Notice",
+    "Warning"
+};
+
+const std::string XEnumSyslogFieldsSyslogFieldsVersionMapping[] = {
+    "4.0"
+};
+
+XSyslogFieldsImp::XSyslogFieldsImp(std::shared_ptr<XCommonEventHeader> header,
+    XEnumSyslogFieldsEventSourceType eventSourceType,
+    const XString& syslogTag,
+    const XString& syslogMsg
+    ):
+        header_(header),
+        eventSourceType_(eventSourceType),
+        syslogFieldsVersion_(XEnumSyslogFieldsSyslogFieldsVersion4_0),
+        syslogMsg_(syslogMsg),
+        syslogTag_(syslogTag)
+{
+
+}
+
+std::string XSyslogFieldsImp::toString()
+{
+    try
+    {
+        auto js = toJson();
+        return js.dump();
+    }
+    catch (json::exception& e)
+    {
+        SPDLOG_ERROR("Fail to dump XSyslogFields to json string:{}.", e.what());
+        return "";
+    }
+}
+
+void XSyslogFieldsImp::setSyslogProcId(XNumber syslogProcId)
+{
+    comVals_["syslogProcId"] = syslogProcId;
+}
+            
+void XSyslogFieldsImp::setSyslogFacility(XInteger syslogFacility)
+{
+    comVals_["syslogFacility"] = syslogFacility;
+}
+            
+void XSyslogFieldsImp::setSyslogPri(XInteger syslogPri)
+{
+    comVals_["syslogPri"] = syslogPri;
+}
+            
+void XSyslogFieldsImp::setEventSourceType(XEnumSyslogFieldsEventSourceType eventSourceType)
+{
+    auto val = XEnumSyslogFieldsEventSourceTypeMapping[eventSourceType];
+    comVals_["eventSourceType"] = val;
+}
+            
+void XSyslogFieldsImp::setSyslogMsgHost(const XString& syslogMsgHost)
+{
+    comVals_["syslogMsgHost"] = syslogMsgHost;
+}
+            
+void XSyslogFieldsImp::setSyslogSev(XEnumSyslogFieldsSyslogSev syslogSev)
+{
+    auto val = XEnumSyslogFieldsSyslogSevMapping[syslogSev];
+    comVals_["syslogSev"] = val;
+}
+            
+void XSyslogFieldsImp::setSyslogSData(const XString& syslogSData)
+{
+    comVals_["syslogSData"] = syslogSData;
+}
+            
+void XSyslogFieldsImp::setSyslogMsg(const XString& syslogMsg)
+{
+    comVals_["syslogMsg"] = syslogMsg;
+}
+            
+void XSyslogFieldsImp::setSyslogProc(const XString& syslogProc)
+{
+    comVals_["syslogProc"] = syslogProc;
+}
+            
+void XSyslogFieldsImp::setEventSourceHost(const XString& eventSourceHost)
+{
+    comVals_["eventSourceHost"] = eventSourceHost;
+}
+            
+void XSyslogFieldsImp::setSyslogTs(const XString& syslogTs)
+{
+    comVals_["syslogTs"] = syslogTs;
+}
+            
+void XSyslogFieldsImp::setSyslogTag(const XString& syslogTag)
+{
+    comVals_["syslogTag"] = syslogTag;
+}
+            
+void XSyslogFieldsImp::setSyslogVer(XNumber syslogVer)
+{
+    comVals_["syslogVer"] = syslogVer;
+}
+            
+void XSyslogFieldsImp::setAdditionalFields(const XHashMap& additionalFields)
+{
+    additionalFields_ = additionalFields;
+}
+            
+void XSyslogFieldsImp::setSyslogSdId(const XString& syslogSdId)
+{
+    comVals_["syslogSdId"] = syslogSdId;
+}
+
+json XSyslogFieldsImp::toJson()
+{
+    try
+    {
+        json field = {
+            { "eventSourceType", XEnumSyslogFieldsEventSourceTypeMapping[eventSourceType_] },
+            { "syslogMsg", syslogMsg_ },
+            { "syslogFieldsVersion", XEnumSyslogFieldsSyslogFieldsVersionMapping[syslogFieldsVersion_] },
+            { "syslogTag", syslogTag_ }
+        };
+
+        //optional val
+        if (!additionalFields_.empty())
+        {
+            field["additionalFields"] = additionalFields_;
+        }
+
+        field = mergeCommonValues(field, comVals_);
+
+        json jsEvent;
+        header_->setDomain(XEnumCommonEventHeaderDomainSyslog);
+        jsEvent["event"]["commonEventHeader"] = dynamic_pointer_cast<XJsonable>(header_)->toJson();
+        jsEvent["event"]["syslogFields"] = field;
+
+        return jsEvent;
+    }
+    catch (json::exception& e)
+    {
+        SPDLOG_ERROR("Fail to build XSyslogFields to json object:{}.", e.what());
+        return json();
+    }
+}
+
+std::shared_ptr<XCommonEventHeader> XSyslogFieldsImp::getCommonHeader()
+{
+    return header_;
+}
+            
+\ No newline at end of file