| # -*- 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 |