From 6197847e7a2776ccf96e0d65febd95ace84a511a Mon Sep 17 00:00:00 2001 From: viyatb-oai Date: Wed, 3 Jun 2026 12:29:18 -0700 Subject: [PATCH] fix: annotate relay sequence test arguments Co-authored-by: Codex noreply@openai.com --- .../noise_relay/ordered_ciphertext_tests.rs | 20 +++++++++++-------- 1 file changed, 12 insertions(+), 8 deletions(-) diff --git a/codex-rs/exec-server/src/noise_relay/ordered_ciphertext_tests.rs b/codex-rs/exec-server/src/noise_relay/ordered_ciphertext_tests.rs index 97f2c1a9ba..6aa86fcdf0 100644 --- a/codex-rs/exec-server/src/noise_relay/ordered_ciphertext_tests.rs +++ b/codex-rs/exec-server/src/noise_relay/ordered_ciphertext_tests.rs @@ -8,11 +8,11 @@ fn releases_ciphertexts_only_in_nonce_order() { let mut frames = OrderedCiphertextFrames::default(); assert_eq!( - frames.push(1, b"second".to_vec()).unwrap(), + frames.push(/*seq*/ 1, b"second".to_vec()).unwrap(), Vec::>::new() ); assert_eq!( - frames.push(0, b"first".to_vec()).unwrap(), + frames.push(/*seq*/ 0, b"first".to_vec()).unwrap(), vec![b"first".to_vec(), b"second".to_vec()] ); } @@ -22,19 +22,19 @@ fn ignores_duplicate_ciphertexts_without_replacing_buffered_record() { let mut frames = OrderedCiphertextFrames::default(); assert_eq!( - frames.push(1, b"first copy".to_vec()).unwrap(), + frames.push(/*seq*/ 1, b"first copy".to_vec()).unwrap(), Vec::>::new() ); assert_eq!( - frames.push(1, b"replacement".to_vec()).unwrap(), + frames.push(/*seq*/ 1, b"replacement".to_vec()).unwrap(), Vec::>::new() ); assert_eq!( - frames.push(0, b"zero".to_vec()).unwrap(), + frames.push(/*seq*/ 0, b"zero".to_vec()).unwrap(), vec![b"zero".to_vec(), b"first copy".to_vec()] ); assert_eq!( - frames.push(0, b"duplicate".to_vec()).unwrap(), + frames.push(/*seq*/ 0, b"duplicate".to_vec()).unwrap(), Vec::>::new() ); } @@ -43,6 +43,10 @@ fn ignores_duplicate_ciphertexts_without_replacing_buffered_record() { fn rejects_unbounded_reordering() { let mut frames = OrderedCiphertextFrames::default(); - assert!(frames.push(65, Vec::new()).is_err()); - assert!(frames.push(1, vec![0; MAX_PENDING_BYTES + 1]).is_err()); + assert!(frames.push(/*seq*/ 65, Vec::new()).is_err()); + assert!( + frames + .push(/*seq*/ 1, vec![0; MAX_PENDING_BYTES + 1]) + .is_err() + ); }