1 # Copyright 2017 ZTE Corporation.
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
7 # http://www.apache.org/licenses/LICENSE-2.0
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.
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
24 logger = logging.getLogger(__name__)
27 def call_aai(resource, method, content=''):
28 additional_headers = {
29 'X-FromAppId': 'VFC-NFVO-LCM',
30 'X-TransactionId': str(uuid.uuid1())
33 return restcall.call_req(AAI_BASE_URL,
36 restcall.rest_no_auth,
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)
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]
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")
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]
62 def delete_customer_aai(global_customer_id, resource_version=""):
63 resource = "/business/customers/customer/%s" % global_customer_id
65 resource = resource + "?resource-version=%s" % resource_version
66 ret = call_aai(resource, "DELETE")
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]
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)
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]
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")
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]
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)
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]
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")
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])
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)
120 resource = resource + "?resource-version=%s" % resource_version
121 ret = call_aai(resource, "DELETE")
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]
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)
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]
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")
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]
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)
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]
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")
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])
170 def delete_vnf_aai(vnf_id, resource_version=""):
171 resource = "/network/generic-vnfs/generic-vnf/%s" % vnf_id
173 resource = resource + "?resource-version=%s" % resource_version
174 ret = call_aai(resource, "DELETE")
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]
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)
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]
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")
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]
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)
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]
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")
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])
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)
228 resource = resource + "?resource-version=%s" % resource_version
229 ret = call_aai(resource, "DELETE")
231 logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
232 raise NSLCMException("Vserver delete exception in AAI")
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]
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)
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]
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")
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]
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)
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]
272 def query_network_aai(network_id):
273 resource = "/network/l3-networks/l3-network/%s" % network_id
274 ret = call_aai(resource, "GET")
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])
281 def delete_network_aai(network_id, resource_version=""):
282 resource = "/network/l3-networks/l3-network/%s" % network_id
284 resource = resource + "?resource-version=%s" % resource_version
285 ret = call_aai(resource, "DELETE")
287 logger.error("Status code is %s, detail is %s.", ret[2], ret[1])
288 raise NSLCMException("Network delete exception in AAI")
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]
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)
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]
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")
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]
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)
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]
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")
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])
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)
336 resource = resource + "?resource-version=%s" % resource_version
337 ret = call_aai(resource, "DELETE")
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]
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)
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]
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")
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]