feat(api): api update

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
-configured_endpoints: 35
+configured_endpoints: 36
 openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/nen-labs%2Fsteel-f62eb21825a70921af8d88fe8eea69e1de89be49cf6a1b0f4cb068eb95f774c5.yml
 openapi_spec_hash: 535d95b67167cf38a0c5d9d08ed273bd
-config_hash: d62791c689042fb10adf838253a71a6e
+config_hash: e49b3f69d57d7ffa0420acf772d5c846

api.md

@@ -56,6 +56,7 @@ from steel.types import (
     Session,
     SessionContext,
     Sessionslist,
+    SessionComputerResponse,
     SessionEventsResponse,
     SessionLiveDetailsResponse,
     SessionReleaseResponse,
@@ -68,6 +69,7 @@ Methods:
 - <code title="post /v1/sessions">client.sessions.<a href="./src/steel/resources/sessions/sessions.py">create</a>(\*\*<a href="src/steel/types/session_create_params.py">params</a>) -> <a href="./src/steel/types/session.py">Session</a></code>
 - <code title="get /v1/sessions/{id}">client.sessions.<a href="./src/steel/resources/sessions/sessions.py">retrieve</a>(id) -> <a href="./src/steel/types/session.py">Session</a></code>
 - <code title="get /v1/sessions">client.sessions.<a href="./src/steel/resources/sessions/sessions.py">list</a>(\*\*<a href="src/steel/types/session_list_params.py">params</a>) -> SyncSessionsCursor[Session]</code>
+- <code title="post /v1/sessions/{sessionId}/computer">client.sessions.<a href="./src/steel/resources/sessions/sessions.py">computer</a>(session_id, \*\*<a href="src/steel/types/session_computer_params.py">params</a>) -> <a href="./src/steel/types/session_computer_response.py">SessionComputerResponse</a></code>
 - <code title="get /v1/sessions/{id}/context">client.sessions.<a href="./src/steel/resources/sessions/sessions.py">context</a>(id) -> <a href="./src/steel/types/session_context.py">SessionContext</a></code>
 - <code title="get /v1/sessions/{id}/events">client.sessions.<a href="./src/steel/resources/sessions/sessions.py">events</a>(id) -> <a href="./src/steel/types/session_events_response.py">SessionEventsResponse</a></code>
 - <code title="get /v1/sessions/{id}/live-details">client.sessions.<a href="./src/steel/resources/sessions/sessions.py">live_details</a>(id) -> <a href="./src/steel/types/session_live_details_response.py">SessionLiveDetailsResponse</a></code>

src/steel/resources/sessions/sessions.py

@@ -14,7 +14,7 @@
     FilesResourceWithStreamingResponse,
     AsyncFilesResourceWithStreamingResponse,
 )
