summaryrefslogtreecommitdiffhomepage
path: root/test/python/lifespan/empty/asgi.py
diff options
context:
space:
mode:
authorAndrei Zeliankou <zelenkov@nginx.com>2020-10-05 11:05:00 +0100
committerAndrei Zeliankou <zelenkov@nginx.com>2020-10-05 11:05:00 +0100
commit152ad526f491e70905e2fec3b7d33a89cf23813b (patch)
tree9dbd0b69beb14c456eb9fe9d49b003a35a65e959 /test/python/lifespan/empty/asgi.py
parent9d8d2c17585c149601855a09eba575640d156eae (diff)
downloadunit-152ad526f491e70905e2fec3b7d33a89cf23813b.tar.gz
unit-152ad526f491e70905e2fec3b7d33a89cf23813b.tar.bz2
Tests: added ASGI Lifespan.
Diffstat (limited to '')
-rw-r--r--test/python/lifespan/empty/asgi.py27
1 files changed, 27 insertions, 0 deletions
diff --git a/test/python/lifespan/empty/asgi.py b/test/python/lifespan/empty/asgi.py
new file mode 100644
index 00000000..ea43af13
--- /dev/null
+++ b/test/python/lifespan/empty/asgi.py
@@ -0,0 +1,27 @@
+import os
+
+
+async def application(scope, receive, send):
+ if scope['type'] == 'lifespan':
+ with open('version', 'w+') as f:
+ f.write(
+ scope['asgi']['version'] + ' ' + scope['asgi']['spec_version']
+ )
+ while True:
+ message = await receive()
+ if message['type'] == 'lifespan.startup':
+ os.remove('startup')
+ await send({'type': 'lifespan.startup.complete'})
+ elif message['type'] == 'lifespan.shutdown':
+ os.remove('shutdown')
+ await send({'type': 'lifespan.shutdown.complete'})
+ return
+
+ if scope['type'] == 'http':
+ await send(
+ {
+ 'type': 'http.response.start',
+ 'status': 204,
+ 'headers': [(b'content-length', b'0'),],
+ }
+ )