Replace realtime websocket transport with WebRTC

Move the realtime model transport implementation to WebRTC while keeping the core session/event interface intact for the TUI layer.

Co-authored-by: Codex <noreply@openai.com>

codex-rs/codex-api/src/endpoint/realtime_websocket/methods_common.rs

@@ -1,11 +1,9 @@
 use crate::endpoint::realtime_websocket::methods_v1::conversation_handoff_append_message as v1_conversation_handoff_append_message;
 use crate::endpoint::realtime_websocket::methods_v1::conversation_item_create_message as v1_conversation_item_create_message;
 use crate::endpoint::realtime_websocket::methods_v1::session_update_session as v1_session_update_session;
-use crate::endpoint::realtime_websocket::methods_v1::websocket_intent as v1_websocket_intent;
 use crate::endpoint::realtime_websocket::methods_v2::conversation_handoff_append_message as v2_conversation_handoff_append_message;
 use crate::endpoint::realtime_websocket::methods_v2::conversation_item_create_message as v2_conversation_item_create_message;
 use crate::endpoint::realtime_websocket::methods_v2::session_update_session as v2_session_update_session;
-use crate::endpoint::realtime_websocket::methods_v2::websocket_intent as v2_websocket_intent;
 use crate::endpoint::realtime_websocket::protocol::RealtimeEventParser;
 use crate::endpoint::realtime_websocket::protocol::RealtimeOutboundMessage;
 use crate::endpoint::realtime_websocket::protocol::RealtimeSessionMode;
@@ -59,10 +57,3 @@ pub(super) fn session_update_session(
         RealtimeEventParser::RealtimeV2 => v2_session_update_session(instructions, session_mode),
     }
 }
-
-pub(super) fn websocket_intent(event_parser: RealtimeEventParser) -> Option<&'static str> {
-    match event_parser {
-        RealtimeEventParser::V1 => v1_websocket_intent(),
-        RealtimeEventParser::RealtimeV2 => v2_websocket_intent(),
-    }
-}

codex-rs/codex-api/src/endpoint/realtime_websocket/methods_v1.rs

@@ -61,7 +61,3 @@ pub(super) fn session_update_session(instructions: String) -> SessionUpdateSessi
         tool_choice: None,
     }
 }
-
-pub(super) fn websocket_intent() -> Option<&'static str> {
-    Some("quicksilver")
-}

codex-rs/codex-api/src/endpoint/realtime_websocket/methods_v2.rs

@@ -126,7 +126,3 @@ pub(super) fn session_update_session(
         },
     }
 }
-
-pub(super) fn websocket_intent() -> Option<&'static str> {
-    None
-}

codex-rs/codex-api/src/endpoint/realtime_websocket/mod.rs

@@ -9,10 +9,10 @@ mod protocol_v2;
 
 pub use codex_protocol::protocol::RealtimeAudioFrame;
 pub use codex_protocol::protocol::RealtimeEvent;
-pub use methods::RealtimeWebsocketClient;
-pub use methods::RealtimeWebsocketConnection;
-pub use methods::RealtimeWebsocketEvents;
-pub use methods::RealtimeWebsocketWriter;
+pub use methods::RealtimeWebRtcClient;
+pub use methods::RealtimeWebRtcConnection;
+pub use methods::RealtimeWebRtcEvents;
+pub use methods::RealtimeWebRtcWriter;
 pub use protocol::RealtimeEventParser;
 pub use protocol::RealtimeSessionConfig;
 pub use protocol::RealtimeSessionMode;

codex-rs/codex-api/src/endpoint/realtime_websocket/protocol.rs

@@ -32,8 +32,6 @@ pub struct RealtimeSessionConfig {
 #[derive(Debug, Clone, Serialize)]
 #[serde(tag = "type")]
 pub(super) enum RealtimeOutboundMessage {
-    #[serde(rename = "input_audio_buffer.append")]
-    InputAudioBufferAppend { audio: String },
     #[serde(rename = "conversation.handoff.append")]
     ConversationHandoffAppend {
         handoff_id: String,

codex-rs/codex-api/src/lib.rs

@@ -34,8 +34,8 @@ pub use crate::endpoint::models::ModelsClient;
 pub use crate::endpoint::realtime_websocket::RealtimeEventParser;
 pub use crate::endpoint::realtime_websocket::RealtimeSessionConfig;
 pub use crate::endpoint::realtime_websocket::RealtimeSessionMode;
-pub use crate::endpoint::realtime_websocket::RealtimeWebsocketClient;
-pub use crate::endpoint::realtime_websocket::RealtimeWebsocketConnection;
+pub use crate::endpoint::realtime_websocket::RealtimeWebRtcClient;
+pub use crate::endpoint::realtime_websocket::RealtimeWebRtcConnection;
 pub use crate::endpoint::responses::ResponsesClient;
 pub use crate::endpoint::responses::ResponsesOptions;
 pub use crate::endpoint::responses_websocket::ResponsesWebsocketClient;