X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;ds=sidebyside;f=osm_nbi%2Finstance_topics.py;h=210a207d68e6402817d45d194cf5c4edb992b1e7;hb=refs%2Fchanges%2F11%2F7011%2F1;hp=e53f28e3b47d863159090a79f7f4f724d9cdc71f;hpb=e36ab859d275c9c1b863bbb6564a1da56cabe2dd;p=osm%2FNBI.git diff --git a/osm_nbi/instance_topics.py b/osm_nbi/instance_topics.py index e53f28e..210a207 100644 --- a/osm_nbi/instance_topics.py +++ b/osm_nbi/instance_topics.py @@ -783,8 +783,8 @@ class NsiTopic(BaseTopic): step = "" # look for nstd self.logger.info(str(slice_request)) - step = "getting nstd id='{}' from database".format(slice_request.get("nstdId")) - _filter = {"id": slice_request["nstdId"]} + step = "getting nstd id='{}' from database".format(slice_request.get("nstId")) + _filter = {"_id": slice_request["nstId"]} _filter.update(BaseTopic._get_project_filter(session, write=False, show_all=True)) nstd = self.db.get_one("nsts", _filter) nstd.pop("_admin", None) @@ -796,7 +796,11 @@ class NsiTopic(BaseTopic): # TODO: Equal as template for now nsi_descriptor = { "id": nsi_id, + "name": slice_request["nsiName"], + "description": slice_request.get("nsiDescription", ""), + "datacenter": slice_request["vimAccountId"], "nst-ref": nstd["id"], + # "instantiate_params": slice_request, "instantiation-parameters": { "netslice-subnet": [] }, @@ -830,6 +834,8 @@ class NsiTopic(BaseTopic): self.format_on_new(nsi_descriptor, session["project_id"], make_public=make_public) nsi_descriptor["_admin"]["nsiState"] = "NOT_INSTANTIATED" + ns_params = indata.get("ns") + # creates Network Services records (NSRs) step = "creating nsrs at database using NsrTopic.new()" nsrs_list = [] @@ -841,6 +847,11 @@ class NsiTopic(BaseTopic): indata_ns["nsDescription"] = service["description"] indata_ns["key-pair-ref"] = None # NsrTopic(rollback, session, indata_ns, kwargs, headers, force) + # Overwriting ns_params filtering by nsName == netslice-subnet.id + if ns_params: + for ns_param in ns_params: + if ns_param["nsName"] == service["id"]: + indata_ns.update(ns_param) _id_nsr = NsrTopic.new(self, rollback, session, indata_ns, kwargs, headers, force) nsrs_item = {"nsrId": _id_nsr} nsrs_list.append(nsrs_item)