From 18f3d31052e32ddcb719fdc1ae856f8b86772920 Mon Sep 17 00:00:00 2001
From: cai <cai@nbcai.cc>
Date: Tue, 11 Aug 2026 19:08:39 +0800
Subject: [PATCH] fix(asr): preserve missing fixture sequence status
---
src/main.rs | 52 ++++++++++++++++++++++++++++++++++++++++------------
1 files changed, 40 insertions(+), 12 deletions(-)
diff --git a/src/main.rs b/src/main.rs
index 3c5ccc7..9950573 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -3285,7 +3285,9 @@
Ok(metadata) => metadata,
Err(reason) => {
warn!(call_id = %call_id, trace_id = %trace_id, turn_id = %turn_id,
- reason, audioIngressOriginStatus = %AudioIngressMetadata::rejection_status(reason),
+ reason, audioIngressOriginStatus = %AudioIngressMetadata::rejected_origin_status(
+ reason, &attributes
+ ),
"runtime helper asr_realtime_metadata_rejected");
return;
}
@@ -4095,11 +4097,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 +4334,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(
@@ -4439,6 +4435,38 @@
);
assert!(upload.is_none());
vad.reset_current_turn();
+ attrs.remove("clientFixtureSequence");
+ let (_, _, missing_sequence_turn) = observe_bound_participant_frame(
+ "participant-user",
+ Some("participant-user"),
+ &mut vad,
+ "call-001",
+ "trace-001",
+ "participant-user",
+ "track-001",
+ 6,
+ 6_000,
+ &frame,
+ Client::new(),
+ RealtimeAsrConfig {
+ enabled: true,
+ url: Some(format!("http://{address}/runtime/asr/realtime")),
+ runtime_token: Some("test".to_string()),
+ runtime_session_nonce: Some("test".to_string()),
+ chunk_duration_ms: 200,
+ },
+ || attrs.clone(),
+ &mut upload,
+ &mut last_fixture_sequence,
+ true,
+ );
+ assert!(missing_sequence_turn.is_none() && upload.is_none());
+ assert_eq!(
+ "sequence_absent",
+ AudioIngressMetadata::rejected_origin_status("incomplete_metadata", &attrs)
+ );
+ assert_eq!(2, captured_count.load(Ordering::SeqCst));
+ vad.reset_current_turn();
attrs.insert("inputSourceCategory".to_string(), "other".to_string());
let mut invalid_upload = None;
let (_, _, invalid_turn) = observe_bound_participant_frame(
--
Gitblit v1.9.3