+/*******************************************************************************
+################################################################################
+# Copyright (c) [2020-2022] [HCL Technologies Ltd.] #
+# #
+# Licensed under the Apache License, Version 2.0 (the "License"); #
+# you may not use this file except in compliance with the License. #
+# You may obtain a copy of the License at #
+# #
+# http://www.apache.org/licenses/LICENSE-2.0 #
+# #
+# Unless required by applicable law or agreed to in writing, software #
+# distributed under the License is distributed on an "AS IS" BASIS, #
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. #
+# See the License for the specific language governing permissions and #
+# limitations under the License. #
+################################################################################
+*******************************************************************************/
+
+#include <iostream>
+#include <chrono>
+#include <iomanip>
+#include <sstream>
+#include "CellStateChangeStdDef.hpp"
+#include "JsonHelper.hpp"
+/* Default constructor*/
+CellStateChangeStdDef::CellStateChangeStdDef() : Notification(VesEventType::FAULT_NOTIFICATION)
+{
+
+}
+
+/* Default Destructor*/
+CellStateChangeStdDef::~CellStateChangeStdDef()
+{
+
+}
+
+
+/*******************************************************************
+ *
+ * @brief Returns ISO time String
+ *
+ * @details
+ *
+ * Function :getISOEventTime
+ *
+ * Functionality:
+ * - Returns ISO time String
+ *
+ * @params[in] IN - void
+ * @return value of string - success
+ * empty string - failure
+ *
+ * ****************************************************************/
+
+std::string CellStateChangeStdDef::getISOEventTime() {
+ auto now = std::chrono::system_clock::now();
+ auto itt = std::chrono::system_clock::to_time_t(now);
+ std::ostringstream os;
+ os << std::put_time(gmtime(&itt), "%FT%TZ");
+ return os.str();
+}
+
+/*******************************************************************
+ *
+ * @brief prepare CellStateChangeStdDef Fields
+ *
+ * @details
+ *
+ * Function : prepareCellStateChangeStdDefEventFields
+ *
+ * Functionality:
+ * - prepare CellStateChangeStdDef Fields in json format
+ *
+ * @params[in] IN - pointer to pnfFields
+ * @return true - success
+ * false - failure
+ *
+ * ****************************************************************/
+
+bool CellStateChangeStdDef::prepareEventFields(const Message* msg) {
+ const Alarm* alrm = dynamic_cast<const Alarm*> (msg);
+ if(!alrm) {
+ O1_LOG("\nO1 CellStateChangeStdDef : Casting failed in prepareEventFields");
+ return false;
+ }
+ bool ret = true;
+
+
+ cJSON* stndDefinedFields = this->mVesEventFields;
+
+ if(JsonHelper::addNodeToObject(stndDefinedFields, "schemaReference", FAULT_SCHEMA) == 0) {
+ ret = false;
+ }
+
+ cJSON* data = JsonHelper::createNode();
+ if(data == 0) {
+ O1_LOG("\nO1 CellStateChangeStdDef : could not create data JSON object");
+ return false;
+ }
+ else if(JsonHelper::addJsonNodeToObject(stndDefinedFields, "data", \
+ data) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(data, "href", HREF) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(data, "uri", URI) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(data, "notificationId", NOTIFICATION_ID) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(data, "notificationType", NOTIFICATION_TYPE) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(data, "eventTime", getISOEventTime().c_str()) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(data, "systemDN", "") == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(data, "probableCause", PROBABLE_CAUSE) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(data, "perceivedSeverity",PERCEIVED_SEVERITY) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(data, "rootCauseIndicator", (bool)false ) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(data, "specificProblem", "") == 0) {
+ ret = false;
+ }
+
+ cJSON* correlatedNotificationsArr= cJSON_CreateArray();
+ if (correlatedNotificationsArr == NULL)
+ {
+ ret = false;
+ }
+ cJSON_AddItemToObject(data, "correlatedNotifications", correlatedNotificationsArr);
+
+ if(JsonHelper::addNodeToObject(data, "backedUpStatus", (bool)true) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(data, "backUpObject", "") == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(data, "trendIndication", TRND_INDICATION) == 0) {
+ ret = false;
+ }
+
+ cJSON* thresholdInfo = JsonHelper::createNode();
+ if(thresholdInfo == 0) {
+ O1_LOG("\nO1 CellStateChange : could not create thresholdInfo JSON object");
+ return false;
+ }
+ else if(JsonHelper::addJsonNodeToObject(data, "thresholdInfo", \
+ thresholdInfo ) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(thresholdInfo, "observedMeasurement", OBSRVED_MEASUREMENT) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(thresholdInfo, "observedValue", OBSERVED_VALUE) == 0) {
+ ret = false;
+ }
+
+ cJSON* stateChangeDefinitionArr= cJSON_CreateArray();
+ if (stateChangeDefinitionArr == NULL)
+ {
+ ret = false;
+ }
+ cJSON_AddItemToObject(data, "stateChangeDefinition", stateChangeDefinitionArr);
+
+ cJSON* monitoredAttributes = JsonHelper::createNode();
+ if( monitoredAttributes == 0) {
+ O1_LOG("\nO1 CellStateChange : could not create monitoredAttributes JSON object");
+ return false;
+ }
+ else if(JsonHelper::addJsonNodeToObject(data , "monitoredAttributes", \
+ monitoredAttributes ) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(monitoredAttributes, "newAtt", NEW_ATT) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(data, "proposedRepairActions", PROPOSED_REPAIR_ACTION) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(data, "additionalText", ADDITIONAL_TEXT) == 0) {
+ ret = false;
+ }
+
+ cJSON* additionalInformation = JsonHelper::createNode();
+ if(additionalInformation == 0) {
+ O1_LOG("\nO1 CellStateChangeStdDef : could not create additionalInformation JSON object");
+ return false;
+ }
+ else if(JsonHelper::addJsonNodeToObject(data , "additionalInformation", \
+ additionalInformation ) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject( additionalInformation, "addInfo", ADD_INFO) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(data , "alarmId", ALARM_ID) == 0) {
+ ret = false;
+ }
+ else if(JsonHelper::addNodeToObject(data , "alarmType",ALRAM_TYPE ) == 0) {
+ ret = false;
+ }
+
+ else if(JsonHelper::addNodeToObject(stndDefinedFields, "stndDefinedFieldsVersion", STND_DEFINED_FEILD_VERSION) == 0) {
+ ret = false;
+ }
+
+
+
+ return ret;
+}
+
+
+/**********************************************************************
+ End of file
+ **********************************************************************/