chore(api): upload stainless config from cloudflare-config

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 1783
 openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/cloudflare%2Fcloudflare-e408a7cdec2dae3d1a18842dcc59280c56050fb042569139aec3fe0f12e0d461.yml
 openapi_spec_hash: 7e210c76f5dd4c79b3e67204ad279b81
-config_hash: a433f3793b734bc6fcc9d9e0c27ff8c2
+config_hash: 2d45ef3f487fb8c17ee578789175de57

api.md

@@ -131,7 +131,7 @@ from cloudflare.types.accounts.logs import AuditListResponse
 
 Methods:
 
-- <code title="get /accounts/{account_id}/logs/audit">client.accounts.logs.audit.<a href="./src/cloudflare/resources/accounts/logs/audit.py">list</a>(\*, account_id, \*\*<a href="src/cloudflare/types/accounts/logs/audit_list_params.py">params</a>) -> <a href="./src/cloudflare/types/accounts/logs/audit_list_response.py">SyncCursorLimitPagination[AuditListResponse]</a></code>
+- <code title="get /accounts/{account_id}/logs/audit">client.accounts.logs.audit.<a href="./src/cloudflare/resources/accounts/logs/audit.py">list</a>(\*, account_id, \*\*<a href="src/cloudflare/types/accounts/logs/audit_list_params.py">params</a>) -> <a href="./src/cloudflare/types/accounts/logs/audit_list_response.py">SyncCursorPaginationAfter[AuditListResponse]</a></code>
 
 # OriginCACertificates
 
