diff --git a/.release-please-manifest.json b/.release-please-manifest.json index 10f30916..6b7b74c5 100644 --- a/.release-please-manifest.json +++ b/.release-please-manifest.json @@ -1,3 +1,3 @@ { - ".": "0.2.0" + ".": "0.3.0" } \ No newline at end of file diff --git a/.stats.yml b/.stats.yml index b26bed31..d4463c35 100644 --- a/.stats.yml +++ b/.stats.yml @@ -1,4 +1,4 @@ -configured_endpoints: 7 -openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/kernel%2Fkernel-39aa058a60035c34a636e7f580b4b9c76b05400ae401ef04a761572b20a5425b.yml -openapi_spec_hash: bb79a204f9edb6b6ccfe783a0a82a423 -config_hash: 3eb1ed1dd0067258984b31d53a0dab48 +configured_endpoints: 10 +openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/kernel%2Fkernel-3edc7a0eef4a0d4495782efbdb0d9b777a55aee058dab119f90de56019441326.yml +openapi_spec_hash: dff0b1efa1c1614cf770ed8327cefab2 +config_hash: cb04a4d88ee9f530b303ca57ff7090b3 diff --git a/CHANGELOG.md b/CHANGELOG.md index fd4912ed..2d36628e 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,5 +1,21 @@ # Changelog +## 0.3.0 (2025-05-22) + +Full Changelog: [v0.2.0...v0.3.0](https://github.com/onkernel/kernel-python-sdk/compare/v0.2.0...v0.3.0) + +### Features + +* **api:** update via SDK Studio ([e87dc0f](https://github.com/onkernel/kernel-python-sdk/commit/e87dc0f7ab8eac43664050e0325fca9225b12c16)) +* **api:** update via SDK Studio ([e4b0438](https://github.com/onkernel/kernel-python-sdk/commit/e4b0438d63b71ea30feae04328f32ddbcdd2b15e)) +* **api:** update via SDK Studio ([4a8f812](https://github.com/onkernel/kernel-python-sdk/commit/4a8f812a39dcf768ac753c77d1d2d31881d8c4ec)) +* **api:** update via SDK Studio ([260f1a2](https://github.com/onkernel/kernel-python-sdk/commit/260f1a2e5e877e91c066935533c376c341612557)) + + +### Chores + +* **docs:** grammar improvements ([f0f0e85](https://github.com/onkernel/kernel-python-sdk/commit/f0f0e855505db93ad22cea24ec73acf13b4f8ed5)) + ## 0.2.0 (2025-05-21) Full Changelog: [v0.1.0...v0.2.0](https://github.com/onkernel/kernel-python-sdk/compare/v0.1.0...v0.2.0) diff --git a/README.md b/README.md index cd2df758..9d3c4fa3 100644 --- a/README.md +++ b/README.md @@ -87,6 +87,22 @@ Nested request parameters are [TypedDicts](https://docs.python.org/3/library/typ Typed requests and responses provide autocomplete and documentation within your editor. If you would like to see type errors in VS Code to help catch bugs earlier, set `python.analysis.typeCheckingMode` to `basic`. +## Nested params + +Nested parameters are dictionaries, typed using `TypedDict`, for example: + +```python +from kernel import Kernel + +client = Kernel() + +browser = client.browsers.create( + invocation_id="rr33xuugxj9h0bkf1rdt2bet", + persistence={"id": "my-awesome-browser-for-user-1234"}, +) +print(browser.persistence) +``` + ## File uploads Request parameters that correspond to file uploads can be passed as `bytes`, or a [`PathLike`](https://docs.python.org/3/library/os.html#os.PathLike) instance or a tuple of `(filename, contents, media type)`. @@ -123,6 +139,7 @@ client = Kernel() try: client.browsers.create( invocation_id="REPLACE_ME", + persistence={"id": "browser-for-user-1234"}, ) except kernel.APIConnectionError as e: print("The server could not be reached") @@ -168,6 +185,7 @@ client = Kernel( # Or, configure per-request: client.with_options(max_retries=5).browsers.create( invocation_id="REPLACE_ME", + persistence={"id": "browser-for-user-1234"}, ) ``` @@ -193,6 +211,7 @@ client = Kernel( # Override per-request: client.with_options(timeout=5.0).browsers.create( invocation_id="REPLACE_ME", + persistence={"id": "browser-for-user-1234"}, ) ``` @@ -236,6 +255,9 @@ from kernel import Kernel client = Kernel() response = client.browsers.with_raw_response.create( invocation_id="REPLACE_ME", + persistence={ + "id": "browser-for-user-1234" + }, ) print(response.headers.get('X-My-Header')) @@ -256,6 +278,7 @@ To stream the response body, use `.with_streaming_response` instead, which requi ```python with client.browsers.with_streaming_response.create( invocation_id="REPLACE_ME", + persistence={"id": "browser-for-user-1234"}, ) as response: print(response.headers.get("X-My-Header")) diff --git a/SECURITY.md b/SECURITY.md index bd2ba47d..0c6c32d1 100644 --- a/SECURITY.md +++ b/SECURITY.md @@ -16,7 +16,7 @@ before making any information public. ## Reporting Non-SDK Related Security Issues If you encounter security issues that are not directly related to SDKs but pertain to the services -or products provided by Kernel please follow the respective company's security reporting guidelines. +or products provided by Kernel, please follow the respective company's security reporting guidelines. --- diff --git a/api.md b/api.md index 63d7b00d..e94025bc 100644 --- a/api.md +++ b/api.md @@ -41,10 +41,18 @@ Methods: Types: ```python -from kernel.types import BrowserCreateResponse, BrowserRetrieveResponse +from kernel.types import ( + BrowserPersistence, + BrowserCreateResponse, + BrowserRetrieveResponse, + BrowserListResponse, +) ``` Methods: - client.browsers.create(\*\*params) -> BrowserCreateResponse - client.browsers.retrieve(id) -> BrowserRetrieveResponse +- client.browsers.list() -> BrowserListResponse +- client.browsers.delete(\*\*params) -> None +- client.browsers.delete_by_id(id) -> None diff --git a/pyproject.toml b/pyproject.toml index 034e1164..d4bf1e30 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -1,6 +1,6 @@ [project] name = "kernel" -version = "0.2.0" +version = "0.3.0" description = "The official Python library for the kernel API" dynamic = ["readme"] license = "Apache-2.0" diff --git a/src/kernel/_version.py b/src/kernel/_version.py index 4f726fa3..bd4f5195 100644 --- a/src/kernel/_version.py +++ b/src/kernel/_version.py @@ -1,4 +1,4 @@ # File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details. __title__ = "kernel" -__version__ = "0.2.0" # x-release-please-version +__version__ = "0.3.0" # x-release-please-version diff --git a/src/kernel/resources/browsers.py b/src/kernel/resources/browsers.py index 2aa307a8..6816edd6 100644 --- a/src/kernel/resources/browsers.py +++ b/src/kernel/resources/browsers.py @@ -4,8 +4,8 @@ import httpx -from ..types import browser_create_params -from .._types import NOT_GIVEN, Body, Query, Headers, NotGiven +from ..types import browser_create_params, browser_delete_params +from .._types import NOT_GIVEN, Body, Query, Headers, NoneType, NotGiven from .._utils import maybe_transform, async_maybe_transform from .._compat import cached_property from .._resource import SyncAPIResource, AsyncAPIResource @@ -16,7 +16,9 @@ async_to_streamed_response_wrapper, ) from .._base_client import make_request_options +from ..types.browser_list_response import BrowserListResponse from ..types.browser_create_response import BrowserCreateResponse +from ..types.browser_persistence_param import BrowserPersistenceParam from ..types.browser_retrieve_response import BrowserRetrieveResponse __all__ = ["BrowsersResource", "AsyncBrowsersResource"] @@ -46,6 +48,7 @@ def create( self, *, invocation_id: str, + persistence: BrowserPersistenceParam | NotGiven = NOT_GIVEN, # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. # The extra values given here take precedence over values defined on the client or passed to this method. extra_headers: Headers | None = None, @@ -59,6 +62,8 @@ def create( Args: invocation_id: action invocation ID + persistence: Optional persistence configuration for the browser session. + extra_headers: Send extra headers extra_query: Add additional query parameters to the request @@ -69,7 +74,13 @@ def create( """ return self._post( "/browsers", - body=maybe_transform({"invocation_id": invocation_id}, browser_create_params.BrowserCreateParams), + body=maybe_transform( + { + "invocation_id": invocation_id, + "persistence": persistence, + }, + browser_create_params.BrowserCreateParams, + ), options=make_request_options( extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout ), @@ -109,6 +120,97 @@ def retrieve( cast_to=BrowserRetrieveResponse, ) + def list( + self, + *, + # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. + # The extra values given here take precedence over values defined on the client or passed to this method. + extra_headers: Headers | None = None, + extra_query: Query | None = None, + extra_body: Body | None = None, + timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN, + ) -> BrowserListResponse: + """List active browser sessions for the authenticated user""" + return self._get( + "/browsers", + options=make_request_options( + extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout + ), + cast_to=BrowserListResponse, + ) + + def delete( + self, + *, + persistent_id: str, + # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. + # The extra values given here take precedence over values defined on the client or passed to this method. + extra_headers: Headers | None = None, + extra_query: Query | None = None, + extra_body: Body | None = None, + timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN, + ) -> None: + """ + Delete a persistent browser session by persistent_id query parameter. + + Args: + persistent_id: Persistent browser identifier + + extra_headers: Send extra headers + + extra_query: Add additional query parameters to the request + + extra_body: Add additional JSON properties to the request + + timeout: Override the client-level default timeout for this request, in seconds + """ + extra_headers = {"Accept": "*/*", **(extra_headers or {})} + return self._delete( + "/browsers", + options=make_request_options( + extra_headers=extra_headers, + extra_query=extra_query, + extra_body=extra_body, + timeout=timeout, + query=maybe_transform({"persistent_id": persistent_id}, browser_delete_params.BrowserDeleteParams), + ), + cast_to=NoneType, + ) + + def delete_by_id( + self, + id: str, + *, + # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. + # The extra values given here take precedence over values defined on the client or passed to this method. + extra_headers: Headers | None = None, + extra_query: Query | None = None, + extra_body: Body | None = None, + timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN, + ) -> None: + """ + Delete Browser Session by ID + + Args: + extra_headers: Send extra headers + + extra_query: Add additional query parameters to the request + + extra_body: Add additional JSON properties to the request + + timeout: Override the client-level default timeout for this request, in seconds + """ + if not id: + raise ValueError(f"Expected a non-empty value for `id` but received {id!r}") + extra_headers = {"Accept": "*/*", **(extra_headers or {})} + return self._delete( + f"/browsers/{id}", + options=make_request_options( + extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout + ), + cast_to=NoneType, + ) + class AsyncBrowsersResource(AsyncAPIResource): @cached_property @@ -134,6 +236,7 @@ async def create( self, *, invocation_id: str, + persistence: BrowserPersistenceParam | NotGiven = NOT_GIVEN, # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. # The extra values given here take precedence over values defined on the client or passed to this method. extra_headers: Headers | None = None, @@ -147,6 +250,8 @@ async def create( Args: invocation_id: action invocation ID + persistence: Optional persistence configuration for the browser session. + extra_headers: Send extra headers extra_query: Add additional query parameters to the request @@ -158,7 +263,11 @@ async def create( return await self._post( "/browsers", body=await async_maybe_transform( - {"invocation_id": invocation_id}, browser_create_params.BrowserCreateParams + { + "invocation_id": invocation_id, + "persistence": persistence, + }, + browser_create_params.BrowserCreateParams, ), options=make_request_options( extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout @@ -199,6 +308,99 @@ async def retrieve( cast_to=BrowserRetrieveResponse, ) + async def list( + self, + *, + # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. + # The extra values given here take precedence over values defined on the client or passed to this method. + extra_headers: Headers | None = None, + extra_query: Query | None = None, + extra_body: Body | None = None, + timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN, + ) -> BrowserListResponse: + """List active browser sessions for the authenticated user""" + return await self._get( + "/browsers", + options=make_request_options( + extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout + ), + cast_to=BrowserListResponse, + ) + + async def delete( + self, + *, + persistent_id: str, + # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. + # The extra values given here take precedence over values defined on the client or passed to this method. + extra_headers: Headers | None = None, + extra_query: Query | None = None, + extra_body: Body | None = None, + timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN, + ) -> None: + """ + Delete a persistent browser session by persistent_id query parameter. + + Args: + persistent_id: Persistent browser identifier + + extra_headers: Send extra headers + + extra_query: Add additional query parameters to the request + + extra_body: Add additional JSON properties to the request + + timeout: Override the client-level default timeout for this request, in seconds + """ + extra_headers = {"Accept": "*/*", **(extra_headers or {})} + return await self._delete( + "/browsers", + options=make_request_options( + extra_headers=extra_headers, + extra_query=extra_query, + extra_body=extra_body, + timeout=timeout, + query=await async_maybe_transform( + {"persistent_id": persistent_id}, browser_delete_params.BrowserDeleteParams + ), + ), + cast_to=NoneType, + ) + + async def delete_by_id( + self, + id: str, + *, + # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs. + # The extra values given here take precedence over values defined on the client or passed to this method. + extra_headers: Headers | None = None, + extra_query: Query | None = None, + extra_body: Body | None = None, + timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN, + ) -> None: + """ + Delete Browser Session by ID + + Args: + extra_headers: Send extra headers + + extra_query: Add additional query parameters to the request + + extra_body: Add additional JSON properties to the request + + timeout: Override the client-level default timeout for this request, in seconds + """ + if not id: + raise ValueError(f"Expected a non-empty value for `id` but received {id!r}") + extra_headers = {"Accept": "*/*", **(extra_headers or {})} + return await self._delete( + f"/browsers/{id}", + options=make_request_options( + extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout + ), + cast_to=NoneType, + ) + class BrowsersResourceWithRawResponse: def __init__(self, browsers: BrowsersResource) -> None: @@ -210,6 +412,15 @@ def __init__(self, browsers: BrowsersResource) -> None: self.retrieve = to_raw_response_wrapper( browsers.retrieve, ) + self.list = to_raw_response_wrapper( + browsers.list, + ) + self.delete = to_raw_response_wrapper( + browsers.delete, + ) + self.delete_by_id = to_raw_response_wrapper( + browsers.delete_by_id, + ) class AsyncBrowsersResourceWithRawResponse: @@ -222,6 +433,15 @@ def __init__(self, browsers: AsyncBrowsersResource) -> None: self.retrieve = async_to_raw_response_wrapper( browsers.retrieve, ) + self.list = async_to_raw_response_wrapper( + browsers.list, + ) + self.delete = async_to_raw_response_wrapper( + browsers.delete, + ) + self.delete_by_id = async_to_raw_response_wrapper( + browsers.delete_by_id, + ) class BrowsersResourceWithStreamingResponse: @@ -234,6 +454,15 @@ def __init__(self, browsers: BrowsersResource) -> None: self.retrieve = to_streamed_response_wrapper( browsers.retrieve, ) + self.list = to_streamed_response_wrapper( + browsers.list, + ) + self.delete = to_streamed_response_wrapper( + browsers.delete, + ) + self.delete_by_id = to_streamed_response_wrapper( + browsers.delete_by_id, + ) class AsyncBrowsersResourceWithStreamingResponse: @@ -246,3 +475,12 @@ def __init__(self, browsers: AsyncBrowsersResource) -> None: self.retrieve = async_to_streamed_response_wrapper( browsers.retrieve, ) + self.list = async_to_streamed_response_wrapper( + browsers.list, + ) + self.delete = async_to_streamed_response_wrapper( + browsers.delete, + ) + self.delete_by_id = async_to_streamed_response_wrapper( + browsers.delete_by_id, + ) diff --git a/src/kernel/types/__init__.py b/src/kernel/types/__init__.py index e7c3cecd..d6ca9554 100644 --- a/src/kernel/types/__init__.py +++ b/src/kernel/types/__init__.py @@ -4,6 +4,10 @@ from .app_list_params import AppListParams as AppListParams from .app_list_response import AppListResponse as AppListResponse +from .browser_persistence import BrowserPersistence as BrowserPersistence from .browser_create_params import BrowserCreateParams as BrowserCreateParams +from .browser_delete_params import BrowserDeleteParams as BrowserDeleteParams +from .browser_list_response import BrowserListResponse as BrowserListResponse from .browser_create_response import BrowserCreateResponse as BrowserCreateResponse +from .browser_persistence_param import BrowserPersistenceParam as BrowserPersistenceParam from .browser_retrieve_response import BrowserRetrieveResponse as BrowserRetrieveResponse diff --git a/src/kernel/types/browser_create_params.py b/src/kernel/types/browser_create_params.py index 0944a61e..14fd5fe3 100644 --- a/src/kernel/types/browser_create_params.py +++ b/src/kernel/types/browser_create_params.py @@ -4,9 +4,14 @@ from typing_extensions import Required, TypedDict +from .browser_persistence_param import BrowserPersistenceParam + __all__ = ["BrowserCreateParams"] class BrowserCreateParams(TypedDict, total=False): invocation_id: Required[str] """action invocation ID""" + + persistence: BrowserPersistenceParam + """Optional persistence configuration for the browser session.""" diff --git a/src/kernel/types/browser_create_response.py b/src/kernel/types/browser_create_response.py index 647dfc86..f44f3360 100644 --- a/src/kernel/types/browser_create_response.py +++ b/src/kernel/types/browser_create_response.py @@ -1,6 +1,9 @@ # File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details. +from typing import Optional + from .._models import BaseModel +from .browser_persistence import BrowserPersistence __all__ = ["BrowserCreateResponse"] @@ -14,3 +17,6 @@ class BrowserCreateResponse(BaseModel): session_id: str """Unique identifier for the browser session""" + + persistence: Optional[BrowserPersistence] = None + """Optional persistence configuration for the browser session.""" diff --git a/src/kernel/types/browser_delete_params.py b/src/kernel/types/browser_delete_params.py new file mode 100644 index 00000000..4c5b1c6a --- /dev/null +++ b/src/kernel/types/browser_delete_params.py @@ -0,0 +1,12 @@ +# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details. + +from __future__ import annotations + +from typing_extensions import Required, TypedDict + +__all__ = ["BrowserDeleteParams"] + + +class BrowserDeleteParams(TypedDict, total=False): + persistent_id: Required[str] + """Persistent browser identifier""" diff --git a/src/kernel/types/browser_list_response.py b/src/kernel/types/browser_list_response.py new file mode 100644 index 00000000..d3e90d53 --- /dev/null +++ b/src/kernel/types/browser_list_response.py @@ -0,0 +1,26 @@ +# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details. + +from typing import List, Optional +from typing_extensions import TypeAlias + +from .._models import BaseModel +from .browser_persistence import BrowserPersistence + +__all__ = ["BrowserListResponse", "BrowserListResponseItem"] + + +class BrowserListResponseItem(BaseModel): + browser_live_view_url: str + """Remote URL for live viewing the browser session""" + + cdp_ws_url: str + """Websocket URL for Chrome DevTools Protocol connections to the browser session""" + + session_id: str + """Unique identifier for the browser session""" + + persistence: Optional[BrowserPersistence] = None + """Optional persistence configuration for the browser session.""" + + +BrowserListResponse: TypeAlias = List[BrowserListResponseItem] diff --git a/src/kernel/types/browser_persistence.py b/src/kernel/types/browser_persistence.py new file mode 100644 index 00000000..9c6bfc7f --- /dev/null +++ b/src/kernel/types/browser_persistence.py @@ -0,0 +1,10 @@ +# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details. + +from .._models import BaseModel + +__all__ = ["BrowserPersistence"] + + +class BrowserPersistence(BaseModel): + id: str + """Unique identifier for the persistent browser session.""" diff --git a/src/kernel/types/browser_persistence_param.py b/src/kernel/types/browser_persistence_param.py new file mode 100644 index 00000000..b4832918 --- /dev/null +++ b/src/kernel/types/browser_persistence_param.py @@ -0,0 +1,12 @@ +# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details. + +from __future__ import annotations + +from typing_extensions import Required, TypedDict + +__all__ = ["BrowserPersistenceParam"] + + +class BrowserPersistenceParam(TypedDict, total=False): + id: Required[str] + """Unique identifier for the persistent browser session.""" diff --git a/src/kernel/types/browser_retrieve_response.py b/src/kernel/types/browser_retrieve_response.py index e84bb015..8676b532 100644 --- a/src/kernel/types/browser_retrieve_response.py +++ b/src/kernel/types/browser_retrieve_response.py @@ -1,6 +1,9 @@ # File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details. +from typing import Optional + from .._models import BaseModel +from .browser_persistence import BrowserPersistence __all__ = ["BrowserRetrieveResponse"] @@ -14,3 +17,6 @@ class BrowserRetrieveResponse(BaseModel): session_id: str """Unique identifier for the browser session""" + + persistence: Optional[BrowserPersistence] = None + """Optional persistence configuration for the browser session.""" diff --git a/tests/api_resources/test_browsers.py b/tests/api_resources/test_browsers.py index 91fc83ec..260d1719 100644 --- a/tests/api_resources/test_browsers.py +++ b/tests/api_resources/test_browsers.py @@ -9,7 +9,11 @@ from kernel import Kernel, AsyncKernel from tests.utils import assert_matches_type -from kernel.types import BrowserCreateResponse, BrowserRetrieveResponse +from kernel.types import ( + BrowserListResponse, + BrowserCreateResponse, + BrowserRetrieveResponse, +) base_url = os.environ.get("TEST_API_BASE_URL", "http://127.0.0.1:4010") @@ -21,7 +25,16 @@ class TestBrowsers: @parametrize def test_method_create(self, client: Kernel) -> None: browser = client.browsers.create( - invocation_id="ckqwer3o20000jb9s7abcdef", + invocation_id="rr33xuugxj9h0bkf1rdt2bet", + ) + assert_matches_type(BrowserCreateResponse, browser, path=["response"]) + + @pytest.mark.skip() + @parametrize + def test_method_create_with_all_params(self, client: Kernel) -> None: + browser = client.browsers.create( + invocation_id="rr33xuugxj9h0bkf1rdt2bet", + persistence={"id": "my-awesome-browser-for-user-1234"}, ) assert_matches_type(BrowserCreateResponse, browser, path=["response"]) @@ -29,7 +42,7 @@ def test_method_create(self, client: Kernel) -> None: @parametrize def test_raw_response_create(self, client: Kernel) -> None: response = client.browsers.with_raw_response.create( - invocation_id="ckqwer3o20000jb9s7abcdef", + invocation_id="rr33xuugxj9h0bkf1rdt2bet", ) assert response.is_closed is True @@ -41,7 +54,7 @@ def test_raw_response_create(self, client: Kernel) -> None: @parametrize def test_streaming_response_create(self, client: Kernel) -> None: with client.browsers.with_streaming_response.create( - invocation_id="ckqwer3o20000jb9s7abcdef", + invocation_id="rr33xuugxj9h0bkf1rdt2bet", ) as response: assert not response.is_closed assert response.http_request.headers.get("X-Stainless-Lang") == "python" @@ -93,6 +106,110 @@ def test_path_params_retrieve(self, client: Kernel) -> None: "", ) + @pytest.mark.skip() + @parametrize + def test_method_list(self, client: Kernel) -> None: + browser = client.browsers.list() + assert_matches_type(BrowserListResponse, browser, path=["response"]) + + @pytest.mark.skip() + @parametrize + def test_raw_response_list(self, client: Kernel) -> None: + response = client.browsers.with_raw_response.list() + + assert response.is_closed is True + assert response.http_request.headers.get("X-Stainless-Lang") == "python" + browser = response.parse() + assert_matches_type(BrowserListResponse, browser, path=["response"]) + + @pytest.mark.skip() + @parametrize + def test_streaming_response_list(self, client: Kernel) -> None: + with client.browsers.with_streaming_response.list() as response: + assert not response.is_closed + assert response.http_request.headers.get("X-Stainless-Lang") == "python" + + browser = response.parse() + assert_matches_type(BrowserListResponse, browser, path=["response"]) + + assert cast(Any, response.is_closed) is True + + @pytest.mark.skip() + @parametrize + def test_method_delete(self, client: Kernel) -> None: + browser = client.browsers.delete( + persistent_id="persistent_id", + ) + assert browser is None + + @pytest.mark.skip() + @parametrize + def test_raw_response_delete(self, client: Kernel) -> None: + response = client.browsers.with_raw_response.delete( + persistent_id="persistent_id", + ) + + assert response.is_closed is True + assert response.http_request.headers.get("X-Stainless-Lang") == "python" + browser = response.parse() + assert browser is None + + @pytest.mark.skip() + @parametrize + def test_streaming_response_delete(self, client: Kernel) -> None: + with client.browsers.with_streaming_response.delete( + persistent_id="persistent_id", + ) as response: + assert not response.is_closed + assert response.http_request.headers.get("X-Stainless-Lang") == "python" + + browser = response.parse() + assert browser is None + + assert cast(Any, response.is_closed) is True + + @pytest.mark.skip() + @parametrize + def test_method_delete_by_id(self, client: Kernel) -> None: + browser = client.browsers.delete_by_id( + "id", + ) + assert browser is None + + @pytest.mark.skip() + @parametrize + def test_raw_response_delete_by_id(self, client: Kernel) -> None: + response = client.browsers.with_raw_response.delete_by_id( + "id", + ) + + assert response.is_closed is True + assert response.http_request.headers.get("X-Stainless-Lang") == "python" + browser = response.parse() + assert browser is None + + @pytest.mark.skip() + @parametrize + def test_streaming_response_delete_by_id(self, client: Kernel) -> None: + with client.browsers.with_streaming_response.delete_by_id( + "id", + ) as response: + assert not response.is_closed + assert response.http_request.headers.get("X-Stainless-Lang") == "python" + + browser = response.parse() + assert browser is None + + assert cast(Any, response.is_closed) is True + + @pytest.mark.skip() + @parametrize + def test_path_params_delete_by_id(self, client: Kernel) -> None: + with pytest.raises(ValueError, match=r"Expected a non-empty value for `id` but received ''"): + client.browsers.with_raw_response.delete_by_id( + "", + ) + class TestAsyncBrowsers: parametrize = pytest.mark.parametrize("async_client", [False, True], indirect=True, ids=["loose", "strict"]) @@ -101,7 +218,16 @@ class TestAsyncBrowsers: @parametrize async def test_method_create(self, async_client: AsyncKernel) -> None: browser = await async_client.browsers.create( - invocation_id="ckqwer3o20000jb9s7abcdef", + invocation_id="rr33xuugxj9h0bkf1rdt2bet", + ) + assert_matches_type(BrowserCreateResponse, browser, path=["response"]) + + @pytest.mark.skip() + @parametrize + async def test_method_create_with_all_params(self, async_client: AsyncKernel) -> None: + browser = await async_client.browsers.create( + invocation_id="rr33xuugxj9h0bkf1rdt2bet", + persistence={"id": "my-awesome-browser-for-user-1234"}, ) assert_matches_type(BrowserCreateResponse, browser, path=["response"]) @@ -109,7 +235,7 @@ async def test_method_create(self, async_client: AsyncKernel) -> None: @parametrize async def test_raw_response_create(self, async_client: AsyncKernel) -> None: response = await async_client.browsers.with_raw_response.create( - invocation_id="ckqwer3o20000jb9s7abcdef", + invocation_id="rr33xuugxj9h0bkf1rdt2bet", ) assert response.is_closed is True @@ -121,7 +247,7 @@ async def test_raw_response_create(self, async_client: AsyncKernel) -> None: @parametrize async def test_streaming_response_create(self, async_client: AsyncKernel) -> None: async with async_client.browsers.with_streaming_response.create( - invocation_id="ckqwer3o20000jb9s7abcdef", + invocation_id="rr33xuugxj9h0bkf1rdt2bet", ) as response: assert not response.is_closed assert response.http_request.headers.get("X-Stainless-Lang") == "python" @@ -172,3 +298,107 @@ async def test_path_params_retrieve(self, async_client: AsyncKernel) -> None: await async_client.browsers.with_raw_response.retrieve( "", ) + + @pytest.mark.skip() + @parametrize + async def test_method_list(self, async_client: AsyncKernel) -> None: + browser = await async_client.browsers.list() + assert_matches_type(BrowserListResponse, browser, path=["response"]) + + @pytest.mark.skip() + @parametrize + async def test_raw_response_list(self, async_client: AsyncKernel) -> None: + response = await async_client.browsers.with_raw_response.list() + + assert response.is_closed is True + assert response.http_request.headers.get("X-Stainless-Lang") == "python" + browser = await response.parse() + assert_matches_type(BrowserListResponse, browser, path=["response"]) + + @pytest.mark.skip() + @parametrize + async def test_streaming_response_list(self, async_client: AsyncKernel) -> None: + async with async_client.browsers.with_streaming_response.list() as response: + assert not response.is_closed + assert response.http_request.headers.get("X-Stainless-Lang") == "python" + + browser = await response.parse() + assert_matches_type(BrowserListResponse, browser, path=["response"]) + + assert cast(Any, response.is_closed) is True + + @pytest.mark.skip() + @parametrize + async def test_method_delete(self, async_client: AsyncKernel) -> None: + browser = await async_client.browsers.delete( + persistent_id="persistent_id", + ) + assert browser is None + + @pytest.mark.skip() + @parametrize + async def test_raw_response_delete(self, async_client: AsyncKernel) -> None: + response = await async_client.browsers.with_raw_response.delete( + persistent_id="persistent_id", + ) + + assert response.is_closed is True + assert response.http_request.headers.get("X-Stainless-Lang") == "python" + browser = await response.parse() + assert browser is None + + @pytest.mark.skip() + @parametrize + async def test_streaming_response_delete(self, async_client: AsyncKernel) -> None: + async with async_client.browsers.with_streaming_response.delete( + persistent_id="persistent_id", + ) as response: + assert not response.is_closed + assert response.http_request.headers.get("X-Stainless-Lang") == "python" + + browser = await response.parse() + assert browser is None + + assert cast(Any, response.is_closed) is True + + @pytest.mark.skip() + @parametrize + async def test_method_delete_by_id(self, async_client: AsyncKernel) -> None: + browser = await async_client.browsers.delete_by_id( + "id", + ) + assert browser is None + + @pytest.mark.skip() + @parametrize + async def test_raw_response_delete_by_id(self, async_client: AsyncKernel) -> None: + response = await async_client.browsers.with_raw_response.delete_by_id( + "id", + ) + + assert response.is_closed is True + assert response.http_request.headers.get("X-Stainless-Lang") == "python" + browser = await response.parse() + assert browser is None + + @pytest.mark.skip() + @parametrize + async def test_streaming_response_delete_by_id(self, async_client: AsyncKernel) -> None: + async with async_client.browsers.with_streaming_response.delete_by_id( + "id", + ) as response: + assert not response.is_closed + assert response.http_request.headers.get("X-Stainless-Lang") == "python" + + browser = await response.parse() + assert browser is None + + assert cast(Any, response.is_closed) is True + + @pytest.mark.skip() + @parametrize + async def test_path_params_delete_by_id(self, async_client: AsyncKernel) -> None: + with pytest.raises(ValueError, match=r"Expected a non-empty value for `id` but received ''"): + await async_client.browsers.with_raw_response.delete_by_id( + "", + ) diff --git a/tests/test_client.py b/tests/test_client.py index a2d2dd19..5c906fc2 100644 --- a/tests/test_client.py +++ b/tests/test_client.py @@ -721,7 +721,13 @@ def test_retrying_timeout_errors_doesnt_leak(self, respx_mock: MockRouter) -> No with pytest.raises(APITimeoutError): self.client.post( "/browsers", - body=cast(object, maybe_transform(dict(invocation_id="REPLACE_ME"), BrowserCreateParams)), + body=cast( + object, + maybe_transform( + dict(invocation_id="REPLACE_ME", persistence={"id": "browser-for-user-1234"}), + BrowserCreateParams, + ), + ), cast_to=httpx.Response, options={"headers": {RAW_RESPONSE_HEADER: "stream"}}, ) @@ -737,7 +743,13 @@ def test_retrying_status_errors_doesnt_leak(self, respx_mock: MockRouter) -> Non with pytest.raises(APIStatusError): self.client.post( "/browsers", - body=cast(object, maybe_transform(dict(invocation_id="REPLACE_ME"), BrowserCreateParams)), + body=cast( + object, + maybe_transform( + dict(invocation_id="REPLACE_ME", persistence={"id": "browser-for-user-1234"}), + BrowserCreateParams, + ), + ), cast_to=httpx.Response, options={"headers": {RAW_RESPONSE_HEADER: "stream"}}, ) @@ -770,7 +782,7 @@ def retry_handler(_request: httpx.Request) -> httpx.Response: respx_mock.post("/browsers").mock(side_effect=retry_handler) - response = client.browsers.with_raw_response.create(invocation_id="ckqwer3o20000jb9s7abcdef") + response = client.browsers.with_raw_response.create(invocation_id="rr33xuugxj9h0bkf1rdt2bet") assert response.retries_taken == failures_before_success assert int(response.http_request.headers.get("x-stainless-retry-count")) == failures_before_success @@ -795,7 +807,7 @@ def retry_handler(_request: httpx.Request) -> httpx.Response: respx_mock.post("/browsers").mock(side_effect=retry_handler) response = client.browsers.with_raw_response.create( - invocation_id="ckqwer3o20000jb9s7abcdef", extra_headers={"x-stainless-retry-count": Omit()} + invocation_id="rr33xuugxj9h0bkf1rdt2bet", extra_headers={"x-stainless-retry-count": Omit()} ) assert len(response.http_request.headers.get_list("x-stainless-retry-count")) == 0 @@ -820,7 +832,7 @@ def retry_handler(_request: httpx.Request) -> httpx.Response: respx_mock.post("/browsers").mock(side_effect=retry_handler) response = client.browsers.with_raw_response.create( - invocation_id="ckqwer3o20000jb9s7abcdef", extra_headers={"x-stainless-retry-count": "42"} + invocation_id="rr33xuugxj9h0bkf1rdt2bet", extra_headers={"x-stainless-retry-count": "42"} ) assert response.http_request.headers.get("x-stainless-retry-count") == "42" @@ -1513,7 +1525,13 @@ async def test_retrying_timeout_errors_doesnt_leak(self, respx_mock: MockRouter) with pytest.raises(APITimeoutError): await self.client.post( "/browsers", - body=cast(object, maybe_transform(dict(invocation_id="REPLACE_ME"), BrowserCreateParams)), + body=cast( + object, + maybe_transform( + dict(invocation_id="REPLACE_ME", persistence={"id": "browser-for-user-1234"}), + BrowserCreateParams, + ), + ), cast_to=httpx.Response, options={"headers": {RAW_RESPONSE_HEADER: "stream"}}, ) @@ -1529,7 +1547,13 @@ async def test_retrying_status_errors_doesnt_leak(self, respx_mock: MockRouter) with pytest.raises(APIStatusError): await self.client.post( "/browsers", - body=cast(object, maybe_transform(dict(invocation_id="REPLACE_ME"), BrowserCreateParams)), + body=cast( + object, + maybe_transform( + dict(invocation_id="REPLACE_ME", persistence={"id": "browser-for-user-1234"}), + BrowserCreateParams, + ), + ), cast_to=httpx.Response, options={"headers": {RAW_RESPONSE_HEADER: "stream"}}, ) @@ -1563,7 +1587,7 @@ def retry_handler(_request: httpx.Request) -> httpx.Response: respx_mock.post("/browsers").mock(side_effect=retry_handler) - response = await client.browsers.with_raw_response.create(invocation_id="ckqwer3o20000jb9s7abcdef") + response = await client.browsers.with_raw_response.create(invocation_id="rr33xuugxj9h0bkf1rdt2bet") assert response.retries_taken == failures_before_success assert int(response.http_request.headers.get("x-stainless-retry-count")) == failures_before_success @@ -1589,7 +1613,7 @@ def retry_handler(_request: httpx.Request) -> httpx.Response: respx_mock.post("/browsers").mock(side_effect=retry_handler) response = await client.browsers.with_raw_response.create( - invocation_id="ckqwer3o20000jb9s7abcdef", extra_headers={"x-stainless-retry-count": Omit()} + invocation_id="rr33xuugxj9h0bkf1rdt2bet", extra_headers={"x-stainless-retry-count": Omit()} ) assert len(response.http_request.headers.get_list("x-stainless-retry-count")) == 0 @@ -1615,7 +1639,7 @@ def retry_handler(_request: httpx.Request) -> httpx.Response: respx_mock.post("/browsers").mock(side_effect=retry_handler) response = await client.browsers.with_raw_response.create( - invocation_id="ckqwer3o20000jb9s7abcdef", extra_headers={"x-stainless-retry-count": "42"} + invocation_id="rr33xuugxj9h0bkf1rdt2bet", extra_headers={"x-stainless-retry-count": "42"} ) assert response.http_request.headers.get("x-stainless-retry-count") == "42"