openai/codex
1
0
Fork 0
mirror of https://github.com/openai/codex.git synced 2026-11-14 21:40:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

code-mode: annotate host request ids

Browse Source
This commit is contained in:
Channing Conger
2026-06-25 01:03:58 +00:00
parent 464273e64d
commit 1886ad6344
1 changed files with 13 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
codex-rs/code-mode-host/src/host_tests.rs
+13 -7
View File
@@ -61,7 +61,10 @@ async fn handshake_and_multiple_session_lifecycles_are_ordered() {
)))
);
for (request_id, id) in [(request_id(1), "session-1"), (request_id(2), "session-2")] {
for (request_id, id) in [
(request_id(/*value*/ 1), "session-1"),
(request_id(/*value*/ 2), "session-2"),
] {
writer
.write(&ClientToHost::Request {
id: request_id,
@@ -84,7 +87,10 @@ async fn handshake_and_multiple_session_lifecycles_are_ordered() {
);
}
for (request_id, id) in [(request_id(3), "session-1"), (request_id(4), "session-2")] {
for (request_id, id) in [
(request_id(/*value*/ 3), "session-1"),
(request_id(/*value*/ 4), "session-2"),
] {
writer
.write(&ClientToHost::Request {
id: request_id,
@@ -145,7 +151,7 @@ async fn incompatible_or_invalid_handshake_is_rejected() {
let mut writer = FramedWriter::new(client_writer);
writer
.write(&ClientToHost::Request {
id: request_id(1),
id: request_id(/*value*/ 1),
request: HostRequest::OpenSession {
session_id: session_id("session-1"),
},
@@ -210,13 +216,13 @@ async fn session_id_cannot_be_reused_after_shutdown() {
let id = session_id("session-1");
for (request_id, request) in [
(
request_id(1),
request_id(/*value*/ 1),
HostRequest::OpenSession {
session_id: id.clone(),
},
),
(
request_id(2),
request_id(/*value*/ 2),
HostRequest::ShutdownSession {
session_id: id.clone(),
},
@@ -237,7 +243,7 @@ async fn session_id_cannot_be_reused_after_shutdown() {
}
writer
.write(&ClientToHost::Request {
id: request_id(3),
id: request_id(/*value*/ 3),
request: HostRequest::OpenSession { session_id: id },
})
.await
@@ -245,7 +251,7 @@ async fn session_id_cannot_be_reused_after_shutdown() {
assert_eq!(
reader.read::<HostToClient>().await.expect("reuse response"),
Some(HostToClient::Response {
id: request_id(3),
id: request_id(/*value*/ 3),
result: WireResult::Err {
message: "code-mode session ID `session-1` was reused".to_string(),
},