cai
2026-08-11 dc98e7dbb2e909beab577f287da8dccac374c714
test(asr): exercise origin status production boundary
2 files modified
20 ■■■■■ changed files
src/asr_realtime.rs 4 ●●●● patch | view | raw | blame | history
src/main.rs 16 ●●●●● patch | view | raw | blame | history
src/asr_realtime.rs
@@ -586,11 +586,11 @@
            AudioIngressMetadata::rejection_status("invalid_source_or_sequence")
        );
        assert_eq!(
            "sequence_replayed_or_regressed",
            "origin_unprovable",
            AudioIngressMetadata::rejection_status("sequence_replayed")
        );
        assert_eq!(
            "wrong_participant_or_track",
            "origin_unprovable",
            AudioIngressMetadata::rejection_status("wrong_participant")
        );
        assert_eq!(
src/main.rs
@@ -4095,11 +4095,7 @@
#[cfg(test)]
mod tests {
    use super::{
        ReplyChunkMarker, ReplyChunkMarkerState, RuntimeTurnDeviceOutput, RuntimeTurnStreamEvent,
        RuntimeTurnStreamState, RuntimeTurnStreamTimingPhase, runtime_session_nonce_hash,
        should_publish_device_output,
    };
    use super::*;
    use std::{
        collections::HashSet,
        io::{Read, Write},
@@ -4336,15 +4332,13 @@
        let second_request = request_rx
            .recv_timeout(Duration::from_secs(2))
            .expect("second session request");
        assert!(first_request.contains("\\\"clientFixtureSequence\\\":\\\"fixture-01\\\""));
        assert!(second_request.contains("\\\"clientFixtureSequence\\\":\\\"fixture-02\\\""));
        assert!(first_request.contains("\"clientFixtureSequence\":\"fixture-01\""));
        assert!(second_request.contains("\"clientFixtureSequence\":\"fixture-02\""));
        assert!(
            first_request
                .contains("\\\"audioIngressOriginStatus\\\":\\\"controlled_fixture_bound\\\"")
            first_request.contains("\"audioIngressOriginStatus\":\"controlled_fixture_bound\"")
        );
        assert!(
            second_request
                .contains("\\\"audioIngressOriginStatus\\\":\\\"controlled_fixture_bound\\\"")
            second_request.contains("\"audioIngressOriginStatus\":\"controlled_fixture_bound\"")
        );
        // The same production boundary rejects a wrong participant before VAD/session creation.
        assert!(!is_bound_user_participant(