NsiTopic,
NsiLcmOpTopic,
)
-from osm_nbi.vnf_instance_topics import VnfInstances, VnfLcmOpTopic
from osm_nbi.pmjobs_topics import PmJobsTopic
from osm_nbi.subscription_topics import NslcmSubscriptionsTopic
from base64 import b64encode
"nsilcmops": NsiLcmOpTopic,
"vnfpkgops": VnfPkgOpTopic,
"nslcm_subscriptions": NslcmSubscriptionsTopic,
- "vnf_instances": VnfInstances,
- "vnflcmops": VnfLcmOpTopic,
# [NEW_TOPIC]: add an entry here
# "pm_jobs": PmJobsTopic will be added manually because it needs other parameters
}
},
}
},
- "vnflcm": {
- "v1": {
- "vnf_instances": {"METHODS": ("GET", "POST"),
- "ROLE_PERMISSION": "vnflcm_instances:",
- "<ID>": {"METHODS": ("GET", "DELETE"),
- "ROLE_PERMISSION": "vnflcm_instances:id:",
- "scale": {"METHODS": ("POST",),
- "ROLE_PERMISSION": "vnflcm_instances:id:scale:"
- },
- "terminate": {"METHODS": ("POST",),
- "ROLE_PERMISSION": "vnflcm_instances:id:terminate:"
- },
- "instantiate": {"METHODS": ("POST",),
- "ROLE_PERMISSION": "vnflcm_instances:id:instantiate:"
- },
- }
- },
- "vnf_lcm_op_occs": {"METHODS": ("GET",),
- "ROLE_PERMISSION": "vnf_instances:opps:",
- "<ID>": {"METHODS": ("GET",),
- "ROLE_PERMISSION": "vnf_instances:opps:id:"
- },
- },
- }
- },
"nst": {
"v1": {
"netslice_templates_content": {
"nst",
"nsilcm",
"nspm",
- "vnflcm",
):
raise NbiException(
"URL main_topic '{}' not supported".format(main_topic),
engine_topic = "nslcmops"
if topic == "vnfrs" or topic == "vnf_instances":
engine_topic = "vnfrs"
- elif main_topic == "vnflcm":
- if topic == "vnf_lcm_op_occs":
- engine_topic = "vnflcmops"
elif main_topic == "nst":
engine_topic = "nsts"
elif main_topic == "nsilcm":
"_links": link,
}
cherrypy.response.status = HTTPStatus.CREATED.value
- elif topic == "vnf_instances" and item:
- indata["lcmOperationType"] = item
- indata["vnfInstanceId"] = _id
- _id, _ = self.engine.new_item(rollback, engine_session, "vnflcmops", indata, kwargs)
- self._set_location_header(main_topic, version, "vnf_lcm_op_occs", _id)
- outdata = {"id": _id}
- cherrypy.response.status = HTTPStatus.ACCEPTED.value
else:
_id, op_id = self.engine.new_item(
rollback,
+++ /dev/null
-# Copyright 2021 K Sai Kiran (Tata Elxsi)
-#
-# 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.
+++ /dev/null
-# Copyright 2021 K Sai Kiran (Tata Elxsi)
-#
-# 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.
-
-__author__ = "K Sai Kiran <saikiran.k@tataelxsi.co.in>, Selvi Jayaraman <selvi.j@tataelxsi.co.in>"
-__date__ = "$12-June-2021 8:30:59$"
-
-
-import logging
-
-
-class BaseMethod:
-
- def __init__(self):
- """
- Constructor of the base method
- """
- self.logger = logging.getLogger("nbi.engine")
+++ /dev/null
-# Copyright 2021 K Sai Kiran (Tata Elxsi)
-#
-# 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.
-
-__author__ = "K Sai Kiran <saikiran.k@tataelxsi.co.in>, Selvi Jayaraman <selvi.j@tataelxsi.co.in>"
-__date__ = "$12-June-2021 8:30:59$"
-
-from osm_nbi.instance_topics import NsrTopic, NsLcmOpTopic, VnfrTopic
-from .base_methods import BaseMethod
-
-
-class VnfLcmOp2NsLcmOp:
-
- def __init__(self, db, fs, msg, auth):
- """
- Constructor of Vnf lcm op to Ns lcm op
- """
- self.new_vnf_lcmop = NewVnfLcmOp(db, fs, msg, auth)
- self.list_vnf_lcmop = ListVnfLcmOp(db, fs, msg, auth)
- self.show_vnf_lcmop = ShowVnfLcmOp(db, fs, msg, auth)
-
- def new(self, rollback, session, indata=None, kwargs=None, headers=None):
- """
- Creates a new entry into database.
- :param rollback: list to append created items at database in case a rollback may to be done
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param indata: data to be inserted
- :param kwargs: used to override the indata descriptor
- :param headers: http request headers
- :return: _id, op_id:
- _id: identity of the inserted data.
- op_id: operation id if this is asynchronous, None otherwise
- """
- return self.new_vnf_lcmop.action(rollback, session, indata, kwargs, headers)
-
- def list(self, session, filter_q=None, api_req=False):
- """
- Get a list of the Vnf Lcm Operation that matches a filter
- :param session: contains the used login username and working project
- :param filter_q: filter of data to be applied
- :param api_req: True if this call is serving an external API request. False if serving internal request.
- :return: The list, it can be empty if no one match the filter.
- """
- return self.list_vnf_lcmop.action(session, filter_q, api_req)
-
- def show(self, session, _id, api_req=False):
- """
- Get complete information on an Vnf Lcm Operation
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param _id: server internal id
- :param api_req: True if this call is serving an external API request. False if serving internal request.
- :return: dictionary, raise exception if not found.
- """
- return self.show_vnf_lcmop.action(session, _id, api_req)
-
-
-class NewVnfLcmOp(BaseMethod):
-
- def __init__(self, db, fs, msg, auth):
- """
- Constructor of new Vnf Lcm Op
- """
- super().__init__()
- self.msg = msg
- self.nslcmoptopic = NsLcmOpTopic(db, fs, msg, auth)
- self.nsrtopic = NsrTopic(db, fs, msg, auth)
- self.vnfrtopic = VnfrTopic(db, fs, msg, auth)
-
- def __get_nsdid(self, session, vnf_instance_id):
- """
- Returns a nsd id from vnf instance id.
- :param session: contains the used login username and working project
- :param vnf_instance_id: id of vnf instance
- :return: id of nsd id
- """
- nsr = self.nsrtopic.show(session, vnf_instance_id)
- return nsr['nsd']['_id']
-
- def __get_formatted_indata(self, session, indata):
- """
- Returns formatted data for new vnf lcm op
- :param session: contains the used login username and working project
- :param indata: contains information for new lcm operation.
- :return: formatted indata for new lcm op.
- """
- formatted_indata = {}
- if indata["lcmOperationType"] == "instantiate":
- formatted_indata = {
- "nsName": indata["vnfName"],
- "nsDescription": indata["vnfDescription"],
- "nsdId": self.__get_nsdid(session, indata["vnfInstanceId"]),
- "vimAccountId": indata["vimAccountId"],
- "nsr_id": indata["vnfInstanceId"],
- "lcmOperationType": indata["lcmOperationType"],
- "nsInstanceId": indata["vnfInstanceId"]
- }
- elif indata["lcmOperationType"] == "terminate":
- formatted_indata = {
- "lcmOperationType": indata["lcmOperationType"],
- "nsInstanceId": indata["vnfInstanceId"]
- }
- elif indata["lcmOperationType"] == "scale":
- formatted_indata = {
- "lcmOperationType": indata["lcmOperationType"],
- "nsInstanceId": indata["vnfInstanceId"],
- "scaleType": "SCALE_VNF",
- "scaleVnfData": {
- "scaleVnfType": indata["type"],
- "scaleByStepData": {
- "scaling-group-descriptor": indata["aspectId"],
- "member-vnf-index": indata["additionalParams"]["member-vnf-index"]
- }
- }
- }
- elif indata["lcmOperationType"] == "action":
- formatted_indata = {
- "lcmOperationType": indata["lcmOperationType"],
- "nsInstanceId": indata["vnfInstanceId"],
- "member_vnf_index": indata["member_vnf_index"],
- "primitive": indata["primitive"],
- "primitive_params": indata["primitive_params"]
- }
- return formatted_indata
-
- def action(self, rollback, session, indata=None, kwargs=None, headers=None):
- """
- Creates an new lcm operation.
- :param rollback: list to append the created items at database in case a rollback must be done
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param indata: params to be used for the nsr
- :param kwargs: used to override the indata
- :param headers: http request headers
- :return: id of new lcm operation.
- """
- vnfInstanceId = indata["vnfInstanceId"]
- lcm_operation = indata["lcmOperationType"]
- vnfr = self.vnfrtopic.show(session, vnfInstanceId)
- indata["vnfInstanceId"] = vnfr.get("nsr-id-ref")
- indata = self.__get_formatted_indata(session, indata)
- op_id, _ = self.nslcmoptopic.new(rollback, session, indata, kwargs, headers)
- return op_id, _
-
-
-class ListVnfLcmOp(BaseMethod):
-
- def __init__(self, db, fs, msg, auth):
- """
- Constructor call for listing vnf lcm operations
- """
- super().__init__()
- self.nslcmoptopic = NsLcmOpTopic(db, fs, msg, auth)
- self.nsrtopic = NsrTopic(db, fs, msg, auth)
-
- def action(self, session, filter_q=None, api_req=False):
- """
- To get list of vnf lcm operations that matches a filter
- :param session: contains the used login username and working project
- :param filter_q: filter of data to be applied
- :param api_req: True if this call is serving an external API request. False if serving internal request.
- :return: The list, it can be empty if no one match the filter.
- """
- list = []
- records = self.nslcmoptopic.list(session, filter_q, api_req)
- for record in records:
- ns_id = record.get("nsInstanceId")
- nsr = self.nsrtopic.show(session, ns_id)
- vnfInstance_id = nsr['constituent-vnfr-ref'][0]
- outdata = sol003_projection(record, vnfInstance_id)
- list.append(outdata)
- return list
-
-
-class ShowVnfLcmOp(BaseMethod):
-
- def __init__(self, db, fs, msg, auth):
- """
- Constructor call for showing vnf lcm operation
- """
- super().__init__()
- self.nslcmoptopic = NsLcmOpTopic(db, fs, msg, auth)
- self.nsrtopic = NsrTopic(db, fs, msg, auth)
-
- def action(self, session, _id, api_req=False):
- """
- Get complete information on an Vnf Lcm Operation.
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param _id: Vnf Lcm operation id
- :param api_req: True if this call is serving an external API request. False if serving internal request.
- :return: dictionary, raise exception if not found.
- """
- record = self.nslcmoptopic.show(session, _id, api_req)
- ns_id = record.get("nsInstanceId")
- nsr = self.nsrtopic.show(session, ns_id)
- vnfinstance_id = nsr['constituent-vnfr-ref'][0]
- outdata = sol003_projection(record, vnfinstance_id)
- return outdata
-
-
-def sol003_projection(data, vnfinstance_id):
- """
- Returns SOL003 formatted data
- :param data: contains Lcm Operation information
- :param vnfinstance_id: id of vnf_instance
- :return: SOL003 formatted data of vnf lcm op
- """
- data.pop("nsInstanceId")
- data.pop("operationParams")
- data.pop("links")
- links = {
- "self": "/osm/vnflcm/v1/vnf_lcm_op_occs/" + data["_id"],
- "vnfInstance": "/osm/vnflcm/v1/vnf_instances/" + vnfinstance_id,
- }
- data["_links"] = links
- data["vnfInstanceId"] = vnfinstance_id
- return data
+++ /dev/null
-# Copyright 2021 K Sai Kiran (Tata Elxsi)
-#
-# 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.
-
-__author__ = "K Sai Kiran <saikiran.k@tataelxsi.co.in>, Selvi Jayaraman <selvi.j@tataelxsi.co.in>"
-__date__ = "$12-June-2021 8:30:59$"
-
-from copy import deepcopy
-from osm_nbi.descriptor_topics import NsdTopic
-from .base_methods import BaseMethod
-
-from osm_nbi.instance_topics import NsrTopic, VnfrTopic
-
-
-class VnfInstances2NsInstances:
-
- def __init__(self, db, fs, msg, auth):
- """
- Constructor of Vnf Instances to Ns Instances
- """
- self.new_vnf_instance = NewVnfInstance(db, fs, msg, auth)
- self.list_vnf_instance = ListVnfInstance(db, fs, msg, auth)
- self.show_vnf_instance = ShowVnfInstance(db, fs, msg, auth)
- self.delete_vnf_instance = DeleteVnfInstance(db, fs, msg, auth)
-
- def new(self, rollback, session, indata=None, kwargs=None, headers=None):
- """
- Creates a new entry into database.
- :param rollback: list to append created items at database in case a rollback may have to be done
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param indata: data to be inserted
- :param kwargs: used to override the indata descriptor
- :param headers: http request headers
- :return: _id, op_id:
- _id: identity of the inserted data.
- op_id: operation id if this is asynchronous, None otherwise
- """
- return self.new_vnf_instance.action(rollback, session, indata, kwargs, headers)
-
- def list(self, session, filter_q=None, api_req=False):
- """
- Get a list of the Vnfs that match a filter
- :param session: contains the used login username and working project
- :param filter_q: filter of data to be applied
- :param api_req: True if this call is serving an external API request. False if serving internal request.
- :return: The list, it can be empty if no one match the filter.
- """
- return self.list_vnf_instance.action(session, filter_q, api_req)
-
- def show(self, session, _id, api_req=False):
- """
- Get complete information on an Vnf
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param _id: server internal id
- :param api_req: True if this call is serving an external API request. False if serving internal request.
- :return: dictionary, raise exception if not found.
- """
- return self.show_vnf_instance.action(session, _id, api_req)
-
- def delete(self, session, _id, dry_run=False, not_send_msg=None):
- """
- Delete item by its internal _id
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param _id: server internal id
- :param dry_run: make checking but do not delete
- :param not_send_msg: To not send message (False) or store content (list) instead
- :return: operation id (None if there is not operation), raise exception if error or not found, conflict, ...
- """
- return self.delete_vnf_instance.action(session, _id, dry_run, not_send_msg)
-
-
-class NewVnfInstance(BaseMethod):
-
- # sample ns descriptor
- sample_nsd = {
- "nsd": {
- "nsd": [
- {
- "df": [
- {
- "id": "default-df",
- "vnf-profile": [
- {
- "id": 1,
- "virtual-link-connectivity": [
- {
- "constituent-cpd-id": [
- {"constituent-base-element-id": 1,
- "constituent-cpd-id": "eth0-ext"}
- ],
- "virtual-link-profile-id": "mgmtnet",
- }
- ],
- "vnfd-id": "cirros_vnfd"
- }
- ],
- }
- ],
- "vnfd-id": ["cirros_vnfd"],
- "description": "Generated by OSM pacakage generator",
- "id": "cirros_2vnf_nsd",
- "name": "cirros_2vnf_ns",
- "short-name": "cirros_2vnf_ns",
- "vendor": "OSM",
- "version": "1.0",
- }
- ]
- }
- }
-
- @staticmethod
- def __get_formatted_indata(indata, nsd_id):
- """
- Create indata for nsd_id
- :param indata: Contains unformatted data for new vnf instance
- :param nsd_id: Id of nsd
- :return: formatted indata for nsd_id
- """
- formatted_indata = deepcopy(indata)
- formatted_indata["nsdId"] = nsd_id
- formatted_indata["nsName"] = indata["vnfInstanceName"] + "-ns"
- for invalid_key in ("vnfdId", "vnfInstanceName", "vnfInstanceDescription", "additionalParams"):
- formatted_indata.pop(invalid_key)
- return formatted_indata
-
- def __init__(self, db, fs, msg, auth):
- """
- Constructor for new vnf instance
- """
- super().__init__()
- self.msg = msg
- self.nsdtopic = NsdTopic(db, fs, msg, auth)
- self.nsrtopic = NsrTopic(db, fs, msg, auth)
-
- def __get_vnfd(self):
- # get vnfd from nfvo
- pass
-
- def __onboard_vnfd(self):
- self.__get_vnfd()
- pass
-
- def __create_nsd(self, rollback, session, indata=None, kwargs=None, headers=None):
- """
- Creates new ns descriptor from a vnfd.
- :param rollback: list to append the created items at database in case a rollback must be done
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param indata: params to be used for the nsr
- :param kwargs: used to override the indata
- :param headers: http request headers
- :return: id of new nsd created
- """
- _id, *others = self.nsdtopic.new(rollback, session, {}, None, headers)
- new_nsd = deepcopy(NewVnfInstance.sample_nsd)
- vnf_content = {
- "id":"default-df",
- "vnf-profile": [
- {
- "id": "1",
- "virtual-link-connectivity": [
- {
- "constituent-cpd-id": [
- {
- "constituent-base-element-id": "1",
- "constituent-cpd-id": indata["additionalParams"]["constituent-cpd-id"]
- }
- ],
- "virtual-link-profile-id": indata["additionalParams"]["virtual-link-profile-id"]
- }
- ],
- "vnfd-id": indata["vnfdId"]
- }
- ]
- }
- new_nsd["nsd"]["nsd"][0] = {
- "description": indata["vnfInstanceDescription"],
- "designer": "OSM",
- "id": indata["vnfdId"] + "-ns",
- "name": indata["vnfdId"] + "-ns",
- "version": "1.0",
- "df": [vnf_content, ],
- "virtual-link-desc": indata["additionalParams"]["virtual-link-desc"],
- "vnfd-id": [indata["vnfdId"]]
- }
- return _id, new_nsd
-
- def __create_nsr(self, rollback, session, indata=None, kwargs=None, headers=None):
- """
- Creates an new ns record in database
- :param rollback: list to append the created items at database in case a rollback must be done
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param indata: params to be used for the nsr
- :param kwargs: used to override the indata
- :param headers: http request headers
- :return: id of new nsr
- """
- return self.nsrtopic.new(rollback, session, indata, kwargs, headers)
-
- def __action_pre_processing(self, rollback, session, indata=None, kwargs=None, headers=None):
- """
- Pre process for creating new vnf instance
- :param rollback: list to append the created items at database in case a rollback must be done
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param indata: params to be used for the nsr
- :param kwargs: used to override the indata
- :param headers: http request headers
- :return: id nsr
- """
- self.__onboard_vnfd()
- nsd_id, nsd = self.__create_nsd(rollback, session, indata, kwargs, headers)
- self.nsdtopic.upload_content(session, nsd_id, nsd, kwargs, headers)
- formatted_indata = NewVnfInstance.__get_formatted_indata(indata, nsd_id)
- nsr_id, _ = self.__create_nsr(rollback, session, formatted_indata, kwargs, headers)
- nsr = self.nsrtopic.show(session, nsr_id)
- vnfr_id = nsr['constituent-vnfr-ref'][0]
- return vnfr_id, None
-
- def action(self, rollback, session, indata=None, kwargs=None, headers=None):
- """
- Creates an new vnf instance
- :param rollback: list to append the created items at database in case a rollback must be done
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param indata: params to be used for the nsr
- :param kwargs: used to override the indata
- :param headers: http request headers
- :return: id of new vnf instance
- """
- return self.__action_pre_processing(rollback, session, indata, kwargs, headers)
-
-
-class ListVnfInstance(BaseMethod):
-
- def __init__(self, db, fs, msg, auth):
- """
- Constructor call for listing vnfs
- """
- super().__init__()
- self.vnfrtopic = VnfrTopic(db, fs, msg, auth)
-
- def action(self, session, filter_q=None, api_req=False):
- """
- To get list of vnfs that matches a filter
- :param session: contains the used login username and working project
- :param filter_q: filter of data to be applied
- :param api_req: True if this call is serving an external API request. False if serving internal request.
- :return: The list, it can be empty if no one match the filter.
- """
- return self.vnfrtopic.list(session, filter_q, api_req)
-
-
-class ShowVnfInstance(BaseMethod):
-
- def __init__(self, db, fs, msg, auth):
- """
- Constructor call for showing vnf lcm operation
- """
- super().__init__()
- self.vnfrtopic = VnfrTopic(db, fs, msg, auth)
-
- def action(self, session, _id, api_req=False):
- """
- Get complete information on an Vnf Lcm Operation.
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param _id: Vnf Lcm operation id
- :param api_req: True if this call is serving an external API request. False if serving internal request.
- :return: dictionary, raise exception if not found.
- """
- return self.vnfrtopic.show(session, _id, api_req)
-
-
-class DeleteVnfInstance(BaseMethod):
-
- def __init__(self, db, fs, msg, auth):
- """
- Constructor call for deleting vnf
- """
- super().__init__()
- self.msg = msg
- self.nsrtopic = NsrTopic(db, fs, msg, auth)
- self.nsdtopic = NsdTopic(db, fs, msg, auth)
- self.vnfrtopic = VnfrTopic(db, fs, msg, auth)
-
- def action(self, session, _id, dry_run=False, not_send_msg=None):
- """
- Delete vnf instance by its internal _id
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param _id: server internal id
- :param dry_run: make checking but do not delete
- :param not_send_msg: To not send message (False) or store content (list) instead
- :return: operation id (None if there is not operation), raise exception if error or not found, conflict, ...
- """
- vnfInstanceId = _id
- vnfr = self.vnfrtopic.show(session, vnfInstanceId)
- ns_id = vnfr.get("nsr-id-ref")
- nsr = self.nsrtopic.show(session, ns_id)
- nsd_to_del = nsr['nsd']['_id']
- self.nsrtopic.delete(session, ns_id, dry_run, not_send_msg)
- return self.nsdtopic.delete(session, nsd_to_del, dry_run, not_send_msg)
"GET /nslcm/v1/vnfrs/<vnfInstanceId>": "vnf_instances:id:get"
"GET /nslcm/v1/vnf_instances/<vnfInstanceId>": "vnf_instances:id:get"
- "GET /vnflcm/v1/vnf_instances/": "vnflcm_instances:get"
- "POST /vnflcm/v1/vnf_instances/": "vnflcm_instances:post"
-
- "GET /vnflcm/v1/vnf_instances/<vnfInstanceId>": "vnflcm_instances:id:get"
- "DELETE /vnflcm/v1/vnf_instances/<vnfInstanceId>": "vnflcm_instances:id:delete"
-
################################################################################
#################################### Tokens ####################################
################################################################################
vnfd-id: 7637bcf8-cf14-42dc-ad70-c66fcf1e6e77
vnfd-ref: hackfest3charmed-vnf
"""
-
-db_vnfm_vnfd_text = """
----
-- _admin:
- created: 1647529096.3635302
- modified: 1650456936.518325
- onboardingState: ONBOARDED
- operationalState: ENABLED
- projects_read:
- - 25b5aebf-3da1-49ed-99de-1d2b4a86d6e4
- projects_write:
- - 25b5aebf-3da1-49ed-99de-1d2b4a86d6e4
- storage:
- descriptor: hackfest_basic_metrics_vnf/hackfest_basic_metrics_vnfd.yaml
- folder: 70b47595-fafa-4f63-904b-fc3ada60eebb
- fs: mongo
- path: /app/storage/
- pkg-dir: hackfest_basic_metrics_vnf
- zipfile: package.tar.gz
- type: vnfd
- usageState: NOT_IN_USE
- userDefinedData: {}
- _id: 70b47595-fafa-4f63-904b-fc3ada60eebb
- _links:
- packageContent:
- href: /vnfpkgm/v1/vnf_packages/70b47595-fafa-4f63-904b-fc3ada60eebb/package_content
- self:
- href: /vnfpkgm/v1/vnf_packages/70b47595-fafa-4f63-904b-fc3ada60eebb
- vnfd:
- href: /vnfpkgm/v1/vnf_packages/70b47595-fafa-4f63-904b-fc3ada60eebb/vnfd
- description: A basic VNF descriptor with one VDU and VIM metrics
- df:
- - id: default-df
- instantiation-level:
- - id: default-instantiation-level
- vdu-level:
- - number-of-instances: 1
- vdu-id: hackfest_basic_metrics-VM
- scaling-aspect:
- - aspect-delta-details:
- deltas:
- - id: vdu_autoscale-delta
- vdu-delta:
- - id: hackfest_basic_metrics-VM
- number-of-instances: 1
- id: vdu_autoscale
- max-scale-level: 1
- name: vdu_autoscale
- scaling-policy:
- - cooldown-time: 120
- name: cpu_util_above_threshold
- scaling-criteria:
- - name: cpu_util_above_threshold
- scale-in-relational-operation: LT
- scale-in-threshold: '10.0000000000'
- scale-out-relational-operation: GT
- scale-out-threshold: '60.0000000000'
- vnf-monitoring-param-ref: vnf_cpu_util
- scaling-type: automatic
- threshold-time: 10
- vdu-profile:
- - id: hackfest_basic_metrics-VM
- max-number-of-instances: 2
- min-number-of-instances: 1
- ext-cpd:
- - id: vnf-cp0-ext
- int-cpd:
- cpd: vdu-eth0-int
- vdu-id: hackfest_basic_metrics-VM
- id: hackfest_basic_metrics-vnf
- mgmt-cp: vnf-cp0-ext
- onboardingState: ONBOARDED
- operationalState: ENABLED
- product-name: hackfest_basic_metrics-vnf
- sw-image-desc:
- - id: bionic
- image: bionic
- name: bionic
- - id: ubuntu18.04-aws
- image: ubuntu/images/hvm-ssd/ubuntu-artful-17.10-amd64-server-20180509
- name: ubuntu18.04-aws
- vim-type: aws
- - id: ubuntu18.04-azure
- image: Canonical:UbuntuServer:18.04-LTS:latest
- name: ubuntu18.04-azure
- vim-type: azure
- - id: ubuntu18.04-gcp
- image: ubuntu-os-cloud:image-family:ubuntu-1804-lts
- name: ubuntu18.04-gcp
- vim-type: gcp
- usageState: NOT_IN_USE
- vdu:
- - alarm:
- - actions:
- alarm:
- - url: https://webhook.site/b79f9bf9-4c19-429d-81ed-19be26a3d5d8
- insufficient-data:
- - url: https://webhook.site/b79f9bf9-4c19-429d-81ed-19be26a3d5d8
- ok:
- - url: https://webhook.site/b79f9bf9-4c19-429d-81ed-19be26a3d5d8
- alarm-id: alarm-1
- operation: LT
- value: '20.0000'
- vnf-monitoring-param-ref: vnf_cpu_util
- alternative-sw-image-desc:
- - ubuntu18.04-aws
- - ubuntu18.04-azure
- - ubuntu18.04-gcp
- cloud-init-file: cloud-config
- id: hackfest_basic_metrics-VM
- int-cpd:
- - id: vdu-eth0-int
- virtual-network-interface-requirement:
- - name: vdu-eth0
- virtual-interface:
- type: PARAVIRT
- monitoring-parameter:
- - id: vnf_cpu_util
- name: vnf_cpu_util
- performance-metric: cpu_utilization
- - id: vnf_memory_util
- name: vnf_memory_util
- performance-metric: average_memory_utilization
- - id: vnf_packets_sent
- name: vnf_packets_sent
- performance-metric: packets_sent
- - id: vnf_packets_received
- name: vnf_packets_received
- performance-metric: packets_received
- name: hackfest_basic_metrics-VM
- sw-image-desc: bionic
- virtual-compute-desc: hackfest_basic_metrics-VM-compute
- virtual-storage-desc:
- - hackfest_basic_metrics-VM-storage
- version: '1.0'
- virtual-compute-desc:
- - id: hackfest_basic_metrics-VM-compute
- virtual-cpu:
- num-virtual-cpu: 1
- virtual-memory:
- size: 1.0
- virtual-storage-desc:
- - id: hackfest_basic_metrics-VM-storage
- size-of-storage: '10'
-"""
+++ /dev/null
-# Copyright 2021 Selvi Jayaraman (Tata Elxsi)
-#
-# 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.
-
-__author__ = "Selvi Jayaraman <selvi.j@tataelxsi.co.in>"
-
-import unittest
-from uuid import uuid4
-from unittest.mock import Mock, patch, mock_open
-from osm_common.dbmemory import DbMemory
-from osm_common.fsbase import FsBase
-from osm_common.msgbase import MsgBase
-from osm_nbi.vnf_instance_topics import VnfInstances, VnfLcmOpTopic
-from osm_nbi.instance_topics import NsrTopic
-from osm_nbi.tests.test_db_descriptors import (
- db_vim_accounts_text,
- db_vnfm_vnfd_text,
- db_nsds_text,
- db_nsrs_text,
- db_vnfrs_text,
- db_nslcmops_text
-)
-import yaml
-
-
-class TestVnfInstances(unittest.TestCase):
- def setUp(self):
- self.db = DbMemory()
- self.fs = Mock(FsBase())
- self.msg = Mock(MsgBase())
- self.vnfinstances = VnfInstances(self.db, self.fs, self.msg, None)
- self.nsrtopic = NsrTopic(self.db, self.fs, self.msg, None)
- self.db.create_list(
- "vim_accounts", yaml.load(db_vim_accounts_text, Loader=yaml.Loader)
- )
- self.db.create_list("vnfds", yaml.load(db_vnfm_vnfd_text, Loader=yaml.Loader))
- self.vnfd = self.db.get_list("vnfds")[0]
- self.vnfd_id = self.vnfd["id"]
- self.vnfd_project = self.vnfd["_admin"]["projects_read"][0]
-
- self.vim = self.db.get_list("vim_accounts")[0]
- self.vim_id = self.vim["_id"]
-
- @patch("osm_nbi.descriptor_topics.shutil")
- @patch("osm_nbi.descriptor_topics.os.rename")
- def test_create_identifier(self, mock_rename, mock_shutil):
- session = {
- "force": True,
- "admin": False,
- "public": False,
- "project_id": [self.vnfd_project],
- "method": "write",
- }
- indata = {
- "vnfdId": self.vnfd_id,
- "vnfInstanceName": "vnf_instance_name",
- "vnfInstanceDescription": "vnf instance description",
- "vimAccountId": self.vim_id,
- "additionalParams": {
- "virtual-link-desc": [
- {
- "id": "mgmt-net",
- "mgmt-network": True
- }
- ],
- "constituent-cpd-id": "vnf-cp0-ext",
- "virtual-link-profile-id": "mgmt-net"
- }
- }
- rollback = []
- headers = {}
- self.fs.path = ""
- self.fs.get_params.return_value = {}
- self.fs.file_exists.return_value = False
- self.fs.file_open.side_effect = lambda path, mode: open(
- "/tmp/" + str(uuid4()), "a+b"
- )
-
- vnfr_id, _ = self.vnfinstances.new(
- rollback, session, indata, {}, headers={"Content-Type": []}
- )
- vnfr = self.db.get_one("vnfrs")
- self.assertEqual(
- vnfr_id,
- vnfr["id"],
- "Mismatch between return id and database id"
- )
- self.assertEqual(
- "NOT_INSTANTIATED",
- vnfr["_admin"]["nsState"],
- "Database record must contain 'nsState' NOT_INSTANTIATED"
- )
- self.assertEqual(
- self.vnfd_id,
- vnfr["vnfd-ref"],
- "vnfr record is not properly created for the given vnfd")
-
- def test_show_vnfinstance(self):
- session = {
- "force": False,
- "admin": False,
- "public": False,
- "project_id": [self.vnfd_project],
- "method": "write",
- }
- filter_q = {}
- self.db.create_list("vnfrs", yaml.load(db_vnfrs_text, Loader=yaml.Loader))
- actual_vnfr = self.db.get_list("vnfrs")[0]
- id = actual_vnfr["_id"]
- expected_vnfr = self.vnfinstances.show(session, id, filter_q)
- self.assertEqual(
- actual_vnfr["_id"],
- expected_vnfr["_id"],
- "Mismatch between return vnfr Id and database vnfr Id"
- )
-
- def test_delete_vnfinstance(self):
- session = {
- "force": False,
- "admin": False,
- "public": False,
- "project_id": [self.vnfd_project],
- "method": "delete",
- }
- self.db.create_list("vnfrs", yaml.load(db_vnfrs_text, Loader=yaml.Loader))
- self.db.create_list("nsrs", yaml.load(db_nsrs_text, Loader=yaml.Loader))
- self.db.create_list("nsds", yaml.load(db_nsds_text, Loader=yaml.Loader))
-
- self.vnfr = self.db.get_list("vnfrs")[0]
- self.vnfr_id = self.vnfr["_id"]
- self.db.set_one = self.db.set_one
- self.db.set_one = Mock()
-
- self.vnfinstances.delete(session, self.vnfr_id)
- msg_args = self.msg.write.call_args[0]
- self.assertEqual(msg_args[1], "deleted", "Wrong message action")
-
-
-class TestVnfLcmOpTopic(unittest.TestCase):
- def setUp(self):
- self.db = DbMemory()
- self.fs = Mock(FsBase())
- self.fs.get_params.return_value = {"./fake/folder"}
- self.fs.file_open = mock_open()
- self.msg = Mock(MsgBase())
-
- self.vnflcmop_topic = VnfLcmOpTopic(self.db, self.fs, self.msg, None)
- self.vnflcmop_topic.check_quota = Mock(return_value=None) # skip quota
-
- self.db.create_list(
- "vim_accounts", yaml.load(db_vim_accounts_text, Loader=yaml.Loader)
- )
- self.db.create_list("nsds", yaml.load(db_nsds_text, Loader=yaml.Loader))
- self.db.create_list("vnfds", yaml.load(db_vnfm_vnfd_text, Loader=yaml.Loader))
- self.db.create_list("vnfrs", yaml.load(db_vnfrs_text, Loader=yaml.Loader))
- self.db.create_list("nsrs", yaml.load(db_nsrs_text, Loader=yaml.Loader))
-
- self.vnfd = self.db.get_list("vnfds")[0]
- self.vnfd_id = self.vnfd["_id"]
- self.vnfr = self.db.get_list("vnfrs")[0]
- self.vnfr_id = self.vnfr["_id"]
-
- self.vnfd_project = self.vnfd["_admin"]["projects_read"][0]
-
- self.vim = self.db.get_list("vim_accounts")[0]
- self.vim_id = self.vim["_id"]
-
- def test_create_vnf_instantiate(self):
- session = {
- "force": False,
- "admin": False,
- "public": False,
- "project_id": [self.vnfd_project],
- "method": "write",
- }
- indata = {
- "vnfInstanceId": self.vnfr_id,
- "lcmOperationType": "instantiate",
- "vnfName": "vnf_instance_name",
- "vnfDescription": "vnf instance description",
- "vnfId": self.vnfd_id,
- "vimAccountId": self.vim_id
- }
- rollback = []
- headers = {}
- vnflcmop_id, _ = self.vnflcmop_topic.new(
- rollback, session, indata, kwargs=None, headers=headers
- )
- vnflcmop_info = self.db.get_one("nslcmops")
- self.assertEqual(
- vnflcmop_id,
- vnflcmop_info["_id"],
- "Mismatch between return id and database '_id'",
- )
- self.assertTrue(
- vnflcmop_info["lcmOperationType"] == "instantiate",
- "Database record must contain 'lcmOperationType=instantiate'",
- )
-
- def test_show_vnflmcop(self):
- session = {
- "force": False,
- "admin": False,
- "public": False,
- "project_id": [self.vnfd_project],
- "method": "write",
- }
- self.db.create_list("nslcmops", yaml.load(db_nslcmops_text, Loader=yaml.Loader))
- filter_q = {}
- actual_lcmop = self.db.get_list("nslcmops")[0]
- id = actual_lcmop["_id"]
- vnfr = self.db.get_list("vnfrs")[0]
- vnfr_id = vnfr["_id"]
- vnflcmop = self.vnflcmop_topic.show(session, id, filter_q)
- _id = vnflcmop["vnfInstanceId"]
- self.assertEqual(_id, vnfr_id, "Mismatch between vnflcmop's vnfInstanceId and database vnfr's id")
+++ /dev/null
-# Copyright 2021 K Sai Kiran (Tata Elxsi)
-#
-# 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.
-
-__author__ = "K Sai Kiran <saikiran.k@tataelxsi.co.in>, Selvi Jayaraman <selvi.j@tataelxsi.co.in>"
-__date__ = "$12-June-2021 8:30:59$"
-
-from osm_nbi.base_topic import BaseTopic
-from .osm_vnfm.vnf_instances import VnfInstances2NsInstances
-from .osm_vnfm.vnf_instance_actions import VnfLcmOp2NsLcmOp
-
-
-class VnfInstances(BaseTopic):
-
- def __init__(self, db, fs, msg, auth):
- """
- Constructor call for vnf instance topic
- """
- BaseTopic.__init__(self, db, fs, msg, auth)
- self.vnfinstances2nsinstances = VnfInstances2NsInstances(db, fs, msg, auth)
-
- def new(self, rollback, session, indata=None, kwargs=None, headers=None):
- """
- Creates new vnf instance
- :param rollback: list to append the created items at database in case a rollback must be done
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param indata: params to be used for the vnf instance
- :param kwargs: used to override the indata descriptor
- :param headers: http request headers
- :return: the _id of vnf instance created at database. Or an exception.
- """
- return self.vnfinstances2nsinstances.new(rollback, session, indata, kwargs, headers)
-
- def list(self, session, filter_q=None, api_req=False):
- """
- Get a list of the vnf instances that match a filter
- :param session: contains the used login username and working project
- :param filter_q: filter of data to be applied
- :param api_req: True if this call is serving an external API request. False if serving internal request.
- :return: The list, it can be empty if no one match the filter.
- """
- return self.vnfinstances2nsinstances.list(session, filter_q, api_req)
-
- def show(self, session, _id, filter_q=None, api_req=False):
- """
- Get complete information on an vnf instance
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param _id: server internal id
- :param api_req: True if this call is serving an external API request. False if serving internal request.
- :return: dictionary, raise exception if not found.
- """
- return self.vnfinstances2nsinstances.show(session, _id, api_req)
-
- def delete(self, session, _id, dry_run=False, not_send_msg=None):
- """
- Delete vnf instance by its internal _id
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param _id: server internal id
- :param dry_run: make checking but do not delete
- :param not_send_msg: To not send message (False) or store content (list) instead
- :return: operation id (None if there is not operation), raise exception if error or not found, conflict, ...
- """
- return self.vnfinstances2nsinstances.delete(session, _id, dry_run, not_send_msg)
-
-
-class VnfLcmOpTopic(BaseTopic):
-
- def __init__(self, db, fs, msg, auth):
- """
- Constructor call for vnf lcm op topic
- """
- BaseTopic.__init__(self, db, fs, msg, auth)
- self.vnflcmop2nslcmop = VnfLcmOp2NsLcmOp(db, fs, msg, auth)
-
- def new(self, rollback, session, indata=None, kwargs=None, headers=None):
- """
- Creates new vnf lcm op
- :param rollback: list to append the created items at database in case a rollback must be done
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param indata: params to be used for the vnf instance
- :param kwargs: used to override the indata descriptor
- :param headers: http request headers
- :return: the _id of vnf lcm op created at database. Or an exception.
- """
- return self.vnflcmop2nslcmop.new(rollback, session, indata, kwargs, headers)
-
- def list(self, session, filter_q=None, api_req=False):
- """
- Get a list of the vnf lcm op that match a filter
- :param session: contains the used login username and working project
- :param filter_q: filter of data to be applied
- :param api_req: True if this call is serving an external API request. False if serving internal request.
- :return: The list, it can be empty if no one match the filter.
- """
- return self.vnflcmop2nslcmop.list(session, filter_q, api_req)
-
- def show(self, session, _id, filter_q=None, api_req=False):
- """
- Get complete information on an vnf lcm op
- :param session: contains "username", "admin", "force", "public", "project_id", "set_project"
- :param _id: server internal id
- :param api_req: True if this call is serving an external API request. False if serving internal request.
- :return: dictionary, raise exception if not found.
- """
- return self.vnflcmop2nslcmop.show(session, _id, api_req)
projects / osm / NBI.git / commitdiff