commit 48683b8ca543c63a03c8d594a768d48d4a1a87b9
author Gabriel Cuba <gcuba@whitestack.com> Wed Nov 08 00:14:33 2023 -0500
committer garciadeblas <gerardo.garciadeblas@telefonica.com> Tue Jan 30 15:36:12 2024 +0100
tree 0b54815a6cc0be9ab07e90d46d0e80b85076a1ba
parent bd02208d93ce9e5319b911258f60b85803d1c3be

Bug 1830 fixed: maps completed operations to original operation types

Change-Id: I1a2f60f183ede39cabd9a7441ae64f10d7557232
Signed-off-by: Gabriel Cuba <gcuba@whitestack.com>

osm_nbi/notifications.py

diff --git a/osm_nbi/notifications.py b/osm_nbi/notifications.py
index 63d4ce8..22413d0 100644
--- a/osm_nbi/notifications.py
+++ b/osm_nbi/notifications.py
@@ -235,6 +235,14 @@
 
 
 class NsLcmNotification(NotificationBase):
+    # maps kafka commands of completed operations to the original operation type
+    completed_operation_map = {
+        "INSTANTIATED": "INSTANTIATE",
+        "SCALED": "SCALE",
+        "TERMINATED": "TERMINATE",
+        "UPDATED": "UPDATE",
+        "HEALED": "HEAL",
+    }
     # SOL005 response model for nslcm notifications
     response_models = {
         "NsLcmOperationOccurrenceNotification": {
@@ -358,7 +366,8 @@
         if op_state:
             filter_q["operationStates"].append(op_state)
         if command:
-            filter_q["operationTypes"].append(command)
+            op_type = self.completed_operation_map.get(command, command)
+            filter_q["operationTypes"].append(op_type)
         # self.logger.debug("Db query is: {}".format(filter_q))
         subscribers = []
         try: