feat(sol006): LCM migration to SOL006

[osm/LCM.git] / osm_lcm / data_utils / vnfr.py

diff --git a/osm_lcm/data_utils/vnfr.py b/osm_lcm/data_utils/vnfr.py
new file mode 100644 (file)
index 0000000..042788e
--- /dev/null
+++ b/osm_lcm/data_utils/vnfr.py
@@ -0,0 +1,59 @@
+# -*- coding: utf-8 -*-
+
+# Copyright 2020 Whitestack, LLC
+# *************************************************************
+#
+# This file is part of OSM Monitoring module
+# All Rights Reserved to Whitestack, LLC
+#
+# Licensed under the Apache License, Version 2.0 (the "License"); you may
+# not use this file except in compliance with the License. You may obtain
+# a copy of the License at
+#
+#         http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+# License for the specific language governing permissions and limitations
+# under the License.
+#
+# For those usages not covered by the Apache License, Version 2.0 please
+# 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)
+
+
+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")
+        if db_vnfr.get(x) is not None
+    }
+    osm_params["ns_id"] = db_vnfr["nsr-id-ref"]
+    osm_params["vnf_id"] = db_vnfr["_id"]
+    osm_params["member_vnf_index"] = db_vnfr["member-vnf-index-ref"]
+    if db_vnfr.get("vdur"):
+        osm_params["vdu"] = {}
+        for vdur in db_vnfr["vdur"]:
+            vdu = {
+                "count_index": vdur["count-index"],
+                "vdu_id": vdur["vdu-id-ref"],
+                "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_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