Add support for aiohttp.web

Author: sean

openapi_core/contrib/aiohttp/__init__.py

@@ -0,0 +1,7 @@
+from openapi_core.contrib.aiohttp.requests import AIOHTTPOpenAPIWebRequest
+from openapi_core.contrib.aiohttp.responses import AIOHTTPOpenAPIWebResponse
+
+__all__ = [
+    "AIOHTTPOpenAPIWebRequest",
+    "AIOHTTPOpenAPIWebResponse",
+]

openapi_core/contrib/aiohttp/requests.py

@@ -0,0 +1,53 @@
+"""OpenAPI core contrib aiohttp requests module"""
+from __future__ import annotations
+
+from typing import cast
+
+from aiohttp import web
+from asgiref.sync import AsyncToSync
+
+from openapi_core.datatypes import RequestParameters
+
+
+class Empty:
+    ...
+
+
+_empty = Empty()
+
+
+class AIOHTTPOpenAPIWebRequest:
+    __slots__ = ("request", "parameters", "_get_body", "_body")
+
+    def __init__(self, request: web.Request, *, body: str | None):
+        if not isinstance(request, web.Request):
+            raise TypeError(
+                f"'request' argument is not type of {web.Request.__qualname__!r}"
+            )
+        self.request = request
+        self.parameters = RequestParameters(
+            query=self.request.query,
+            header=self.request.headers,
+            cookie=self.request.cookies,
+        )
+        self._body = body
+
+    @property
+    def host_url(self) -> str:
+        return self.request.url.host or ""
+
+    @property
+    def path(self) -> str:
+        return self.request.url.path
+
+    @property
+    def method(self) -> str:
+        return self.request.method.lower()
+
+    @property
+    def body(self) -> str | None:
+        return self._body
+
+    @property
+    def mimetype(self) -> str:
+        return self.request.content_type

openapi_core/contrib/aiohttp/responses.py

@@ -0,0 +1,32 @@
+"""OpenAPI core contrib aiohttp responses module"""
+
+import multidict
+from aiohttp import web
+
+
+class AIOHTTPOpenAPIWebResponse:
+    def __init__(self, response: web.Response):
+        if not isinstance(response, web.Response):
+            raise TypeError(
+                f"'response' argument is not type of {web.Response.__qualname__!r}"
+            )
+        self.response = response
+
+    @property
+    def data(self) -> str:
+        if isinstance(self.response.body, bytes):
+            return self.response.body.decode("utf-8")
+        assert isinstance(self.response.body, str)
+        return self.response.body
+
+    @property
+    def status_code(self) -> int:
+        return self.response.status
+
+    @property
+    def mimetype(self) -> str:
+        return self.response.content_type or ""
+
+    @property
+    def headers(self) -> multidict.CIMultiDict[str]:
+        return self.response.headers

poetry.lock

@@ -59,6 +59,8 @@ python = "^3.7.0"
 django = {version = ">=3.0", optional = true}
 falcon = {version = ">=3.0", optional = true}
 flask = {version = "*", optional = true}
+aiohttp = {version = ">=3.0", optional = true}
+starlette = {version = ">=0.26.1,<0.28.0", optional = true}
 isodate = "*"
 more-itertools = "*"
 parse = "*"
@@ -71,16 +73,16 @@ jsonschema-spec = "^0.1.1"
 backports-cached-property = {version = "^1.0.2", python = "<3.8" }
 asgiref = "^3.6.0"
 jsonschema = "^4.17.3"
-starlette = {version = ">=0.26.1,<0.28.0", optional = true}
 
 [tool.poetry.extras]
 django = ["django"]
 falcon = ["falcon"]
 flask = ["flask"]
 requests = ["requests"]
+aiohttp = ["aiohttp"]
 starlette = ["starlette"]
 
-[tool.poetry.dev-dependencies]
+[tool.poetry.group.dev.dependencies]
 black = "^23.3.0"
 django = ">=3.0"
 djangorestframework = "^3.11.2"
@@ -97,7 +99,8 @@ webob = "*"
 mypy = "^1.2"
 httpx = "^0.24.0"
 deptry = { version = "^0.11.0", python = ">=3.8" }
-
+aiohttp = "^3.8.4"
+pytest-aiohttp = "^1.0.4"
 
 [tool.poetry.group.docs.dependencies]
 sphinx = "^5.3.0"
@@ -113,6 +116,7 @@ addopts = """
 --cov-report=term-missing
 --cov-report=xml
 """
+asyncio_mode = "auto"
 
 [tool.black]
 line-length = 79
@@ -125,4 +129,4 @@ force_single_line = true
 [tool.deptry.package_module_name_map]
 backports-cached-property = [
     "backports"
-]
+]

pyproject.toml

