Jakarta changes in slice-analysis-ms for IBN Cloud leased line update and CCVPN closed-loop. This commit contains work in sub-task: 1) AAI monitor thread; 2) bandwidth evaluator; 3) policy notification code.1.1.0-slice-analysis-ms

Issue-ID: DCAEGEN2-3063
Signed-off-by: decheng zhang <decheng.zhang@huawei.com>
Change-Id: I9029ffd7563e65be59f7fd76adc2a749ff624172
Signed-off-by: decheng zhang <decheng.zhang@huawei.com>

1 files changed, 112 insertions, 0 deletions

diff --git a/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/VesNotificationCallback.java b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/VesNotificationCallback.java
new file mode 100644
index 00000000..83bfcdbe
--- /dev/null
+++ b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/VesNotificationCallback.java
@@ -0,0 +1,112 @@
+/*******************************************************************************
+ *  ============LICENSE_START=======================================================
+ *  slice-analysis-ms
+ *  ================================================================================
+ *  Copyright (C) 2022 Huawei Canada Limited.
+ *  ==============================================================================
+ *     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.
+ *     ============LICENSE_END=========================================================
+ *
+ *******************************************************************************/
+
+package org.onap.slice.analysis.ms.dmaap;
+
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.onap.slice.analysis.ms.models.Configuration;
+import org.onap.slice.analysis.ms.models.vesnotification.NotificationFields;
+
+import org.onap.slice.analysis.ms.service.ccvpn.CCVPNPmDatastore;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+import java.io.IOException;
+
+/**
+ * Handles Notification on dmaap for ves notification events
+ */
+@Component
+public class VesNotificationCallback implements NotificationCallback {
+
+    private Configuration configuration;
+    private String NOTIFICATIONFIELDS = "notificationFields";
+    private String EVENT = "event";
+    private String vesNotifChangeIdentifier;
+    private String vesNotfiChangeType;
+
+    @Autowired
+    CCVPNPmDatastore ccvpnPmDatastore;
+
+    private static Logger log = LoggerFactory.getLogger(VesNotificationCallback.class);
+
+    /**
+     * init ves callback; load configuration.
+     */
+    @PostConstruct
+    public void init(){
+        configuration = Configuration.getInstance();
+        vesNotifChangeIdentifier = configuration.getVesNotifChangeIdentifier();
+        vesNotfiChangeType = configuration.getVesNotifChangeType();
+    }
+
+    /**
+     * Triggers on handleNofitication method
+     * @param msg incoming message
+     */
+    @Override
+    public void activateCallBack(String msg) {
+        handleNotification(msg);
+    }
+
+    /**
+     * Parse Performance dmaap notification and save to DB 
+     * @param msg incoming message
+     */
+    private void handleNotification(String msg) {
+        log.info("Message received from VES : {}" ,msg);
+        ObjectMapper obj = new ObjectMapper();
+        NotificationFields output = null;
+        String notifChangeIdentifier = "";
+        String notifChangeType = "";
+        String cllId = null;
+        String uniId = null;
+        String bw = null;
+        try {
+            JsonNode node = obj.readTree(msg);
+            JsonNode notificationNode = node.get(EVENT).get(NOTIFICATIONFIELDS);
+            output = obj.treeToValue(notificationNode, NotificationFields.class);
+
+            //Filter out target notification changeIdentifier and changeType
+            notifChangeIdentifier = output.getChangeIdentifier();
+            notifChangeType = output.getChangeType();
+            if (notifChangeType.equals(vesNotfiChangeType)
+            && notifChangeIdentifier.equals(vesNotifChangeIdentifier)) {
+                cllId = output.getArrayOfNamedHashMap().get(0).getHashMap().getCllId();
+                uniId = output.getArrayOfNamedHashMap().get(0).getHashMap().getUniId();
+                bw = output.getArrayOfNamedHashMap().get(0).getHashMap().getBandwidthValue();
+            }
+        }
+        catch (IOException e) {
+            log.error("Error converting VES msg to object, {}", e.getMessage());
+        }
+        if (cllId != null && uniId != null && bw != null){
+            ccvpnPmDatastore.addUsedBwToEndpoint(cllId, uniId, bw);
+        }
+
+    }
+
+}