@@ -2560,7 +2560,7 @@ from cloudflare.types.kv.namespaces import (
 
 Methods:
 
-- <code title="get /accounts/{account_id}/storage/kv/namespaces/{namespace_id}/keys">client.kv.namespaces.keys.<a href="./src/cloudflare/resources/kv/namespaces/keys.py">list</a>(namespace_id, \*, account_id, \*\*<a href="src/cloudflare/types/kv/namespaces/key_list_params.py">params</a>) -> <a href="./src/cloudflare/types/kv/namespaces/key.py">SyncCursorLimitPagination[Key]</a></code>
+- <code title="get /accounts/{account_id}/storage/kv/namespaces/{namespace_id}/keys">client.kv.namespaces.keys.<a href="./src/cloudflare/resources/kv/namespaces/keys.py">list</a>(namespace_id, \*, account_id, \*\*<a href="src/cloudflare/types/kv/namespaces/key_list_params.py">params</a>) -> <a href="./src/cloudflare/types/kv/namespaces/key.py">SyncCursorPaginationAfter[Key]</a></code>
 - <code title="post /accounts/{account_id}/storage/kv/namespaces/{namespace_id}/bulk/delete">client.kv.namespaces.keys.<a href="./src/cloudflare/resources/kv/namespaces/keys.py">bulk_delete</a>(namespace_id, \*, account_id, \*\*<a href="src/cloudflare/types/kv/namespaces/key_bulk_delete_params.py">params</a>) -> <a href="./src/cloudflare/types/kv/namespaces/key_bulk_delete_response.py">Optional[KeyBulkDeleteResponse]</a></code>
 - <code title="post /accounts/{account_id}/storage/kv/namespaces/{namespace_id}/bulk/get">client.kv.namespaces.keys.<a href="./src/cloudflare/resources/kv/namespaces/keys.py">bulk_get</a>(namespace_id, \*, account_id, \*\*<a href="src/cloudflare/types/kv/namespaces/key_bulk_get_params.py">params</a>) -> <a href="./src/cloudflare/types/kv/namespaces/key_bulk_get_response.py">Optional[KeyBulkGetResponse]</a></code>
 - <code title="put /accounts/{account_id}/storage/kv/namespaces/{namespace_id}/bulk">client.kv.namespaces.keys.<a href="./src/cloudflare/resources/kv/namespaces/keys.py">bulk_update</a>(namespace_id, \*, account_id, \*\*<a href="src/cloudflare/types/kv/namespaces/key_bulk_update_params.py">params</a>) -> <a href="./src/cloudflare/types/kv/namespaces/key_bulk_update_response.py">Optional[KeyBulkUpdateResponse]</a></code>
@@ -2609,7 +2609,7 @@ from cloudflare.types.durable_objects.namespaces import DurableObject
 
 Methods:
 
-- <code title="get /accounts/{account_id}/workers/durable_objects/namespaces/{id}/objects">client.durable_objects.namespaces.objects.<a href="./src/cloudflare/resources/durable_objects/namespaces/objects.py">list</a>(id, \*, account_id, \*\*<a href="src/cloudflare/types/durable_objects/namespaces/object_list_params.py">params</a>) -> <a href="./src/cloudflare/types/durable_objects/namespaces/durable_object.py">SyncCursorLimitPagination[DurableObject]</a></code>
+- <code title="get /accounts/{account_id}/workers/durable_objects/namespaces/{id}/objects">client.durable_objects.namespaces.objects.<a href="./src/cloudflare/resources/durable_objects/namespaces/objects.py">list</a>(id, \*, account_id, \*\*<a href="src/cloudflare/types/durable_objects/namespaces/object_list_params.py">params</a>) -> <a href="./src/cloudflare/types/durable_objects/namespaces/durable_object.py">SyncCursorPaginationAfter[DurableObject]</a></code>
 
 # Queues
 

src/cloudflare/pagination.py

@@ -17,6 +17,10 @@
     "CursorPaginationResultInfo",
     "SyncCursorPagination",
     "AsyncCursorPagination",
+    "CursorPaginationAfterResultInfo",
+    "CursorPaginationAfterCursors",
+    "SyncCursorPaginationAfter",
+    "AsyncCursorPaginationAfter",
     "CursorLimitPaginationResultInfo",
     "SyncCursorLimitPagination",
     "AsyncCursorLimitPagination",
@@ -175,6 +179,62 @@ def next_page_info(self) -> Optional[PageInfo]:
         return PageInfo(params={"cursor": cursor})
 
 
+class CursorPaginationAfterCursors(BaseModel):
+    after: Optional[str] = None
+
+
+class CursorPaginationAfterResultInfo(BaseModel):
+    cursors: Optional[CursorPaginationAfterCursors] = None
+
+
+class SyncCursorPaginationAfter(BaseSyncPage[_T], BasePage[_T], Generic[_T]):
+    result: List[_T]
+    result_info: Optional[CursorPaginationAfterResultInfo] = None
+
+    @override
+    def _get_page_items(self) -> List[_T]:
+        result = self.result
+        if not result:
+            return []
+        return result
+
+    @override
+    def next_page_info(self) -> Optional[PageInfo]:
+        after = None
+        if self.result_info is not None:
+            if self.result_info.cursors is not None:
+                if self.result_info.cursors.after is not None:
+                    after = self.result_info.cursors.after
+        if not after:
+            return None
+
+        return PageInfo(params={"cursor": after})
+
+
+class AsyncCursorPaginationAfter(BaseAsyncPage[_T], BasePage[_T], Generic[_T]):
+    result: List[_T]
+    result_info: Optional[CursorPaginationAfterResultInfo] = None
+
+    @override
+    def _get_page_items(self) -> List[_T]:
+        result = self.result
+        if not result:
+            return []
+        return result
+
+    @override
+    def next_page_info(self) -> Optional[PageInfo]:
+        after = None
+        if self.result_info is not None:
+            if self.result_info.cursors is not None:
+                if self.result_info.cursors.after is not None:
+                    after = self.result_info.cursors.after
+        if not after:
+            return None
+
+        return PageInfo(params={"cursor": after})
+
+
 class CursorLimitPaginationResultInfo(BaseModel):
     count: Optional[int] = None
 

src/cloudflare/resources/accounts/logs/audit.py

@@ -18,7 +18,7 @@
     async_to_raw_response_wrapper,
     async_to_streamed_response_wrapper,
 )
-from ....pagination import SyncCursorLimitPagination, AsyncCursorLimitPagination
+from ....pagination import SyncCursorPaginationAfter, AsyncCursorPaginationAfter
 from ...._base_client import AsyncPaginator, make_request_options
 from ....types.accounts.logs import audit_list_params
 from ....types.accounts.logs.audit_list_response import AuditListResponse
@@ -82,7 +82,7 @@ def list(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
-    ) -> SyncCursorLimitPagination[AuditListResponse]:
+    ) -> SyncCursorPaginationAfter[AuditListResponse]:
         """Gets a list of audit logs for an account.
 
         <br /> <br /> This is the beta release
@@ -124,7 +124,7 @@ def list(
             raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
         return self._get_api_list(
             f"/accounts/{account_id}/logs/audit",
-            page=SyncCursorLimitPagination[AuditListResponse],
+            page=SyncCursorPaginationAfter[AuditListResponse],
             options=make_request_options(
                 extra_headers=extra_headers,
                 extra_query=extra_query,
@@ -222,7 +222,7 @@ def list(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
-    ) -> AsyncPaginator[AuditListResponse, AsyncCursorLimitPagination[AuditListResponse]]:
+    ) -> AsyncPaginator[AuditListResponse, AsyncCursorPaginationAfter[AuditListResponse]]:
         """Gets a list of audit logs for an account.
 
         <br /> <br /> This is the beta release
