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
  16 import json
  17 import logging
  18 import uuid
  19
  20 from lcm.pub.config.config import AAI_BASE_URL, AAI_USER, AAI_PASSWD
  21 from lcm.pub.exceptions import NSLCMException
  22 from lcm.pub.utils import restcall
  23
  24
  25 logger = logging.getLogger(__name__)
  26
  27
  28 def call_aai(resource, method, content=''):
  29     additional_headers = {
  30         'X-FromAppId': 'VFC-NFVO-LCM',
  31         'X-TransactionId': str(uuid.uuid1())
  32     }
  33
  34     return restcall.call_req(AAI_BASE_URL,
  35                      AAI_USER,
  36                      AAI_PASSWD,
  37                      restcall.rest_no_auth,
  38                      resource,
  39                      method,
  40                      content,
  41                      additional_headers)
  42
  43 def create_customer_aai(global_customer_id, data):
  44     resource = "/business/customers/customer/%s" % global_customer_id
  45     ret = call_aai(resource, "PUT", data)
  46     if ret[0] != 0:
  47         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
  48         raise NSLCMException("Customer creation exception in AAI")
  49     return json.JSONDecoder().decode(ret[1]), ret[2]
  50
  51
  52 def get_customer_aai(global_customer_id):
  53     resource = "/business/customers/customer/%s?depth=all" % global_customer_id
  54     ret = call_aai(resource, "GET")
  55     if ret[0] != 0:
  56         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
  57         raise NSLCMException("Get customer info exception in AAI")
  58     return json.JSONDecoder().decode(ret[1])
  59
  60
  61 def delete_customer_aai(global_customer_id, resource_version=""):
  62     resource = "/business/customers/customer/%s" % global_customer_id
  63     if resource_version:
  64         resource = resource + "?resource-version=%s" % resource_version
  65     ret = call_aai(resource, "DELETE")
  66     if ret[0] != 0:
  67         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
  68         raise NSLCMException("Customer delete exception in AAI")
  69     return json.JSONDecoder().decode(ret[1]), ret[2]
  70
  71
  72 def create_ns_aai(global_customer_id, service_type, service_instance_id, data):
  73     resource = "/business/customers/customer/%s/service-subscriptions/service-subscription/" \
  74                "%s/service-instances/service-instance/%s" % \
  75                (global_customer_id, service_type, service_instance_id)
  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("Ns instance creation exception in AAI")
  80     return json.JSONDecoder().decode(ret[1]), ret[2]
  81
  82 def delete_ns_aai(global_customer_id, service_type, service_instance_id, resource_version=""):
  83     resource = "/business/customers/customer/%s/service-subscriptions/service-subscription/" \
  84                "%s/service-instances/service-instance/%s" % \
  85                (global_customer_id, service_type, service_instance_id)
  86     if resource_version:
  87         resource = resource + "?resource-version=%s" % resource_version
  88     ret = call_aai(resource, "DELETE")
  89     if ret[0] != 0:
  90         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
  91         raise NSLCMException("Ns instance delete exception in AAI")
  92     return json.JSONDecoder().decode(ret[1])
  93
  94 def query_ns_aai(global_customer_id, service_type, service_instance_id, data):
  95     resource = "/business/customers/customer/%s/service-subscriptions/service-subscription/" \
  96                "%s/service-instances/service-instance/%s?depth=all" % \
  97                (global_customer_id, service_type, service_instance_id)
  98     ret = call_aai(resource, "GET", data)
  99     if ret[0] != 0:
 100         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 101         raise NSLCMException("Ns instance query exception in AAI")
 102     return json.JSONDecoder().decode(ret[1])
 103
 104 def create_vnf_aai(vnf_id, data):
 105     resource = "/network/generic-vnfs/generic-vnf/%s" % vnf_id
 106     ret = call_aai(resource, "PUT", data)
 107     if ret[0] != 0:
 108         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 109         raise NSLCMException("Vnf instance creation exception in AAI")
 110     return json.JSONDecoder().decode(ret[1]), ret[2]
 111
 112 def delete_vnf_aai(vnf_id, resource_version=""):
 113     resource = "/network/generic-vnfs/generic-vnf/%s" % vnf_id
 114     if resource_version:
 115         resource = resource + "?resource-version=%s" % resource_version
 116     ret = call_aai(resource, "DELETE")
 117     if ret[0] != 0:
 118         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 119         raise NSLCMException("Vnf instance delete exception in AAI")
 120     return json.JSONDecoder().decode(ret[1])
 121
 122 def query_vnf_aai(vnf_id):
 123     resource = "/network/generic-vnfs/generic-vnf/%s?depth=all" % vnf_id
 124     ret = call_aai(resource, "GET")
 125     if ret[0] != 0:
 126         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 127         raise NSLCMException("Vnf instance query exception in AAI")
 128     return json.JSONDecoder().decode(ret[1])
 129
 130 def create_vserver_aai(cloud_owner, cloud_region_id, tenant_id, vserver_id, data):
 131     resource = "/cloud-infrastructure/cloud-regions/cloud-region/%s/" \
 132                "%s/tenants/tenant/%s/vservers/vserver/%s" % \
 133                (cloud_owner, cloud_region_id, tenant_id, vserver_id)
 134     ret = call_aai(resource, "PUT", data)
 135     if ret[0] != 0:
 136         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 137         raise NSLCMException("Vserver creation exception in AAI")
 138     return json.JSONDecoder().decode(ret[1]), ret[2]
 139
 140 def delete_vserver_aai(cloud_owner, cloud_region_id, tenant_id, vserver_id, resource_version=""):
 141     resource = "/cloud-infrastructure/cloud-regions/cloud-region/%s/" \
 142                "%s/tenants/tenant/%s/vservers/vserver/%s" % \
 143                (cloud_owner, cloud_region_id, tenant_id, vserver_id)
 144     if resource_version:
 145         resource = resource + "?resource-version=%s" % resource_version
 146     ret = call_aai(resource, "DELETE")
 147     if ret[0] != 0:
 148         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 149         raise NSLCMException("Vserver delete exception in AAI")
 150     return json.JSONDecoder().decode(ret[1])
 151
 152 def query_vserver_aai(cloud_owner, cloud_region_id, tenant_id, vserver_id):
 153     resource = "/cloud-infrastructure/cloud-regions/cloud-region/%s/" \
 154                "%s/tenants/tenant/%s/vservers/vserver/%s?depth=all" % \
 155                (cloud_owner, cloud_region_id, tenant_id, vserver_id)
 156     ret = call_aai(resource, "GET")
 157     if ret[0] != 0:
 158         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 159         raise NSLCMException("Vserver query exception in AAI")
 160     return json.JSONDecoder().decode(ret[1])
 161
 162 def put_vserver_relationship(cloud_owner, cloud_region_id, tenant_id, vserver_id, data):
 163     resource = "/cloud-infrastructure/cloud-regions/cloud-region/%s/" \
 164                "%s/tenants/tenant/%s/vservers/vserver/%s/relationship-list/relationship" % \
 165                (cloud_owner, cloud_region_id, tenant_id, vserver_id)
 166     ret = call_aai(resource, "PUT", data)
 167     if ret[0] != 0:
 168         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 169         raise NSLCMException("Put or update vserver relationship exception in AAI")
 170     return json.JSONDecoder().decode(ret[1])
 171
 172
 173 def delete_vserver_relationship(cloud_owner, cloud_region_id, tenant_id, vserver_id):
 174     resource = "/cloud-infrastructure/cloud-regions/cloud-region/%s/" \
 175                "%s/tenants/tenant/%s/vservers/vserver/%s/relationship-list/relationship" % \
 176                (cloud_owner, cloud_region_id, tenant_id, vserver_id)
 177     ret = call_aai(resource, "DELETE")
 178     if ret[0] != 0:
 179         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 180         raise NSLCMException("Delete vserver relationship exception in AAI")
 181     return json.JSONDecoder().decode(ret[1])
 182
 183
 184 def put_vnf_relationship(vnf_id, data):
 185     resource = "/network/generic-vnfs/generic-vnf/%s/relationship-list/relationship" % vnf_id
 186     ret = call_aai(resource, "PUT", data)
 187     if ret[0] != 0:
 188         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 189         raise NSLCMException("Put or update vnf instance relationship exception in AAI")
 190     return json.JSONDecoder().decode(ret[1])
 191
 192
 193 def delete_vnf_relationship(vnf_id):
 194     resource = "/network/generic-vnfs/generic-vnf/%s/relationship-list/relationship" % vnf_id
 195     ret = call_aai(resource, "DELETE")
 196     if ret[0] != 0:
 197         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 198         raise NSLCMException("Delete vnf instance relationship exception in AAI")
 199     return json.JSONDecoder().decode(ret[1])
 200
 201
 202 def put_ns_relationship(global_customer_id, service_type, service_instance_id, data):
 203     resource = "/business/customers/customer/%s/service-subscriptions/service-subscription/" \
 204                "%s/service-instances/service-instance/%s/relationship-list/relationship" % \
 205                (global_customer_id, service_type, service_instance_id)
 206     ret = call_aai(resource, "PUT", data)
 207     if ret[0] != 0:
 208         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 209         raise NSLCMException("Put or update ns instance relationship exception in AAI")
 210     return json.JSONDecoder().decode(ret[1])
 211
 212
 213 def delete_ns_relationship(global_customer_id, service_type, service_instance_id):
 214     resource = "/business/customers/customer/%s/service-subscriptions/service-subscription/" \
 215                "%s/service-instances/service-instance/%s/relationship-list/relationship" % \
 216                (global_customer_id, service_type, service_instance_id)
 217     ret = call_aai(resource, "DELETE")
 218     if ret[0] != 0:
 219         logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
 220         raise NSLCMException("Delete ns instance relationship exception in AAI")
 221     return json.JSONDecoder().decode(ret[1])