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
117
118
119
120
121
122
123
|
# 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 genericparser.pub.exceptions import GenericparserException
from genericparser.pub.exceptions import BadRequestException
from genericparser.pub.exceptions import NsdmBadRequestException
from genericparser.pub.exceptions import PackageNotFoundException
from genericparser.pub.exceptions import ResourceNotFoundException
from genericparser.pub.exceptions import ArtifactNotFoundException
from genericparser.pub.exceptions import NsdmDuplicateSubscriptionException
from genericparser.pub.exceptions import VnfPkgDuplicateSubscriptionException
from genericparser.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 GenericparserException(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.args[0])
return make_error_resp(
detail=e.args[0],
status=status.HTTP_303_SEE_OTHER
)
except VnfPkgDuplicateSubscriptionException as e:
logger.error(e.args[0])
return make_error_resp(
detail=e.args[0],
status=status.HTTP_303_SEE_OTHER
)
except PackageNotFoundException as e:
logger.error(e.args[0])
return make_error_resp(
detail=e.args[0],
status=status.HTTP_404_NOT_FOUND
)
except ResourceNotFoundException as e:
logger.error(e.args[0])
return make_error_resp(
detail=e.args[0],
status=status.HTTP_404_NOT_FOUND
)
except ArtifactNotFoundException as e:
logger.error(e.args[0])
return make_error_resp(
detail=e.args[0],
status=status.HTTP_404_NOT_FOUND
)
except BadRequestException as e:
logger.error(e.args[0])
return make_error_resp(
detail=e.args[0],
status=status.HTTP_400_BAD_REQUEST
)
except NsdmBadRequestException as e:
logger.error(e.args[0])
return make_error_resp(
detail=e.args[0],
status=status.HTTP_400_BAD_REQUEST
)
except VnfPkgSubscriptionException as e:
logger.error(e.args[0])
return make_error_resp(
detail=e.args[0],
status=status.HTTP_500_INTERNAL_SERVER_ERROR
)
except GenericparserException as e:
logger.error(e.args[0])
return make_error_resp(
detail=e.args[0],
status=status.HTTP_500_INTERNAL_SERVER_ERROR
)
except Exception as e:
logger.error(e.args[0])
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
|
