Release 0.0.9

Author: fern-api[bot]

README.md

@@ -60,6 +60,24 @@ except ApiError as e:
     print(e.body)
 ```
 
+## Pagination
+
+Paginated requests will return a `SyncPager` or `AsyncPager`, which can be used as generators for the underlying object.
+
+```python
+from vapi import Vapi
+
+client = Vapi(
+    token="YOUR_TOKEN",
+)
+response = client.logs.get()
+for item in response:
+    yield item
+# alternatively, you can paginate page-by-page
+for page in response.iter_pages():
+    yield page
+```
+
 ## Advanced
 
 ### Retries

poetry.lock

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "Vapi"
-version = "0.0.1"
+version = "0.0.9"
 description = ""
 readme = "README.md"
 authors = []

pyproject.toml

@@ -3486,7 +3486,12 @@ from vapi import Vapi
 client = Vapi(
     token="YOUR_TOKEN",
 )
-client.logs.get()
+response = client.logs.get()
+for item in response:
+    yield item
+# alternatively, you can paginate page-by-page
+for page in response.iter_pages():
+    yield page
 
 ```
 </dd>

reference.md

@@ -22,7 +22,7 @@ def get_headers(self) -> typing.Dict[str, str]:
         headers: typing.Dict[str, str] = {
             "X-Fern-Language": "Python",
             "X-Fern-SDK-Name": "Vapi",
-            "X-Fern-SDK-Version": "0.0.1",
+            "X-Fern-SDK-Version": "0.0.9",
         }
         headers["Authorization"] = f"Bearer {self._get_token()}"
         return headers

src/vapi/core/client_wrapper.py

@@ -224,7 +224,9 @@ def request(
             json=json_body,
             data=data_body,
             content=content,
-            files=convert_file_dict_to_httpx_tuples(remove_none_from_dict(files)) if files is not None else None,
+            files=convert_file_dict_to_httpx_tuples(remove_none_from_dict(files))
+            if (files is not None and files is not omit)
+            else None,
             timeout=timeout,
         )
 
@@ -306,7 +308,9 @@ def stream(
             json=json_body,
             data=data_body,
             content=content,
-            files=convert_file_dict_to_httpx_tuples(remove_none_from_dict(files)) if files is not None else None,
+            files=convert_file_dict_to_httpx_tuples(remove_none_from_dict(files))
+            if (files is not None and files is not omit)
+            else None,
             timeout=timeout,
         ) as stream:
             yield stream

src/vapi/core/http_client.py

