feat: Forward replay param through telemetry stream passthrough

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 121
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/kernel/kernel-7d6d64b3998b55057f21aa5e33096cd5468f2bb2c4fda65190e9f299b50e5908.yml
-openapi_spec_hash: aa7d3971d38b16eff41b08cc3cbb549d
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/kernel/kernel-01f7f21a2fc892da284edf6b7cfd340d2ce5d0a9eb7ad2b39a8daec27b093134.yml
+openapi_spec_hash: 21972930082b23d985faf285fd656c31
 config_hash: 3a50aee540dce69a53bb8942f5086f5e

api.md

@@ -152,7 +152,7 @@ from kernel.types.browsers import (
 
 Methods:
 
-- <code title="get /browsers/{id}/telemetry/stream">client.browsers.telemetry.<a href="./src/kernel/resources/browsers/telemetry.py">stream</a>(id) -> <a href="./src/kernel/types/browsers/telemetry_stream_response.py">TelemetryStreamResponse</a></code>
+- <code title="get /browsers/{id}/telemetry/stream">client.browsers.telemetry.<a href="./src/kernel/resources/browsers/telemetry.py">stream</a>(id, \*\*<a href="src/kernel/types/browsers/telemetry_stream_params.py">params</a>) -> <a href="./src/kernel/types/browsers/telemetry_stream_response.py">TelemetryStreamResponse</a></code>
 
 ## Replays
 

src/kernel/resources/browsers/telemetry.py

@@ -5,7 +5,7 @@
 import httpx
 
 from ..._types import Body, Omit, Query, Headers, NotGiven, omit, not_given
-from ..._utils import path_template, strip_not_given
+from ..._utils import path_template, maybe_transform, strip_not_given, async_maybe_transform
 from ..._compat import cached_property
 from ..._resource import SyncAPIResource, AsyncAPIResource
 from ..._response import (
@@ -16,6 +16,7 @@
 )
 from ..._streaming import Stream, AsyncStream
 from ..._base_client import make_request_options
+from ...types.browsers import telemetry_stream_params
 from ...types.browsers.telemetry_stream_response import TelemetryStreamResponse
 
 __all__ = ["TelemetryResource", "AsyncTelemetryResource"]
@@ -47,6 +48,7 @@ def stream(
         self,
         id: str,
         *,
+        replay: str | Omit = omit,
         last_event_id: str | 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.
@@ -64,9 +66,14 @@ def stream(
         set; all frames carry JSON in the data: field. A keepalive comment frame is sent
         every 15 seconds when no events arrive. Returns 404 if the browser session does
         not exist. If telemetry was not enabled on the session, the stream opens but no
-        events are delivered.
+        events are delivered. Fresh connections only see new events; pass replay=all to
+        start from the oldest retained event instead.
 
         Args:
+          replay: Pass `all` to start from the oldest retained event instead of only new events;
+              any other value is treated as from-now. The buffer is bounded, so the first
+              event id may be greater than 1 if older events were evicted.
+
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -82,7 +89,11 @@ def stream(
         return self._get(
             path_template("/browsers/{id}/telemetry/stream", id=id),
             options=make_request_options(
-                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+                extra_headers=extra_headers,
+                extra_query=extra_query,
+                extra_body=extra_body,
+                timeout=timeout,
+                query=maybe_transform({"replay": replay}, telemetry_stream_params.TelemetryStreamParams),
             ),
             cast_to=TelemetryStreamResponse,
             stream=True,
@@ -116,6 +127,7 @@ async def stream(
         self,
         id: str,
         *,
+        replay: str | Omit = omit,
         last_event_id: str | 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.
@@ -133,9 +145,14 @@ async def stream(
         set; all frames carry JSON in the data: field. A keepalive comment frame is sent
         every 15 seconds when no events arrive. Returns 404 if the browser session does
         not exist. If telemetry was not enabled on the session, the stream opens but no
-        events are delivered.
+        events are delivered. Fresh connections only see new events; pass replay=all to
+        start from the oldest retained event instead.
 
         Args:
+          replay: Pass `all` to start from the oldest retained event instead of only new events;
+              any other value is treated as from-now. The buffer is bounded, so the first
+              event id may be greater than 1 if older events were evicted.
+
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -151,7 +168,11 @@ async def stream(
         return await self._get(
             path_template("/browsers/{id}/telemetry/stream", id=id),
             options=make_request_options(
-                extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout
+                extra_headers=extra_headers,
+                extra_query=extra_query,
+                extra_body=extra_body,
+                timeout=timeout,
+                query=await async_maybe_transform({"replay": replay}, telemetry_stream_params.TelemetryStreamParams),
             ),
             cast_to=TelemetryStreamResponse,
             stream=True,

src/kernel/types/browsers/__init__.py

@@ -37,6 +37,7 @@
 from .browser_telemetry_event import BrowserTelemetryEvent as BrowserTelemetryEvent
 from .process_resize_response import ProcessResizeResponse as ProcessResizeResponse
 from .process_status_response import ProcessStatusResponse as ProcessStatusResponse
+from .telemetry_stream_params import TelemetryStreamParams as TelemetryStreamParams
 from .browser_telemetry_config import BrowserTelemetryConfig as BrowserTelemetryConfig
 from .browser_cdp_connect_event import BrowserCdpConnectEvent as BrowserCdpConnectEvent
 from .browser_console_log_event import BrowserConsoleLogEvent as BrowserConsoleLogEvent

src/kernel/types/browsers/telemetry_stream_params.py

@@ -0,0 +1,20 @@
+# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
+
+from __future__ import annotations
+
+from typing_extensions import Annotated, TypedDict
+
+from ..._utils import PropertyInfo
+
+__all__ = ["TelemetryStreamParams"]
+
+
+class TelemetryStreamParams(TypedDict, total=False):
+    replay: str
+    """
+    Pass `all` to start from the oldest retained event instead of only new events;
+    any other value is treated as from-now. The buffer is bounded, so the first
+    event id may be greater than 1 if older events were evicted.
+    """
+
+    last_event_id: Annotated[str, PropertyInfo(alias="Last-Event-ID")]

tests/api_resources/browsers/test_telemetry.py

@@ -28,6 +28,7 @@ def test_method_stream(self, client: Kernel) -> None:
     def test_method_stream_with_all_params(self, client: Kernel) -> None:
         telemetry_stream = client.browsers.telemetry.stream(
             id="id",
+            replay="replay",
             last_event_id="Last-Event-ID",
         )
         telemetry_stream.response.close()
@@ -84,6 +85,7 @@ async def test_method_stream(self, async_client: AsyncKernel) -> None:
     async def test_method_stream_with_all_params(self, async_client: AsyncKernel) -> None:
         telemetry_stream = await async_client.browsers.telemetry.stream(
             id="id",
+            replay="replay",
             last_event_id="Last-Event-ID",
         )
         await telemetry_stream.response.aclose()