From 4fdc8e81244e5611519710c81c322b5a0aff43c2 Mon Sep 17 00:00:00 2001 From: Ahmed Ibrahim Date: Fri, 22 May 2026 17:07:48 -0700 Subject: [PATCH] codex: fix CI failure on PR #24142 --- .../app-server/tests/suite/v2/analytics.rs | 32 ------------------- 1 file changed, 32 deletions(-) diff --git a/codex-rs/app-server/tests/suite/v2/analytics.rs b/codex-rs/app-server/tests/suite/v2/analytics.rs index c6f95af95d..c4a48f8caf 100644 --- a/codex-rs/app-server/tests/suite/v2/analytics.rs +++ b/codex-rs/app-server/tests/suite/v2/analytics.rs @@ -98,28 +98,6 @@ pub(crate) async fn mount_analytics_capture(server: &MockServer, codex_home: &Pa Ok(()) } -pub(crate) async fn wait_for_analytics_payload( - server: &MockServer, - read_timeout: Duration, -) -> Result { - let body = timeout(read_timeout, async { - loop { - let Some(requests) = server.received_requests().await else { - tokio::time::sleep(Duration::from_millis(25)).await; - continue; - }; - if let Some(request) = requests.iter().find(|request| { - request.method == "POST" && request.url.path() == "/codex/analytics-events/events" - }) { - break request.body.clone(); - } - tokio::time::sleep(Duration::from_millis(25)).await; - } - }) - .await?; - serde_json::from_slice(&body).map_err(|err| anyhow::anyhow!("invalid analytics payload: {err}")) -} - pub(crate) async fn wait_for_analytics_event( server: &MockServer, read_timeout: Duration, @@ -155,16 +133,6 @@ pub(crate) async fn wait_for_analytics_event( .await? } -pub(crate) fn thread_initialized_event(payload: &Value) -> Result<&Value> { - let events = payload["events"] - .as_array() - .ok_or_else(|| anyhow::anyhow!("analytics payload missing events array"))?; - events - .iter() - .find(|event| event["event_type"] == "codex_thread_initialized") - .ok_or_else(|| anyhow::anyhow!("codex_thread_initialized event should be present")) -} - pub(crate) fn assert_basic_thread_initialized_event( event: &Value, thread_id: &str,