1use super::evaluator::ConditionResult;
8
9pub use super::timezone::{dst_transitions_between, is_mesz_utc, is_mez_utc, parse_dtm303};
11pub use super::werktag::{
12 compute_easter, is_german_holiday, is_werktag, parse_ccyymmdd_prefix, werktage_between,
13};
14
15pub fn validate_max_decimal_places(value: &str, max: usize) -> ConditionResult {
26 if value.is_empty() {
27 return ConditionResult::Unknown;
28 }
29 let decimal_places = match value.find('.') {
30 Some(pos) => value.len() - pos - 1,
31 None => 0,
32 };
33 ConditionResult::from(decimal_places <= max)
34}
35
36pub fn validate_max_integer_digits(value: &str, max: usize) -> ConditionResult {
40 if value.is_empty() {
41 return ConditionResult::Unknown;
42 }
43 let s = value.strip_prefix('-').unwrap_or(value);
44 let integer_part = match s.find('.') {
45 Some(pos) => &s[..pos],
46 None => s,
47 };
48 ConditionResult::from(integer_part.len() <= max)
49}
50
51pub fn validate_numeric(value: &str, op: &str, threshold: f64) -> ConditionResult {
63 if value.is_empty() {
64 return ConditionResult::Unknown;
65 }
66 let parsed = match edifact_number(value) {
67 Some(v) => v,
68 None => return ConditionResult::False,
69 };
70 let result = match op {
71 "==" => (parsed - threshold).abs() < f64::EPSILON,
72 "!=" => (parsed - threshold).abs() >= f64::EPSILON,
73 ">" => parsed > threshold,
74 ">=" => parsed >= threshold,
75 "<" => parsed < threshold,
76 "<=" => parsed <= threshold,
77 _ => return ConditionResult::Unknown,
78 };
79 ConditionResult::from(result)
80}
81
82pub fn is_edifact_number(value: &str) -> bool {
86 edifact_number(value).is_some()
87}
88
89fn edifact_number(value: &str) -> Option<f64> {
92 let unsigned = value.strip_prefix('-').unwrap_or(value);
93 let mut marks = 0;
94 let mut digits = 0;
95 for c in unsigned.chars() {
96 match c {
97 '0'..='9' => digits += 1,
98 '.' | ',' => marks += 1,
99 _ => return None,
100 }
101 }
102 if digits == 0 || marks > 1 {
103 return None;
104 }
105 value.replace(',', ".").parse().ok()
106}
107
108pub fn validate_hhmm_equals(dtm_value: &str, expected_hhmm: &str) -> ConditionResult {
117 if dtm_value.len() < 12 {
118 return ConditionResult::False;
120 }
121 ConditionResult::from(&dtm_value[8..12] == expected_hhmm)
122}
123
124pub fn validate_hhmm_range(dtm_value: &str, min: &str, max: &str) -> ConditionResult {
128 if dtm_value.len() < 12 {
129 return ConditionResult::False;
130 }
131 let hhmm = &dtm_value[8..12];
132 ConditionResult::from(hhmm >= min && hhmm <= max)
133}
134
135pub fn validate_mmddhhmm_equals(dtm_value: &str, expected: &str) -> ConditionResult {
141 if dtm_value.len() < 12 {
142 return ConditionResult::False;
143 }
144 ConditionResult::from(&dtm_value[4..12] == expected)
145}
146
147pub fn validate_timezone_utc(dtm_value: &str) -> ConditionResult {
158 if dtm_value.len() < 15 || !dtm_value.is_char_boundary(dtm_value.len() - 3) {
159 return ConditionResult::False;
161 }
162 ConditionResult::from(&dtm_value[dtm_value.len() - 3..] == "+00")
163}
164
165pub fn validate_email(value: &str) -> ConditionResult {
171 if value.is_empty() {
172 return ConditionResult::Unknown;
173 }
174 ConditionResult::from(value.contains('@') && value.contains('.'))
175}
176
177pub fn validate_phone(value: &str) -> ConditionResult {
182 if value.is_empty() {
183 return ConditionResult::Unknown;
184 }
185 if !value.starts_with('+') || value.len() < 2 {
186 return ConditionResult::from(false);
187 }
188 ConditionResult::from(value[1..].chars().all(|c| c.is_ascii_digit()))
189}
190
191pub fn validate_malo_id(value: &str) -> ConditionResult {
205 if value.len() != 11 {
206 return ConditionResult::from(false);
207 }
208 if !value.chars().all(|c| c.is_ascii_digit()) {
209 return ConditionResult::from(false);
210 }
211 let digits: Vec<u32> = value.chars().filter_map(|c| c.to_digit(10)).collect();
212 let check = digits[10];
213 let mut sum = 0u32;
214 for (i, &d) in digits[..10].iter().enumerate() {
215 if (i + 1) % 2 == 0 {
217 sum += 2 * d;
218 } else {
219 sum += d;
220 }
221 }
222 let expected = (10 - (sum % 10)) % 10;
223 ConditionResult::from(check == expected)
224}
225
226pub fn validate_tr_id(value: &str) -> ConditionResult {
228 if value.is_empty() {
229 return ConditionResult::Unknown;
230 }
231 ConditionResult::from(value.len() <= 35 && value.chars().all(|c| c.is_ascii_alphanumeric()))
232}
233
234fn validate_prefixed_location_id(value: &str, prefix: char) -> ConditionResult {
237 let mut chars = value.chars();
238 ConditionResult::from(
239 value.len() == 11
240 && chars.next() == Some(prefix)
241 && chars.all(|c| c.is_ascii_digit() || c.is_ascii_uppercase()),
242 )
243}
244
245pub fn validate_sr_id(value: &str) -> ConditionResult {
248 validate_prefixed_location_id(value, 'C')
249}
250
251pub fn validate_nelo_id(value: &str) -> ConditionResult {
253 validate_prefixed_location_id(value, 'E')
254}
255
256pub fn parse_obis(value: &str) -> Option<(u32, u32)> {
273 let value = value.trim();
274 let (_ab, cde) = value.split_once(':')?;
276 let cde = cde.split('*').next()?;
278 let mut parts = cde.split('.');
279 let c = parts.next()?.parse::<u32>().ok()?;
280 let d = parts.next()?.parse::<u32>().ok()?;
281 Some((c, d))
282}
283
284pub fn is_obis_wirkarbeit_kumuliert(value: &str) -> bool {
290 matches!(parse_obis(value), Some((1 | 2, 8 | 9)))
291}
292
293pub fn is_obis_wirkarbeit_quarter_hour(value: &str) -> bool {
300 matches!(parse_obis(value), Some((1 | 2, 29)))
301}
302
303pub fn validate_x509_cert_body(value: &str) -> ConditionResult {
322 let trimmed = value.trim();
323 if trimmed.is_empty() {
324 return ConditionResult::Unknown;
325 }
326 let body = trimmed
329 .trim_start_matches("-----BEGIN CERTIFICATE-----")
330 .trim_end_matches("-----END CERTIFICATE-----")
331 .trim();
332 let chars_ok = body.chars().all(|c| {
333 c.is_ascii_alphanumeric() || matches!(c, '+' | '/' | '=' | '\n' | '\r' | '\t' | ' ')
334 });
335 let len_ok = body.chars().filter(|c| !c.is_whitespace()).count() >= 100;
338 ConditionResult::from(chars_ok && len_ok)
339}
340
341pub fn validate_zahlpunkt(value: &str) -> ConditionResult {
343 if value.len() != 33 {
344 return ConditionResult::from(false);
345 }
346 ConditionResult::from(value.chars().all(|c| c.is_ascii_alphanumeric()))
347}
348
349pub fn validate_malo_or_zahlpunkt(value: &str) -> ConditionResult {
351 if value.len() == 11 && validate_malo_id(value).is_true() {
352 return ConditionResult::True;
353 }
354 if value.len() == 33 && validate_zahlpunkt(value).is_true() {
355 return ConditionResult::True;
356 }
357 ConditionResult::False
358}
359
360pub fn validate_artikel_pattern(value: &str, segment_lengths: &[usize]) -> ConditionResult {
369 if value.is_empty() {
370 return ConditionResult::Unknown;
371 }
372 let parts: Vec<&str> = value.split('-').collect();
373 if parts.len() != segment_lengths.len() {
374 return ConditionResult::from(false);
375 }
376 let valid = parts
377 .iter()
378 .zip(segment_lengths.iter())
379 .all(|(part, &expected_len)| {
380 part.len() == expected_len && part.chars().all(|c| c.is_ascii_digit())
381 });
382 ConditionResult::from(valid)
383}
384
385pub fn validate_exact_length(value: &str, expected: usize) -> ConditionResult {
389 if value.is_empty() {
390 return ConditionResult::Unknown;
391 }
392 ConditionResult::from(value.len() == expected)
393}
394
395pub fn validate_max_length(value: &str, max: usize) -> ConditionResult {
397 if value.is_empty() {
398 return ConditionResult::Unknown;
399 }
400 ConditionResult::from(value.len() <= max)
401}
402
403pub fn validate_all_digits(value: &str) -> ConditionResult {
405 if value.is_empty() {
406 return ConditionResult::Unknown;
407 }
408 ConditionResult::from(value.chars().all(|c| c.is_ascii_digit()))
409}
410
411pub fn utc_now_ccyymmddhhmm() -> String {
413 chrono::Utc::now().format("%Y%m%d%H%M").to_string()
414}
415
416#[cfg(test)]
417mod tests {
418 use super::*;
419
420 #[test]
423 fn test_max_decimal_places() {
424 assert_eq!(
425 validate_max_decimal_places("123.45", 2),
426 ConditionResult::True
427 );
428 assert_eq!(
429 validate_max_decimal_places("123.456", 2),
430 ConditionResult::False
431 );
432 assert_eq!(validate_max_decimal_places("123", 2), ConditionResult::True);
433 assert_eq!(validate_max_decimal_places("0.1", 3), ConditionResult::True);
434 assert_eq!(validate_max_decimal_places("", 2), ConditionResult::Unknown);
435 }
436
437 #[test]
438 fn test_no_decimal_places() {
439 assert_eq!(validate_max_decimal_places("100", 0), ConditionResult::True);
440 assert_eq!(
441 validate_max_decimal_places("100.5", 0),
442 ConditionResult::False
443 );
444 }
445
446 #[test]
447 fn test_max_integer_digits() {
448 assert_eq!(
449 validate_max_integer_digits("1234", 4),
450 ConditionResult::True
451 );
452 assert_eq!(
453 validate_max_integer_digits("12345", 4),
454 ConditionResult::False
455 );
456 assert_eq!(
457 validate_max_integer_digits("-123.45", 4),
458 ConditionResult::True
459 );
460 assert_eq!(validate_max_integer_digits("", 4), ConditionResult::Unknown);
461 }
462
463 #[test]
466 fn test_validate_numeric() {
467 assert_eq!(validate_numeric("5.0", ">=", 0.0), ConditionResult::True);
468 assert_eq!(validate_numeric("-1.0", ">=", 0.0), ConditionResult::False);
469 assert_eq!(validate_numeric("1", "==", 1.0), ConditionResult::True);
470 assert_eq!(validate_numeric("2", "==", 1.0), ConditionResult::False);
471 assert_eq!(validate_numeric("0", ">", 0.0), ConditionResult::False);
472 assert_eq!(validate_numeric("1", ">", 0.0), ConditionResult::True);
473 assert_eq!(validate_numeric("abc", ">=", 0.0), ConditionResult::False);
476 assert_eq!(
477 validate_numeric("O5D2DXBG1A", ">", 0.0),
478 ConditionResult::False
479 );
480 assert_eq!(validate_numeric("NaN", ">", 0.0), ConditionResult::False);
481 assert_eq!(validate_numeric("inf", ">", 0.0), ConditionResult::False);
482 assert_eq!(validate_numeric("1e3", ">", 0.0), ConditionResult::False);
483 assert_eq!(validate_numeric("0,5", ">", 0.0), ConditionResult::True);
485 assert_eq!(validate_numeric("-2", "<=", 0.0), ConditionResult::True);
486 assert_eq!(validate_numeric("", ">", 0.0), ConditionResult::Unknown);
487 }
488
489 #[test]
492 fn test_hhmm_equals() {
493 assert_eq!(
494 validate_hhmm_equals("202601012200+00", "2200"),
495 ConditionResult::True
496 );
497 assert_eq!(
498 validate_hhmm_equals("202601012300+00", "2200"),
499 ConditionResult::False
500 );
501 assert_eq!(
502 validate_hhmm_equals("short", "2200"),
503 ConditionResult::False
504 );
505 }
506
507 #[test]
508 fn test_hhmm_range() {
509 assert_eq!(
510 validate_hhmm_range("202601011530+00", "0000", "2359"),
511 ConditionResult::True
512 );
513 assert_eq!(
514 validate_hhmm_range("202601010000+00", "0000", "2359"),
515 ConditionResult::True
516 );
517 assert_eq!(
518 validate_hhmm_range("202601012359+00", "0000", "2359"),
519 ConditionResult::True
520 );
521 }
522
523 #[test]
524 fn test_mmddhhmm_equals() {
525 assert_eq!(
526 validate_mmddhhmm_equals("202612312300+00", "12312300"),
527 ConditionResult::True
528 );
529 assert_eq!(
530 validate_mmddhhmm_equals("202601012200+00", "12312300"),
531 ConditionResult::False
532 );
533 }
534
535 #[test]
536 fn test_timezone_utc() {
537 assert_eq!(
538 validate_timezone_utc("202601012200+00"),
539 ConditionResult::True
540 );
541 assert_eq!(
542 validate_timezone_utc("202601012200+01"),
543 ConditionResult::False
544 );
545 assert_eq!(
546 validate_timezone_utc("202601012200"),
547 ConditionResult::False
548 );
549 assert_eq!(
551 validate_timezone_utc("20260101220000+00"),
552 ConditionResult::True
553 );
554 assert_eq!(
555 validate_timezone_utc("20260101220000+01"),
556 ConditionResult::False
557 );
558 }
559
560 #[test]
563 fn test_email() {
564 assert_eq!(validate_email("user@example.com"), ConditionResult::True);
565 assert_eq!(validate_email("nope"), ConditionResult::False);
566 assert_eq!(validate_email("has@but-no-dot"), ConditionResult::False);
567 assert_eq!(validate_email(""), ConditionResult::Unknown);
568 }
569
570 #[test]
571 fn test_phone() {
572 assert_eq!(validate_phone("+4930123456"), ConditionResult::True);
573 assert_eq!(validate_phone("030123456"), ConditionResult::False);
574 assert_eq!(validate_phone("+"), ConditionResult::False);
575 assert_eq!(validate_phone("+49 30 123"), ConditionResult::False); assert_eq!(validate_phone(""), ConditionResult::Unknown);
577 }
578
579 #[test]
582 fn test_malo_id() {
583 assert_eq!(validate_malo_id("51238696781"), ConditionResult::True);
587 assert_eq!(validate_malo_id("41373559241"), ConditionResult::True);
588 assert_eq!(validate_malo_id("56789012345"), ConditionResult::True);
589 assert_eq!(validate_malo_id("52935155442"), ConditionResult::True);
590
591 assert_eq!(validate_malo_id("41373559240"), ConditionResult::False); assert_eq!(validate_malo_id("512386967890"), ConditionResult::False); assert_eq!(validate_malo_id("1234567890"), ConditionResult::False); assert_eq!(validate_malo_id("abcdefghijk"), ConditionResult::False); }
597
598 #[test]
599 fn test_zahlpunkt() {
600 let valid = "DE0001234567890123456789012345678";
601 assert_eq!(valid.len(), 33);
602 assert_eq!(validate_zahlpunkt(valid), ConditionResult::True);
603 assert_eq!(validate_zahlpunkt("tooshort"), ConditionResult::False);
604 }
605
606 #[test]
609 fn test_artikel_pattern() {
610 assert_eq!(
611 validate_artikel_pattern("1-23-4", &[1, 2, 1]),
612 ConditionResult::True
613 );
614 assert_eq!(
615 validate_artikel_pattern("1-23-4-567", &[1, 2, 1, 3]),
616 ConditionResult::True
617 );
618 assert_eq!(
619 validate_artikel_pattern("1-23-4-56", &[1, 2, 1, 3]),
620 ConditionResult::False
621 );
622 assert_eq!(
623 validate_artikel_pattern("1-AB-4", &[1, 2, 1]),
624 ConditionResult::False
625 );
626 assert_eq!(
627 validate_artikel_pattern("", &[1, 2, 1]),
628 ConditionResult::Unknown
629 );
630 }
631
632 #[test]
635 fn test_tr_id() {
636 assert_eq!(validate_tr_id("ABC123"), ConditionResult::True);
637 assert_eq!(validate_tr_id("A"), ConditionResult::True);
638 assert_eq!(validate_tr_id(&"A".repeat(35)), ConditionResult::True);
639 assert_eq!(validate_tr_id(&"A".repeat(36)), ConditionResult::False);
640 assert_eq!(validate_tr_id("has spaces"), ConditionResult::False);
641 assert_eq!(validate_tr_id("has-dash"), ConditionResult::False);
642 assert_eq!(validate_tr_id(""), ConditionResult::Unknown);
643 }
644
645 #[test]
646 fn test_parse_obis() {
647 assert_eq!(parse_obis("1-1:1.8.0"), Some((1, 8)));
648 assert_eq!(parse_obis("1-1:2.29.0"), Some((2, 29)));
649 assert_eq!(parse_obis("1-0:1.8.0*255"), Some((1, 8))); assert_eq!(parse_obis(" 1-1:1.8.0 "), Some((1, 8))); assert_eq!(parse_obis("no-colon"), None);
652 assert_eq!(parse_obis("1-1:abc.8.0"), None);
653 assert_eq!(parse_obis(""), None);
654 }
655
656 #[test]
657 fn test_obis_wirkarbeit_kumuliert() {
658 assert!(is_obis_wirkarbeit_kumuliert("1-1:1.8.0"));
660 assert!(is_obis_wirkarbeit_kumuliert("1-1:2.8.0"));
661 assert!(is_obis_wirkarbeit_kumuliert("1-1:1.9.0"));
662 assert!(is_obis_wirkarbeit_kumuliert("1-1:2.9.0"));
663 assert!(is_obis_wirkarbeit_kumuliert("1-0:1.8.0*255"));
664 assert!(!is_obis_wirkarbeit_kumuliert("1-1:3.8.0"));
666 assert!(!is_obis_wirkarbeit_kumuliert("1-1:4.8.0"));
667 assert!(!is_obis_wirkarbeit_kumuliert("1-1:1.29.0"));
669 assert!(!is_obis_wirkarbeit_kumuliert("1-1:1.5.0"));
671 }
672
673 #[test]
674 fn test_obis_wirkarbeit_quarter_hour() {
675 assert!(is_obis_wirkarbeit_quarter_hour("1-1:1.29.0"));
677 assert!(is_obis_wirkarbeit_quarter_hour("1-1:2.29.0"));
678 assert!(is_obis_wirkarbeit_quarter_hour("1-0:1.29.0*255"));
679 assert!(!is_obis_wirkarbeit_quarter_hour("1-1:1.8.0"));
681 assert!(!is_obis_wirkarbeit_quarter_hour("1-1:1.9.0"));
682 assert!(!is_obis_wirkarbeit_quarter_hour("1-1:3.29.0"));
684 }
685
686 #[test]
687 fn test_x509_cert_body() {
688 let body = "A".repeat(600);
690 assert_eq!(validate_x509_cert_body(&body), ConditionResult::True);
691
692 let pem_body = "A".repeat(64) + "\n" + &"B".repeat(64) + "\n" + &"C".repeat(64);
694 assert_eq!(validate_x509_cert_body(&pem_body), ConditionResult::True);
695
696 let armored = format!(
698 "-----BEGIN CERTIFICATE-----\n{}\n-----END CERTIFICATE-----",
699 "A".repeat(200)
700 );
701 assert_eq!(validate_x509_cert_body(&armored), ConditionResult::True);
702
703 let with_punct = "AB+/==".to_string() + &"A".repeat(200);
705 assert_eq!(validate_x509_cert_body(&with_punct), ConditionResult::True);
706
707 assert_eq!(validate_x509_cert_body("QUJD"), ConditionResult::False);
709
710 let invalid_chars = "A".repeat(200) + "!@#";
712 assert_eq!(
713 validate_x509_cert_body(&invalid_chars),
714 ConditionResult::False
715 );
716
717 assert_eq!(validate_x509_cert_body(""), ConditionResult::Unknown);
719 assert_eq!(validate_x509_cert_body(" \n "), ConditionResult::Unknown);
720 }
721
722 #[test]
726 fn test_sr_id() {
727 for real in ["C816417ST77", "CZZ6M5DGSS5", "COPFWS2EX96"] {
728 assert_eq!(validate_sr_id(real), ConditionResult::True, "{real}");
729 }
730 assert_eq!(
731 validate_sr_id("51238696781"),
732 ConditionResult::False,
733 "a MaLo-ID"
734 );
735 assert_eq!(validate_sr_id("C12345"), ConditionResult::False);
736 assert_eq!(validate_sr_id(""), ConditionResult::False);
737 }
738
739 #[test]
743 fn test_nelo_id() {
744 for real in ["E1688117482", "EU5UQAWW8D0", "EEW7TM7V906"] {
745 assert_eq!(validate_nelo_id(real), ConditionResult::True, "{real}");
746 }
747 assert_eq!(
748 validate_nelo_id("51238696781"),
749 ConditionResult::False,
750 "a MaLo-ID"
751 );
752 assert_eq!(validate_nelo_id("E123"), ConditionResult::False);
753 assert_eq!(validate_nelo_id("e1688117482"), ConditionResult::False);
754 }
755
756 #[test]
759 fn test_exact_length() {
760 assert_eq!(
761 validate_exact_length("1234567890123456", 16),
762 ConditionResult::True
763 );
764 assert_eq!(validate_exact_length("123", 16), ConditionResult::False);
765 assert_eq!(validate_exact_length("", 16), ConditionResult::Unknown);
766 }
767
768 #[test]
769 fn test_all_digits() {
770 assert_eq!(validate_all_digits("12345"), ConditionResult::True);
771 assert_eq!(validate_all_digits("123a5"), ConditionResult::False);
772 assert_eq!(validate_all_digits(""), ConditionResult::Unknown);
773 }
774}