1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
|
# Copyright 2018 ZTE Corporation.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
import traceback
import logging
from rest_framework import status
from rest_framework.response import Response
from catalog.pub.exceptions import CatalogException
from catalog.pub.exceptions import NsdmBadRequestException
from catalog.pub.exceptions import PackageNotFoundException
from catalog.pub.exceptions import ResourceNotFoundException
from catalog.pub.exceptions import ArtifactNotFoundException
from catalog.pub.exceptions import NsdmDuplicateSubscriptionException
from catalog.pub.exceptions import VnfPkgDuplicateSubscriptionException
from catalog.pub.exceptions import VnfPkgSubscriptionException
logger = logging.getLogger(__name__)
def validate_data(data, serializer):
serialized_data = serializer(data=data)
if not serialized_data.is_valid():
logger.error('Data validation failed.')
raise CatalogException(serialized_data.errors)
return serialized_data
def fmt_error_rsp(error_message, status):
return {"errorMessage": error_message, "error": status}
def make_error_resp(status, detail):
return Response(
data={
'status': status,
'detail': detail
},
status=status
)
def view_safe_call_with_log(logger):
def view_safe_call(func):
def wrapper(*args, **kwargs):
try:
return func(*args, **kwargs)
except NsdmDuplicateSubscriptionException as e:
logger.error(e.message)
return make_error_resp(
detail=e.message,
status=status.HTTP_303_SEE_OTHER
)
except VnfPkgDuplicateSubscriptionException as e:
logger.error(e.message)
return make_error_resp(
detail=e.message,
status=status.HTTP_303_SEE_OTHER
)
except PackageNotFoundException as e:
logger.error(e.message)
return make_error_resp(
detail=e.message,
status=status.HTTP_404_NOT_FOUND
)
except ResourceNotFoundException as e:
logger.error(e.message)
return make_error_resp(
detail=e.message,
status=status.HTTP_404_NOT_FOUND
)
except ArtifactNotFoundException as e:
logger.error(e.message)
return make_error_resp(
detail=e.message,
status=status.HTTP_404_NOT_FOUND
)
except NsdmBadRequestException as e:
logger.error(e.message)
return make_error_resp(
detail=e.message,
status=status.HTTP_400_BAD_REQUEST
)
except VnfPkgSubscriptionException as e:
logger.error(e.message)
return make_error_resp(
detail=e.message,
status=status.HTTP_500_INTERNAL_SERVER_ERROR
)
except CatalogException as e:
logger.error(e.message)
return make_error_resp(
detail=e.message,
status=status.HTTP_500_INTERNAL_SERVER_ERROR
)
except Exception as e:
logger.error(e.message)
logger.error(traceback.format_exc())
return make_error_resp(
detail='Unexpected exception',
status=status.HTTP_500_INTERNAL_SERVER_ERROR
)
return wrapper
return view_safe_call
|
