Feature-9904: Enhancing NG-UI to enable Juju operational view dashboard
Implemented functions to receive vcaStatus update message from kafka
and update nsr record in mongo.
Addressed review comments
Change-Id: I54f526c74fd27328c88721002d41bd85a182f9eb
Signed-off-by: Priyadharshini G S <priyadharshini.g@tataelxsi.co.in>
Signed-off-by: ksaikiranr <saikiran.k@tataelxsi.co.in>
diff --git a/osm_lcm/lcm.py b/osm_lcm/lcm.py
index 6c8be98..659a57c 100644
--- a/osm_lcm/lcm.py
+++ b/osm_lcm/lcm.py
@@ -339,6 +339,13 @@
task = asyncio.ensure_future(self.ns.terminate(nsr_id, nslcmop_id))
self.lcm_tasks.register("ns", nsr_id, nslcmop_id, "ns_terminate", task)
return
+ elif command == "vca_status_refresh":
+ nslcmop = params
+ nslcmop_id = nslcmop["_id"]
+ nsr_id = nslcmop["nsInstanceId"]
+ task = asyncio.ensure_future(self.ns.vca_status_refresh(nsr_id, nslcmop_id))
+ self.lcm_tasks.register("ns", nsr_id, nslcmop_id, "ns_vca_status_refresh", task)
+ return
elif command == "action":
# self.logger.debug("Update NS {}".format(nsr_id))
nslcmop = params