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 (c) 2013 Red Hat, Inc.
#
# 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 json
from oslo_utils import importutils
from zaqarclient.common import http
from zaqarclient.transport import base
from zaqarclient.transport import response
osprofiler_web = importutils.try_import("osprofiler.web")
class HttpTransport(base.Transport):
def __init__(self, options):
super(HttpTransport, self).__init__(options)
self.client = http.Client()
def _prepare(self, request):
if not request.api:
return request.endpoint, 'GET', request
# TODO(flaper87): Validate if the user
# explicitly wants so. Validation must
# happen before any other operation here.
# request.validate()
schema = {}
ref_params = {}
ref = request.ref
if request.operation:
schema = request.api.get_schema(request.operation)
ref = ref or schema.get('ref', '')
# FIXME(flaper87): We expect the endpoint
# to have the API version label already,
# however in a follow-your-nose implementation
# it should be the other way around.
ref = ref.lstrip('/' + request.api.label)
for param in list(request.params.keys()):
if '{{{0}}}'.format(param) in ref:
value = request.params.pop(param)
# NOTE(flaper87): Zaqar API parses
# sequences encoded as '1,2,3,4'. Let's
# encode lists, tuples and sets before
# sending them to the server.
if isinstance(value, (list, tuple, set)):
value = ','.join(value)
ref_params[param] = value
url = '{0}/{1}/{2}'.format(request.endpoint.rstrip('/'),
request.api.label,
ref.format(**ref_params))
return url, schema.get('method', 'GET'), request
def send(self, request):
url, method, request = self._prepare(request)
# NOTE(flape87): Do not modify
# request's headers directly.
headers = request.headers.copy()
if request.operation == 'queue_update':
headers['content-type'] = \
'application/openstack-messaging-v2.0-json-patch'
else:
headers['content-type'] = 'application/json'
if osprofiler_web:
headers.update(osprofiler_web.get_trace_id_headers())
if request.verify:
if request.cert:
verify = request.cert
else:
verify = True
else:
verify = False
resp = self.client.request(method,
url=url,
params=request.params,
headers=headers,
data=request.content,
verify=verify)
if resp.status_code in self.http_to_zaqar:
kwargs = {}
try:
error_body = json.loads(resp.text)
kwargs['title'] = error_body['title']
kwargs['description'] = error_body['description']
except Exception:
# TODO(flaper87): Log this exception
# but don't stop raising the corresponding
# exception
# Note(Eva-i): most of the error responses from Zaqar have
# dict with title and description in their bodies. If it's not
# the case, let's just show body text.
kwargs['text'] = resp.text
raise self.http_to_zaqar[resp.status_code](**kwargs)
# NOTE(flaper87): This reads the whole content
# and will consume any attempt of streaming.
return response.Response(request, resp.text,
headers=resp.headers,
status_code=resp.status_code)
|
