X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_lcm%2Fdata_utils%2Fvnfr.py;h=653a7eda01e866a104d3d44b26d4c108e444e952;hb=HEAD;hp=042788e2042869d76a761c20f4fdda659556e7ec;hpb=922c41753ffbb4b526f2135a23c39f480c58e2cb;p=osm%2FLCM.git

diff --git a/osm_lcm/data_utils/vnfr.py b/osm_lcm/data_utils/vnfr.py
index 042788e..653a7ed 100644
--- a/osm_lcm/data_utils/vnfr.py
+++ b/osm_lcm/data_utils/vnfr.py
@@ -22,16 +22,13 @@
 # contact: fbravo@whitestack.com
 ##
 
-from osm_lcm.data_utils import list_utils
-
-
-def find_VNFR_by_VDU_ID(vnfr, vdu_id):
-    list_utils.find_in_list(vnfr, lambda vnfr: False)
+from osm_lcm.lcm_utils import get_iterable
 
 
 def get_osm_params(db_vnfr, vdu_id=None, vdu_count_index=0):
     osm_params = {
-        x.replace("-", "_"): db_vnfr[x] for x in ("ip-address", "vim-account-id", "vnfd-id", "vnfd-ref")
+        x.replace("-", "_"): db_vnfr[x]
+        for x in ("ip-address", "vim-account-id", "vnfd-id", "vnfd-ref")
         if db_vnfr.get(x) is not None
     }
     osm_params["ns_id"] = db_vnfr["nsr-id-ref"]
@@ -43,17 +40,62 @@ def get_osm_params(db_vnfr, vdu_id=None, vdu_count_index=0):
             vdu = {
                 "count_index": vdur["count-index"],
                 "vdu_id": vdur["vdu-id-ref"],
-                "interfaces": {}
+                "interfaces": {},
             }
             if vdur.get("ip-address"):
                 vdu["ip_address"] = vdur["ip-address"]
             for iface in vdur["interfaces"]:
-                vdu["interfaces"][iface["name"]] = \
-                    {x.replace("-", "_"): iface[x] for x in ("mac-address", "ip-address", "name")
-                        if iface.get(x) is not None}
+                vdu["interfaces"][iface["name"]] = {
+                    x.replace("-", "_"): iface[x]
+                    for x in ("mac-address", "ip-address", "name")
+                    if iface.get(x) is not None
+                }
             vdu_id_index = "{}-{}".format(vdur["vdu-id-ref"], vdur["count-index"])
             osm_params["vdu"][vdu_id_index] = vdu
         if vdu_id:
             osm_params["vdu_id"] = vdu_id
             osm_params["count_index"] = vdu_count_index
     return osm_params
+
+
+def get_vdur_index(db_vnfr, vdu_delta):
+    vdur_list = get_iterable(db_vnfr, "vdur")
+    if vdur_list:
+        return len([x for x in vdur_list if x.get("vdu-id-ref") == vdu_delta["id"]])
+    else:
+        return 0
+
+
+def get_kdur(db_vnfr, kdu_name):
+    kdur_list = get_iterable(db_vnfr, "kdur")
+    if kdur_list:
+        return next(x for x in kdur_list if x.get("kdu-name") == kdu_name)
+    else:
+        return None
+
+
+def get_volumes_from_instantiation_params(
+    vdu_instantiation_params: dict, vdud: dict
+) -> list:
+    """Get the VDU volumes from instantiation parameters
+
+    Args:
+        vdu_instantiation_params:   VDU instantiation parameters
+        vdud:   VDU description as a dictionary extracted from VNFD
+    Returns:
+        vdu_volume_list:(list)
+
+    """
+    vdu_volume_list = []
+    if vdu_instantiation_params.get("volume"):
+        for volume in vdu_instantiation_params["volume"]:
+            if volume.get("vim-volume-id") and volume.get("name") in vdud.get(
+                "virtual-storage-desc"
+            ):
+                vdu_volume = {
+                    "name": volume["name"],
+                    "vim-volume-id": volume["vim-volume-id"],
+                }
+                vdu_volume_list.append(vdu_volume)
+
+    return vdu_volume_list