Turn complete events

examples/dialog_providers/google.rs

@@ -59,6 +59,10 @@ impl ProviderApi for GoogleProvider {
                 call_id,
                 arguments: Some(arguments),
             })),
+            ServiceOutputEvent::TurnComplete => {
+                tracing::info!("Turn complete");
+                Ok(None)
+            }
             ServiceOutputEvent::ToolCallCancellation { call_id } => {
                 tracing::info!("Tool call cancelled: {call_id}");
                 Ok(None)

examples/dialog_providers/openai.rs

@@ -61,6 +61,10 @@ impl ProviderApi for OpenAIProvider {
                 call_id,
                 arguments,
             })),
+            OpenAIServiceOutputEvent::TurnComplete => {
+                tracing::info!("Turn complete");
+                Ok(None)
+            }
             OpenAIServiceOutputEvent::SessionUpdated { tools } => {
                 tracing::info!("Session updated: {tools:?}");
                 Ok(None)

services/google-dialog/src/client.rs

@@ -160,10 +160,10 @@ impl Client {
             ServerEvent::GenerationComplete => {}
             ServerEvent::TurnComplete => {
                 self.finalize_output_transcription(text_outputs, output, state)?;
-                output.request_completed(None)?;
+                output.service_event(OutputPath::Media, ServiceOutputEvent::TurnComplete)?;
             }
             ServerEvent::Interrupted => {
-                // We expect a TurnComplete afterwards, so don't finalize the output transcription
+                // We expect a TurnComplete afterward, so don't finalize the output transcription
                 // when interrupted.
                 output.clear_audio()?;
             }
@@ -277,7 +277,7 @@ impl Client {
 fn normalize_function_response(output: serde_json::Value) -> serde_json::Value {
     match output {
         serde_json::Value::Object(_) => output,
-        // Gemini requires `functionResponse.response` to be a protobuf struct, i.e. a JSON object.
+        // Gemini requires `functionResponse.response` to be a JSON object.
         value => serde_json::json!({ "result": value }),
     }
 }

services/google-dialog/src/types.rs

@@ -183,7 +183,10 @@ pub enum ServiceOutputEvent {
         arguments: serde_json::Value,
     },
     #[serde(rename_all = "camelCase")]
-    ToolCallCancellation { call_id: String },
+    ToolCallCancellation {
+        call_id: String,
+    },
+    TurnComplete,
 }
 
 #[cfg(test)]

services/openai-dialog/src/client.rs

@@ -667,6 +667,8 @@ impl Client {
                     )?;
                 }
 
+                output.service_event(OutputPath::Media, ServiceOutputEvent::TurnComplete)?;
+
                 #[cfg(feature = "prompt-delay")]
                 {
                     self.prompt_coordinator

services/openai-dialog/src/types.rs

@@ -76,4 +76,5 @@ pub enum ServiceOutputEvent {
         #[serde(skip_serializing_if = "Option::is_none")]
         tools: Option<Vec<types::ToolDefinition>>,
     },
+    TurnComplete,
 }