Implement Sites API client with CRUD operations

Co-authored-by: rnovatorov <20299819+rnovatorov@users.noreply.github.com>

Author: Copilot

src/enapter/http/api/__init__.py

@@ -2,6 +2,6 @@
 from .config import Config
 from .errors import Error, MultiError, check_error
 
-from . import devices  # isort: skip
+from . import devices, sites  # isort: skip
 
-__all__ = ["Client", "Config", "devices", "Error", "MultiError", "check_error"]
+__all__ = ["Client", "Config", "devices", "sites", "Error", "MultiError", "check_error"]

src/enapter/http/api/client.py

@@ -2,7 +2,7 @@
 
 import httpx
 
-from enapter.http.api import devices
+from enapter.http.api import devices, sites
 
 from .config import Config
 
@@ -33,3 +33,7 @@ async def __aexit__(self, *exc) -> None:
     @property
     def devices(self) -> devices.Client:
         return devices.Client(client=self._client)
+
+    @property
+    def sites(self) -> sites.Client:
+        return sites.Client(client=self._client)

src/enapter/http/api/sites/__init__.py

@@ -0,0 +1,7 @@
+from .client import Client
+from .site import Site
+
+__all__ = [
+    "Client",
+    "Site",
+]

src/enapter/http/api/sites/client.py

@@ -0,0 +1,56 @@
+from typing import AsyncGenerator
+
+import httpx
+
+from enapter import async_
+from enapter.http import api
+
+from .site import Site
+
+
+class Client:
+
+    def __init__(self, client: httpx.AsyncClient) -> None:
+        self._client = client
+
+    async def create(self, name: str) -> Site:
+        url = "v3/sites"
+        response = await self._client.post(url, json={"name": name})
+        api.check_error(response)
+        return Site.from_dto(response.json()["site"])
+
+    async def get(self, site_id: str) -> Site:
+        url = f"v3/sites/{site_id}"
+        response = await self._client.get(url)
+        api.check_error(response)
+        return Site.from_dto(response.json()["site"])
+
+    @async_.generator
+    async def list(self) -> AsyncGenerator[Site, None]:
+        url = "v3/sites"
+        limit = 50
+        offset = 0
+        while True:
+            response = await self._client.get(
+                url, params={"limit": limit, "offset": offset}
+            )
+            api.check_error(response)
+            payload = response.json()
+            if not payload["sites"]:
+                return
+            for dto in payload["sites"]:
+                yield Site.from_dto(dto)
+            offset += limit
+
+    async def update(self, site_id: str, name: str | None = None) -> Site:
+        if name is None:
+            return await self.get(site_id)
+        url = f"v3/sites/{site_id}"
+        response = await self._client.patch(url, json={"name": name})
+        api.check_error(response)
+        return Site.from_dto(response.json()["site"])
+
+    async def delete(self, site_id: str) -> None:
+        url = f"v3/sites/{site_id}"
+        response = await self._client.delete(url)
+        api.check_error(response)

src/enapter/http/api/sites/site.py

@@ -0,0 +1,29 @@
+import dataclasses
+import datetime
+from typing import Any, Self
+
+
+@dataclasses.dataclass
+class Site:
+
+    id: str
+    name: str
+    created_at: datetime.datetime
+    updated_at: datetime.datetime
+
+    @classmethod
+    def from_dto(cls, dto: dict[str, Any]) -> Self:
+        return cls(
+            id=dto["id"],
+            name=dto["name"],
+            created_at=datetime.datetime.fromisoformat(dto["created_at"]),
+            updated_at=datetime.datetime.fromisoformat(dto["updated_at"]),
+        )
+
+    def to_dto(self) -> dict[str, Any]:
+        return {
+            "id": self.id,
+            "name": self.name,
+            "created_at": self.created_at.isoformat(),
+            "updated_at": self.updated_at.isoformat(),
+        }