fix(gpt-5.3-codex-spark): support tool call arguments in done event without deltas (#2558)

Co-authored-by: autofix-ci[bot] <114827586+autofix-ci[bot]@users.noreply.github.com>

Author: amitksingh1490

crates/forge_domain/src/retry_config.rs

@@ -42,7 +42,7 @@ impl Default for RetryConfig {
             min_delay_ms: 1000,
             backoff_factor: 2,
             max_retry_attempts: 8,
-            retry_status_codes: vec![429, 500, 502, 503, 504, 408, 522],
+            retry_status_codes: vec![429, 500, 502, 503, 504, 408, 522, 520],
             max_delay: None,
             suppress_retry_errors: false,
         }
@@ -71,7 +71,7 @@ mod tests {
         assert_eq!(config.max_retry_attempts, 8);
         assert_eq!(
             config.retry_status_codes,
-            vec![429, 500, 502, 503, 504, 408, 522]
+            vec![429, 500, 502, 503, 504, 408, 522, 520]
         );
         assert_eq!(config.suppress_retry_errors, false);
     }

crates/forge_infra/src/http.rs

@@ -33,7 +33,7 @@ fn to_reqwest_tls(tls: TlsVersion) -> reqwest::tls::Version {
     }
 }
 
-impl<F> ForgeHttpInfra<F> {
+impl<F: forge_app::FileWriterInfra + 'static> ForgeHttpInfra<F> {
     pub fn new(env: Environment, file_writer: Arc<F>) -> Self {
         let env = env.clone();
         let env_http = env.clone();
@@ -118,6 +118,8 @@ impl<F> ForgeHttpInfra<F> {
         let mut request_headers = self.headers(headers);
         request_headers.insert("Content-Type", HeaderValue::from_static("application/json"));
 
+        self.write_debug_request(&body);
+
         self.execute_request("POST", url, |client| {
             client.post(url.clone()).headers(request_headers).body(body)
         })
@@ -202,6 +204,17 @@ impl<F> ForgeHttpInfra<F> {
 }
 
 impl<F: forge_app::FileWriterInfra + 'static> ForgeHttpInfra<F> {
+    fn write_debug_request(&self, body: &Bytes) {
+        if let Some(debug_path) = &self.env.debug_requests {
+            let file_writer = self.file.clone();
+            let body_clone = body.clone();
+            let debug_path = debug_path.clone();
+            tokio::spawn(async move {
+                let _ = file_writer.write(&debug_path, body_clone).await;
+            });
+        }
+    }
+
     async fn eventsource(
         &self,
         url: &Url,
@@ -211,15 +224,7 @@ impl<F: forge_app::FileWriterInfra + 'static> ForgeHttpInfra<F> {
         let mut request_headers = self.headers(headers);
         request_headers.insert("Content-Type", HeaderValue::from_static("application/json"));
 
-        if let Some(debug_path) = &self.env.debug_requests {
-            let file_writer = self.file.clone();
-            let body_clone = body.clone();
-            let debug_path = debug_path.clone();
-            tokio::spawn(async move {
-                // Use debug_path if parent dir can be created, otherwise use fallback
-                let _ = file_writer.write(&debug_path, body_clone).await;
-            });
-        }
+        self.write_debug_request(&body);
 
         self.client
             .post(url.clone())
@@ -385,6 +390,53 @@ mod tests {
         assert_eq!(writes[0].1, body);
     }
 
+    #[tokio::test]
+    async fn test_debug_requests_post_none_does_not_write() {
+        let file_writer = MockFileWriter::new();
+        let env = create_test_env(None);
+        let http = ForgeHttpInfra::new(env, Arc::new(file_writer.clone()));
+
+        let body = Bytes::from("test request body");
+        let url = Url::parse("http://127.0.0.1:9/responses").unwrap();
+
+        let _ = http.post(&url, None, body).await;
+
+        // Give async task time to complete
+        tokio::time::sleep(tokio::time::Duration::from_millis(100)).await;
+
+        let writes = file_writer.get_writes().await;
+        assert_eq!(
+            writes.len(),
+            0,
+            "No files should be written for POST when debug_requests is None"
+        );
+    }
+
+    #[tokio::test]
+    async fn test_debug_requests_post_writes_body() {
+        let file_writer = MockFileWriter::new();
+        let debug_path = PathBuf::from("/tmp/forge-test/debug-post.json");
+        let env = create_test_env(Some(debug_path.clone()));
+        let http = ForgeHttpInfra::new(env, Arc::new(file_writer.clone()));
+
+        let body = Bytes::from("test request body");
+        let url = Url::parse("http://127.0.0.1:9/responses").unwrap();
+
+        let _ = http.post(&url, None, body.clone()).await;
+
+        // Give async task time to complete
+        tokio::time::sleep(tokio::time::Duration::from_millis(100)).await;
+
+        let writes = file_writer.get_writes().await;
+        assert_eq!(
+            writes.len(),
+            1,
+            "Should write one file for POST when debug_requests is set"
+        );
+        assert_eq!(writes[0].0, debug_path);
+        assert_eq!(writes[0].1, body);
+    }
+
     #[tokio::test]
     async fn test_debug_requests_fallback_on_dir_creation_failure() {
         let file_writer = MockFileWriter::new();

crates/forge_repo/src/provider/openai_responses/repository.rs

@@ -1022,7 +1022,7 @@ mod tests {
 
         assert_eq!(
             repo.retry_config.retry_status_codes,
-            vec![429, 500, 502, 503, 504, 408, 522]
+            vec![429, 500, 502, 503, 504, 408, 522, 520]
         );
     }