asgi: get valid/invalid http tests to pass

* change asgi HTTP error exceptions to match base sync worker
* use StopAsyncIteration in async def
* override config in cases tests/test_asgi.py::MockConfig has non-default

Author: pajod

gunicorn/asgi/message.py

@@ -16,6 +16,7 @@
 
 from gunicorn.http.errors import (
     InvalidHeader, InvalidHeaderName, NoMoreData,
+    ChunkMissingTerminator, InvalidChunkSize,
     InvalidRequestLine, InvalidRequestMethod, InvalidHTTPVersion,
     LimitRequestLine, LimitRequestHeaders,
     UnsupportedTransferCoding, ObsoleteFolding,
@@ -177,7 +178,7 @@ async def _read_into(self, buf, stop=False):
         data = await self.unreader.read()
         if not data:
             if stop:
-                raise StopIteration()
+                raise StopAsyncIteration
             raise NoMoreData(bytes(buf))
         buf.extend(data)
 
@@ -628,9 +629,9 @@ async def _chunked_body_reader(self):
                 chunk_size = chunk_size.rstrip(b" \t")
 
             if any(n not in b"0123456789abcdefABCDEF" for n in chunk_size):
-                raise InvalidHeader("Invalid chunk size")
+                raise InvalidChunkSize(chunk_size)
             if len(chunk_size) == 0:
-                raise InvalidHeader("Invalid chunk size")
+                raise InvalidChunkSize(chunk_size)
 
             chunk_size = int(chunk_size, 16)
 
@@ -658,7 +659,7 @@ async def _chunked_body_reader(self):
                         break
                     crlf += more
                 if crlf != b"\r\n":
-                    raise InvalidHeader("Missing chunk terminator")
+                    raise ChunkMissingTerminator(crlf)
 
     async def _read_chunk_size_line(self):
         """Read a chunk size line."""

tests/requests/invalid/006.py

@@ -1,2 +1,5 @@
+from gunicorn.config import Config
 from gunicorn.http.errors import LimitRequestLine
+cfg = Config()
+cfg.set("limit_request_line", 4094)
 request = LimitRequestLine

tests/requests/valid/040.py

@@ -1,3 +1,7 @@
+from gunicorn.config import Config
+cfg = Config()
+cfg.set("header_map", "drop")
+
 request = {
     "method": "GET",
     "uri": uri("/keep/same/as?invalid/040"),