| | |
| | | } |
| | | |
| | | 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); |
| | |
| | | (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", |
| | | } |
| | | } |
| | | |
| | |
| | | "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") |
| | | ); |
| | | assert_eq!(8, AudioIngressMetadata::ORIGIN_STATUSES.len()); |
| | | } |
| | | |
| | | #[test] |