fix(chatgpt): retry transient WebSocket response failures

Cargo.toml

@@ -49,7 +49,7 @@ agentkit-loop = { version = "=0.10.13", features = ["otel"] }
 agentkit-mcp = "=0.10.7"
 agentkit-http = "=0.10.7"
 agentkit-plugins = "=0.10.7"
-agentkit-provider-openai = "=0.10.12"
+agentkit-provider-openai = "=0.10.13"
 agentkit-provider-openrouter = "=0.10.8"
 agentkit-task-manager = "=0.10.7"
 agentkit-tool-compose = { version = "=0.10.12", default-features = false, features = ["runlet"] }

src/provider/chatgpt/websocket_tests.rs

@@ -502,6 +502,39 @@ async fn subscription_retries_reach_the_session_retry_observer() {
     assert!(retries.load(std::sync::atomic::Ordering::SeqCst) > 0);
 }
 
+#[tokio::test]
+async fn subscription_retries_correlated_transient_response_failure() {
+    let (endpoint, peer) = server(|listener| {
+        let mut failed = tungstenite::accept(accept(&listener)).unwrap();
+        receive(&mut failed, false);
+        failed
+            .send(Message::Text(response("failed", "")[0].to_string().into()))
+            .unwrap();
+        failed
+            .send(Message::Text(
+                json!({
+                    "type": "response.failed",
+                    "response": {
+                        "id": "failed",
+                        "error": {"type": "server_error", "code": "server_error", "status": 503}
+                    }
+                })
+                .to_string()
+                .into(),
+            ))
+            .unwrap();
+        // Keep the failed socket open: recovery must follow the terminal event,
+        // not a transport disconnect. The replacement sends the full request.
+        let mut fresh = tungstenite::accept(accept(&listener)).unwrap();
+        receive(&mut fresh, false);
+        success(&mut fresh, "retried", "first answer");
+    });
+    let mut session = session_with_retries(&endpoint, 1).await;
+    let mut turn = begin(&mut session, false).await;
+    finished(&mut turn, "retried", "first answer").await;
+    peer.join().unwrap();
+}
+
 #[tokio::test]
 async fn subscription_auto_426_fallback_stays_http_for_future_turns() {
     let (endpoint, peer) = server(|listener| {