From 594d7aa3f24cc5a5fa6a12f68718cd2851059bac Mon Sep 17 00:00:00 2001
From: cai <cai@nbcai.cc>
Date: Tue, 11 Aug 2026 21:30:36 +0800
Subject: [PATCH] test(helper): cover pre-audio probe order
---
src/asr_realtime.rs | 60 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 60 insertions(+), 0 deletions(-)
diff --git a/src/asr_realtime.rs b/src/asr_realtime.rs
index e12cf08..ad99ff2 100644
--- a/src/asr_realtime.rs
+++ b/src/asr_realtime.rs
@@ -37,6 +37,17 @@
}
impl AudioIngressMetadata {
+ pub(crate) const ORIGIN_STATUSES: [&'static str; 8] = [
+ "controlled_fixture_bound",
+ "ordinary_mic_absent",
+ "participant_attributes_absent",
+ "participant_attributes_invalid",
+ "sequence_absent",
+ "sequence_replayed_or_regressed",
+ "wrong_participant_or_track",
+ "origin_unprovable",
+ ];
+
pub(crate) fn origin_status(attributes: &HashMap<String, String>) -> &'static str {
let source = attributes.get("inputSourceCategory").map(String::as_str);
let sequence = attributes.get("clientFixtureSequence").map(String::as_str);
@@ -48,6 +59,26 @@
(Some("controlled_fixture"), None) => "sequence_absent",
(Some("controlled_fixture"), Some(_)) => "participant_attributes_invalid",
(Some(_), _) | (None, Some(_)) => "participant_attributes_invalid",
+ }
+ }
+
+ pub(crate) fn rejection_status(reason: &str) -> &'static str {
+ match reason {
+ "incomplete_metadata" => "participant_attributes_absent",
+ "invalid_source_or_sequence" => "participant_attributes_invalid",
+ _ => "origin_unprovable",
+ }
+ }
+
+ pub(crate) fn rejected_origin_status(
+ reason: &str,
+ attributes: &HashMap<String, String>,
+ ) -> &'static str {
+ let status = Self::origin_status(attributes);
+ if status == "sequence_absent" {
+ status
+ } else {
+ Self::rejection_status(reason)
}
}
@@ -558,6 +589,35 @@
"ordinary_mic_absent",
AudioIngressMetadata::origin_status(&HashMap::new())
);
+ assert_eq!(
+ "participant_attributes_absent",
+ AudioIngressMetadata::rejection_status("incomplete_metadata")
+ );
+ assert_eq!(
+ "participant_attributes_invalid",
+ AudioIngressMetadata::rejection_status("invalid_source_or_sequence")
+ );
+ assert_eq!(
+ "origin_unprovable",
+ AudioIngressMetadata::rejection_status("sequence_replayed")
+ );
+ assert_eq!(
+ "origin_unprovable",
+ AudioIngressMetadata::rejection_status("wrong_participant")
+ );
+ assert_eq!(
+ "origin_unprovable",
+ AudioIngressMetadata::rejection_status("unknown")
+ );
+ let missing_sequence = HashMap::from([(
+ "inputSourceCategory".to_string(),
+ "controlled_fixture".to_string(),
+ )]);
+ assert_eq!(
+ "sequence_absent",
+ AudioIngressMetadata::rejected_origin_status("incomplete_metadata", &missing_sequence)
+ );
+ assert_eq!(8, AudioIngressMetadata::ORIGIN_STATUSES.len());
}
#[test]
--
Gitblit v1.9.3