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 {
61 let parsed = match value.parse::<f64>() {
62 Ok(v) => v,
63 Err(_) => return ConditionResult::Unknown,
64 };
65 let result = match op {
66 "==" => (parsed - threshold).abs() < f64::EPSILON,
67 "!=" => (parsed - threshold).abs() >= f64::EPSILON,
68 ">" => parsed > threshold,
69 ">=" => parsed >= threshold,
70 "<" => parsed < threshold,
71 "<=" => parsed <= threshold,
72 _ => return ConditionResult::Unknown,
73 };
74 ConditionResult::from(result)
75}
76
77pub fn validate_hhmm_equals(dtm_value: &str, expected_hhmm: &str) -> ConditionResult {
86 if dtm_value.len() < 12 {
87 return ConditionResult::False;
89 }
90 ConditionResult::from(&dtm_value[8..12] == expected_hhmm)
91}
92
93pub fn validate_hhmm_range(dtm_value: &str, min: &str, max: &str) -> ConditionResult {
97 if dtm_value.len() < 12 {
98 return ConditionResult::False;
99 }
100 let hhmm = &dtm_value[8..12];
101 ConditionResult::from(hhmm >= min && hhmm <= max)
102}
103
104pub fn validate_mmddhhmm_equals(dtm_value: &str, expected: &str) -> ConditionResult {
110 if dtm_value.len() < 12 {
111 return ConditionResult::False;
112 }
113 ConditionResult::from(&dtm_value[4..12] == expected)
114}
115
116pub fn validate_timezone_utc(dtm_value: &str) -> ConditionResult {
124 if dtm_value.len() < 15 {
125 return ConditionResult::False;
127 }
128 ConditionResult::from(&dtm_value[12..] == "+00")
129}
130
131pub fn validate_email(value: &str) -> ConditionResult {
137 if value.is_empty() {
138 return ConditionResult::Unknown;
139 }
140 ConditionResult::from(value.contains('@') && value.contains('.'))
141}
142
143pub fn validate_phone(value: &str) -> ConditionResult {
148 if value.is_empty() {
149 return ConditionResult::Unknown;
150 }
151 if !value.starts_with('+') || value.len() < 2 {
152 return ConditionResult::from(false);
153 }
154 ConditionResult::from(value[1..].chars().all(|c| c.is_ascii_digit()))
155}
156
157pub fn validate_malo_id(value: &str) -> ConditionResult {
171 if value.len() != 11 {
172 return ConditionResult::from(false);
173 }
174 if !value.chars().all(|c| c.is_ascii_digit()) {
175 return ConditionResult::from(false);
176 }
177 let digits: Vec<u32> = value.chars().filter_map(|c| c.to_digit(10)).collect();
178 let check = digits[10];
179 let mut sum = 0u32;
180 for (i, &d) in digits[..10].iter().enumerate() {
181 if (i + 1) % 2 == 0 {
183 sum += 2 * d;
184 } else {
185 sum += d;
186 }
187 }
188 let expected = (10 - (sum % 10)) % 10;
189 ConditionResult::from(check == expected)
190}
191
192pub fn validate_tr_id(value: &str) -> ConditionResult {
194 if value.is_empty() {
195 return ConditionResult::Unknown;
196 }
197 ConditionResult::from(value.len() <= 35 && value.chars().all(|c| c.is_ascii_alphanumeric()))
198}
199
200pub fn validate_sr_id(value: &str) -> ConditionResult {
202 validate_malo_id(value)
203}
204
205pub fn parse_obis(value: &str) -> Option<(u32, u32)> {
222 let value = value.trim();
223 let (_ab, cde) = value.split_once(':')?;
225 let cde = cde.split('*').next()?;
227 let mut parts = cde.split('.');
228 let c = parts.next()?.parse::<u32>().ok()?;
229 let d = parts.next()?.parse::<u32>().ok()?;
230 Some((c, d))
231}
232
233pub fn is_obis_wirkarbeit_kumuliert(value: &str) -> bool {
239 matches!(parse_obis(value), Some((1 | 2, 8 | 9)))
240}
241
242pub fn is_obis_wirkarbeit_quarter_hour(value: &str) -> bool {
249 matches!(parse_obis(value), Some((1 | 2, 29)))
250}
251
252pub fn validate_x509_cert_body(value: &str) -> ConditionResult {
271 let trimmed = value.trim();
272 if trimmed.is_empty() {
273 return ConditionResult::Unknown;
274 }
275 let body = trimmed
278 .trim_start_matches("-----BEGIN CERTIFICATE-----")
279 .trim_end_matches("-----END CERTIFICATE-----")
280 .trim();
281 let chars_ok = body.chars().all(|c| {
282 c.is_ascii_alphanumeric()
283 || matches!(c, '+' | '/' | '=' | '\n' | '\r' | '\t' | ' ')
284 });
285 let len_ok = body.chars().filter(|c| !c.is_whitespace()).count() >= 100;
288 ConditionResult::from(chars_ok && len_ok)
289}
290
291pub fn validate_zahlpunkt(value: &str) -> ConditionResult {
293 if value.len() != 33 {
294 return ConditionResult::from(false);
295 }
296 ConditionResult::from(value.chars().all(|c| c.is_ascii_alphanumeric()))
297}
298
299pub fn validate_malo_or_zahlpunkt(value: &str) -> ConditionResult {
301 if value.len() == 11 && validate_malo_id(value).is_true() {
302 return ConditionResult::True;
303 }
304 if value.len() == 33 && validate_zahlpunkt(value).is_true() {
305 return ConditionResult::True;
306 }
307 ConditionResult::False
308}
309
310pub fn validate_artikel_pattern(value: &str, segment_lengths: &[usize]) -> ConditionResult {
319 if value.is_empty() {
320 return ConditionResult::Unknown;
321 }
322 let parts: Vec<&str> = value.split('-').collect();
323 if parts.len() != segment_lengths.len() {
324 return ConditionResult::from(false);
325 }
326 let valid = parts
327 .iter()
328 .zip(segment_lengths.iter())
329 .all(|(part, &expected_len)| {
330 part.len() == expected_len && part.chars().all(|c| c.is_ascii_digit())
331 });
332 ConditionResult::from(valid)
333}
334
335pub fn validate_exact_length(value: &str, expected: usize) -> ConditionResult {
339 if value.is_empty() {
340 return ConditionResult::Unknown;
341 }
342 ConditionResult::from(value.len() == expected)
343}
344
345pub fn validate_max_length(value: &str, max: usize) -> ConditionResult {
347 if value.is_empty() {
348 return ConditionResult::Unknown;
349 }
350 ConditionResult::from(value.len() <= max)
351}
352
353pub fn validate_all_digits(value: &str) -> ConditionResult {
355 if value.is_empty() {
356 return ConditionResult::Unknown;
357 }
358 ConditionResult::from(value.chars().all(|c| c.is_ascii_digit()))
359}
360
361pub fn utc_now_ccyymmddhhmm() -> String {
363 chrono::Utc::now().format("%Y%m%d%H%M").to_string()
364}
365
366#[cfg(test)]
367mod tests {
368 use super::*;
369
370 #[test]
373 fn test_max_decimal_places() {
374 assert_eq!(
375 validate_max_decimal_places("123.45", 2),
376 ConditionResult::True
377 );
378 assert_eq!(
379 validate_max_decimal_places("123.456", 2),
380 ConditionResult::False
381 );
382 assert_eq!(validate_max_decimal_places("123", 2), ConditionResult::True);
383 assert_eq!(validate_max_decimal_places("0.1", 3), ConditionResult::True);
384 assert_eq!(validate_max_decimal_places("", 2), ConditionResult::Unknown);
385 }
386
387 #[test]
388 fn test_no_decimal_places() {
389 assert_eq!(validate_max_decimal_places("100", 0), ConditionResult::True);
390 assert_eq!(
391 validate_max_decimal_places("100.5", 0),
392 ConditionResult::False
393 );
394 }
395
396 #[test]
397 fn test_max_integer_digits() {
398 assert_eq!(
399 validate_max_integer_digits("1234", 4),
400 ConditionResult::True
401 );
402 assert_eq!(
403 validate_max_integer_digits("12345", 4),
404 ConditionResult::False
405 );
406 assert_eq!(
407 validate_max_integer_digits("-123.45", 4),
408 ConditionResult::True
409 );
410 assert_eq!(validate_max_integer_digits("", 4), ConditionResult::Unknown);
411 }
412
413 #[test]
416 fn test_validate_numeric() {
417 assert_eq!(validate_numeric("5.0", ">=", 0.0), ConditionResult::True);
418 assert_eq!(validate_numeric("-1.0", ">=", 0.0), ConditionResult::False);
419 assert_eq!(validate_numeric("1", "==", 1.0), ConditionResult::True);
420 assert_eq!(validate_numeric("2", "==", 1.0), ConditionResult::False);
421 assert_eq!(validate_numeric("0", ">", 0.0), ConditionResult::False);
422 assert_eq!(validate_numeric("1", ">", 0.0), ConditionResult::True);
423 assert_eq!(validate_numeric("abc", ">=", 0.0), ConditionResult::Unknown);
424 }
425
426 #[test]
429 fn test_hhmm_equals() {
430 assert_eq!(
431 validate_hhmm_equals("202601012200+00", "2200"),
432 ConditionResult::True
433 );
434 assert_eq!(
435 validate_hhmm_equals("202601012300+00", "2200"),
436 ConditionResult::False
437 );
438 assert_eq!(
439 validate_hhmm_equals("short", "2200"),
440 ConditionResult::False
441 );
442 }
443
444 #[test]
445 fn test_hhmm_range() {
446 assert_eq!(
447 validate_hhmm_range("202601011530+00", "0000", "2359"),
448 ConditionResult::True
449 );
450 assert_eq!(
451 validate_hhmm_range("202601010000+00", "0000", "2359"),
452 ConditionResult::True
453 );
454 assert_eq!(
455 validate_hhmm_range("202601012359+00", "0000", "2359"),
456 ConditionResult::True
457 );
458 }
459
460 #[test]
461 fn test_mmddhhmm_equals() {
462 assert_eq!(
463 validate_mmddhhmm_equals("202612312300+00", "12312300"),
464 ConditionResult::True
465 );
466 assert_eq!(
467 validate_mmddhhmm_equals("202601012200+00", "12312300"),
468 ConditionResult::False
469 );
470 }
471
472 #[test]
473 fn test_timezone_utc() {
474 assert_eq!(
475 validate_timezone_utc("202601012200+00"),
476 ConditionResult::True
477 );
478 assert_eq!(
479 validate_timezone_utc("202601012200+01"),
480 ConditionResult::False
481 );
482 assert_eq!(
483 validate_timezone_utc("202601012200"),
484 ConditionResult::False
485 );
486 }
487
488 #[test]
491 fn test_email() {
492 assert_eq!(validate_email("user@example.com"), ConditionResult::True);
493 assert_eq!(validate_email("nope"), ConditionResult::False);
494 assert_eq!(validate_email("has@but-no-dot"), ConditionResult::False);
495 assert_eq!(validate_email(""), ConditionResult::Unknown);
496 }
497
498 #[test]
499 fn test_phone() {
500 assert_eq!(validate_phone("+4930123456"), ConditionResult::True);
501 assert_eq!(validate_phone("030123456"), ConditionResult::False);
502 assert_eq!(validate_phone("+"), ConditionResult::False);
503 assert_eq!(validate_phone("+49 30 123"), ConditionResult::False); assert_eq!(validate_phone(""), ConditionResult::Unknown);
505 }
506
507 #[test]
510 fn test_malo_id() {
511 assert_eq!(validate_malo_id("51238696781"), ConditionResult::True);
515 assert_eq!(validate_malo_id("41373559241"), ConditionResult::True);
516 assert_eq!(validate_malo_id("56789012345"), ConditionResult::True);
517 assert_eq!(validate_malo_id("52935155442"), ConditionResult::True);
518
519 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); }
525
526 #[test]
527 fn test_zahlpunkt() {
528 let valid = "DE0001234567890123456789012345678";
529 assert_eq!(valid.len(), 33);
530 assert_eq!(validate_zahlpunkt(valid), ConditionResult::True);
531 assert_eq!(validate_zahlpunkt("tooshort"), ConditionResult::False);
532 }
533
534 #[test]
537 fn test_artikel_pattern() {
538 assert_eq!(
539 validate_artikel_pattern("1-23-4", &[1, 2, 1]),
540 ConditionResult::True
541 );
542 assert_eq!(
543 validate_artikel_pattern("1-23-4-567", &[1, 2, 1, 3]),
544 ConditionResult::True
545 );
546 assert_eq!(
547 validate_artikel_pattern("1-23-4-56", &[1, 2, 1, 3]),
548 ConditionResult::False
549 );
550 assert_eq!(
551 validate_artikel_pattern("1-AB-4", &[1, 2, 1]),
552 ConditionResult::False
553 );
554 assert_eq!(
555 validate_artikel_pattern("", &[1, 2, 1]),
556 ConditionResult::Unknown
557 );
558 }
559
560 #[test]
563 fn test_tr_id() {
564 assert_eq!(validate_tr_id("ABC123"), ConditionResult::True);
565 assert_eq!(validate_tr_id("A"), ConditionResult::True);
566 assert_eq!(validate_tr_id(&"A".repeat(35)), ConditionResult::True);
567 assert_eq!(validate_tr_id(&"A".repeat(36)), ConditionResult::False);
568 assert_eq!(validate_tr_id("has spaces"), ConditionResult::False);
569 assert_eq!(validate_tr_id("has-dash"), ConditionResult::False);
570 assert_eq!(validate_tr_id(""), ConditionResult::Unknown);
571 }
572
573 #[test]
574 fn test_parse_obis() {
575 assert_eq!(parse_obis("1-1:1.8.0"), Some((1, 8)));
576 assert_eq!(parse_obis("1-1:2.29.0"), Some((2, 29)));
577 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);
580 assert_eq!(parse_obis("1-1:abc.8.0"), None);
581 assert_eq!(parse_obis(""), None);
582 }
583
584 #[test]
585 fn test_obis_wirkarbeit_kumuliert() {
586 assert!(is_obis_wirkarbeit_kumuliert("1-1:1.8.0"));
588 assert!(is_obis_wirkarbeit_kumuliert("1-1:2.8.0"));
589 assert!(is_obis_wirkarbeit_kumuliert("1-1:1.9.0"));
590 assert!(is_obis_wirkarbeit_kumuliert("1-1:2.9.0"));
591 assert!(is_obis_wirkarbeit_kumuliert("1-0:1.8.0*255"));
592 assert!(!is_obis_wirkarbeit_kumuliert("1-1:3.8.0"));
594 assert!(!is_obis_wirkarbeit_kumuliert("1-1:4.8.0"));
595 assert!(!is_obis_wirkarbeit_kumuliert("1-1:1.29.0"));
597 assert!(!is_obis_wirkarbeit_kumuliert("1-1:1.5.0"));
599 }
600
601 #[test]
602 fn test_obis_wirkarbeit_quarter_hour() {
603 assert!(is_obis_wirkarbeit_quarter_hour("1-1:1.29.0"));
605 assert!(is_obis_wirkarbeit_quarter_hour("1-1:2.29.0"));
606 assert!(is_obis_wirkarbeit_quarter_hour("1-0:1.29.0*255"));
607 assert!(!is_obis_wirkarbeit_quarter_hour("1-1:1.8.0"));
609 assert!(!is_obis_wirkarbeit_quarter_hour("1-1:1.9.0"));
610 assert!(!is_obis_wirkarbeit_quarter_hour("1-1:3.29.0"));
612 }
613
614 #[test]
615 fn test_x509_cert_body() {
616 let body = "A".repeat(600);
618 assert_eq!(validate_x509_cert_body(&body), ConditionResult::True);
619
620 let pem_body = "A".repeat(64) + "\n" + &"B".repeat(64) + "\n" + &"C".repeat(64);
622 assert_eq!(validate_x509_cert_body(&pem_body), ConditionResult::True);
623
624 let armored = format!(
626 "-----BEGIN CERTIFICATE-----\n{}\n-----END CERTIFICATE-----",
627 "A".repeat(200)
628 );
629 assert_eq!(validate_x509_cert_body(&armored), ConditionResult::True);
630
631 let with_punct = "AB+/==".to_string() + &"A".repeat(200);
633 assert_eq!(validate_x509_cert_body(&with_punct), ConditionResult::True);
634
635 assert_eq!(validate_x509_cert_body("QUJD"), ConditionResult::False);
637
638 let invalid_chars = "A".repeat(200) + "!@#";
640 assert_eq!(
641 validate_x509_cert_body(&invalid_chars),
642 ConditionResult::False
643 );
644
645 assert_eq!(validate_x509_cert_body(""), ConditionResult::Unknown);
647 assert_eq!(validate_x509_cert_body(" \n "), ConditionResult::Unknown);
648 }
649
650 #[test]
651 fn test_sr_id() {
652 assert_eq!(validate_sr_id("51238696781"), ConditionResult::True);
655 assert_eq!(validate_sr_id("41373559240"), ConditionResult::False);
656 assert_eq!(validate_sr_id("1234567890"), ConditionResult::False);
657 assert_eq!(validate_sr_id(""), ConditionResult::False);
658 }
659
660 #[test]
663 fn test_exact_length() {
664 assert_eq!(
665 validate_exact_length("1234567890123456", 16),
666 ConditionResult::True
667 );
668 assert_eq!(validate_exact_length("123", 16), ConditionResult::False);
669 assert_eq!(validate_exact_length("", 16), ConditionResult::Unknown);
670 }
671
672 #[test]
673 fn test_all_digits() {
674 assert_eq!(validate_all_digits("12345"), ConditionResult::True);
675 assert_eq!(validate_all_digits("123a5"), ConditionResult::False);
676 assert_eq!(validate_all_digits(""), ConditionResult::Unknown);
677 }
678}