From dc98e7dbb2e909beab577f287da8dccac374c714 Mon Sep 17 00:00:00 2001
From: cai <cai@nbcai.cc>
Date: Tue, 11 Aug 2026 19:00:19 +0800
Subject: [PATCH] test(asr): exercise origin status production boundary
---
src/main.rs | 30 ++++++++++++++++++++----------
1 files changed, 20 insertions(+), 10 deletions(-)
diff --git a/src/main.rs b/src/main.rs
index a3aec30..b880777 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -3243,6 +3243,10 @@
F: FnOnce() -> std::collections::HashMap<String, String>,
{
if !is_bound_user_participant(participant_identity, expected_participant) {
+ warn!(
+ "audioIngressOriginStatus" = "wrong_participant_or_track",
+ "runtime helper rejected audio participant before VAD/session"
+ );
return (vad.in_speech, vad.in_speech, None);
}
observe_frame_and_start_session(
@@ -3275,11 +3279,14 @@
realtime_enabled: bool,
) {
let turn_id = format!("turn-{:04}", vad.turn_index);
- let metadata = match AudioIngressMetadata::from_participant(&read_attributes()) {
+ let attributes = read_attributes();
+ let origin_status = AudioIngressMetadata::origin_status(&attributes);
+ let metadata = match AudioIngressMetadata::from_participant(&attributes) {
Ok(metadata) => metadata,
Err(reason) => {
warn!(call_id = %call_id, trace_id = %trace_id, turn_id = %turn_id,
- reason, "runtime helper asr_realtime_metadata_rejected");
+ reason, audioIngressOriginStatus = %AudioIngressMetadata::rejection_status(reason),
+ "runtime helper asr_realtime_metadata_rejected");
return;
}
};
@@ -3289,6 +3296,7 @@
&metadata.client_fixture_sequence,
) {
warn!(call_id = %call_id, trace_id = %trace_id, turn_id = %turn_id,
+ audioIngressOriginStatus = "sequence_replayed_or_regressed",
"runtime helper asr_realtime_metadata_sequence_rejected");
return;
}
@@ -3307,7 +3315,7 @@
*last_fixture_sequence = Some(metadata.client_fixture_sequence);
}
info!(call_id = %call_id, trace_id = %trace_id, turn_id = %turn_id,
- "runtime helper asr_realtime_session_started");
+ origin_status, "runtime helper asr_realtime_session_started");
*upload_slot = Some(upload);
}
Err(error) if realtime_enabled => {
@@ -4087,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},
@@ -4328,8 +4332,14 @@
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\"")
+ );
+ assert!(
+ second_request.contains("\"audioIngressOriginStatus\":\"controlled_fixture_bound\"")
+ );
// The same production boundary rejects a wrong participant before VAD/session creation.
assert!(!is_bound_user_participant(
"participant-other",
--
Gitblit v1.9.3