Adding operationHistory for get_creds

Change-Id: Ibd8a19ec34e4cbbcf0cd3912ae5cba7b3141fbbc
Signed-off-by: shahithya <shahithya.y@tataelxsi.co.in>

diff --git a/osm_lcm/k8s.py b/osm_lcm/k8s.py
index 6074155..572b902 100644 (file)
--- a/osm_lcm/k8s.py
+++ b/osm_lcm/k8s.py
@@ -19,6 +19,7 @@ __author__ = (
 )
 
 import logging
+from time import time
 from osm_lcm.lcm_utils import LcmBase
 from copy import deepcopy
 from osm_lcm import odu_workflows
@@ -471,12 +472,18 @@ class ClusterLcm(LcmBase):
             self.db.del_one("clusters", {"_id": db_cluster["_id"]})
         return
 
-    async def get_creds(self, db_cluster):
+    async def get_creds(self, op_id, db_cluster):
         self.logger.info("Cluster get creds Enter")
         result, cluster_creds = await self.odu.get_cluster_credentials(db_cluster)
         if result:
             db_cluster["credentials"] = cluster_creds
-            self.db.set_one("clusters", {"_id": db_cluster["_id"]}, db_cluster)
+        op_len = 0
+        for operations in db_cluster["operationHistory"]:
+            if operations["op_id"] == op_id:
+                db_cluster["operationHistory"][op_len]["result"] = result
+                db_cluster["operationHistory"][op_len]["endDate"] = time()
+            op_len += 1
+        self.db.set_one("clusters", {"_id": db_cluster["_id"]}, db_cluster)
         return
 
     async def update(self, op_id, op_params, content):

diff --git a/osm_lcm/lcm.py b/osm_lcm/lcm.py
index a138565..f4c8f32 100644 (file)
--- a/osm_lcm/lcm.py
+++ b/osm_lcm/lcm.py
@@ -850,9 +850,10 @@ class Lcm:
                 )
                 return
             elif command == "get_creds":
-                cluster_id = params["_id"]
+                cluster_id = params["cluster_id"]
+                op_id = params["operation_id"]
                 db_cluster = self.db.get_one("clusters", {"_id": cluster_id})
-                task = asyncio.ensure_future(self.cluster.get_creds(db_cluster))
+                task = asyncio.ensure_future(self.cluster.get_creds(op_id, db_cluster))
                 self.lcm_tasks.register(
                     "cluster", cluster_id, cluster_id, "cluster_get_credentials", task
                 )