Async client implementation (#17)

* Async client implementation

Author: foarsitter

noxfile.py

@@ -150,7 +150,7 @@ def mypy(session: Session) -> None:
     """Type-check using mypy."""
     args = session.posargs or ["src", "tests", "docs/conf.py"]
     session.install(".")
-    session.install("mypy", "pytest", "respx")
+    session.install("mypy", "pytest", "respx", "pytest-asyncio")
     session.run("mypy", *args)
     if not session.posargs:
         session.run("mypy", f"--python-executable={sys.executable}", "noxfile.py")
@@ -160,7 +160,7 @@ def mypy(session: Session) -> None:
 def tests(session: Session) -> None:
     """Run the test suite."""
     session.install(".")
-    session.install("coverage[toml]", "pytest", "pygments", "respx")
+    session.install("coverage[toml]", "pytest", "pygments", "respx", "pytest-asyncio")
     try:
         session.run("coverage", "run", "--parallel", "-m", "pytest", *session.posargs)
     finally:
@@ -185,7 +185,7 @@ def coverage(session: Session) -> None:
 def typeguard(session: Session) -> None:
     """Runtime type checking using Typeguard."""
     session.install(".")
-    session.install("pytest", "typeguard", "pygments", "respx")
+    session.install("pytest", "typeguard", "pygments", "respx", "pytest-asyncio")
     session.run("pytest", f"--typeguard-packages={package}", *session.posargs)
 
 

pyproject.toml

@@ -49,6 +49,7 @@ typeguard = ">=2.13.3"
 xdoctest = { extras = ["colors"], version = ">=0.15.10" }
 myst-parser = { version = ">=0.16.1" }
 respx = ">=0.20.1"
+pytest-asyncio = "^0.21.0"
 
 [tool.poetry.scripts]
 kikinzage = "kikinzage.__main__:main"

src/kikinzage/__main__.py

@@ -10,6 +10,7 @@
 
 from kikinzage.client import DefaultClient
 from kikinzage.client import RequestFixtures
+from kikinzage.models import Formaat
 
 
 @click.group()
@@ -50,7 +51,7 @@ def postcode(ctx: Context, postcode: str, huisnummer: str) -> None:
     kik.eigendomsinformatie_postcode_get(
         postcode=postcode,
         huisnummer=huisnummer,
-        formaat="json",
+        formaat=Formaat.JSON,
         klantreferentie="onbekend",
     )
 

src/kikinzage/client/__init__.py

@@ -2,10 +2,10 @@
 from typing import Dict
 
 from .asyncio import AsyncClient  # noqa
-from .base import BaseClient  # noqa
+from .base import KikinzageBaseClient  # noqa
 from .default import DefaultClient  # noqa
 
 
-__all__ = ["BaseClient", "DefaultClient", "AsyncClient"]
+__all__ = ["KikinzageBaseClient", "DefaultClient", "AsyncClient"]
 
 RequestFixtures = Dict[str, Dict[str, Dict[str, Any]]]

src/kikinzage/client/asyncio.py

@@ -1,5 +1,91 @@
-from kikinzage.client.base import BaseClient
+from typing import Any
+from typing import Literal
+from typing import Optional
+from typing import Type
+from typing import Union
 
+import httpx
+from httpx import USE_CLIENT_DEFAULT
+from httpx._client import UseClientDefault
 
-class AsyncClient(BaseClient):
+from .. import models
+from ..models import Formaat
+from ..models import ResponseType
+from .base import KikinzageBaseClient
+
+
+FormaatDefault: Literal["FormaatFormaatDefault"] = "FormaatFormaatDefault"
+Klantreferentie: Literal["Klantreferentie"] = "Klantreferentie"
+
+
+class AsyncClient(KikinzageBaseClient):
     """Client for async requests"""
+
+    client: httpx.AsyncClient
+
+    def __init__(
+        self,
+        username: str,
+        password: str,
+        base_url: str = "https://service10.kadaster.nl/kik-inzage-eto/v6/",
+        formaat: Formaat = Formaat.JSON,
+        klantreferentie: Optional[str] = None,
+        gebruikeridentificatie: Optional[str] = None,
+        hyperlinkopproduct: Optional[bool] = None,
+        inkoopnummer: Optional[str] = None,
+        referentienummer: Optional[str] = None,
+        **httpx_kwargs: Any,
+    ) -> None:
+        super().__init__(
+            username=username,
+            password=password,
+            base_url=base_url,
+            formaat=formaat,
+            klantreferentie=klantreferentie,
+            gebruikeridentificatie=gebruikeridentificatie,
+            hyperlinkopproduct=hyperlinkopproduct,
+            inkoopnummer=inkoopnummer,
+            referentienummer=referentienummer,
+        )
+
+        httpx_kwargs.setdefault("base_url", base_url)
+        httpx_kwargs.setdefault("auth", (self.username, self.password))
+
+        self.client = self.create_client(**httpx_kwargs)
+
+    def create_client(self, **httpx_kwargs: Any) -> httpx.AsyncClient:
+        return httpx.AsyncClient(**httpx_kwargs)
+
+    async def eigendomsinformatie_kadastraalobjectidentificatie_get(
+        self,
+        kadastraalobjectidentificatie: str,
+        formaat: Union[Formaat, UseClientDefault] = USE_CLIENT_DEFAULT,
+        klantreferentie: Union[str, UseClientDefault] = USE_CLIENT_DEFAULT,
+        gebruikeridentificatie: Optional[str] = None,
+        hyperlinkopproduct: Optional[bool] = None,
+        inkoopnummer: Optional[str] = None,
+        referentienummer: Optional[str] = None,
+    ) -> models.Eigendomsinformatie:
+        """GET /eigendomsinformatie/kadastraalobjectidentificatie/{kadastraalobjectidentificatie}"""
+
+        request = self.request_eigendomsinformatie_kadastraalobjectidentificatie(
+            kadastraalobjectidentificatie=kadastraalobjectidentificatie,
+            formaat=formaat,
+            klantreferentie=klantreferentie,
+            gebruikeridentificatie=gebruikeridentificatie,
+            hyperlinkopproduct=hyperlinkopproduct,
+            inkoopnummer=inkoopnummer,
+            referentienummer=referentienummer,
+        )
+
+        return await self.send(request, models.Eigendomsinformatie)
+
+    async def send(
+        self,
+        request: httpx.Request,
+        model: Type[ResponseType],
+        status_code_success: int = 200,
+    ) -> ResponseType:
+        response = await self.client.send(request)
+
+        return self.process_response(response, model, status_code_success)