Add controlled fixture ACK observability

cai

2026-08-12 9eca12eae4372c79eb35cef972f1ab4756c0a5e0

 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]