fix: align telegram bridge with latest app-server protocol

Author: thorseraq

codex-rs/Cargo.lock

@@ -764,7 +764,7 @@ impl CodexMessageProcessor {
                     app_server_client_name.clone(),
                     request_source,
                 )
-                    .await;
+                .await;
             }
             ClientRequest::PluginUninstall { request_id, params } => {
                 self.plugin_uninstall(to_connection_request_id(request_id), params)
@@ -5865,7 +5865,7 @@ impl CodexMessageProcessor {
 
         match turn_id {
             Ok(turn_id) => {
-                let thread_state = self.thread_state_manager.thread_state(thread_id);
+                let thread_state = self.thread_state_manager.thread_state(thread_id).await;
                 let mut thread_state = thread_state.lock().await;
                 thread_state.set_reply_relay_cwd(relay_cwd);
                 if let Some(prompt) = relay_prompt {

codex-rs/app-server/src/codex_message_processor.rs

@@ -406,6 +406,7 @@ fn start_uninitialized(args: InProcessStartArgs) -> InProcessClientHandle {
                 cloud_requirements: args.cloud_requirements,
                 feedback: args.feedback,
                 log_db: None,
+                telegram_reply_relay: None,
                 config_warnings: args.config_warnings,
                 session_source: args.session_source,
                 enable_codex_api_key_env: args.enable_codex_api_key_env,

codex-rs/app-server/src/in_process.rs

@@ -13,6 +13,7 @@ use codex_app_server_protocol::DynamicToolCallOutputContentItem;
 use codex_app_server_protocol::DynamicToolCallResponse;
 use codex_app_server_protocol::FileChangeApprovalDecision;
 use codex_app_server_protocol::FileChangeRequestApprovalResponse;
+use codex_app_server_protocol::GrantedPermissionProfile;
 use codex_app_server_protocol::InitializeCapabilities;
 use codex_app_server_protocol::InitializeParams;
 use codex_app_server_protocol::InitializeResponse;
@@ -22,14 +23,16 @@ use codex_app_server_protocol::JSONRPCMessage;
 use codex_app_server_protocol::JSONRPCNotification;
 use codex_app_server_protocol::JSONRPCRequest;
 use codex_app_server_protocol::JSONRPCResponse;
+use codex_app_server_protocol::McpServerElicitationAction;
+use codex_app_server_protocol::McpServerElicitationRequestResponse;
 use codex_app_server_protocol::Model;
 use codex_app_server_protocol::ModelListParams;
 use codex_app_server_protocol::ModelListResponse;
+use codex_app_server_protocol::PermissionGrantScope;
+use codex_app_server_protocol::PermissionsRequestApprovalResponse;
 use codex_app_server_protocol::RequestId;
 use codex_app_server_protocol::ServerNotification;
 use codex_app_server_protocol::ServerRequest;
-use codex_app_server_protocol::SkillApprovalDecision;
-use codex_app_server_protocol::SkillRequestApprovalResponse;
 use codex_app_server_protocol::ThreadItem;
 use codex_app_server_protocol::ThreadResumeParams;
 use codex_app_server_protocol::ThreadResumeResponse;
@@ -142,6 +145,7 @@ impl AppServerClient {
             params: Some(
                 serde_json::to_value(params).context("serialize `turn/interrupt` params")?,
             ),
+            trace: None,
         });
         self.write_jsonrpc_message(request)
     }
@@ -316,13 +320,11 @@ impl AppServerClient {
                 let response = FileChangeRequestApprovalResponse { decision };
                 self.send_response(request_id, response)
             }
-            Ok(ServerRequest::SkillRequestApproval { request_id, .. }) => {
-                let decision = if approvals.auto_approve_commands {
-                    SkillApprovalDecision::Approve
-                } else {
-                    SkillApprovalDecision::Decline
+            Ok(ServerRequest::PermissionsRequestApproval { request_id, .. }) => {
+                let response = PermissionsRequestApprovalResponse {
+                    permissions: GrantedPermissionProfile::default(),
+                    scope: PermissionGrantScope::Turn,
                 };
-                let response = SkillRequestApprovalResponse { decision };
                 self.send_response(request_id, response)
             }
             Ok(ServerRequest::ToolRequestUserInput { request_id, params }) => {
@@ -344,6 +346,14 @@ impl AppServerClient {
                 let response = ToolRequestUserInputResponse { answers };
                 self.send_response(request_id, response)
             }
+            Ok(ServerRequest::McpServerElicitationRequest { request_id, .. }) => {
+                let response = McpServerElicitationRequestResponse {
+                    action: McpServerElicitationAction::Cancel,
+                    content: None,
+                    meta: None,
+                };
+                self.send_response(request_id, response)
+            }
             Ok(ServerRequest::DynamicToolCall { request_id, .. }) => {
                 let response = DynamicToolCallResponse {
                     content_items: vec![DynamicToolCallOutputContentItem::InputText {
@@ -408,6 +418,7 @@ impl AppServerClient {
             id: request_id.clone(),
             method: method.to_string(),
             params: Some(serde_json::to_value(params).context("serialize request params")?),
+            trace: None,
         });
         self.write_jsonrpc_message(request)?;
 

codex-rs/bridges/core/src/app_server.rs

@@ -693,7 +693,7 @@ async fn run_exec_session(args: ExecRunArgs) -> anyhow::Result<()> {
                     params: TurnStartParams {
                         thread_id: primary_thread_id_for_span.clone(),
                         input: items.into_iter().map(Into::into).collect(),
-                        cwd: Some(default_cwd),
+                        cwd: Some(default_cwd.clone()),
                         approval_policy: Some(default_approval_policy.into()),
                         sandbox_policy: Some(default_sandbox_policy.clone().into()),
                         model: None,