commit 09682c03bb6faed2a1c97fd166c0637b0270174d
author tierno <alfonso.tiernosepulveda@telefonica.com> Wed Jun 27 15:06:50 2018 +0200
committer tierno <alfonso.tiernosepulveda@telefonica.com> Wed Jun 27 16:11:23 2018 +0200
tree 87bdf3afb503ddc5255ba239f3869182602edd1e
parent b87f356a33c02e87e0e079a2967e197c4b82f2ac

Fix multivim bug at updating vnfr

Change-Id: I86ea26a786c1d88b1623edfbd13d126c70bd22e1
Signed-off-by: tierno <alfonso.tiernosepulveda@telefonica.com>

osm_lcm/__init__.py

diff --git a/osm_lcm/__init__.py b/osm_lcm/__init__.py
index b1ad67b..038e365 100644
--- a/osm_lcm/__init__.py
+++ b/osm_lcm/__init__.py
@@ -1,2 +1,2 @@
-version = '0.1.6'
+version = '0.1.7'
 date_version = '2018-06-27'

osm_lcm/lcm.py

diff --git a/osm_lcm/lcm.py b/osm_lcm/lcm.py
index b14f640..c679add 100644
--- a/osm_lcm/lcm.py
+++ b/osm_lcm/lcm.py
@@ -815,11 +815,13 @@
             for vnf_index, vnfr in db_vnfr.items():
                 if vnfr.get("vim-account-id"):
                     continue
-                if db_nsr["instantiate_params"].get("vnf") and db_nsr["instantiate_params"]["vnf"].get(vnf_index) \
-                        and db_nsr["instantiate_params"]["vnf"][vnf_index].get("vimAccountId"):
-                    vnfr["vim-account-id"] = db_nsr["instantiate_params"]["vnf"][vnf_index]["vimAccountId"]
-                else:
-                    vnfr["vim-account-id"] = db_nsr["instantiate_params"]["vimAccountId"]
+                vnfr["vim-account-id"] = db_nsr["instantiate_params"]["vimAccountId"]
+                if db_nsr["instantiate_params"].get("vnf"):
+                    for vnf_params in db_nsr["instantiate_params"]["vnf"]:
+                        if vnf_params.get("member-vnf-index") == vnf_index:
+                            if vnf_params.get("vimAccountId"):
+                                vnfr["vim-account-id"] = vnf_params.get("vimAccountId")
+                            break
                 self.update_db("vnfrs", vnfr["_id"], vnfr)
 
             # wait until NS is ready
@@ -1158,6 +1160,7 @@
                 self.db.del_one("nsrs", {"_id": nsr_id})
                 self.db.del_list("nslcmops", {"nsInstanceId": nsr_id})
                 self.db.del_list("vnfrs", {"nsr-id-ref": nsr_id})
+                self.logger.debug(logging_text + "Delete from database")
             else:
                 db_nsr_update = {
                     "operational-status": "terminated",