Merge pull request #1113 from arnulfojr/bugfix/content-length-header-on-X04
Content Length header on 204 and 304 responses
This commit is contained in:
commit
8b920d9d56
|
@ -72,6 +72,8 @@ STATUS_CODES = {
|
||||||
511: b'Network Authentication Required'
|
511: b'Network Authentication Required'
|
||||||
}
|
}
|
||||||
|
|
||||||
|
EMPTY_STATUS_CODES = [204, 304]
|
||||||
|
|
||||||
|
|
||||||
class BaseHTTPResponse:
|
class BaseHTTPResponse:
|
||||||
def _encode_body(self, data):
|
def _encode_body(self, data):
|
||||||
|
@ -195,8 +197,14 @@ class HTTPResponse(BaseHTTPResponse):
|
||||||
timeout_header = b''
|
timeout_header = b''
|
||||||
if keep_alive and keep_alive_timeout is not None:
|
if keep_alive and keep_alive_timeout is not None:
|
||||||
timeout_header = b'Keep-Alive: %d\r\n' % keep_alive_timeout
|
timeout_header = b'Keep-Alive: %d\r\n' % keep_alive_timeout
|
||||||
self.headers['Content-Length'] = self.headers.get(
|
|
||||||
'Content-Length', len(self.body))
|
body = b''
|
||||||
|
content_length = 0
|
||||||
|
if self.status not in EMPTY_STATUS_CODES:
|
||||||
|
body = self.body
|
||||||
|
content_length = self.headers.get('Content-Length', len(self.body))
|
||||||
|
|
||||||
|
self.headers['Content-Length'] = content_length
|
||||||
self.headers['Content-Type'] = self.headers.get(
|
self.headers['Content-Type'] = self.headers.get(
|
||||||
'Content-Type', self.content_type)
|
'Content-Type', self.content_type)
|
||||||
|
|
||||||
|
@ -218,7 +226,7 @@ class HTTPResponse(BaseHTTPResponse):
|
||||||
b'keep-alive' if keep_alive else b'close',
|
b'keep-alive' if keep_alive else b'close',
|
||||||
timeout_header,
|
timeout_header,
|
||||||
headers,
|
headers,
|
||||||
self.body
|
body
|
||||||
)
|
)
|
||||||
|
|
||||||
@property
|
@property
|
||||||
|
|
|
@ -104,18 +104,20 @@ def test_json():
|
||||||
|
|
||||||
assert results.get('test') == True
|
assert results.get('test') == True
|
||||||
|
|
||||||
|
|
||||||
def test_empty_json():
|
def test_empty_json():
|
||||||
app = Sanic('test_json')
|
app = Sanic('test_json')
|
||||||
|
|
||||||
@app.route('/')
|
@app.route('/')
|
||||||
async def handler(request):
|
async def handler(request):
|
||||||
assert request.json == None
|
assert request.json is None
|
||||||
return json(request.json)
|
return json(request.json)
|
||||||
|
|
||||||
request, response = app.test_client.get('/')
|
request, response = app.test_client.get('/')
|
||||||
assert response.status == 200
|
assert response.status == 200
|
||||||
assert response.text == 'null'
|
assert response.text == 'null'
|
||||||
|
|
||||||
|
|
||||||
def test_invalid_json():
|
def test_invalid_json():
|
||||||
app = Sanic('test_json')
|
app = Sanic('test_json')
|
||||||
|
|
||||||
|
|
|
@ -16,7 +16,6 @@ from unittest.mock import MagicMock
|
||||||
JSON_DATA = {'ok': True}
|
JSON_DATA = {'ok': True}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
def test_response_body_not_a_string():
|
def test_response_body_not_a_string():
|
||||||
"""Test when a response body sent from the application is not a string"""
|
"""Test when a response body sent from the application is not a string"""
|
||||||
app = Sanic('response_body_not_a_string')
|
app = Sanic('response_body_not_a_string')
|
||||||
|
@ -35,6 +34,7 @@ async def sample_streaming_fn(response):
|
||||||
await asyncio.sleep(.001)
|
await asyncio.sleep(.001)
|
||||||
response.write('bar')
|
response.write('bar')
|
||||||
|
|
||||||
|
|
||||||
def test_method_not_allowed():
|
def test_method_not_allowed():
|
||||||
app = Sanic('method_not_allowed')
|
app = Sanic('method_not_allowed')
|
||||||
|
|
||||||
|
@ -43,7 +43,7 @@ def test_method_not_allowed():
|
||||||
return response.json({'hello': 'world'})
|
return response.json({'hello': 'world'})
|
||||||
|
|
||||||
request, response = app.test_client.head('/')
|
request, response = app.test_client.head('/')
|
||||||
assert response.headers['Allow']== 'GET'
|
assert response.headers['Allow'] == 'GET'
|
||||||
|
|
||||||
@app.post('/')
|
@app.post('/')
|
||||||
async def test(request):
|
async def test(request):
|
||||||
|
@ -63,6 +63,22 @@ def json_app():
|
||||||
async def test(request):
|
async def test(request):
|
||||||
return json(JSON_DATA)
|
return json(JSON_DATA)
|
||||||
|
|
||||||
|
@app.get("/no-content")
|
||||||
|
async def no_content_handler(request):
|
||||||
|
return json(JSON_DATA, status=204)
|
||||||
|
|
||||||
|
@app.get("/no-content/unmodified")
|
||||||
|
async def no_content_unmodified_handler(request):
|
||||||
|
return json(None, status=304)
|
||||||
|
|
||||||
|
@app.get("/unmodified")
|
||||||
|
async def unmodified_handler(request):
|
||||||
|
return json(JSON_DATA, status=304)
|
||||||
|
|
||||||
|
@app.delete("/")
|
||||||
|
async def delete_handler(request):
|
||||||
|
return json(None, status=204)
|
||||||
|
|
||||||
return app
|
return app
|
||||||
|
|
||||||
|
|
||||||
|
@ -73,6 +89,29 @@ def test_json_response(json_app):
|
||||||
assert response.text == json_dumps(JSON_DATA)
|
assert response.text == json_dumps(JSON_DATA)
|
||||||
assert response.json == JSON_DATA
|
assert response.json == JSON_DATA
|
||||||
|
|
||||||
|
|
||||||
|
def test_no_content(json_app):
|
||||||
|
request, response = json_app.test_client.get('/no-content')
|
||||||
|
assert response.status == 204
|
||||||
|
assert response.text == ''
|
||||||
|
assert response.headers['Content-Length'] == '0'
|
||||||
|
|
||||||
|
request, response = json_app.test_client.get('/no-content/unmodified')
|
||||||
|
assert response.status == 304
|
||||||
|
assert response.text == ''
|
||||||
|
assert response.headers['Content-Length'] == '0'
|
||||||
|
|
||||||
|
request, response = json_app.test_client.get('/unmodified')
|
||||||
|
assert response.status == 304
|
||||||
|
assert response.text == ''
|
||||||
|
assert response.headers['Content-Length'] == '0'
|
||||||
|
|
||||||
|
request, response = json_app.test_client.delete('/')
|
||||||
|
assert response.status == 204
|
||||||
|
assert response.text == ''
|
||||||
|
assert response.headers['Content-Length'] == '0'
|
||||||
|
|
||||||
|
|
||||||
@pytest.fixture
|
@pytest.fixture
|
||||||
def streaming_app():
|
def streaming_app():
|
||||||
app = Sanic('streaming')
|
app = Sanic('streaming')
|
||||||
|
@ -156,9 +195,11 @@ def get_file_content(static_file_directory, file_name):
|
||||||
with open(os.path.join(static_file_directory, file_name), 'rb') as file:
|
with open(os.path.join(static_file_directory, file_name), 'rb') as file:
|
||||||
return file.read()
|
return file.read()
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.parametrize('file_name', ['test.file', 'decode me.txt', 'python.png'])
|
@pytest.mark.parametrize('file_name', ['test.file', 'decode me.txt', 'python.png'])
|
||||||
def test_file_response(file_name, static_file_directory):
|
def test_file_response(file_name, static_file_directory):
|
||||||
app = Sanic('test_file_helper')
|
app = Sanic('test_file_helper')
|
||||||
|
|
||||||
@app.route('/files/<filename>', methods=['GET'])
|
@app.route('/files/<filename>', methods=['GET'])
|
||||||
def file_route(request, filename):
|
def file_route(request, filename):
|
||||||
file_path = os.path.join(static_file_directory, filename)
|
file_path = os.path.join(static_file_directory, filename)
|
||||||
|
@ -170,10 +211,12 @@ def test_file_response(file_name, static_file_directory):
|
||||||
assert response.body == get_file_content(static_file_directory, file_name)
|
assert response.body == get_file_content(static_file_directory, file_name)
|
||||||
assert 'Content-Disposition' not in response.headers
|
assert 'Content-Disposition' not in response.headers
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.parametrize('source,dest', [
|
@pytest.mark.parametrize('source,dest', [
|
||||||
('test.file', 'my_file.txt'), ('decode me.txt', 'readme.md'), ('python.png', 'logo.png')])
|
('test.file', 'my_file.txt'), ('decode me.txt', 'readme.md'), ('python.png', 'logo.png')])
|
||||||
def test_file_response_custom_filename(source, dest, static_file_directory):
|
def test_file_response_custom_filename(source, dest, static_file_directory):
|
||||||
app = Sanic('test_file_helper')
|
app = Sanic('test_file_helper')
|
||||||
|
|
||||||
@app.route('/files/<filename>', methods=['GET'])
|
@app.route('/files/<filename>', methods=['GET'])
|
||||||
def file_route(request, filename):
|
def file_route(request, filename):
|
||||||
file_path = os.path.join(static_file_directory, filename)
|
file_path = os.path.join(static_file_directory, filename)
|
||||||
|
@ -185,9 +228,11 @@ def test_file_response_custom_filename(source, dest, static_file_directory):
|
||||||
assert response.body == get_file_content(static_file_directory, source)
|
assert response.body == get_file_content(static_file_directory, source)
|
||||||
assert response.headers['Content-Disposition'] == 'attachment; filename="{}"'.format(dest)
|
assert response.headers['Content-Disposition'] == 'attachment; filename="{}"'.format(dest)
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.parametrize('file_name', ['test.file', 'decode me.txt'])
|
@pytest.mark.parametrize('file_name', ['test.file', 'decode me.txt'])
|
||||||
def test_file_head_response(file_name, static_file_directory):
|
def test_file_head_response(file_name, static_file_directory):
|
||||||
app = Sanic('test_file_helper')
|
app = Sanic('test_file_helper')
|
||||||
|
|
||||||
@app.route('/files/<filename>', methods=['GET', 'HEAD'])
|
@app.route('/files/<filename>', methods=['GET', 'HEAD'])
|
||||||
async def file_route(request, filename):
|
async def file_route(request, filename):
|
||||||
file_path = os.path.join(static_file_directory, filename)
|
file_path = os.path.join(static_file_directory, filename)
|
||||||
|
@ -212,9 +257,11 @@ def test_file_head_response(file_name, static_file_directory):
|
||||||
'Content-Length']) == len(
|
'Content-Length']) == len(
|
||||||
get_file_content(static_file_directory, file_name))
|
get_file_content(static_file_directory, file_name))
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.parametrize('file_name', ['test.file', 'decode me.txt', 'python.png'])
|
@pytest.mark.parametrize('file_name', ['test.file', 'decode me.txt', 'python.png'])
|
||||||
def test_file_stream_response(file_name, static_file_directory):
|
def test_file_stream_response(file_name, static_file_directory):
|
||||||
app = Sanic('test_file_helper')
|
app = Sanic('test_file_helper')
|
||||||
|
|
||||||
@app.route('/files/<filename>', methods=['GET'])
|
@app.route('/files/<filename>', methods=['GET'])
|
||||||
def file_route(request, filename):
|
def file_route(request, filename):
|
||||||
file_path = os.path.join(static_file_directory, filename)
|
file_path = os.path.join(static_file_directory, filename)
|
||||||
|
@ -227,10 +274,12 @@ def test_file_stream_response(file_name, static_file_directory):
|
||||||
assert response.body == get_file_content(static_file_directory, file_name)
|
assert response.body == get_file_content(static_file_directory, file_name)
|
||||||
assert 'Content-Disposition' not in response.headers
|
assert 'Content-Disposition' not in response.headers
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.parametrize('source,dest', [
|
@pytest.mark.parametrize('source,dest', [
|
||||||
('test.file', 'my_file.txt'), ('decode me.txt', 'readme.md'), ('python.png', 'logo.png')])
|
('test.file', 'my_file.txt'), ('decode me.txt', 'readme.md'), ('python.png', 'logo.png')])
|
||||||
def test_file_stream_response_custom_filename(source, dest, static_file_directory):
|
def test_file_stream_response_custom_filename(source, dest, static_file_directory):
|
||||||
app = Sanic('test_file_helper')
|
app = Sanic('test_file_helper')
|
||||||
|
|
||||||
@app.route('/files/<filename>', methods=['GET'])
|
@app.route('/files/<filename>', methods=['GET'])
|
||||||
def file_route(request, filename):
|
def file_route(request, filename):
|
||||||
file_path = os.path.join(static_file_directory, filename)
|
file_path = os.path.join(static_file_directory, filename)
|
||||||
|
@ -242,9 +291,11 @@ def test_file_stream_response_custom_filename(source, dest, static_file_director
|
||||||
assert response.body == get_file_content(static_file_directory, source)
|
assert response.body == get_file_content(static_file_directory, source)
|
||||||
assert response.headers['Content-Disposition'] == 'attachment; filename="{}"'.format(dest)
|
assert response.headers['Content-Disposition'] == 'attachment; filename="{}"'.format(dest)
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.parametrize('file_name', ['test.file', 'decode me.txt'])
|
@pytest.mark.parametrize('file_name', ['test.file', 'decode me.txt'])
|
||||||
def test_file_stream_head_response(file_name, static_file_directory):
|
def test_file_stream_head_response(file_name, static_file_directory):
|
||||||
app = Sanic('test_file_helper')
|
app = Sanic('test_file_helper')
|
||||||
|
|
||||||
@app.route('/files/<filename>', methods=['GET', 'HEAD'])
|
@app.route('/files/<filename>', methods=['GET', 'HEAD'])
|
||||||
async def file_route(request, filename):
|
async def file_route(request, filename):
|
||||||
file_path = os.path.join(static_file_directory, filename)
|
file_path = os.path.join(static_file_directory, filename)
|
||||||
|
|
Loading…
Reference in New Issue
Block a user