Add synchronous VisorClient (step 11)

src/visor/__init__.py

@@ -1,4 +1,4 @@
-from visor._client import AsyncVisorClient
+from visor._client import AsyncVisorClient, VisorClient
 from visor._pagination import (
     iter_dealers,
     iter_listings,
@@ -45,6 +45,7 @@
 __all__ = [
     # client
     "AsyncVisorClient",
+    "VisorClient",
     # pagination
     "paginate_listings",
     "paginate_dealers",

src/visor/_client.py

@@ -2,7 +2,7 @@
 from datetime import date
 from typing import Literal
 
-from visor._transport import DEFAULT_BASE_URL, AsyncVisorTransport
+from visor._transport import DEFAULT_BASE_URL, AsyncVisorTransport, SyncVisorTransport
 from visor.models.dealers import DealerDetail, DealerFilter, DealersPage
 from visor.models.facets import FacetsFilter, FacetsResponse
 from visor.models.listings import ListingDetail, ListingsFilter, ListingsPage
@@ -111,3 +111,104 @@ async def get_usage(
             params["metering_class"] = ",".join(metering_class)
         data = await self._transport.get("/usage", params)
         return UsageSummary.model_validate(data)
+
+
+class VisorClient:
+    def __init__(
+        self,
+        api_key: str | None = None,
+        timeout: float = 30.0,
+        base_url: str = DEFAULT_BASE_URL,
+    ) -> None:
+        key = api_key or os.environ.get("VISOR_API_KEY")
+        if not key:
+            raise ValueError(
+                "api_key is required. Pass it directly or set VISOR_API_KEY."
+            )
+        self._transport = SyncVisorTransport(key, base_url=base_url, timeout=timeout)
+
+    def __enter__(self) -> "VisorClient":
+        return self
+
+    def __exit__(self, *args: object) -> None:
+        self.close()
+
+    def close(self) -> None:
+        self._transport.close()
+
+    # ------------------------------------------------------------------ #
+    # Inventory                                                            #
+    # ------------------------------------------------------------------ #
+
+    def filter_listings(self, filter: ListingsFilter | None = None) -> ListingsPage:
+        params = (filter or ListingsFilter()).to_params()
+        data = self._transport.get("/listings", params)
+        return ListingsPage.model_validate(data)
+
+    def get_listing(
+        self,
+        listing_id: str,
+        include: list[Literal["price_history", "options"]] | None = None,
+    ) -> ListingDetail:
+        params: dict[str, str] = {}
+        if include:
+            params["include"] = ",".join(include)
+        data = self._transport.get(f"/listings/{listing_id}", params)
+        return ListingDetail.model_validate(data["data"])
+
+    def lookup_vin(
+        self,
+        vin: str,
+        include: list[Literal["price_history", "options"]] | None = None,
+    ) -> VinDetail:
+        params: dict[str, str] = {}
+        if include:
+            params["include"] = ",".join(include)
+        data = self._transport.get(f"/vins/{vin}", params)
+        return VinDetail.model_validate(data["data"])
+
+    def filter_facets(self, filter: FacetsFilter) -> FacetsResponse:
+        data = self._transport.get("/facets", filter.to_params())
+        return FacetsResponse.model_validate(data)
+
+    # ------------------------------------------------------------------ #
+    # Dealers                                                              #
+    # ------------------------------------------------------------------ #
+
+    def search_dealers(self, filter: DealerFilter | None = None) -> DealersPage:
+        params = (filter or DealerFilter()).to_params()
+        data = self._transport.get("/dealers", params)
+        return DealersPage.model_validate(data)
+
+    def get_dealer(self, dealer_id: str) -> DealerDetail:
+        data = self._transport.get(f"/dealers/{dealer_id}")
+        return DealerDetail.model_validate(data["data"])
+
+    def dealer_inventory(
+        self,
+        dealer_id: str,
+        filter: ListingsFilter | None = None,
+    ) -> ListingsPage:
+        params = (filter or ListingsFilter()).to_params()
+        data = self._transport.get(f"/dealers/{dealer_id}/listings", params)
+        return ListingsPage.model_validate(data)
+
+    # ------------------------------------------------------------------ #
+    # Usage                                                                #
+    # ------------------------------------------------------------------ #
+
+    def get_usage(
+        self,
+        start_date: date | None = None,
+        end_date: date | None = None,
+        metering_class: list[str] | None = None,
+    ) -> UsageSummary:
+        params: dict[str, str] = {}
+        if start_date:
+            params["start_date"] = start_date.isoformat()
+        if end_date:
+            params["end_date"] = end_date.isoformat()
+        if metering_class:
+            params["metering_class"] = ",".join(metering_class)
+        data = self._transport.get("/usage", params)
+        return UsageSummary.model_validate(data)