X-Git-Url: https://osm.etsi.org/gitweb/?p=osm%2FNBI.git;a=blobdiff_plain;f=osm_nbi%2Finstance_topics.py;h=bf0e3a918d64409333cc858ac1bb62c1d27bfac2;hp=7b3e9ad7166908d1846c31a8aa31f2050f80c658;hb=9b33fa825aaf935e4f467b1a01f65c85d1b9b694;hpb=e76b88289b7ee86fa8f79effae73499eb637fadf diff --git a/osm_nbi/instance_topics.py b/osm_nbi/instance_topics.py index 7b3e9ad..bf0e3a9 100644 --- a/osm_nbi/instance_topics.py +++ b/osm_nbi/instance_topics.py @@ -586,12 +586,6 @@ class NsrTopic(BaseTopic): "name": icp.get("id"), } - if "port-security-enabled" in icp: - vdu_icp["port-security-enabled"] = icp["port-security-enabled"] - - if "port-security-disable-strategy" in icp: - vdu_icp["port-security-disable-strategy"] = icp["port-security-disable-strategy"] - vdur["internal-connection-point"].append(vdu_icp) for iface in icp.get("virtual-network-interface-requirement", ()): @@ -599,6 +593,12 @@ class NsrTopic(BaseTopic): vdu_iface = {x: iface[x] for x in iface_fields if iface.get(x) is not None} vdu_iface["internal-connection-point-ref"] = vdu_icp["id"] + if "port-security-enabled" in icp: + vdu_iface["port-security-enabled"] = icp["port-security-enabled"] + + if "port-security-disable-strategy" in icp: + vdu_iface["port-security-disable-strategy"] = icp["port-security-disable-strategy"] + for ext_cp in vnfd.get("ext-cpd", ()): if not ext_cp.get("int-cpd"): continue @@ -606,6 +606,17 @@ class NsrTopic(BaseTopic): continue if icp["id"] == ext_cp["int-cpd"].get("cpd"): vdu_iface["external-connection-point-ref"] = ext_cp.get("id") + + if "port-security-enabled" in ext_cp: + vdu_iface["port-security-enabled"] = ( + ext_cp["port-security-enabled"] + ) + + if "port-security-disable-strategy" in ext_cp: + vdu_iface["port-security-disable-strategy"] = ( + ext_cp["port-security-disable-strategy"] + ) + break if vnfd_mgmt_cp and vdu_iface.get("external-connection-point-ref") == vnfd_mgmt_cp: @@ -761,18 +772,20 @@ class NsLcmOpTopic(BaseTopic): descriptor_configuration = utils.find_in_list( configs, lambda config: config["id"] == indata["vdu_id"] - ).get("config-primitive") + ) elif indata.get("kdu_name"): self._check_valid_kdu(vnfd, indata["kdu_name"]) descriptor_configuration = utils.find_in_list( configs, lambda config: config["id"] == indata.get("kdu_name") - ).get("config-primitive") + ) else: descriptor_configuration = utils.find_in_list( configs, lambda config: config["id"] == vnfd["id"] - ).get("config-primitive") + ) + if descriptor_configuration is not None: + descriptor_configuration = descriptor_configuration.get("config-primitive") else: # use a NSD descriptor_configuration = nsd.get("ns-configuration", {}).get("config-primitive")