@@ -71,6 +71,24 @@ def convert_and_respect_annotation_metadata(
     if typing_extensions.is_typeddict(clean_type) and isinstance(object_, typing.Mapping):
         return _convert_mapping(object_, clean_type, direction)
 
+    if (
+        typing_extensions.get_origin(clean_type) == typing.Dict
+        or typing_extensions.get_origin(clean_type) == dict
+        or clean_type == typing.Dict
+    ) and isinstance(object_, typing.Dict):
+        key_type = typing_extensions.get_args(clean_type)[0]
+        value_type = typing_extensions.get_args(clean_type)[1]
+
+        return {
+            key: convert_and_respect_annotation_metadata(
+                object_=value,
+                annotation=annotation,
+                inner_type=value_type,
+                direction=direction,
+            )
+            for key, value in object_.items()
+        }
+
     # If you're iterating on a string, do not bother to coerce it to a sequence.
     if not isinstance(object_, str):
         if (

src/vapi/core/serialization.py

@@ -6,12 +6,15 @@
 from .types.logs_get_request_sort_order import LogsGetRequestSortOrder
 import datetime as dt
 from ..core.request_options import RequestOptions
-from ..types.logs_paginated_response import LogsPaginatedResponse
+from ..core.pagination import SyncPager
+from ..types.log import Log
 from ..core.datetime_utils import serialize_datetime
+from ..types.logs_paginated_response import LogsPaginatedResponse
 from ..core.pydantic_utilities import parse_obj_as
 from json.decoder import JSONDecodeError
 from ..core.api_error import ApiError
 from ..core.client_wrapper import AsyncClientWrapper
+from ..core.pagination import AsyncPager
 
 
 class LogsClient:
@@ -40,7 +43,7 @@ def get(
         updated_at_ge: typing.Optional[dt.datetime] = None,
         updated_at_le: typing.Optional[dt.datetime] = None,
         request_options: typing.Optional[RequestOptions] = None,
-    ) -> LogsPaginatedResponse:
+    ) -> SyncPager[Log]:
         """
         Parameters
         ----------
@@ -103,7 +106,7 @@ def get(
 
         Returns
         -------
-        LogsPaginatedResponse
+        SyncPager[Log]
 
 
         Examples
@@ -113,8 +116,14 @@ def get(
         client = Vapi(
             token="YOUR_TOKEN",
         )
-        client.logs.get()
+        response = client.logs.get()
+        for item in response:
+            yield item
+        # alternatively, you can paginate page-by-page
+        for page in response.iter_pages():
+            yield page
         """
+        page = page if page is not None else 1
         _response = self._client_wrapper.httpx_client.request(
             "logs",
             method="GET",
@@ -142,13 +151,37 @@ def get(
         )
         try:
             if 200 <= _response.status_code < 300:
-                return typing.cast(
+                _parsed_response = typing.cast(
                     LogsPaginatedResponse,
                     parse_obj_as(
                         type_=LogsPaginatedResponse,  # type: ignore
                         object_=_response.json(),
                     ),
                 )
+                _has_next = True
+                _get_next = lambda: self.get(
+                    org_id=org_id,
+                    type=type,
+                    assistant_id=assistant_id,
+                    phone_number_id=phone_number_id,
+                    customer_id=customer_id,
+                    squad_id=squad_id,
+                    call_id=call_id,
+                    page=page + 1,
+                    sort_order=sort_order,
+                    limit=limit,
+                    created_at_gt=created_at_gt,
+                    created_at_lt=created_at_lt,
+                    created_at_ge=created_at_ge,
+                    created_at_le=created_at_le,
+                    updated_at_gt=updated_at_gt,
+                    updated_at_lt=updated_at_lt,
+                    updated_at_ge=updated_at_ge,
+                    updated_at_le=updated_at_le,
+                    request_options=request_options,
+                )
+                _items = _parsed_response.results
+                return SyncPager(has_next=_has_next, items=_items, get_next=_get_next)
             _response_json = _response.json()
         except JSONDecodeError:
             raise ApiError(status_code=_response.status_code, body=_response.text)
@@ -181,7 +214,7 @@ async def get(
         updated_at_ge: typing.Optional[dt.datetime] = None,
         updated_at_le: typing.Optional[dt.datetime] = None,
         request_options: typing.Optional[RequestOptions] = None,
-    ) -> LogsPaginatedResponse:
+    ) -> AsyncPager[Log]:
         """
         Parameters
         ----------
@@ -244,7 +277,7 @@ async def get(
 
         Returns
         -------
-        LogsPaginatedResponse
+        AsyncPager[Log]
 
 
         Examples
@@ -259,11 +292,17 @@ async def get(
 
 
         async def main() -> None:
-            await client.logs.get()
+            response = await client.logs.get()
+            async for item in response:
+                yield item
+            # alternatively, you can paginate page-by-page
+            async for page in response.iter_pages():
+                yield page
 
 
         asyncio.run(main())
         """
+        page = page if page is not None else 1
         _response = await self._client_wrapper.httpx_client.request(
             "logs",
             method="GET",
@@ -291,13 +330,37 @@ async def main() -> None:
         )
         try:
             if 200 <= _response.status_code < 300:
-                return typing.cast(
+                _parsed_response = typing.cast(
                     LogsPaginatedResponse,
                     parse_obj_as(
                         type_=LogsPaginatedResponse,  # type: ignore
                         object_=_response.json(),
                     ),
                 )
+                _has_next = True
+                _get_next = lambda: self.get(
+                    org_id=org_id,
+                    type=type,
+                    assistant_id=assistant_id,
+                    phone_number_id=phone_number_id,
+                    customer_id=customer_id,
+                    squad_id=squad_id,
+                    call_id=call_id,
+                    page=page + 1,
+                    sort_order=sort_order,
+                    limit=limit,
+                    created_at_gt=created_at_gt,
+                    created_at_lt=created_at_lt,
+                    created_at_ge=created_at_ge,
+                    created_at_le=created_at_le,
+                    updated_at_gt=updated_at_gt,
+                    updated_at_lt=updated_at_lt,
+                    updated_at_ge=updated_at_ge,
+                    updated_at_le=updated_at_le,
+                    request_options=request_options,
+                )
+                _items = _parsed_response.results
+                return AsyncPager(has_next=_has_next, items=_items, get_next=_get_next)
             _response_json = _response.json()
         except JSONDecodeError:
             raise ApiError(status_code=_response.status_code, body=_response.text)