1 files changed, 246 insertions, 0 deletions
diff --git a/veslibrary/ves_cpplibrary/src/lib/encode/XMobileFlowFieldsImp.cpp b/veslibrary/ves_cpplibrary/src/lib/encode/XMobileFlowFieldsImp.cpp
new file mode 100755
index 0000000..8889db9
--- /dev/null
+++ b/veslibrary/ves_cpplibrary/src/lib/encode/XMobileFlowFieldsImp.cpp
@@ -0,0 +1,246 @@
+#include "XMobileFlowFieldsImp.h"
+
+const std::string XEnumMobileFlowFieldsMobileFlowFieldsVersionMapping[] = {
+    "4.0"
+};
+
+XMobileFlowFieldsImp::XMobileFlowFieldsImp(std::shared_ptr<XCommonEventHeader> header,
+                const XString& flowDirection,
+                const XGtpPerFlowMetrics& gtpPerFlowMetrics,
+                const XString& ipProtocolType,
+                const XString& ipVersion,
+                const XString& otherEndpointIpAddress,
+                XInteger otherEndpointPort,
+                const XString& reportingEndpointIpAddr,
+                XInteger reportingEndpointPort
+    ):
+        header_(header),
+        flowDirection_(flowDirection),
+        gtpPerFlowMetrics_(gtpPerFlowMetrics),
+        ipProtocolType_(ipProtocolType),
+        ipVersion_(ipVersion),
+        mobileFlowFieldsVersion_(XEnumMobileFlowFieldsMobileFlowFieldsVersion4_0),
+        otherEndpointIpAddress_(otherEndpointIpAddress),
+        otherEndpointPort_(otherEndpointPort),
+        reportingEndpointIpAddr_(reportingEndpointIpAddr),
+        reportingEndpointPort_(reportingEndpointPort)
+{
+
+}
+
+std::string XMobileFlowFieldsImp::toString()
+{
+    try
+    {
+        auto js = toJson();
+        return js.dump();
+    }
+    catch (json::exception& e)
+    {
+        SPDLOG_ERROR("Fail to dump XMobileFlowFields to json string:{}.", e.what());
+        return "";
+    }
+}
+
+void XMobileFlowFieldsImp::setRac(const XString& rac)
+{
+    comVals_["rac"] = rac;
+}
+            
+void XMobileFlowFieldsImp::setSac(const XString& sac)
+{
+    comVals_["sac"] = sac;
+}
+            
+void XMobileFlowFieldsImp::setSamplingAlgorithm(XInteger samplingAlgorithm)
+{
+    comVals_["samplingAlgorithm"] = samplingAlgorithm;
+}
+            
+void XMobileFlowFieldsImp::setIpVersion(const XString& ipVersion)
+{
+    comVals_["ipVersion"] = ipVersion;
+}
+            
+void XMobileFlowFieldsImp::setGtpPerFlowMetrics(const XGtpPerFlowMetrics& gtpPerFlowMetrics)
+{
+    gtpPerFlowMetrics_ = gtpPerFlowMetrics;
+}
+            
+void XMobileFlowFieldsImp::setTac(const XString& tac)
+{
+    comVals_["tac"] = tac;
+}
+            
+void XMobileFlowFieldsImp::setMnc(const XString& mnc)
+{
+    comVals_["mnc"] = mnc;
+}
+            
+void XMobileFlowFieldsImp::setTunnelId(const XString& tunnelId)
+{
+    comVals_["tunnelId"] = tunnelId;
+}
+            
+void XMobileFlowFieldsImp::setAppProtocolVersion(const XString& appProtocolVersion)
+{
+    comVals_["appProtocolVersion"] = appProtocolVersion;
+}
+            
+void XMobileFlowFieldsImp::setGtpVersion(const XString& gtpVersion)
+{
+    comVals_["gtpVersion"] = gtpVersion;
+}
+            
+void XMobileFlowFieldsImp::setConnectionType(const XString& connectionType)
+{
+    comVals_["connectionType"] = connectionType;
+}
+            
+void XMobileFlowFieldsImp::setAdditionalFields(const XHashMap& additionalFields)
+{
+    additionalFields_ = additionalFields;
+}
+            
+void XMobileFlowFieldsImp::setHttpHeader(const XString& httpHeader)
+{
+    comVals_["httpHeader"] = httpHeader;
+}
+            
+void XMobileFlowFieldsImp::setImsi(const XString& imsi)
+{
+    comVals_["imsi"] = imsi;
+}
+            
+void XMobileFlowFieldsImp::setApplicationType(const XString& applicationType)
+{
+    comVals_["applicationType"] = applicationType;
+}
+            
+void XMobileFlowFieldsImp::setMsisdn(const XString& msisdn)
+{
+    comVals_["msisdn"] = msisdn;
+}
+            
+void XMobileFlowFieldsImp::setMcc(const XString& mcc)
+{
+    comVals_["mcc"] = mcc;
+}
+            
+void XMobileFlowFieldsImp::setFlowDirection(const XString& flowDirection)
+{
+    comVals_["flowDirection"] = flowDirection;
+}
+            
+void XMobileFlowFieldsImp::setLac(const XString& lac)
+{
+    comVals_["lac"] = lac;
+}
+            
+void XMobileFlowFieldsImp::setOtherEndpointPort(XInteger otherEndpointPort)
+{
+    comVals_["otherEndpointPort"] = otherEndpointPort;
+}
+            
+void XMobileFlowFieldsImp::setVlanId(const XString& vlanId)
+{
+    comVals_["vlanId"] = vlanId;
+}
+            
+void XMobileFlowFieldsImp::setImei(const XString& imei)
+{
+    comVals_["imei"] = imei;
+}
+            
+void XMobileFlowFieldsImp::setGtpProtocolType(const XString& gtpProtocolType)
+{
+    comVals_["gtpProtocolType"] = gtpProtocolType;
+}
+            
+void XMobileFlowFieldsImp::setEcgi(const XString& ecgi)
+{
+    comVals_["ecgi"] = ecgi;
+}
+            
+void XMobileFlowFieldsImp::setCid(const XString& cid)
+{
+    comVals_["cid"] = cid;
+}
+            
+void XMobileFlowFieldsImp::setReportingEndpointPort(XInteger reportingEndpointPort)
+{
+    comVals_["reportingEndpointPort"] = reportingEndpointPort;
+}
+            
+void XMobileFlowFieldsImp::setRadioAccessTechnology(const XString& radioAccessTechnology)
+{
+    comVals_["radioAccessTechnology"] = radioAccessTechnology;
+}
+            
+void XMobileFlowFieldsImp::setAppProtocolType(const XString& appProtocolType)
+{
+    comVals_["appProtocolType"] = appProtocolType;
+}
+            
+void XMobileFlowFieldsImp::setOtherEndpointIpAddress(const XString& otherEndpointIpAddress)
+{
+    comVals_["otherEndpointIpAddress"] = otherEndpointIpAddress;
+}
+            
+void XMobileFlowFieldsImp::setIpProtocolType(const XString& ipProtocolType)
+{
+    comVals_["ipProtocolType"] = ipProtocolType;
+}
+            
+void XMobileFlowFieldsImp::setOtherFunctionalRole(const XString& otherFunctionalRole)
+{
+    comVals_["otherFunctionalRole"] = otherFunctionalRole;
+}
+            
+void XMobileFlowFieldsImp::setReportingEndpointIpAddr(const XString& reportingEndpointIpAddr)
+{
+    comVals_["reportingEndpointIpAddr"] = reportingEndpointIpAddr;
+}
+
+json XMobileFlowFieldsImp::toJson()
+{
+    try
+    {
+        json field = {
+            {"ipVersion", ipVersion_},
+            {"mobileFlowFieldsVersion", XEnumMobileFlowFieldsMobileFlowFieldsVersionMapping[mobileFlowFieldsVersion_]},
+            {"gtpPerFlowMetrics", dynamic_pointer_cast<XJsonable>(gtpPerFlowMetrics_.imp_)->toJson()},
+            {"flowDirection", flowDirection_},
+            {"otherEndpointPort", otherEndpointPort_},
+            {"reportingEndpointPort", reportingEndpointPort_},
+            {"otherEndpointIpAddress", otherEndpointIpAddress_},
+            {"ipProtocolType", ipProtocolType_},
+            {"reportingEndpointIpAddr", reportingEndpointIpAddr_}
+        };
+
+        //optional val
+        if (!additionalFields_.empty())
+        {
+            field["additionalFields"] = additionalFields_;
+        }
+        field = mergeCommonValues(field, comVals_);
+
+        json jsEvent;
+        header_->setDomain(XEnumCommonEventHeaderDomainMobileFlow);
+        jsEvent["event"]["commonEventHeader"] = dynamic_pointer_cast<XJsonable>(header_)->toJson();
+        jsEvent["event"]["mobileFlowFields"] = field;
+
+        return jsEvent;
+    }
+    catch (json::exception& e)
+    {
+        SPDLOG_ERROR("Fail to build XMobileFlowFields to json object:{}.", e.what());
+        return json();
+    }
+}
+
+std::shared_ptr<XCommonEventHeader> XMobileFlowFieldsImp::getCommonHeader()
+{
+    return header_;
+}
+            
+\ No newline at end of file