From dbb73f5406a884a108d2498bb40501e9a876c52d Mon Sep 17 00:00:00 2001
From: cai <cai@nbcai.cc>
Date: Tue, 11 Aug 2026 18:44:12 +0800
Subject: [PATCH] feat(asr): record audio ingress origin status
---
src/main.rs | 20 ++++++++++++++++----
1 files changed, 16 insertions(+), 4 deletions(-)
diff --git a/src/main.rs b/src/main.rs
index d49fd28..01bee3e 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -809,6 +809,7 @@
turn_bridge_config.clone(),
http.clone(),
sink.clone(),
+ user_participant_identity.clone(),
participant,
);
}
@@ -2921,6 +2922,7 @@
turn_bridge_config: TurnBridgeConfig,
http: Client,
sink: Arc<BotAudioOutputSink>,
+ expected_participant_identity: Option<String>,
participant: RemoteParticipant,
) -> JoinHandle<()> {
tokio::spawn(async move {
@@ -3037,7 +3039,7 @@
let participant_identity = participant.identity().to_string();
let (was_in_speech, is_in_speech, turn) = observe_bound_participant_frame(
&participant_identity,
- Some(&participant_identity),
+ expected_participant_identity.as_deref(),
vad,
&call_id,
&trace_id,
@@ -3273,11 +3275,13 @@
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, origin_status, "runtime helper asr_realtime_metadata_rejected");
return;
}
};
@@ -3305,7 +3309,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 => {
@@ -4328,6 +4332,14 @@
.expect("second session request");
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