openai/codex
1
0
Fork 0
mirror of https://github.com/openai/codex.git synced 2026-11-05 20:10:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(code-mode): allow coalesced notifications

Browse Source
This commit is contained in:
Channing Conger
2026-06-26 18:56:12 +00:00
parent eeb2bd19ad
commit 650bfd8c49
1 changed files with 26 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
codex-rs/core/tests/suite/code_mode_canonical_script.rs
+26 -4
View File
@@ -299,8 +299,11 @@ void tool_call_d().then(() => text("D res"), () => {});
let first_frame_request = first_frame_mock.single_request();
let first_outputs = exec_outputs(&first_frame_request, "call-1");
assert_eq!(first_outputs.len(), 1);
let first_items = output_items(&first_outputs[0]);
let first_items = output_items(
first_outputs
.first()
.expect("first response should contain the yielded exec output"),
);
assert_eq!(first_items.len(), 2);
super::assert_regex_match(
concat!(
@@ -312,12 +315,31 @@ void tool_call_d().then(() => text("D res"), () => {});
assert_eq!(text_item(&first_items, /*index*/ 1), "hello world");
let cell_id = extract_running_cell_id(text_item(&first_items, /*index*/ 0));
let notification_request = notification_mock.single_request();
let notification_outputs = exec_outputs(&notification_request, "call-1");
let notification_requests = notification_mock.requests();
// The notification may join the yielded output in the first request or be drained into a
// separate request, depending on pending-input drain timing.
let notification_outputs = match notification_requests.as_slice() {
[] => {
assert_eq!(first_outputs.len(), 2);
first_outputs
}
[notification_request] => {
assert_eq!(first_outputs.len(), 1);
let notification_outputs = exec_outputs(notification_request, "call-1");
assert_eq!(notification_outputs.first(), first_outputs.first());
notification_outputs
}
requests => panic!(
"expected at most one separate notification response request, got {}",
requests.len()
),
};
assert_eq!(notification_outputs.len(), 2);
assert_eq!(notification_outputs[1]["name"], "exec");
assert_eq!(notification_outputs[1]["output"], "boo");
server.reset().await;
responses::mount_sse_once(
&server,
sse(vec![