| 1 |
|
# Copyright 2021 K Sai Kiran (Tata Elxsi) |
| 2 |
|
# |
| 3 |
|
# Licensed under the Apache License, Version 2.0 (the "License"); |
| 4 |
|
# you may not use this file except in compliance with the License. |
| 5 |
|
# You may obtain a copy of the License at |
| 6 |
|
# |
| 7 |
|
# http://www.apache.org/licenses/LICENSE-2.0 |
| 8 |
|
# |
| 9 |
|
# Unless required by applicable law or agreed to in writing, software |
| 10 |
|
# distributed under the License is distributed on an "AS IS" BASIS, |
| 11 |
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or |
| 12 |
|
# implied. |
| 13 |
|
# See the License for the specific language governing permissions and |
| 14 |
|
# limitations under the License. |
| 15 |
|
|
| 16 |
1 |
__author__ = "K Sai Kiran <saikiran.k@tataelxsi.co.in>, Selvi Jayaraman <selvi.j@tataelxsi.co.in>" |
| 17 |
1 |
__date__ = "$12-June-2021 8:30:59$" |
| 18 |
|
|
| 19 |
1 |
from copy import deepcopy |
| 20 |
1 |
from osm_nbi.descriptor_topics import NsdTopic |
| 21 |
1 |
from .base_methods import BaseMethod |
| 22 |
|
|
| 23 |
1 |
from osm_nbi.instance_topics import NsrTopic, VnfrTopic |
| 24 |
|
|
| 25 |
|
|
| 26 |
1 |
class VnfInstances2NsInstances: |
| 27 |
1 |
def __init__(self, db, fs, msg, auth): |
| 28 |
|
""" |
| 29 |
|
Constructor of Vnf Instances to Ns Instances |
| 30 |
|
""" |
| 31 |
1 |
self.new_vnf_instance = NewVnfInstance(db, fs, msg, auth) |
| 32 |
1 |
self.list_vnf_instance = ListVnfInstance(db, fs, msg, auth) |
| 33 |
1 |
self.show_vnf_instance = ShowVnfInstance(db, fs, msg, auth) |
| 34 |
1 |
self.delete_vnf_instance = DeleteVnfInstance(db, fs, msg, auth) |
| 35 |
|
|
| 36 |
1 |
def new(self, rollback, session, indata=None, kwargs=None, headers=None): |
| 37 |
|
""" |
| 38 |
|
Creates a new entry into database. |
| 39 |
|
:param rollback: list to append created items at database in case a rollback may have to be done |
| 40 |
|
:param session: contains "username", "admin", "force", "public", "project_id", "set_project" |
| 41 |
|
:param indata: data to be inserted |
| 42 |
|
:param kwargs: used to override the indata descriptor |
| 43 |
|
:param headers: http request headers |
| 44 |
|
:return: _id, op_id: |
| 45 |
|
_id: identity of the inserted data. |
| 46 |
|
op_id: operation id if this is asynchronous, None otherwise |
| 47 |
|
""" |
| 48 |
1 |
return self.new_vnf_instance.action(rollback, session, indata, kwargs, headers) |
| 49 |
|
|
| 50 |
1 |
def list(self, session, filter_q=None, api_req=False): |
| 51 |
|
""" |
| 52 |
|
Get a list of the Vnfs that match a filter |
| 53 |
|
:param session: contains the used login username and working project |
| 54 |
|
:param filter_q: filter of data to be applied |
| 55 |
|
:param api_req: True if this call is serving an external API request. False if serving internal request. |
| 56 |
|
:return: The list, it can be empty if no one match the filter. |
| 57 |
|
""" |
| 58 |
0 |
return self.list_vnf_instance.action(session, filter_q, api_req) |
| 59 |
|
|
| 60 |
1 |
def show(self, session, _id, api_req=False): |
| 61 |
|
""" |
| 62 |
|
Get complete information on an Vnf |
| 63 |
|
:param session: contains "username", "admin", "force", "public", "project_id", "set_project" |
| 64 |
|
:param _id: server internal id |
| 65 |
|
:param api_req: True if this call is serving an external API request. False if serving internal request. |
| 66 |
|
:return: dictionary, raise exception if not found. |
| 67 |
|
""" |
| 68 |
1 |
return self.show_vnf_instance.action(session, _id, api_req) |
| 69 |
|
|
| 70 |
1 |
def delete(self, session, _id, dry_run=False, not_send_msg=None): |
| 71 |
|
""" |
| 72 |
|
Delete item by its internal _id |
| 73 |
|
:param session: contains "username", "admin", "force", "public", "project_id", "set_project" |
| 74 |
|
:param _id: server internal id |
| 75 |
|
:param dry_run: make checking but do not delete |
| 76 |
|
:param not_send_msg: To not send message (False) or store content (list) instead |
| 77 |
|
:return: operation id (None if there is not operation), raise exception if error or not found, conflict, ... |
| 78 |
|
""" |
| 79 |
1 |
return self.delete_vnf_instance.action(session, _id, dry_run, not_send_msg) |
| 80 |
|
|
| 81 |
|
|
| 82 |
1 |
class NewVnfInstance(BaseMethod): |
| 83 |
|
# sample ns descriptor |
| 84 |
1 |
sample_nsd = { |
| 85 |
|
"nsd": { |
| 86 |
|
"nsd": [ |
| 87 |
|
{ |
| 88 |
|
"df": [ |
| 89 |
|
{ |
| 90 |
|
"id": "default-df", |
| 91 |
|
"vnf-profile": [ |
| 92 |
|
{ |
| 93 |
|
"id": 1, |
| 94 |
|
"virtual-link-connectivity": [ |
| 95 |
|
{ |
| 96 |
|
"constituent-cpd-id": [ |
| 97 |
|
{ |
| 98 |
|
"constituent-base-element-id": 1, |
| 99 |
|
"constituent-cpd-id": "eth0-ext", |
| 100 |
|
} |
| 101 |
|
], |
| 102 |
|
"virtual-link-profile-id": "mgmtnet", |
| 103 |
|
} |
| 104 |
|
], |
| 105 |
|
"vnfd-id": "cirros_vnfd", |
| 106 |
|
} |
| 107 |
|
], |
| 108 |
|
} |
| 109 |
|
], |
| 110 |
|
"vnfd-id": ["cirros_vnfd"], |
| 111 |
|
"description": "Generated by OSM pacakage generator", |
| 112 |
|
"id": "cirros_2vnf_nsd", |
| 113 |
|
"name": "cirros_2vnf_ns", |
| 114 |
|
"short-name": "cirros_2vnf_ns", |
| 115 |
|
"vendor": "OSM", |
| 116 |
|
"version": "1.0", |
| 117 |
|
} |
| 118 |
|
] |
| 119 |
|
} |
| 120 |
|
} |
| 121 |
|
|
| 122 |
1 |
@staticmethod |
| 123 |
1 |
def __get_formatted_indata(indata, nsd_id): |
| 124 |
|
""" |
| 125 |
|
Create indata for nsd_id |
| 126 |
|
:param indata: Contains unformatted data for new vnf instance |
| 127 |
|
:param nsd_id: Id of nsd |
| 128 |
|
:return: formatted indata for nsd_id |
| 129 |
|
""" |
| 130 |
1 |
formatted_indata = deepcopy(indata) |
| 131 |
1 |
formatted_indata["nsdId"] = nsd_id |
| 132 |
1 |
formatted_indata["nsName"] = indata["vnfInstanceName"] + "-ns" |
| 133 |
1 |
for invalid_key in ( |
| 134 |
|
"vnfdId", |
| 135 |
|
"vnfInstanceName", |
| 136 |
|
"vnfInstanceDescription", |
| 137 |
|
"additionalParams", |
| 138 |
|
): |
| 139 |
1 |
formatted_indata.pop(invalid_key) |
| 140 |
1 |
return formatted_indata |
| 141 |
|
|
| 142 |
1 |
def __init__(self, db, fs, msg, auth): |
| 143 |
|
""" |
| 144 |
|
Constructor for new vnf instance |
| 145 |
|
""" |
| 146 |
1 |
super().__init__() |
| 147 |
1 |
self.msg = msg |
| 148 |
1 |
self.nsdtopic = NsdTopic(db, fs, msg, auth) |
| 149 |
1 |
self.nsrtopic = NsrTopic(db, fs, msg, auth) |
| 150 |
|
|
| 151 |
1 |
def __get_vnfd(self): |
| 152 |
|
# get vnfd from nfvo |
| 153 |
1 |
pass |
| 154 |
|
|
| 155 |
1 |
def __onboard_vnfd(self): |
| 156 |
1 |
self.__get_vnfd() |
| 157 |
1 |
pass |
| 158 |
|
|
| 159 |
1 |
def __create_nsd(self, rollback, session, indata=None, kwargs=None, headers=None): |
| 160 |
|
""" |
| 161 |
|
Creates new ns descriptor from a vnfd. |
| 162 |
|
:param rollback: list to append the created items at database in case a rollback must be done |
| 163 |
|
:param session: contains "username", "admin", "force", "public", "project_id", "set_project" |
| 164 |
|
:param indata: params to be used for the nsr |
| 165 |
|
:param kwargs: used to override the indata |
| 166 |
|
:param headers: http request headers |
| 167 |
|
:return: id of new nsd created |
| 168 |
|
""" |
| 169 |
1 |
_id, *others = self.nsdtopic.new(rollback, session, {}, None, headers) |
| 170 |
1 |
new_nsd = deepcopy(NewVnfInstance.sample_nsd) |
| 171 |
1 |
vnf_content = { |
| 172 |
|
"id": "default-df", |
| 173 |
|
"vnf-profile": [ |
| 174 |
|
{ |
| 175 |
|
"id": "1", |
| 176 |
|
"virtual-link-connectivity": [ |
| 177 |
|
{ |
| 178 |
|
"constituent-cpd-id": [ |
| 179 |
|
{ |
| 180 |
|
"constituent-base-element-id": "1", |
| 181 |
|
"constituent-cpd-id": indata["additionalParams"][ |
| 182 |
|
"constituent-cpd-id" |
| 183 |
|
], |
| 184 |
|
} |
| 185 |
|
], |
| 186 |
|
"virtual-link-profile-id": indata["additionalParams"][ |
| 187 |
|
"virtual-link-profile-id" |
| 188 |
|
], |
| 189 |
|
} |
| 190 |
|
], |
| 191 |
|
"vnfd-id": indata["vnfdId"], |
| 192 |
|
} |
| 193 |
|
], |
| 194 |
|
} |
| 195 |
1 |
new_nsd["nsd"]["nsd"][0] = { |
| 196 |
|
"description": indata["vnfInstanceDescription"], |
| 197 |
|
"designer": "OSM", |
| 198 |
|
"id": indata["vnfdId"] + "-ns", |
| 199 |
|
"name": indata["vnfdId"] + "-ns", |
| 200 |
|
"version": "1.0", |
| 201 |
|
"df": [ |
| 202 |
|
vnf_content, |
| 203 |
|
], |
| 204 |
|
"virtual-link-desc": indata["additionalParams"]["virtual-link-desc"], |
| 205 |
|
"vnfd-id": [indata["vnfdId"]], |
| 206 |
|
} |
| 207 |
1 |
return _id, new_nsd |
| 208 |
|
|
| 209 |
1 |
def __create_nsr(self, rollback, session, indata=None, kwargs=None, headers=None): |
| 210 |
|
""" |
| 211 |
|
Creates an new ns record in database |
| 212 |
|
:param rollback: list to append the created items at database in case a rollback must be done |
| 213 |
|
:param session: contains "username", "admin", "force", "public", "project_id", "set_project" |
| 214 |
|
:param indata: params to be used for the nsr |
| 215 |
|
:param kwargs: used to override the indata |
| 216 |
|
:param headers: http request headers |
| 217 |
|
:return: id of new nsr |
| 218 |
|
""" |
| 219 |
1 |
return self.nsrtopic.new(rollback, session, indata, kwargs, headers) |
| 220 |
|
|
| 221 |
1 |
def __action_pre_processing( |
| 222 |
|
self, rollback, session, indata=None, kwargs=None, headers=None |
| 223 |
|
): |
| 224 |
|
""" |
| 225 |
|
Pre process for creating new vnf instance |
| 226 |
|
:param rollback: list to append the created items at database in case a rollback must be done |
| 227 |
|
:param session: contains "username", "admin", "force", "public", "project_id", "set_project" |
| 228 |
|
:param indata: params to be used for the nsr |
| 229 |
|
:param kwargs: used to override the indata |
| 230 |
|
:param headers: http request headers |
| 231 |
|
:return: id nsr |
| 232 |
|
""" |
| 233 |
1 |
self.__onboard_vnfd() |
| 234 |
1 |
nsd_id, nsd = self.__create_nsd(rollback, session, indata, kwargs, headers) |
| 235 |
1 |
self.nsdtopic.upload_content(session, nsd_id, nsd, kwargs, headers) |
| 236 |
1 |
formatted_indata = NewVnfInstance.__get_formatted_indata(indata, nsd_id) |
| 237 |
1 |
nsr_id, _ = self.__create_nsr( |
| 238 |
|
rollback, session, formatted_indata, kwargs, headers |
| 239 |
|
) |
| 240 |
1 |
nsr = self.nsrtopic.show(session, nsr_id) |
| 241 |
1 |
vnfr_id = nsr["constituent-vnfr-ref"][0] |
| 242 |
1 |
if vnfr_id: |
| 243 |
1 |
links = {"vnfInstance": "/osm/vnflcm/v1/vnf_instances/" + vnfr_id} |
| 244 |
1 |
indata["vnfInstanceId"] = vnfr_id |
| 245 |
1 |
indata["_links"] = links |
| 246 |
1 |
self.msg.write("vnf", "create", indata) |
| 247 |
1 |
return vnfr_id, None |
| 248 |
|
|
| 249 |
1 |
def action(self, rollback, session, indata=None, kwargs=None, headers=None): |
| 250 |
|
""" |
| 251 |
|
Creates an new vnf instance |
| 252 |
|
:param rollback: list to append the created items at database in case a rollback must be done |
| 253 |
|
:param session: contains "username", "admin", "force", "public", "project_id", "set_project" |
| 254 |
|
:param indata: params to be used for the nsr |
| 255 |
|
:param kwargs: used to override the indata |
| 256 |
|
:param headers: http request headers |
| 257 |
|
:return: id of new vnf instance |
| 258 |
|
""" |
| 259 |
1 |
return self.__action_pre_processing(rollback, session, indata, kwargs, headers) |
| 260 |
|
|
| 261 |
|
|
| 262 |
1 |
class ListVnfInstance(BaseMethod): |
| 263 |
1 |
def __init__(self, db, fs, msg, auth): |
| 264 |
|
""" |
| 265 |
|
Constructor call for listing vnfs |
| 266 |
|
""" |
| 267 |
1 |
super().__init__() |
| 268 |
1 |
self.vnfrtopic = VnfrTopic(db, fs, msg, auth) |
| 269 |
|
|
| 270 |
1 |
def action(self, session, filter_q=None, api_req=False): |
| 271 |
|
""" |
| 272 |
|
To get list of vnfs that matches a filter |
| 273 |
|
:param session: contains the used login username and working project |
| 274 |
|
:param filter_q: filter of data to be applied |
| 275 |
|
:param api_req: True if this call is serving an external API request. False if serving internal request. |
| 276 |
|
:return: The list, it can be empty if no one match the filter. |
| 277 |
|
""" |
| 278 |
0 |
return self.vnfrtopic.list(session, filter_q, api_req) |
| 279 |
|
|
| 280 |
|
|
| 281 |
1 |
class ShowVnfInstance(BaseMethod): |
| 282 |
1 |
def __init__(self, db, fs, msg, auth): |
| 283 |
|
""" |
| 284 |
|
Constructor call for showing vnf lcm operation |
| 285 |
|
""" |
| 286 |
1 |
super().__init__() |
| 287 |
1 |
self.vnfrtopic = VnfrTopic(db, fs, msg, auth) |
| 288 |
|
|
| 289 |
1 |
def action(self, session, _id, api_req=False): |
| 290 |
|
""" |
| 291 |
|
Get complete information on an Vnf Lcm Operation. |
| 292 |
|
:param session: contains "username", "admin", "force", "public", "project_id", "set_project" |
| 293 |
|
:param _id: Vnf Lcm operation id |
| 294 |
|
:param api_req: True if this call is serving an external API request. False if serving internal request. |
| 295 |
|
:return: dictionary, raise exception if not found. |
| 296 |
|
""" |
| 297 |
1 |
return self.vnfrtopic.show(session, _id, api_req) |
| 298 |
|
|
| 299 |
|
|
| 300 |
1 |
class DeleteVnfInstance(BaseMethod): |
| 301 |
1 |
def __init__(self, db, fs, msg, auth): |
| 302 |
|
""" |
| 303 |
|
Constructor call for deleting vnf |
| 304 |
|
""" |
| 305 |
1 |
super().__init__() |
| 306 |
1 |
self.msg = msg |
| 307 |
1 |
self.nsrtopic = NsrTopic(db, fs, msg, auth) |
| 308 |
1 |
self.nsdtopic = NsdTopic(db, fs, msg, auth) |
| 309 |
1 |
self.vnfrtopic = VnfrTopic(db, fs, msg, auth) |
| 310 |
|
|
| 311 |
1 |
def action(self, session, _id, dry_run=False, not_send_msg=None): |
| 312 |
|
""" |
| 313 |
|
Delete vnf instance by its internal _id |
| 314 |
|
:param session: contains "username", "admin", "force", "public", "project_id", "set_project" |
| 315 |
|
:param _id: server internal id |
| 316 |
|
:param dry_run: make checking but do not delete |
| 317 |
|
:param not_send_msg: To not send message (False) or store content (list) instead |
| 318 |
|
:return: operation id (None if there is not operation), raise exception if error or not found, conflict, ... |
| 319 |
|
""" |
| 320 |
1 |
vnfInstanceId = _id |
| 321 |
1 |
vnfr = self.vnfrtopic.show(session, vnfInstanceId) |
| 322 |
1 |
ns_id = vnfr.get("nsr-id-ref") |
| 323 |
1 |
nsr = self.nsrtopic.show(session, ns_id) |
| 324 |
1 |
nsd_to_del = nsr["nsd"]["_id"] |
| 325 |
1 |
links = {"vnfInstance": "/osm/vnflcm/v1/vnf_instances/" + _id} |
| 326 |
1 |
params = {"vnfdId": vnfr["vnfd-ref"], "vnfInstanceId": _id, "_links": links} |
| 327 |
1 |
self.msg.write("vnf", "delete", params) |
| 328 |
1 |
self.nsrtopic.delete(session, ns_id, dry_run, not_send_msg) |
| 329 |
1 |
return self.nsdtopic.delete(session, nsd_to_del, dry_run, not_send_msg) |
![[Jenkins]](/jenkins/static/c06f6c43/images/jenkins-header-logo-v2.svg){kind=logo}