@@ -0,0 +1,118 @@
+import asyncio
+import pathlib
+from typing import Any
+from unittest import mock
+
+import pytest
+from aiohttp import web
+from aiohttp.test_utils import TestClient
+
+from openapi_core import openapi_request_validator
+from openapi_core import openapi_response_validator
+from openapi_core.contrib.aiohttp import AIOHTTPOpenAPIWebRequest
+from openapi_core.contrib.aiohttp import AIOHTTPOpenAPIWebResponse
+
+
+@pytest.fixture
+def spec(factory):
+    directory = pathlib.Path(__file__).parent
+    specfile = directory / "data" / "v3.0" / "aiohttp_factory.yaml"
+    return factory.spec_from_file(str(specfile))
+
+
+@pytest.fixture
+def response_getter() -> mock.MagicMock:
+    return mock.MagicMock(return_value={"data": "data"})
+
+
+@pytest.fixture
+def no_validation(response_getter):
+    async def test_route(request: web.Request) -> web.Response:
+        await asyncio.sleep(0)
+        response = web.json_response(
+            response_getter(),
+            headers={"X-Rate-Limit": "12"},
+            status=200,
+        )
+        return response
+
+    return test_route
+
+
+@pytest.fixture
+def request_validation(spec, response_getter):
+    async def test_route(request: web.Request) -> web.Response:
+        request_body = await request.text()
+        openapi_request = AIOHTTPOpenAPIWebRequest(request, body=request_body)
+        result = openapi_request_validator.validate(spec, openapi_request)
+        response: dict[str, Any] = response_getter()
+        status = 200
+        if result.errors:
+            status = 400
+            response = {"errors": [{"message": str(e) for e in result.errors}]}
+        return web.json_response(
+            response,
+            headers={"X-Rate-Limit": "12"},
+            status=status,
+        )
+
+    return test_route
+
+
+@pytest.fixture
+def response_validation(spec, response_getter):
+    async def test_route(request: web.Request) -> web.Response:
+        request_body = await request.text()
+        openapi_request = AIOHTTPOpenAPIWebRequest(request, body=request_body)
+        response_body = response_getter()
+        response = web.json_response(
+            response_body,
+            headers={"X-Rate-Limit": "12"},
+            status=200,
+        )
+        openapi_response = AIOHTTPOpenAPIWebResponse(response)
+        result = openapi_response_validator.validate(
+            spec, openapi_request, openapi_response
+        )
+        if result.errors:
+            response = web.json_response(
+                {"errors": [{"message": str(e) for e in result.errors}]},
+                headers={"X-Rate-Limit": "12"},
+                status=400,
+            )
+        return response
+
+    return test_route
+
+
+@pytest.fixture(
+    params=["no_validation", "request_validation", "response_validation"]
+)
+def router(
+    request,
+    no_validation,
+    request_validation,
+    response_validation,
+) -> web.RouteTableDef:
+    test_routes = dict(
+        no_validation=no_validation,
+        request_validation=request_validation,
+        response_validation=response_validation,
+    )
+    router_ = web.RouteTableDef()
+    handler = test_routes[request.param]
+    route = router_.post("/browse/{id}/")(handler)
+    return router_
+
+
+@pytest.fixture
+def app(router):
+    app = web.Application()
+    app.add_routes(router)
+
+    return app
+
+
+@pytest.fixture
+async def client(app, aiohttp_client) -> TestClient:
+    return await aiohttp_client(app)

tests/integration/contrib/aiohttp/conftest.py

@@ -0,0 +1,73 @@
+openapi: "3.0.0"
+info:
+  title: Basic OpenAPI specification used with starlette integration tests
+  version: "0.1"
+servers:
+  - url: '/'
+    description: 'testing'
+paths:
+  '/browse/{id}/':
+    parameters:
+      - name: id
+        in: path
+        required: true
+        description: the ID of the resource to retrieve
+        schema:
+          type: integer
+      - name: q
+        in: query
+        required: true
+        description: query key
+        schema:
+          type: string
+    post:
+      requestBody:
+        description: request data
+        required: True
+        content:
+          application/json:
+            schema:
+              type: object
+              required:
+                - param1
+              properties:
+                param1:
+                  type: integer
+      responses:
+        200:
+          description: Return the resource.
+          content:
+            application/json:
+              schema:
+                type: object
+                required:
+                  - data
+                properties:
+                  data:
+                    type: string
+          headers:
+            X-Rate-Limit:
+              description: Rate limit
+              schema:
+                type: integer
+              required: true
+        default:
+          description: Return errors.
+          content:
+            application/json:
+              schema:
+                type: object
+                required:
+                  - errors
+                properties:
+                  errors:
+                    type: array
+                    items:
+                      type: object
+                      properties:
+                        title:
+                          type: string
+                        code:
+                          type: string
+                        message:
+                          type: string

tests/integration/contrib/aiohttp/data/v3.0/aiohttp_factory.yaml

@@ -0,0 +1,56 @@
+from __future__ import annotations
+
+from typing import TYPE_CHECKING
+from unittest import mock
+
+import pytest
+
+if TYPE_CHECKING:
+    from aiohttp.test_utils import TestClient
+
+
+async def test_aiohttp_integration_valid_input(client: TestClient):
+    # Given
+    given_query_string = {
+        "q": "string",
+    }
+    given_headers = {"content-type": "application/json"}
+    given_data = {"param1": 1}
+    expected_status_code = 200
+    expected_response_data = {"data": "data"}
+    # When
+    response = await client.post(
+        "/browse/12/",
+        params=given_query_string,
+        json=given_data,
+        headers=given_headers,
+    )
+    response_data = await response.json()
+    assert response.status == expected_status_code
+    assert response_data == expected_response_data
+
+
+async def test_aiohttp_integration_invalid_input(
+    client: TestClient, response_getter, request
+):
+    if "no_validation" in request.node.name:
+        pytest.skip("No validation for given handler.")
+    # Given
+    given_query_string = {
+        "q": "string",
+    }
+    given_headers = {"content-type": "application/json"}
+    given_data = {"param1": "string"}
+    response_getter.return_value = {"data": 1}
+    expected_status_code = 400
+    expected_response_data = {"errors": [{"message": mock.ANY}]}
+    # When
+    response = await client.post(
+        "/browse/12/",
+        params=given_query_string,
+        json=given_data,
+        headers=given_headers,
+    )
+    response_data = await response.json()
+    assert response.status == expected_status_code
+    assert response_data == expected_response_data