1use crate::defaults::QUEUE_KEY_PREFIX;
2
3#[must_use]
4pub fn normalize_queue_name(queue_name: &str) -> String {
5 if queue_name.starts_with(QUEUE_KEY_PREFIX) {
6 queue_name.to_string()
7 } else {
8 format!("{QUEUE_KEY_PREFIX}{queue_name}")
9 }
10}
11
12#[cfg(test)]
13mod tests {
14 use super::normalize_queue_name;
15
16 #[test]
17 fn normalize_queue_name_adds_prefix_for_bare_names() {
18 assert_eq!(normalize_queue_name("default"), "rrq:queue:default");
19 }
20
21 #[test]
22 fn normalize_queue_name_preserves_prefixed_names() {
23 assert_eq!(
24 normalize_queue_name("rrq:queue:mail-ingest"),
25 "rrq:queue:mail-ingest"
26 );
27 }
28}