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

src/resources/browsers/telemetry.ts

@@ -20,7 +20,8 @@ export class Telemetry extends APIResource {
    * 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.
    *
    * @example
    * ```ts
@@ -34,8 +35,9 @@ export class Telemetry extends APIResource {
     params: TelemetryStreamParams | undefined = {},
     options?: RequestOptions,
   ): APIPromise<Stream<TelemetryStreamResponse>> {
-    const { 'Last-Event-ID': lastEventID } = params ?? {};
+    const { 'Last-Event-ID': lastEventID, ...query } = params ?? {};
     return this._client.get(path`/browsers/${id}/telemetry/stream`, {
+      query,
       ...options,
       headers: buildHeaders([
         {
@@ -2001,8 +2003,16 @@ export interface TelemetryStreamResponse {
 
 export interface TelemetryStreamParams {
   /**
-   * Last event sequence number for SSE reconnection (sent by SSE clients on
-   * reconnect)
+   * Query param: 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.
+   */
+  replay?: string;
+
+  /**
+   * Header param: Last event sequence number for SSE reconnection (sent by SSE
+   * clients on reconnect). Takes precedence over replay when both are present, so
+   * reconnect resumes instead of re-replaying.
    */
   'Last-Event-ID'?: string;
 }

tests/api-resources/browsers/telemetry.test.ts

@@ -26,7 +26,7 @@ describe('resource telemetry', () => {
     await expect(
       client.browsers.telemetry.stream(
         'id',
-        { 'Last-Event-ID': 'Last-Event-ID' },
+        { replay: 'replay', 'Last-Event-ID': 'Last-Event-ID' },
         { path: '/_stainless_unknown_path' },
       ),
     ).rejects.toThrow(Kernel.NotFoundError);