feat: Add explicit SSE event names for local v3 streaming

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 8
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/browserbase%2Fstagehand-975ca868b31b1e45fb00b31a53d9df1ceec8663f6c2851bf40fdaa84171afadc.yml
-openapi_spec_hash: 37891379e0f47e5c69769fbaa1064dab
-config_hash: 0209737a4ab2a71afececb0ff7459998
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/browserbase%2Fstagehand-a4a5ea048bb50d06460d81d6828b53b12b19e9224121ee6338dcd1f0781e22a1.yml
+openapi_spec_hash: 9b81c0ae04576318d13d7a80d4ab7b5a
+config_hash: d6c6f623d03971bdba921650e5eb7e5f

lib/stagehand/internal/stream.rb

@@ -15,18 +15,10 @@ class Stream
       #
       # @return [Enumerable<generic<Elem>>]
       private def iterator
-        # rubocop:disable Metrics/BlockLength
         @iterator ||= Stagehand::Internal::Util.chain_fused(@stream) do |y|
-          consume = false
-
           @stream.each do |msg|
-            next if consume
-
             case msg
-            in {data: String => data} if data.start_with?("{\"data\":{\"status\":\"finished\"")
-              consume = true
-              next
-            in {data: String => data} if data.start_with?("error")
+            in {event: "error", data: String => data}
               decoded = Kernel.then do
                 JSON.parse(data, symbolize_names: true)
               rescue JSON::ParserError
@@ -41,15 +33,14 @@ class Stream
                 response: @response
               )
               raise err
-            in {event: nil, data: String => data}
+            in {event: "starting" | "connected" | "running" | "finished", data: String => data}
               decoded = JSON.parse(data, symbolize_names: true)
               unwrapped = Stagehand::Internal::Util.dig(decoded, @unwrap)
               y << Stagehand::Internal::Type::Converter.coerce(@model, unwrapped)
             else
             end
           end
         end
-        # rubocop:enable Metrics/BlockLength
       end
     end
   end

lib/stagehand/models/stream_event.rb

@@ -22,7 +22,8 @@ class StreamEvent < Stagehand::Internal::Type::BaseModel
 
       # @!method initialize(id:, data:, type:)
       #   Server-Sent Event emitted during streaming responses. Events are sent as
-      #   `data: <JSON>\n\n`. Key order: data (with status first), type, id.
+      #   `event: <status>\ndata: <JSON>\n\n`, where the JSON payload has the shape
+      #   `{ data, type, id }`.
       #
       #   @param id [String] Unique identifier for this event
       #

rbi/stagehand/models/stream_event.rbi

@@ -20,7 +20,8 @@ module Stagehand
       attr_accessor :type
 
       # Server-Sent Event emitted during streaming responses. Events are sent as
-      # `data: <JSON>\n\n`. Key order: data (with status first), type, id.
+      # `event: <status>\ndata: <JSON>\n\n`, where the JSON payload has the shape
+      # `{ data, type, id }`.
       sig do
         params(
           id: String,