@@ -264,7 +264,7 @@ def list(
             raise ValueError(f"Expected a non-empty value for `account_id` but received {account_id!r}")
         return self._get_api_list(
             f"/accounts/{account_id}/logs/audit",
-            page=AsyncCursorLimitPagination[AuditListResponse],
+            page=AsyncCursorPaginationAfter[AuditListResponse],
             options=make_request_options(
                 extra_headers=extra_headers,
                 extra_query=extra_query,

src/cloudflare/resources/durable_objects/namespaces/objects.py

@@ -14,7 +14,7 @@
     async_to_raw_response_wrapper,
     async_to_streamed_response_wrapper,
 )
-from ....pagination import SyncCursorLimitPagination, AsyncCursorLimitPagination
+from ....pagination import SyncCursorPaginationAfter, AsyncCursorPaginationAfter
 from ...._base_client import AsyncPaginator, make_request_options
 from ....types.durable_objects.namespaces import object_list_params
 from ....types.durable_objects.namespaces.durable_object import DurableObject
@@ -55,7 +55,7 @@ def list(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
-    ) -> SyncCursorLimitPagination[DurableObject]:
+    ) -> SyncCursorPaginationAfter[DurableObject]:
         """
         Returns the Durable Objects in a given namespace.
 
@@ -85,7 +85,7 @@ def list(
             raise ValueError(f"Expected a non-empty value for `id` but received {id!r}")
         return self._get_api_list(
             f"/accounts/{account_id}/workers/durable_objects/namespaces/{id}/objects",
-            page=SyncCursorLimitPagination[DurableObject],
+            page=SyncCursorPaginationAfter[DurableObject],
             options=make_request_options(
                 extra_headers=extra_headers,
                 extra_query=extra_query,
@@ -136,7 +136,7 @@ def list(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
-    ) -> AsyncPaginator[DurableObject, AsyncCursorLimitPagination[DurableObject]]:
+    ) -> AsyncPaginator[DurableObject, AsyncCursorPaginationAfter[DurableObject]]:
         """
         Returns the Durable Objects in a given namespace.
 
@@ -166,7 +166,7 @@ def list(
             raise ValueError(f"Expected a non-empty value for `id` but received {id!r}")
         return self._get_api_list(
             f"/accounts/{account_id}/workers/durable_objects/namespaces/{id}/objects",
-            page=AsyncCursorLimitPagination[DurableObject],
+            page=AsyncCursorPaginationAfter[DurableObject],
             options=make_request_options(
                 extra_headers=extra_headers,
                 extra_query=extra_query,

src/cloudflare/resources/kv/namespaces/keys.py

@@ -19,7 +19,7 @@
     async_to_streamed_response_wrapper,
 )
 from ...._wrappers import ResultWrapper
-from ....pagination import SyncCursorLimitPagination, AsyncCursorLimitPagination
+from ....pagination import SyncCursorPaginationAfter, AsyncCursorPaginationAfter
 from ...._base_client import AsyncPaginator, make_request_options
 from ....types.kv.namespaces import key_list_params, key_bulk_get_params, key_bulk_update_params
 from ....types.kv.namespaces.key import Key
@@ -64,7 +64,7 @@ def list(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
-    ) -> SyncCursorLimitPagination[Key]:
+    ) -> SyncCursorPaginationAfter[Key]:
         """
         Lists a namespace's keys.
 
@@ -98,7 +98,7 @@ def list(
             raise ValueError(f"Expected a non-empty value for `namespace_id` but received {namespace_id!r}")
         return self._get_api_list(
             f"/accounts/{account_id}/storage/kv/namespaces/{namespace_id}/keys",
-            page=SyncCursorLimitPagination[Key],
+            page=SyncCursorPaginationAfter[Key],
             options=make_request_options(
                 extra_headers=extra_headers,
                 extra_query=extra_query,
@@ -323,7 +323,7 @@ def list(
         extra_query: Query | None = None,
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
-    ) -> AsyncPaginator[Key, AsyncCursorLimitPagination[Key]]:
+    ) -> AsyncPaginator[Key, AsyncCursorPaginationAfter[Key]]:
         """
         Lists a namespace's keys.
 
@@ -357,7 +357,7 @@ def list(
             raise ValueError(f"Expected a non-empty value for `namespace_id` but received {namespace_id!r}")
         return self._get_api_list(
             f"/accounts/{account_id}/storage/kv/namespaces/{namespace_id}/keys",
-            page=AsyncCursorLimitPagination[Key],
+            page=AsyncCursorPaginationAfter[Key],
             options=make_request_options(
                 extra_headers=extra_headers,
                 extra_query=extra_query,

tests/api_resources/accounts/logs/test_audit.py

@@ -10,7 +10,7 @@
 from cloudflare import Cloudflare, AsyncCloudflare
 from tests.utils import assert_matches_type
 from cloudflare._utils import parse_date
-from cloudflare.pagination import SyncCursorLimitPagination, AsyncCursorLimitPagination
+from cloudflare.pagination import SyncCursorPaginationAfter, AsyncCursorPaginationAfter
 from cloudflare.types.accounts.logs import AuditListResponse
 
 base_url = os.environ.get("TEST_API_BASE_URL", "http://127.0.0.1:4010")
@@ -27,7 +27,7 @@ def test_method_list(self, client: Cloudflare) -> None:
             before=parse_date("2024-10-31"),
             since=parse_date("2024-10-30"),
         )
-        assert_matches_type(SyncCursorLimitPagination[AuditListResponse], audit, path=["response"])
+        assert_matches_type(SyncCursorPaginationAfter[AuditListResponse], audit, path=["response"])
 
     @pytest.mark.skip(reason="TODO:investigate broken test")
     @parametrize
@@ -61,7 +61,7 @@ def test_method_list_with_all_params(self, client: Cloudflare) -> None:
             zone_id={"not": ["string"]},
             zone_name={"not": ["example.com"]},
         )
-        assert_matches_type(SyncCursorLimitPagination[AuditListResponse], audit, path=["response"])
+        assert_matches_type(SyncCursorPaginationAfter[AuditListResponse], audit, path=["response"])
 
     @pytest.mark.skip(reason="TODO:investigate broken test")
     @parametrize
@@ -75,7 +75,7 @@ def test_raw_response_list(self, client: Cloudflare) -> None:
         assert response.is_closed is True
         assert response.http_request.headers.get("X-Stainless-Lang") == "python"
         audit = response.parse()
-        assert_matches_type(SyncCursorLimitPagination[AuditListResponse], audit, path=["response"])
+        assert_matches_type(SyncCursorPaginationAfter[AuditListResponse], audit, path=["response"])
 
     @pytest.mark.skip(reason="TODO:investigate broken test")
     @parametrize
@@ -89,7 +89,7 @@ def test_streaming_response_list(self, client: Cloudflare) -> None:
             assert response.http_request.headers.get("X-Stainless-Lang") == "python"
 
             audit = response.parse()
-            assert_matches_type(SyncCursorLimitPagination[AuditListResponse], audit, path=["response"])
+            assert_matches_type(SyncCursorPaginationAfter[AuditListResponse], audit, path=["response"])
 
         assert cast(Any, response.is_closed) is True
 
@@ -117,7 +117,7 @@ async def test_method_list(self, async_client: AsyncCloudflare) -> None:
             before=parse_date("2024-10-31"),
             since=parse_date("2024-10-30"),
         )
-        assert_matches_type(AsyncCursorLimitPagination[AuditListResponse], audit, path=["response"])
+        assert_matches_type(AsyncCursorPaginationAfter[AuditListResponse], audit, path=["response"])
 
     @pytest.mark.skip(reason="TODO:investigate broken test")
     @parametrize
@@ -151,7 +151,7 @@ async def test_method_list_with_all_params(self, async_client: AsyncCloudflare)
             zone_id={"not": ["string"]},
             zone_name={"not": ["example.com"]},
         )
-        assert_matches_type(AsyncCursorLimitPagination[AuditListResponse], audit, path=["response"])
+        assert_matches_type(AsyncCursorPaginationAfter[AuditListResponse], audit, path=["response"])
 
     @pytest.mark.skip(reason="TODO:investigate broken test")
     @parametrize
@@ -165,7 +165,7 @@ async def test_raw_response_list(self, async_client: AsyncCloudflare) -> None:
         assert response.is_closed is True
         assert response.http_request.headers.get("X-Stainless-Lang") == "python"
         audit = await response.parse()
-        assert_matches_type(AsyncCursorLimitPagination[AuditListResponse], audit, path=["response"])
+        assert_matches_type(AsyncCursorPaginationAfter[AuditListResponse], audit, path=["response"])
 
     @pytest.mark.skip(reason="TODO:investigate broken test")
     @parametrize
@@ -179,7 +179,7 @@ async def test_streaming_response_list(self, async_client: AsyncCloudflare) -> N
             assert response.http_request.headers.get("X-Stainless-Lang") == "python"
 
             audit = await response.parse()
-            assert_matches_type(AsyncCursorLimitPagination[AuditListResponse], audit, path=["response"])
+            assert_matches_type(AsyncCursorPaginationAfter[AuditListResponse], audit, path=["response"])
 
         assert cast(Any, response.is_closed) is True