clone/codex
1
0
Fork 0
mirror of https://github.com/openai/codex.git synced 2026-04-30 17:36:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

Forward live realtime transcript updates

Browse Source 
Emit transcript update notifications from realtime transcript deltas instead of waiting for handoff.

Co-authored-by: Codex <noreply@openai.com>
This commit is contained in:
Ahmed Ibrahim
2026-03-20 13:16:14 -07:00
parent 4125a6a05f
commit e30dfcac7b
16 changed files with 181 additions and 218 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
codex-rs/app-server/tests/suite/v2/realtime_conversation.rs
View File

@@ -21,8 +21,8 @@ use codex_app_server_protocol::ThreadRealtimeStartResponse;
use codex_app_server_protocol::ThreadRealtimeStartedNotification;
use codex_app_server_protocol::ThreadRealtimeStopParams;
use codex_app_server_protocol::ThreadRealtimeStopResponse;
use codex_app_server_protocol::ThreadRealtimeTranscriptAddedNotification;
use codex_app_server_protocol::ThreadRealtimeTranscriptEntry;
use codex_app_server_protocol::ThreadRealtimeTranscriptUpdatedNotification;
use codex_app_server_protocol::ThreadStartParams;
use codex_app_server_protocol::ThreadStartResponse;
use codex_features::FEATURES;
@@ -76,12 +76,6 @@ async fn realtime_conversation_streams_v2_notifications() -> Result<()> {
"type": "conversation.output_transcript.delta",
"delta": "working"
}),
json!({
"type": "conversation.handoff.requested",
"handoff_id": "handoff_1",
"item_id": "item_2",
"input_transcript": "delegate now"
}),
json!({
"type": "error",
"message": "upstream boom"
@@ -196,16 +190,29 @@ async fn realtime_conversation_streams_v2_notifications() -> Result<()> {
assert_eq!(item_added.thread_id, output_audio.thread_id);
assert_eq!(item_added.item["type"], json!("message"));
let transcript_added = read_notification::<ThreadRealtimeTranscriptAddedNotification>(
let first_transcript_update = read_notification::<ThreadRealtimeTranscriptUpdatedNotification>(
&mut mcp,
"thread/realtime/transcriptAdded",
"thread/realtime/transcriptUpdated",
)
.await?;
assert_eq!(transcript_added.thread_id, output_audio.thread_id);
assert_eq!(transcript_added.handoff_id, "handoff_1");
assert_eq!(transcript_added.item_id, "item_2");
assert_eq!(first_transcript_update.thread_id, output_audio.thread_id);
assert_eq!(
transcript_added.transcript,
first_transcript_update.transcript,
vec![ThreadRealtimeTranscriptEntry {
role: "user".to_string(),
text: "delegate now".to_string(),
}]
);
let second_transcript_update =
read_notification::<ThreadRealtimeTranscriptUpdatedNotification>(
&mut mcp,
"thread/realtime/transcriptUpdated",
)
.await?;
assert_eq!(second_transcript_update.thread_id, output_audio.thread_id);
assert_eq!(
second_transcript_update.transcript,
vec![
ThreadRealtimeTranscriptEntry {
role: "user".to_string(),