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_network_aai(network_id, data):
 263     resource = "/network/l3-networks/l3-network/%s" % network_id
 264     data = json.JSONEncoder().encode(data)
 265     ret = call_aai(resource, "PUT", data)
 266     if ret[0] != 0:
 267         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 268         raise NSLCMException("Network creation exception in AAI")
 269     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 270
 271
 272 def query_network_aai(network_id):
 273     resource = "/network/l3-networks/l3-network/%s" % network_id
 274     ret = call_aai(resource, "GET")
 275     if ret[0] != 0:
 276         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 277         raise NSLCMException("Network query exception in AAI")
 278     return json.JSONDecoder().decode(ret[1])
 279
 280
 281 def delete_network_aai(network_id, resource_version=""):
 282     resource = "/network/l3-networks/l3-network/%s" % network_id
 283     if resource_version:
 284         resource = resource + "?resource-version=%s" % resource_version
 285     ret = call_aai(resource, "DELETE")
 286     if ret[0] != 0:
 287         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 288         raise NSLCMException("Network delete exception in AAI")
 289     if ret[2] == 404:
 290         logger.error("Network has been deleted in aai")
 291         raise RequestException("Network delete exception in AAI")
 292     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 293
 294
 295 def put_network_relationship(network_id, data):
 296     resource = "/network/l3-networks/l3-network/%s/relationship-list/relationship" % network_id
 297     data = json.JSONEncoder().encode(data)
 298     ret = call_aai(resource, "PUT", data)
 299     if ret[0] != 0:
 300         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 301         raise NSLCMException("Put or update network relationship exception in AAI")
 302     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 303
 304
 305 def delete_network_relationship(network_id):
 306     resource = "/network/l3-networks/l3-network/%s/relationship-list/relationship" % network_id
 307     ret = call_aai(resource, "DELETE")
 308     if ret[0] != 0:
 309         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 310         raise NSLCMException("Delete network relationship exception in AAI")
 311     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 312
 313
 314 def create_subnet_aai(network_id, subnet_id, data):
 315     resource = "/network/l3-networks/l3-network/%s/subnets/subnet/%s" % (network_id, subnet_id)
 316     data = json.JSONEncoder().encode(data)
 317     ret = call_aai(resource, "PUT", data)
 318     if ret[0] != 0:
 319         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 320         raise NSLCMException("Subnetwork creation exception in AAI")
 321     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 322
 323
 324 def query_subnet_aai(network_id, subnet_id):
 325     resource = "/network/l3-networks/l3-network/%s/subnets/subnet/%s" % (network_id, subnet_id)
 326     ret = call_aai(resource, "GET")
 327     if ret[0] != 0:
 328         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 329         raise NSLCMException("Subnetwork query exception in AAI")
 330     return json.JSONDecoder().decode(ret[1])
 331
 332
 333 def delete_subnet_aai(network_id, subnet_id, resource_version=""):
 334     resource = "/network/l3-networks/l3-network/%s/subnets/subnet/%s" % (network_id, subnet_id)
 335     if resource_version:
 336         resource = resource + "?resource-version=%s" % resource_version
 337     ret = call_aai(resource, "DELETE")
 338     if ret[0] != 0:
 339         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 340         raise NSLCMException("Subnetwork delete exception in AAI")
 341     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 342
 343
 344 def put_subnet_relationship(network_id, subnet_id, data):
 345     resource = "/network/l3-networks/l3-network/%s/subnets/subnet/%s/relationship-list/relationship"\
 346                % (network_id, subnet_id)
 347     data = json.JSONEncoder().encode(data)
 348     ret = call_aai(resource, "PUT", data)
 349     if ret[0] != 0:
 350         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 351         raise NSLCMException("Put or update subnetwork relationship exception in AAI")
 352     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]
 353
 354
 355 def delete_subnet_relationship(network_id, subnet_id):
 356     resource = "/network/l3-networks/l3-network/%s/subnets/subnet/%s/relationship-list/relationship"\
 357                % (network_id, subnet_id)
 358     ret = call_aai(resource, "DELETE")
 359     if ret[0] != 0:
 360         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 361         raise NSLCMException("Delete subnetwork relationship exception in AAI")
 362     return json.JSONDecoder().decode(ret[1]) if ret[1] else ret[1], ret[2]