-from ...types import session_list_params, session_create_params
+from ...types import session_list_params, session_create_params, session_computer_params
 from ..._types import Body, Omit, Query, Headers, NotGiven, SequenceNotStr, omit, not_given
 from ..._utils import maybe_transform, async_maybe_transform
 from .captchas import (
@@ -40,6 +40,7 @@
 from ...types.session_context import SessionContext
 from ...types.session_events_response import SessionEventsResponse
 from ...types.session_release_response import SessionReleaseResponse
+from ...types.session_computer_response import SessionComputerResponse
 from ...types.session_release_all_response import SessionReleaseAllResponse
 from ...types.session_live_details_response import SessionLiveDetailsResponse
 
@@ -286,6 +287,43 @@ def list(
             model=SessionslistSession,
         )
 
+    def computer(
+        self,
+        session_id: str,
+        *,
+        body: object | Omit = omit,
+        # 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,
+    ) -> SessionComputerResponse:
+        """
+        Execute computer actions like mouse movements, clicks, keyboard input, and more
+
+        Args:
+          body: Computer action to execute (validation done in controller)
+
+          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 session_id:
+            raise ValueError(f"Expected a non-empty value for `session_id` but received {session_id!r}")
+        return self._post(
+            f"/v1/sessions/{session_id}/computer",
+            body=maybe_transform(body, session_computer_params.SessionComputerParams),
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=SessionComputerResponse,
+        )
+
     def context(
         self,
         id: str,
@@ -678,6 +716,43 @@ def list(
             model=SessionslistSession,
         )
 
+    async def computer(
+        self,
+        session_id: str,
+        *,
+        body: object | Omit = omit,
+        # 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,
+    ) -> SessionComputerResponse:
+        """
+        Execute computer actions like mouse movements, clicks, keyboard input, and more
+
+        Args:
+          body: Computer action to execute (validation done in controller)
+
+          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 session_id:
+            raise ValueError(f"Expected a non-empty value for `session_id` but received {session_id!r}")
+        return await self._post(
+            f"/v1/sessions/{session_id}/computer",
+            body=await async_maybe_transform(body, session_computer_params.SessionComputerParams),
+            options=make_request_options(
+                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+            ),
+            cast_to=SessionComputerResponse,
+        )
+
     async def context(
         self,
         id: str,
@@ -843,6 +918,9 @@ def __init__(self, sessions: SessionsResource) -> None:
         self.list = to_raw_response_wrapper(
             sessions.list,
         )
+        self.computer = to_raw_response_wrapper(
+            sessions.computer,
+        )
         self.context = to_raw_response_wrapper(
             sessions.context,
         )
@@ -881,6 +959,9 @@ def __init__(self, sessions: AsyncSessionsResource) -> None:
         self.list = async_to_raw_response_wrapper(
             sessions.list,
         )
+        self.computer = async_to_raw_response_wrapper(
+            sessions.computer,
+        )
         self.context = async_to_raw_response_wrapper(
             sessions.context,
         )
@@ -919,6 +1000,9 @@ def __init__(self, sessions: SessionsResource) -> None:
         self.list = to_streamed_response_wrapper(
             sessions.list,
         )
+        self.computer = to_streamed_response_wrapper(
+            sessions.computer,
+        )
         self.context = to_streamed_response_wrapper(
             sessions.context,
         )
@@ -957,6 +1041,9 @@ def __init__(self, sessions: AsyncSessionsResource) -> None:
         self.list = async_to_streamed_response_wrapper(
             sessions.list,
         )
+        self.computer = async_to_streamed_response_wrapper(
+            sessions.computer,
+        )
         self.context = async_to_streamed_response_wrapper(
             sessions.context,
         )

src/steel/types/__init__.py

@@ -22,6 +22,7 @@
 from .extension_update_params import ExtensionUpdateParams as ExtensionUpdateParams
 from .extension_upload_params import ExtensionUploadParams as ExtensionUploadParams
 from .profile_create_response import ProfileCreateResponse as ProfileCreateResponse
+from .session_computer_params import SessionComputerParams as SessionComputerParams
 from .session_events_response import SessionEventsResponse as SessionEventsResponse
 from .client_screenshot_params import ClientScreenshotParams as ClientScreenshotParams
 from .credential_create_params import CredentialCreateParams as CredentialCreateParams
@@ -32,6 +33,7 @@
 from .extension_delete_response import ExtensionDeleteResponse as ExtensionDeleteResponse
 from .extension_update_response import ExtensionUpdateResponse as ExtensionUpdateResponse
 from .extension_upload_response import ExtensionUploadResponse as ExtensionUploadResponse
+from .session_computer_response import SessionComputerResponse as SessionComputerResponse
 from .credential_create_response import CredentialCreateResponse as CredentialCreateResponse
 from .credential_delete_response import CredentialDeleteResponse as CredentialDeleteResponse
 from .credential_update_response import CredentialUpdateResponse as CredentialUpdateResponse

src/steel/types/session_computer_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 TypedDict
+
+__all__ = ["SessionComputerParams"]
+
+
+class SessionComputerParams(TypedDict, total=False):
+    body: object
+    """Computer action to execute (validation done in controller)"""

src/steel/types/session_computer_response.py

@@ -0,0 +1,21 @@
+# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+from typing import Optional
+
+from .._models import BaseModel
+
+__all__ = ["SessionComputerResponse"]
+
+
+class SessionComputerResponse(BaseModel):
+    base64_image: Optional[str] = None
+    """Base64 encoded screenshot if requested"""
+
+    error: Optional[str] = None
+    """Error message if action failed"""
+
+    output: Optional[str] = None
+    """Output message from the action"""
+
+    system: Optional[str] = None
+    """System information"""

tests/api_resources/test_sessions.py

@@ -13,6 +13,7 @@
     SessionContext,
     SessionEventsResponse,
     SessionReleaseResponse,
+    SessionComputerResponse,
     SessionReleaseAllResponse,
     SessionLiveDetailsResponse,
 )
@@ -217,6 +218,52 @@ def test_streaming_response_list(self, client: Steel) -> None:
 
         assert cast(Any, response.is_closed) is True
 
+    @parametrize
+    def test_method_computer(self, client: Steel) -> None:
+        session = client.sessions.computer(
+            session_id="sessionId",
+        )
+        assert_matches_type(SessionComputerResponse, session, path=["response"])
+
+    @parametrize
+    def test_method_computer_with_all_params(self, client: Steel) -> None:
+        session = client.sessions.computer(
+            session_id="sessionId",
+            body={},
+        )
+        assert_matches_type(SessionComputerResponse, session, path=["response"])
+
+    @parametrize
+    def test_raw_response_computer(self, client: Steel) -> None:
+        response = client.sessions.with_raw_response.computer(
+            session_id="sessionId",
+        )
+
+        assert response.is_closed is True
+        assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+        session = response.parse()
+        assert_matches_type(SessionComputerResponse, session, path=["response"])
+
+    @parametrize
+    def test_streaming_response_computer(self, client: Steel) -> None:
+        with client.sessions.with_streaming_response.computer(
+            session_id="sessionId",
+        ) as response:
+            assert not response.is_closed
+            assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+
+            session = response.parse()
+            assert_matches_type(SessionComputerResponse, session, path=["response"])
+
+        assert cast(Any, response.is_closed) is True
+
+    @parametrize
+    def test_path_params_computer(self, client: Steel) -> None:
+        with pytest.raises(ValueError, match=r"Expected a non-empty value for `session_id` but received ''"):
+            client.sessions.with_raw_response.computer(
+                session_id="",
+            )
+
     @parametrize
     def test_method_context(self, client: Steel) -> None:
         session = client.sessions.context(
@@ -590,6 +637,52 @@ async def test_streaming_response_list(self, async_client: AsyncSteel) -> None:
 
         assert cast(Any, response.is_closed) is True
 
+    @parametrize
+    async def test_method_computer(self, async_client: AsyncSteel) -> None:
+        session = await async_client.sessions.computer(
+            session_id="sessionId",
+        )
+        assert_matches_type(SessionComputerResponse, session, path=["response"])
+
+    @parametrize
+    async def test_method_computer_with_all_params(self, async_client: AsyncSteel) -> None:
+        session = await async_client.sessions.computer(
+            session_id="sessionId",
+            body={},
+        )
+        assert_matches_type(SessionComputerResponse, session, path=["response"])
+
+    @parametrize
+    async def test_raw_response_computer(self, async_client: AsyncSteel) -> None:
+        response = await async_client.sessions.with_raw_response.computer(
+            session_id="sessionId",
+        )
+
+        assert response.is_closed is True
+        assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+        session = await response.parse()
+        assert_matches_type(SessionComputerResponse, session, path=["response"])
+
+    @parametrize
+    async def test_streaming_response_computer(self, async_client: AsyncSteel) -> None:
+        async with async_client.sessions.with_streaming_response.computer(
+            session_id="sessionId",
+        ) as response:
+            assert not response.is_closed
+            assert response.http_request.headers.get("X-Stainless-Lang") == "python"
+
+            session = await response.parse()
+            assert_matches_type(SessionComputerResponse, session, path=["response"])
+
+        assert cast(Any, response.is_closed) is True
+
+    @parametrize
+    async def test_path_params_computer(self, async_client: AsyncSteel) -> None:
+        with pytest.raises(ValueError, match=r"Expected a non-empty value for `session_id` but received ''"):
+            await async_client.sessions.with_raw_response.computer(
+                session_id="",
+            )
+
     @parametrize
     async def test_method_context(self, async_client: AsyncSteel) -> None:
         session = await async_client.sessions.context(