Added post_read_async hook

Author: fantix

nginx/hooks.py

@@ -42,3 +42,14 @@ def post_read(request):
         if rv != ReturnCode.declined:
             return rv
     return rv
+
+
+async def post_read_async(request):
+    rv = ReturnCode.declined
+    for mod in _modules:
+        rv = await mod.post_read_async(request)
+        if rv in (ReturnCode.again,):
+            raise ValueError('post_read_async cannot return NGX_AGAIN')
+        if rv != ReturnCode.declined:
+            return rv
+    return rv

nginx/http/module.py

@@ -3,6 +3,7 @@
 from . import log
 from .._nginx import run_phases
 from ..module import BaseModule, ReturnCode
+from ..hooks import post_read_async
 
 
 class HTTPModule(BaseModule):
@@ -14,15 +15,20 @@ def init_process(self):
 
     def post_read(self, request):
         if request._started():
+            log.debug('post_read end')
             return request._result()
         else:
+            log.debug('post_read start')
             return request._start(self.loop.create_task(self._handle(request)))
 
     async def _handle(self, request):
         try:
-            log.info('Handling request...')
-            await asyncio.sleep(1)
-            log.info('Done')
-            return ReturnCode.declined
+            return await post_read_async(request)
         finally:
             self.loop.call_soon(run_phases, request)
+
+    async def post_read_async(self, request):
+        log.info('Delaying request for 1 second...')
+        await asyncio.sleep(1)
+        log.info('Now continue with the request')
+        return ReturnCode.declined

nginx/module.py

@@ -20,6 +20,9 @@ def exit_process(self):
     def post_read(self, request):
         return ReturnCode.declined
 
+    async def post_read_async(self, request):
+        return ReturnCode.declined
+
 
 def load_modules():
     log.debug('loading modules')