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.
18 from drf_yasg import openapi
19 from drf_yasg.utils import no_body, swagger_auto_schema
20 from rest_framework import status
21 from rest_framework.decorators import api_view
22 from rest_framework.response import Response
24 from catalog.jobs.views import CATALOG_API
25 from catalog.packages.biz import sdc_vnf_package, sdc_ns_package
26 from catalog.packages.biz.pnf_descriptor import PnfDescriptor
27 from catalog.packages.biz.sdc_service_package import ServicePackage
28 from catalog.packages.const import TAG_PARSER_API
29 from catalog.packages.serializers.catalog_serializers import InternalErrorRequestSerializer, \
30 ServicePackageDistributeRequestSerializer, ServicePackagesSerializer, ServicePackageSerializer
31 from catalog.packages.serializers.catalog_serializers import NfPackageDistributeRequestSerializer
32 from catalog.packages.serializers.catalog_serializers import NfPackageSerializer
33 from catalog.packages.serializers.catalog_serializers import NfPackagesSerializer
34 from catalog.packages.serializers.catalog_serializers import NsPackageDistributeRequestSerializer
35 from catalog.packages.serializers.catalog_serializers import NsPackageDistributeResponseSerializer
36 from catalog.packages.serializers.catalog_serializers import NsPackageSerializer
37 from catalog.packages.serializers.catalog_serializers import NsPackagesSerializer
38 from catalog.packages.serializers.catalog_serializers import ParseModelRequestSerializer
39 from catalog.packages.serializers.catalog_serializers import ParseModelResponseSerializer
40 from catalog.packages.serializers.catalog_serializers import PostJobResponseSerializer
41 from catalog.packages.views.common import fmt_error_rsp
42 from catalog.pub.exceptions import PackageNotFoundException, PackageHasExistsException
43 from catalog.pub.utils.syscomm import fun_name
44 from catalog.pub.utils.values import ignore_case_get
46 logger = logging.getLogger(__name__)
51 operation_description="On distribute NS package",
53 request_body=NsPackageDistributeRequestSerializer,
55 status.HTTP_202_ACCEPTED: NsPackageDistributeResponseSerializer,
56 status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
59 operation_description="Query NS packages",
63 status.HTTP_200_OK: NsPackagesSerializer,
64 status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
65 @api_view(http_method_names=['POST', 'GET'])
66 def nspackages_rc(request, *args, **kwargs):
67 logger.debug("Enter %s, method is %s", fun_name(), request.method)
68 ret, normal_status, response_serializer, validation_error = None, None, None, None
70 if request.method == 'GET':
71 # Gets ns package list
72 ret = sdc_ns_package.ns_get_csars()
73 normal_status = status.HTTP_200_OK
76 response_serializer = NsPackagesSerializer(data=ret[1])
77 validation_error = handleValidatonError(
78 response_serializer, False)
80 return validation_error
81 elif request.method == 'POST':
82 # Distributes the package accroding to the given csarId
83 request_serializer = NsPackageDistributeRequestSerializer(data=request.data)
84 validation_error = handleValidatonError(request_serializer, True)
86 return validation_error
88 csar_id = ignore_case_get(request.data, "csarId")
89 logger.debug("csar_id is %s", csar_id)
90 ret = sdc_ns_package.ns_on_distribute(csar_id)
91 normal_status = status.HTTP_202_ACCEPTED
93 logger.debug("Leave %s, Return value is %s", fun_name(), ret)
98 status=status.HTTP_500_INTERNAL_SERVER_ERROR)
100 return Response(data=ret[1], status=normal_status)
103 @swagger_auto_schema(
105 operation_description="On distribute Nf package",
107 request_body=NfPackageDistributeRequestSerializer(),
109 status.HTTP_202_ACCEPTED: PostJobResponseSerializer,
110 status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
111 @swagger_auto_schema(
113 operation_description="Query Nf packages",
115 request_body=no_body,
117 status.HTTP_200_OK: NfPackagesSerializer,
118 status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
119 @api_view(http_method_names=['POST', 'GET'])
120 def nfpackages_rc(request, *args, **kwargs):
122 "Enter %s%s, method is %s",
126 ret, normal_status, response_serializer, validation_error = None, None, None, None
127 if request.method == 'GET':
128 ret = sdc_vnf_package.nf_get_csars()
129 normal_status = status.HTTP_200_OK
130 response_serializer = NfPackagesSerializer(data=ret[1])
131 elif request.method == 'POST':
132 request_serivalizer = NfPackageDistributeRequestSerializer(
134 validation_error = handleValidatonError(
135 request_serivalizer, True)
137 return validation_error
139 csar_id = ignore_case_get(request_serivalizer.data, "csarId")
140 vim_ids = ignore_case_get(request_serivalizer.data, "vimIds")
141 lab_vim_id = ignore_case_get(request_serivalizer.data, "labVimId")
142 job_id = str(uuid.uuid4())
143 sdc_vnf_package.NfDistributeThread(
144 csar_id, vim_ids, lab_vim_id, job_id).start()
145 ret = [0, {"jobId": job_id}]
146 normal_status = status.HTTP_202_ACCEPTED
148 response_serializer = PostJobResponseSerializer(data=ret[1])
149 logger.debug("Leave %s, Return value is %s", fun_name(), ret)
155 status=status.HTTP_500_INTERNAL_SERVER_ERROR)
157 validation_error = handleValidatonError(
158 response_serializer, False)
160 return validation_error
162 return Response(data=response_serializer.data, status=normal_status)
165 @swagger_auto_schema(
167 operation_description="Delete one NS package",
169 request_body=no_body,
175 type=openapi.TYPE_STRING)],
177 status.HTTP_200_OK: NsPackageDistributeResponseSerializer,
178 status.HTTP_500_INTERNAL_SERVER_ERROR: openapi.Response(
181 type=openapi.TYPE_STRING))})
182 @swagger_auto_schema(
184 operation_description="Query one NS package",
186 request_body=no_body,
192 type=openapi.TYPE_STRING)],
194 status.HTTP_200_OK: NsPackageSerializer,
195 status.HTTP_500_INTERNAL_SERVER_ERROR: openapi.Response(
198 type=openapi.TYPE_STRING))})
199 @api_view(http_method_names=['DELETE', 'GET'])
200 def ns_rd_csar(request, *args, **kwargs):
201 csar_id = ignore_case_get(kwargs, "csarId")
202 logger.info("Enter %s, method is %s, csar_id is %s",
203 fun_name(), request.method, csar_id)
204 ret, normal_status, response_serializer, validation_error = None, None, None, None
205 if request.method == 'GET':
206 ret = sdc_ns_package.ns_get_csar(csar_id)
207 normal_status = status.HTTP_200_OK
209 response_serializer = NsPackageSerializer(data=ret[1])
210 validation_error = handleValidatonError(response_serializer, False)
212 return validation_error
213 elif request.method == 'DELETE':
214 ret = sdc_ns_package.ns_delete_csar(csar_id)
215 normal_status = status.HTTP_200_OK
216 logger.info("Leave %s, Return value is %s", fun_name(), ret)
221 status=status.HTTP_500_INTERNAL_SERVER_ERROR)
222 return Response(data=ret[1], status=normal_status)
225 @swagger_auto_schema(
227 operation_description="On distribute Service package",
229 request_body=ServicePackageDistributeRequestSerializer,
231 status.HTTP_202_ACCEPTED: "",
232 status.HTTP_400_BAD_REQUEST: InternalErrorRequestSerializer,
233 status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
234 @swagger_auto_schema(
236 operation_description="Query Service packages",
238 request_body=no_body,
240 status.HTTP_200_OK: ServicePackagesSerializer,
241 status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
242 @api_view(http_method_names=['POST', 'GET'])
243 def servicepackages_rc(request, *args, **kwargs):
244 logger.debug("Enter %s, method is %s", fun_name(), request.method)
246 if request.method == 'GET':
247 # Gets service package list
249 csar_list = ServicePackage().get_csars()
250 response_serializer = ServicePackagesSerializer(data=csar_list)
251 validation_error = handleValidatonError(response_serializer, False)
253 return validation_error
254 return Response(data=csar_list, status=status.HTTP_200_OK)
255 except Exception as e:
256 error_status = status.HTTP_500_INTERNAL_SERVER_ERROR
257 return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
258 elif request.method == 'POST':
259 # Distributes the package according to the given csarId
260 request_serializer = ServicePackageDistributeRequestSerializer(data=request.data)
261 validation_error = handleValidatonError(request_serializer, True)
263 return validation_error
265 csar_id = ignore_case_get(request.data, "csarId")
266 logger.debug("csar_id is %s", csar_id)
268 ServicePackage().on_distribute(csar_id)
269 return Response(status=status.HTTP_202_ACCEPTED)
270 except PackageHasExistsException as e:
271 error_status = status.HTTP_400_BAD_REQUEST
272 return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
273 except Exception as e:
274 error_status = status.HTTP_500_INTERNAL_SERVER_ERROR
275 return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
278 @swagger_auto_schema(
280 operation_description="Delete one Service package",
282 request_body=no_body,
288 type=openapi.TYPE_STRING)],
290 status.HTTP_204_NO_CONTENT: "",
291 status.HTTP_404_NOT_FOUND: InternalErrorRequestSerializer,
292 status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
293 @swagger_auto_schema(
295 operation_description="Query one Service package",
297 request_body=no_body,
303 type=openapi.TYPE_STRING)],
305 status.HTTP_200_OK: ServicePackageSerializer,
306 status.HTTP_404_NOT_FOUND: InternalErrorRequestSerializer,
307 status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
308 @api_view(http_method_names=['DELETE', 'GET'])
309 def service_rd_csar(request, *args, **kwargs):
310 csar_id = ignore_case_get(kwargs, "csarId")
311 logger.info("Enter %s, method is %s, csar_id is %s", fun_name(), request.method, csar_id)
313 if request.method == 'GET':
315 ret = ServicePackage().get_csar(csar_id)
316 response_serializer = ServicePackageSerializer(data=ret)
317 validation_error = handleValidatonError(response_serializer, False)
319 return validation_error
320 return Response(data=ret, status=status.HTTP_200_OK)
321 except PackageNotFoundException as e:
322 error_status = status.HTTP_404_NOT_FOUND
323 return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
324 except Exception as e:
325 error_status = status.HTTP_500_INTERNAL_SERVER_ERROR
326 return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
328 elif request.method == 'DELETE':
330 ServicePackage().delete_csar(csar_id)
331 return Response(status=status.HTTP_204_NO_CONTENT)
332 except PackageNotFoundException as e:
333 error_status = status.HTTP_404_NOT_FOUND
334 return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
335 except Exception as e:
336 error_status = status.HTTP_500_INTERNAL_SERVER_ERROR
337 return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
340 @swagger_auto_schema(
342 operation_description="Delete one Nf package",
344 request_body=no_body,
350 type=openapi.TYPE_STRING)],
352 status.HTTP_202_ACCEPTED: PostJobResponseSerializer,
353 status.HTTP_500_INTERNAL_SERVER_ERROR: openapi.Response(
356 type=openapi.TYPE_STRING))})
357 @swagger_auto_schema(
359 operation_description="Query one Nf package",
361 request_body=no_body,
367 type=openapi.TYPE_STRING)],
369 status.HTTP_200_OK: NfPackageSerializer,
370 status.HTTP_500_INTERNAL_SERVER_ERROR: openapi.Response(
373 type=openapi.TYPE_STRING))})
374 @api_view(http_method_names=['DELETE', 'GET'])
375 def nf_rd_csar(request, *args, **kwargs):
376 csar_id = ignore_case_get(kwargs, "csarId")
377 logger.info("Enter %s, method is %s, csar_id is %s",
378 fun_name(), request.method, csar_id)
379 ret, normal_status, response_serializer, validation_error = None, None, None, None
381 if request.method == 'GET':
382 ret = sdc_vnf_package.nf_get_csar(csar_id)
383 normal_status = status.HTTP_200_OK
384 response_serializer = NfPackageSerializer(data=ret[1])
386 elif request.method == 'DELETE':
387 job_id = str(uuid.uuid4())
388 sdc_vnf_package.NfPkgDeleteThread(csar_id, job_id).start()
389 ret = [0, {"jobId": job_id}]
390 normal_status = status.HTTP_202_ACCEPTED
391 response_serializer = PostJobResponseSerializer(data=ret[1])
393 logger.info("Leave %s, Return value is %s", fun_name(), ret)
398 status=status.HTTP_500_INTERNAL_SERVER_ERROR)
400 validation_error = handleValidatonError(
401 response_serializer, False)
403 return validation_error
405 return Response(data=response_serializer.data, status=normal_status)
408 @swagger_auto_schema(
410 operation_description="Parse model(NS, Service, VNF, PNF)",
411 tags=[TAG_PARSER_API],
412 request_body=ParseModelRequestSerializer,
414 status.HTTP_202_ACCEPTED: ParseModelResponseSerializer,
415 status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
416 @api_view(http_method_names=['POST'])
417 def model_parser(request, *args, **kwargs):
418 csar_id = ignore_case_get(request.data, "csarId")
419 package_type = ignore_case_get(request.data, "packageType")
420 inputs = ignore_case_get(request.data, "inputs")
422 "Enter %s, csar_id=%s, package_type=%s, inputs=%s",
428 if package_type.lower().__eq__("service"):
430 ret = ServicePackage().parse_serviced(csar_id, inputs)
431 response_serializer = ParseModelResponseSerializer(data=ret)
432 validation_error = handleValidatonError(
433 response_serializer, False)
435 return validation_error
436 return Response(data=response_serializer.data, status=status.HTTP_202_ACCEPTED)
437 except PackageNotFoundException as e:
438 error_status = status.HTTP_404_NOT_FOUND
439 return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
440 except Exception as e:
441 error_status = status.HTTP_500_INTERNAL_SERVER_ERROR
442 return Response(data=fmt_error_rsp(e.args[0], error_status), status=error_status)
443 elif package_type.lower().__eq__("ns"):
444 ret = sdc_ns_package.parse_nsd(csar_id, inputs)
445 elif package_type.lower().__eq__("vnf"):
446 ret = sdc_vnf_package.parse_vnfd(csar_id, inputs)
447 elif package_type.lower().__eq__("pnf"):
448 ret = PnfDescriptor().parse_pnfd(csar_id, inputs)
450 error_status = status.HTTP_400_BAD_REQUEST
451 error_message = "Invalid package type, it should be one of [VNF, PNF, NS, Service]"
452 return Response(data=fmt_error_rsp(error_message, error_status), status=error_status)
458 status=status.HTTP_500_INTERNAL_SERVER_ERROR)
460 response_serializer = ParseModelResponseSerializer(data=ret[1])
461 validation_error = handleValidatonError(
462 response_serializer, False)
464 return validation_error
466 return Response(data=response_serializer.data, status=status.HTTP_202_ACCEPTED)
469 @swagger_auto_schema(
471 operation_description="Parse NS model",
472 tags=[TAG_PARSER_API],
473 request_body=ParseModelRequestSerializer,
475 status.HTTP_202_ACCEPTED: ParseModelResponseSerializer,
476 status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
477 @api_view(http_method_names=['POST'])
478 def ns_model_parser(request, *args, **kwargs):
479 csar_id = ignore_case_get(request.data, "csarId")
480 inputs = ignore_case_get(request.data, "inputs")
482 "Enter %s, csar_id=%s, inputs=%s",
486 ret = sdc_ns_package.parse_nsd(csar_id, inputs)
487 logger.info("Leave %s, Return value is %s", fun_name(), ret)
492 status=status.HTTP_500_INTERNAL_SERVER_ERROR)
494 response_serializer = ParseModelResponseSerializer(data=ret[1])
495 validation_error = handleValidatonError(
496 response_serializer, False)
498 return validation_error
500 return Response(data=response_serializer.data, status=status.HTTP_202_ACCEPTED)
503 @swagger_auto_schema(
505 operation_description="Parse NF model",
506 tags=[TAG_PARSER_API],
507 request_body=ParseModelRequestSerializer,
509 status.HTTP_202_ACCEPTED: ParseModelResponseSerializer,
510 status.HTTP_500_INTERNAL_SERVER_ERROR: InternalErrorRequestSerializer})
511 @api_view(http_method_names=['POST'])
512 def vnf_model_parser(request, *args, **kwargs):
513 csar_id = ignore_case_get(request.data, "csarId")
514 inputs = ignore_case_get(request.data, "inputs")
516 "Enter %s, csar_id=%s, inputs=%s",
520 ret = sdc_vnf_package.parse_vnfd(csar_id, inputs)
521 logger.info("Leave %s, Return value is %s", fun_name(), ret)
526 status=status.HTTP_500_INTERNAL_SERVER_ERROR)
528 response_serializer = ParseModelResponseSerializer(data=ret[1])
529 validation_error = handleValidatonError(
530 response_serializer, False)
532 return validation_error
534 return Response(data=response_serializer.data, status=status.HTTP_202_ACCEPTED)
537 def handleValidatonError(base_serializer, is_request):
540 if not base_serializer.is_valid():
541 errormessage = base_serializer.errors
542 logger.error(errormessage)
545 message = 'Invalid request'
547 message = 'Invalid response'
548 logger.error(message)
550 data={'error': errormessage},
551 status=status.HTTP_500_INTERNAL_SERVER_ERROR)