async view funcs

Author: maximdanilchenko

tests/conftest.py

@@ -60,7 +60,7 @@ class ResponseSchema(Schema):
         ({"location": "query"}, False),
     ]
 )
-def aiohttp_app(request_schema, request_callable_schema, loop, test_client, request):
+def aiohttp_app(request_schema, request_callable_schema, loop, aiohttp_client, request):
     locations, nested = request.param
 
     @docs(
@@ -69,26 +69,26 @@ def aiohttp_app(request_schema, request_callable_schema, loop, test_client, requ
         description="Test method description",
     )
     @use_kwargs(request_schema, **locations)
-    def handler_get(request):
+    async def handler_get(request):
         print(request.data)
         return web.json_response({"msg": "done", "data": {}})
 
     @use_kwargs(request_schema)
-    def handler_post(request):
+    async def handler_post(request):
         print(request.data)
         return web.json_response({"msg": "done", "data": {}})
 
     @use_kwargs(request_callable_schema)
-    def handler_post_callable_schema(request):
+    async def handler_post_callable_schema(request):
         print(request.data)
         return web.json_response({"msg": "done", "data": {}})
 
     @use_kwargs(request_schema)
-    def handler_post_echo(request):
+    async def handler_post_echo(request):
         return web.json_response(request["data"])
 
     @use_kwargs(request_schema, **locations)
-    def handler_get_echo(request):
+    async def handler_get_echo(request):
         print(request.data)
         return web.json_response(request["data"])
 
@@ -101,7 +101,7 @@ def handler_get_echo(request):
             }
         ]
     )
-    def handler_get_variable(request):
+    async def handler_get_variable(request):
         print(request.data)
         return web.json_response(request["data"])
 
@@ -119,11 +119,11 @@ async def delete(self):
             return web.json_response({"hello": "world"})
 
     @use_kwargs(request_schema, **locations)
-    def handler_get_echo_old_data(request):
+    async def handler_get_echo_old_data(request):
         print(request.data)
         return web.json_response(request.data)
 
-    def other(request):
+    async def other(request):
         return web.Response()
 
     app = web.Application()
@@ -164,4 +164,4 @@ def other(request):
         )
         app.middlewares.append(validation_middleware)
 
-    return loop.run_until_complete(test_client(app))
+    return loop.run_until_complete(aiohttp_client(app))

tests/test_decorators.py

@@ -14,7 +14,7 @@ def aiohttp_view_all(self, request_schema, response_schema):
         )
         @use_kwargs(request_schema, locations=["query"])
         @marshal_with(response_schema, 200)
-        def index(request, **data):
+        async def index(request, **data):
             return web.json_response({"msg": "done", "data": {}})
 
         return index
@@ -26,23 +26,23 @@ def aiohttp_view_docs(self):
             summary="Test method summary",
             description="Test method description",
         )
-        def index(request, **data):
+        async def index(request, **data):
             return web.json_response({"msg": "done", "data": {}})
 
         return index
 
     @pytest.fixture
     def aiohttp_view_kwargs(self, request_schema):
         @use_kwargs(request_schema, locations=["query"])
-        def index(request, **data):
+        async def index(request, **data):
             return web.json_response({"msg": "done", "data": {}})
 
         return index
 
     @pytest.fixture
     def aiohttp_view_marshal(self, response_schema):
         @marshal_with(response_schema, 200, description="Method description")
-        def index(request, **data):
+        async def index(request, **data):
             return web.json_response({"msg": "done", "data": {}})
 
         return index
@@ -114,7 +114,7 @@ def test_view_multiple_body_parameters(self, request_schema):
 
             @use_kwargs(request_schema, locations=["body"])
             @use_kwargs(request_schema, locations=["body"])
-            def index(request, **data):
+            async def index(request, **data):
                 return web.json_response({"msg": "done", "data": {}})
 
         assert isinstance(ex.value, RuntimeError)