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() + ); }