Yasuke/moto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

return proper status codes in range get, fix suffix range

Browse Source
This commit is contained in:
Konstantinos Koukopoulos 2015-02-10 19:14:47 +02:00
parent 9efd12c43c
commit 418a6a118e
2 changed files with 26 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
moto/s3/responses.py
View File

@ -228,25 +228,40 @@ class ResponseObject(_TemplateEnvironmentMixin):
return 200, headers, template.render(deleted=deleted_names, delete_errors=error_names)
def _handle_range_header(self, request, headers, response_content):
length = len(response_content)
_, rspec = request.headers.get('range').split('=')
if ',' in rspec:
raise NotImplementedError(
"Multiple range specifiers not supported")
toint = lambda i: int(i) if i else None
begin, end = map(toint, rspec.split('-'))
if begin is not None: # byte range
end = end or length
elif end is not None: # suffix byte range
begin = length - end
end = length
else:
return 400, headers, ""
if begin < 0 or end > length or begin > min(end, length):
return 416, headers, ""
return 206, headers, response_content[begin:end]
def key_response(self, request, full_url, headers):
try:
response = self._key_response(request, full_url, headers)
except MissingBucket:
return 404, headers, ""
begin = 0
end = None
if 'range' in request.headers:
_, rspec = request.headers.get('range').split('=')
if ',' in rspec:
raise NotImplementedError("Multiple range specifiers not supported")
begin, end = map(lambda i: int(i) if i else None, rspec.split('-'))
if isinstance(response, six.string_types):
return 200, headers, response[begin:end]
status_code = 200
response_content = response
else:
status_code, headers, response_content = response
return status_code, headers, response_content[begin:end]
if status_code == 200 and 'range' in request.headers:
return self._handle_range_header(request, headers, response_content)
return status_code, headers, response_content
def _key_response(self, request, full_url, headers):
parsed_url = urlparse(full_url)

2
tests/test_s3/test_s3.py
View File

@ -703,4 +703,4 @@ def test_ranged_get():
key.set_contents_from_string('0' * 50 + '1' * 50)
key.get_contents_as_string(headers={'Range': 'bytes=45-55'}).should.equal(b'0' * 5 + b'1' * 5)
key.get_contents_as_string(headers={'Range': 'bytes=45-'}).should.equal(b'0' * 5 + b'1' * 50)
key.get_contents_as_string(headers={'Range': 'bytes=-55'}).should.equal(b'0' * 50 + b'1' * 5)
key.get_contents_as_string(headers={'Range': 'bytes=-55'}).should.equal(b'0' * 5 + b'1' * 50)