Tests: added ASGI HTTP applications.

1 files changed, 40 insertions, 0 deletions

diff --git a/test/python/variables/asgi.py b/test/python/variables/asgi.py
new file mode 100644
index 00000000..dd1cca72
--- /dev/null
+++ b/test/python/variables/asgi.py
@@ -0,0 +1,40 @@
+async def application(scope, receive, send):
+    assert scope['type'] == 'http'
+
+    body = b''
+    while True:
+        m = await receive()
+        body += m.get('body', b'')
+        if not m.get('more_body', False):
+            break
+
+    headers = scope.get('headers', [])
+
+    def get_header(n):
+        res = []
+        for h in headers:
+            if h[0] == n:
+                res.append(h[1])
+        return b', '.join(res)
+
+    await send({
+        'type': 'http.response.start',
+        'status': 200,
+        'headers': [
+            (b'content-type', get_header(b'content-type')),
+            (b'content-length', str(len(body)).encode()),
+            (b'request-method', scope['method'].encode()),
+            (b'request-uri', scope['path'].encode()),
+            (b'http-host', get_header(b'host')),
+            (b'http-version', scope['http_version'].encode()),
+            (b'asgi-version', scope['asgi']['version'].encode()),
+            (b'asgi-spec-version', scope['asgi']['spec_version'].encode()),
+            (b'scheme', scope['scheme'].encode()),
+            (b'custom-header', get_header(b'custom-header')),
+        ]
+    })
+
+    await send({
+        'type': 'http.response.body',
+        'body': body,
+    })