clone/codex
1
0
Fork 0
mirror of https://github.com/openai/codex.git synced 2026-04-24 06:35:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

codex: fix CI failure on PR #16960

Browse Source 
Co-authored-by: Codex <noreply@openai.com>
This commit is contained in:
Ahmed Ibrahim
2026-04-06 18:37:22 -07:00
parent de3ff8f081
commit cd942fb802
2 changed files with 18 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
codex-rs/app-server/tests/suite/v2/realtime_conversation.rs
View File

@@ -64,7 +64,10 @@ impl RealtimeCallRequestCapture {
}
fn single_request(&self) -> WiremockRequest {
let requests = self.requests.lock().unwrap();
let requests = self
.requests
.lock()
.unwrap_or_else(std::sync::PoisonError::into_inner);
assert_eq!(requests.len(), 1, "expected one realtime call request");
requests[0].clone()
}
@@ -72,7 +75,10 @@ impl RealtimeCallRequestCapture {
impl Match for RealtimeCallRequestCapture {
fn matches(&self, request: &WiremockRequest) -> bool {
self.requests.lock().unwrap().push(request.clone());
self.requests
.lock()
.unwrap_or_else(std::sync::PoisonError::into_inner)
.push(request.clone());
true
}
}
@@ -465,7 +471,7 @@ async fn realtime_call_create_returns_offer() -> Result<()> {
let request = call_capture.single_request();
assert_eq!(request.url.path(), "/v1/realtime/calls");
assert_eq!(request.url.query(), None);
let body = String::from_utf8(request.body.clone()).context("multipart body should be utf-8")?;
let body = String::from_utf8(request.body).context("multipart body should be utf-8")?;
assert!(body.contains("Content-Disposition: form-data; name=\"sdp\""));
assert!(body.contains("v=offer\r\n"));
assert!(body.contains("Content-Disposition: form-data; name=\"session\""));

12
codex-rs/core/tests/suite/realtime_conversation.rs
View File

@@ -64,7 +64,10 @@ impl RealtimeCallRequestCapture {
}
fn single_request(&self) -> WiremockRequest {
let requests = self.requests.lock().unwrap();
let requests = self
.requests
.lock()
.unwrap_or_else(std::sync::PoisonError::into_inner);
assert_eq!(requests.len(), 1, "expected one realtime call request");
requests[0].clone()
}
@@ -72,7 +75,10 @@ impl RealtimeCallRequestCapture {
impl Match for RealtimeCallRequestCapture {
fn matches(&self, request: &WiremockRequest) -> bool {
self.requests.lock().unwrap().push(request.clone());
self.requests
.lock()
.unwrap_or_else(std::sync::PoisonError::into_inner)
.push(request.clone());
true
}
}
@@ -381,7 +387,7 @@ async fn conversation_call_create_posts_generated_session() -> Result<()> {
.and_then(|value| value.to_str().ok()),
Some("multipart/form-data; boundary=codex-realtime-call-boundary")
);
let body = String::from_utf8(request.body.clone()).context("multipart body should be utf-8")?;
let body = String::from_utf8(request.body).context("multipart body should be utf-8")?;
assert!(body.contains("Content-Disposition: form-data; name=\"sdp\""));
assert!(body.contains("v=offer\r\n"));
assert!(body.contains("Content-Disposition: form-data; name=\"session\""));