lcm/pub/msapi/aai.py

   1 # Copyright 2017 ZTE Corporation.
   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 implied.
  12 # See the License for the specific language governing permissions and
  13 # limitations under the License.
  14
  15 import json
  16 import logging
  17 import uuid
  18
  19 from lcm.pub.config.config import AAI_BASE_URL, AAI_USER, AAI_PASSWD
  20 from lcm.pub.exceptions import NSLCMException, RequestException
  21 from lcm.pub.utils import restcall
  22
  23
  24 logger = logging.getLogger(__name__)
  25
  26
  27 def call_aai(resource, method, content=''):
  28     additional_headers = {
  29         'X-FromAppId': 'VFC-NFVO-LCM',
  30         'X-TransactionId': str(uuid.uuid1())
  31     }
  32
  33     return restcall.call_req(AAI_BASE_URL,
  34                              AAI_USER,
  35                              AAI_PASSWD,
  36                              restcall.rest_no_auth,
  37                              resource,
  38                              method,
  39                              content,
  40                              additional_headers)
  41
  42
  43 def create_customer_aai(global_customer_id, data):
  44     resource = "/business/customers/customer/%s" % global_customer_id
  45     data = json.JSONEncoder().encode(data)
  46     ret = call_aai(resource, "PUT", data)
  47     if ret[0] != 0:
  48         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
  49         raise NSLCMException("Customer creation exception in AAI")
  50     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
  51
  52
  53 def query_customer_aai(global_customer_id):
  54     resource = "/business/customers/customer/%s?depth=all" % global_customer_id
  55     ret = call_aai(resource, "GET")
  56     if ret[0] != 0:
  57         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
  58         raise NSLCMException("Get customer info exception in AAI")
  59     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1]
  60
  61
  62 def delete_customer_aai(global_customer_id, resource_version=""):
  63     resource = "/business/customers/customer/%s" % global_customer_id
  64     if resource_version:
  65         resource = resource + "?resource-version=%s" % resource_version
  66     ret = call_aai(resource, "DELETE")
  67     if ret[0] != 0:
  68         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
  69         raise NSLCMException("Customer delete exception in AAI")
  70     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
  71
  72
  73 def put_customer_relationship(global_customer_id, data):
  74     resource = "/business/customers/customer/{global-customer-id}/relationship-list/relationship" % global_customer_id
  75     data = json.JSONEncoder().encode(data)
  76     ret = call_aai(resource, "PUT", data)
  77     if ret[0] != 0:
  78         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
  79         raise NSLCMException("Put or update customer relationship exception in AAI")
  80     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
  81
  82
  83 def delete_customer_relationship(global_customer_id):
  84     resource = "/business/customers/customer/{global-customer-id}/relationship-list/relationship" % global_customer_id
  85     ret = call_aai(resource, "DELETE")
  86     if ret[0] != 0:
  87         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
  88         raise NSLCMException("Delete customer relationship exception in AAI")
  89     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
  90
  91
  92 def create_ns_aai(global_customer_id, service_type, service_instance_id, data):
  93     resource = "/business/customers/customer/%s/service-subscriptions/service-subscription/" \
  94                "%s/service-instances/service-instance/%s" % \
  95                (global_customer_id, service_type, service_instance_id)
  96     data = json.JSONEncoder().encode(data)
  97     ret = call_aai(resource, "PUT", data)
  98     if ret[0] != 0:
  99         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 100         raise NSLCMException("Ns instance creation exception in AAI")
 101     return json.loads(ret[1]) if ret[1] else ret[1], ret[2]
 102
 103
 104 def query_ns_aai(global_customer_id, service_type, service_instance_id):
 105     resource = "/business/customers/customer/%s/service-subscriptions/service-subscription/" \
 106                "%s/service-instances/service-instance/%s?depth=all" % \
 107                (global_customer_id, service_type, service_instance_id)
 108     ret = call_aai(resource, "GET")
 109     if ret[0] != 0:
 110         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 111         raise NSLCMException("Ns instance query exception in AAI")
 112     return json.JSONDecoder().decode(ret[1])
 113
 114
 115 def delete_ns_aai(global_customer_id, service_type, service_instance_id, resource_version=""):
 116     resource = "/business/customers/customer/%s/service-subscriptions/service-subscription/" \
 117                "%s/service-instances/service-instance/%s" % \
 118                (global_customer_id, service_type, service_instance_id)
 119     if resource_version:
 120         resource = resource + "?resource-version=%s" % resource_version
 121     ret = call_aai(resource, "DELETE")
 122     if ret[0] != 0:
 123         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 124         raise NSLCMException("Ns instance delete exception in AAI")
 125     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 126
 127
 128 def put_ns_relationship(global_customer_id, service_type, service_instance_id, data):
 129     resource = "/business/customers/customer/%s/service-subscriptions/service-subscription/" \
 130                "%s/service-instances/service-instance/%s/relationship-list/relationship" % \
 131                (global_customer_id, service_type, service_instance_id)
 132     data = json.JSONEncoder().encode(data)
 133     ret = call_aai(resource, "PUT", data)
 134     if ret[0] != 0:
 135         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 136         raise NSLCMException("Put or update ns instance relationship exception in AAI")
 137     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 138
 139
 140 def delete_ns_relationship(global_customer_id, service_type, service_instance_id):
 141     resource = "/business/customers/customer/%s/service-subscriptions/service-subscription/" \
 142                "%s/service-instances/service-instance/%s/relationship-list/relationship" % \
 143                (global_customer_id, service_type, service_instance_id)
 144     ret = call_aai(resource, "DELETE")
 145     if ret[0] != 0:
 146         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 147         raise NSLCMException("Delete ns instance relationship exception in AAI")
 148     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 149
 150
 151 def create_vnf_aai(vnf_id, data):
 152     resource = "/network/generic-vnfs/generic-vnf/%s" % vnf_id
 153     data = json.JSONEncoder().encode(data)
 154     ret = call_aai(resource, "PUT", data)
 155     if ret[0] != 0:
 156         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 157         raise NSLCMException("Vnf instance creation exception in AAI")
 158     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 159
 160
 161 def query_vnf_aai(vnf_id):
 162     resource = "/network/generic-vnfs/generic-vnf/%s?depth=all" % vnf_id
 163     ret = call_aai(resource, "GET")
 164     if ret[0] != 0:
 165         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 166         raise NSLCMException("Vnf instance query exception in AAI")
 167     return json.JSONDecoder().decode(ret[1])
 168
 169
 170 def delete_vnf_aai(vnf_id, resource_version=""):
 171     resource = "/network/generic-vnfs/generic-vnf/%s" % vnf_id
 172     if resource_version:
 173         resource = resource + "?resource-version=%s" % resource_version
 174     ret = call_aai(resource, "DELETE")
 175     if ret[0] != 0:
 176         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 177         raise NSLCMException("Vnf instance delete exception in AAI")
 178     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 179
 180
 181 def put_vnf_relationship(vnf_id, data):
 182     resource = "/network/generic-vnfs/generic-vnf/%s/relationship-list/relationship" % vnf_id
 183     data = json.JSONEncoder().encode(data)
 184     ret = call_aai(resource, "PUT", data)
 185     if ret[0] != 0:
 186         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 187         raise NSLCMException("Put or update vnf instance relationship exception in AAI")
 188     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 189
 190
 191 def delete_vnf_relationship(vnf_id):
 192     resource = "/network/generic-vnfs/generic-vnf/%s/relationship-list/relationship" % vnf_id
 193     ret = call_aai(resource, "DELETE")
 194     if ret[0] != 0:
 195         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 196         raise NSLCMException("Delete vnf instance relationship exception in AAI")
 197     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 198
 199
 200 def create_vserver_aai(cloud_owner, cloud_region_id, tenant_id, vserver_id, data):
 201     resource = "/cloud-infrastructure/cloud-regions/cloud-region/%s/" \
 202                "%s/tenants/tenant/%s/vservers/vserver/%s" % \
 203                (cloud_owner, cloud_region_id, tenant_id, vserver_id)
 204     data = json.JSONEncoder().encode(data)
 205     ret = call_aai(resource, "PUT", data)
 206     if ret[0] != 0:
 207         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 208         raise NSLCMException("Vserver creation exception in AAI")
 209     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 210
 211
 212 def query_vserver_aai(cloud_owner, cloud_region_id, tenant_id, vserver_id):
 213     resource = "/cloud-infrastructure/cloud-regions/cloud-region/%s/" \
 214                "%s/tenants/tenant/%s/vservers/vserver/%s?depth=all" % \
 215                (cloud_owner, cloud_region_id, tenant_id, vserver_id)
 216     ret = call_aai(resource, "GET")
 217     if ret[0] != 0:
 218         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 219         raise NSLCMException("Vserver query exception in AAI")
 220     return json.JSONDecoder().decode(ret[1])
 221
 222
 223 def delete_vserver_aai(cloud_owner, cloud_region_id, tenant_id, vserver_id, resource_version=""):
 224     resource = "/cloud-infrastructure/cloud-regions/cloud-region/%s/" \
 225                "%s/tenants/tenant/%s/vservers/vserver/%s" % \
 226                (cloud_owner, cloud_region_id, tenant_id, vserver_id)
 227     if resource_version:
 228         resource = resource + "?resource-version=%s" % resource_version
 229     ret = call_aai(resource, "DELETE")
 230     if ret[0] != 0:
 231         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 232         raise NSLCMException("Vserver delete exception in AAI")
 233     if ret[2] == 404:
 234         logger.error("Vserver has been deleted in aai")
 235         raise RequestException("Vserver delete exception in AAI")
 236     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 237
 238
 239 def put_vserver_relationship(cloud_owner, cloud_region_id, tenant_id, vserver_id, data):
 240     resource = "/cloud-infrastructure/cloud-regions/cloud-region/%s/" \
 241                "%s/tenants/tenant/%s/vservers/vserver/%s/relationship-list/relationship" % \
 242                (cloud_owner, cloud_region_id, tenant_id, vserver_id)
 243     data = json.JSONEncoder().encode(data)
 244     ret = call_aai(resource, "PUT", data)
 245     if ret[0] != 0:
 246         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 247         raise NSLCMException("Put or update vserver relationship exception in AAI")
 248     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 249
 250
 251 def delete_vserver_relationship(cloud_owner, cloud_region_id, tenant_id, vserver_id):
 252     resource = "/cloud-infrastructure/cloud-regions/cloud-region/%s/" \
 253                "%s/tenants/tenant/%s/vservers/vserver/%s/relationship-list/relationship" % \
 254                (cloud_owner, cloud_region_id, tenant_id, vserver_id)
 255     ret = call_aai(resource, "DELETE")
 256     if ret[0] != 0:
 257         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 258         raise NSLCMException("Delete vserver relationship exception in AAI")
 259     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 260
 261
 262 def create_l_interface_aai(vnf_id, interface_name):
 263     resource = "/network/generic-vnfs/generic-vnf/%s/l-interfaces/l-interface/%s" % (vnf_id, interface_name)
 264     ret = call_aai(resource, "PUT")
 265     if ret[0] != 0:
 266         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 267         raise NSLCMException("l-interface creation exception in AAI")
 268     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 269
 270
 271 def query_l_interface_aai(vnf_id, interface_name):
 272     resource = "/network/generic-vnfs/generic-vnf/%s/l-interfaces/l-interface/%s" % (vnf_id, interface_name)
 273     ret = call_aai(resource, "GET")
 274     if ret[0] != 0:
 275         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 276         raise NSLCMException("Get l-interface info exception in AAI")
 277     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 278
 279
 280 def delete_l_interface_aai(vnf_id, interface_name, resource_version=""):
 281     resource = "/network/generic-vnfs/generic-vnf/%s/l-interfaces/l-interface/%s" % (vnf_id, interface_name)
 282     if resource_version:
 283         resource = resource + "?resource-version=%s" % resource_version
 284     ret = call_aai(resource, "DELETE")
 285     if ret[0] != 0:
 286         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 287         raise NSLCMException("l_interface delete exception in AAI")
 288     if ret[2] == 404:
 289         logger.error("No l_interface %s in AAI" % interface_name)
 290         raise RequestException("No l_interface %s in AAI" % interface_name)
 291     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 292
 293
 294 def create_l3_interface_ipv4_address_list_aai(vnf_id, interface_name, ipv4_addr):
 295     resource = "/network/generic-vnfs/generic-vnf/%s/l-interfaces/l-interface/%s/" \
 296                "l3-interface-ipv4-address-list/%s" % (vnf_id, interface_name, ipv4_addr)
 297     ret = call_aai(resource, "PUT")
 298     if ret[0] != 0:
 299         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 300         raise NSLCMException("Ip address list creation exception in AAI")
 301     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 302
 303
 304 def create_network_aai(network_id, data):
 305     resource = "/network/l3-networks/l3-network/%s" % network_id
 306     data = json.JSONEncoder().encode(data)
 307     ret = call_aai(resource, "PUT", data)
 308     if ret[0] != 0:
 309         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 310         raise NSLCMException("Network creation exception in AAI")
 311     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 312
 313
 314 def query_network_aai(network_id):
 315     resource = "/network/l3-networks/l3-network/%s" % network_id
 316     ret = call_aai(resource, "GET")
 317     if ret[0] != 0:
 318         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 319         raise NSLCMException("Network query exception in AAI")
 320     return json.JSONDecoder().decode(ret[1])
 321
 322
 323 def delete_network_aai(network_id, resource_version=""):
 324     resource = "/network/l3-networks/l3-network/%s" % network_id
 325     if resource_version:
 326         resource = resource + "?resource-version=%s" % resource_version
 327     ret = call_aai(resource, "DELETE")
 328     if ret[0] != 0:
 329         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 330         raise NSLCMException("Network delete exception in AAI")
 331     if ret[2] == 404:
 332         logger.error("Network has been deleted in aai")
 333         raise RequestException("Network delete exception in AAI")
 334     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 335
 336
 337 def put_network_relationship(network_id, data):
 338     resource = "/network/l3-networks/l3-network/%s/relationship-list/relationship" % network_id
 339     data = json.JSONEncoder().encode(data)
 340     ret = call_aai(resource, "PUT", data)
 341     if ret[0] != 0:
 342         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 343         raise NSLCMException("Put or update network relationship exception in AAI")
 344     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 345
 346
 347 def delete_network_relationship(network_id):
 348     resource = "/network/l3-networks/l3-network/%s/relationship-list/relationship" % network_id
 349     ret = call_aai(resource, "DELETE")
 350     if ret[0] != 0:
 351         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 352         raise NSLCMException("Delete network relationship exception in AAI")
 353     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 354
 355
 356 def create_subnet_aai(network_id, subnet_id, data):
 357     resource = "/network/l3-networks/l3-network/%s/subnets/subnet/%s" % (network_id, subnet_id)
 358     data = json.JSONEncoder().encode(data)
 359     ret = call_aai(resource, "PUT", data)
 360     if ret[0] != 0:
 361         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 362         raise NSLCMException("Subnetwork creation exception in AAI")
 363     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 364
 365
 366 def query_subnet_aai(network_id, subnet_id):
 367     resource = "/network/l3-networks/l3-network/%s/subnets/subnet/%s" % (network_id, subnet_id)
 368     ret = call_aai(resource, "GET")
 369     if ret[0] != 0:
 370         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 371         raise NSLCMException("Subnetwork query exception in AAI")
 372     return json.JSONDecoder().decode(ret[1])
 373
 374
 375 def delete_subnet_aai(network_id, subnet_id, resource_version=""):
 376     resource = "/network/l3-networks/l3-network/%s/subnets/subnet/%s" % (network_id, subnet_id)
 377     if resource_version:
 378         resource = resource + "?resource-version=%s" % resource_version
 379     ret = call_aai(resource, "DELETE")
 380     if ret[0] != 0:
 381         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 382         raise NSLCMException("Subnetwork delete exception in AAI")
 383     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 384
 385
 386 def put_subnet_relationship(network_id, subnet_id, data):
 387     resource = "/network/l3-networks/l3-network/%s/subnets/subnet/%s/relationship-list/relationship"\
 388                % (network_id, subnet_id)
 389     data = json.JSONEncoder().encode(data)
 390     ret = call_aai(resource, "PUT", data)
 391     if ret[0] != 0:
 392         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 393         raise NSLCMException("Put or update subnetwork relationship exception in AAI")
 394     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 395
 396
 397 def delete_subnet_relationship(network_id, subnet_id):
 398     resource = "/network/l3-networks/l3-network/%s/subnets/subnet/%s/relationship-list/relationship"\
 399                % (network_id, subnet_id)
 400     ret = call_aai(resource, "DELETE")
 401     if ret[0] != 0:
 402         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 403         raise NSLCMException("Delete subnetwork relationship exception in AAI")
 404     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]