Remove unused code.
This commit is contained in:
parent
1c42a5ef4e
commit
0712026e14
|
@ -363,89 +363,3 @@ class ASGIApp:
|
||||||
Handle the incoming request.
|
Handle the incoming request.
|
||||||
"""
|
"""
|
||||||
await self.sanic_app.handle_request(self.request)
|
await self.sanic_app.handle_request(self.request)
|
||||||
|
|
||||||
async def stream_callback(self, response: HTTPResponse) -> None:
|
|
||||||
"""
|
|
||||||
Write the response.
|
|
||||||
"""
|
|
||||||
headers: List[Tuple[bytes, bytes]] = []
|
|
||||||
cookies: Dict[str, str] = {}
|
|
||||||
try:
|
|
||||||
cookies = {
|
|
||||||
v.key: v
|
|
||||||
for _, v in list(
|
|
||||||
filter(
|
|
||||||
lambda item: item[0].lower() == "set-cookie",
|
|
||||||
response.headers.items(),
|
|
||||||
)
|
|
||||||
)
|
|
||||||
}
|
|
||||||
headers += [
|
|
||||||
(str(name).encode("latin-1"), str(value).encode("latin-1"))
|
|
||||||
for name, value in response.headers.items()
|
|
||||||
if name.lower() not in ["set-cookie"]
|
|
||||||
]
|
|
||||||
except AttributeError:
|
|
||||||
logger.error(
|
|
||||||
"Invalid response object for url %s, "
|
|
||||||
"Expected Type: HTTPResponse, Actual Type: %s",
|
|
||||||
self.request.url,
|
|
||||||
type(response),
|
|
||||||
)
|
|
||||||
exception = ServerError("Invalid response type")
|
|
||||||
response = self.sanic_app.error_handler.response(
|
|
||||||
self.request, exception
|
|
||||||
)
|
|
||||||
headers = [
|
|
||||||
(str(name).encode("latin-1"), str(value).encode("latin-1"))
|
|
||||||
for name, value in response.headers.items()
|
|
||||||
if name not in (b"Set-Cookie",)
|
|
||||||
]
|
|
||||||
|
|
||||||
if "content-length" not in response.headers and not isinstance(
|
|
||||||
response, StreamingHTTPResponse
|
|
||||||
):
|
|
||||||
headers += [
|
|
||||||
(b"content-length", str(len(response.body)).encode("latin-1"))
|
|
||||||
]
|
|
||||||
|
|
||||||
if "content-type" not in response.headers:
|
|
||||||
headers += [
|
|
||||||
(b"content-type", str(response.content_type).encode("latin-1"))
|
|
||||||
]
|
|
||||||
|
|
||||||
if response.cookies:
|
|
||||||
cookies.update(
|
|
||||||
{
|
|
||||||
v.key: v
|
|
||||||
for _, v in response.cookies.items()
|
|
||||||
if v.key not in cookies.keys()
|
|
||||||
}
|
|
||||||
)
|
|
||||||
|
|
||||||
headers += [
|
|
||||||
(b"set-cookie", cookie.encode("utf-8"))
|
|
||||||
for k, cookie in cookies.items()
|
|
||||||
]
|
|
||||||
|
|
||||||
await self.transport.send(
|
|
||||||
{
|
|
||||||
"type": "http.response.start",
|
|
||||||
"status": response.status,
|
|
||||||
"headers": headers,
|
|
||||||
}
|
|
||||||
)
|
|
||||||
|
|
||||||
if isinstance(response, StreamingHTTPResponse):
|
|
||||||
response.protocol = self.transport.get_protocol()
|
|
||||||
await response.stream()
|
|
||||||
await response.protocol.complete()
|
|
||||||
|
|
||||||
else:
|
|
||||||
await self.transport.send(
|
|
||||||
{
|
|
||||||
"type": "http.response.body",
|
|
||||||
"body": response.body,
|
|
||||||
"more_body": False,
|
|
||||||
}
|
|
||||||
)
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user