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
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
# 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, SubscriptionDoesNotExistsException
from catalog.pub.exceptions import BadRequestException
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 validate_req_data(data, serializer):
serialized_data = serializer(data=data)
if not serialized_data.is_valid():
logger.error('Data validation failed.')
raise BadRequestException(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])
resp = Response(status=status.HTTP_303_SEE_OTHER, headers={'Location': e.args[0]})
# resp["Location"] = e.args[0]
return resp
except VnfPkgDuplicateSubscriptionException as e:
logger.error(e.args[0])
resp = Response(status=status.HTTP_303_SEE_OTHER, headers={'Location': e.args[0]})
# resp["Location"] = e.args[0]
return resp
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 SubscriptionDoesNotExistsException as e:
logger.error(e.args[0])
return make_error_resp(
detail=e.args[0],
status=status.HTTP_404_NOT_FOUND
)
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 CatalogException 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
|
