Skip to main content

automapper_validation/eval/
format_validators.rs

1//! Format validation helpers for AHB 900-series conditions.
2//!
3//! These validate the FORMAT of data element values (decimal places, numeric ranges,
4//! time patterns, ID formats, etc.). They operate on string values extracted from
5//! EDIFACT segments and return `ConditionResult`.
6
7use super::evaluator::ConditionResult;
8
9// Re-export timezone helpers so generated code can use `use crate::eval::format_validators::*`
10pub 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
15// --- Decimal/digit place validation ---
16
17/// Validate that a numeric string has at most `max` decimal places.
18///
19/// Returns `True` if the value has <= max decimal places (or no decimal point),
20/// `False` if it has more, `Unknown` if the value is empty.
21///
22/// Example: `validate_max_decimal_places("123.45", 2)` → True
23/// Example: `validate_max_decimal_places("123.456", 2)` → False
24/// Example: `validate_max_decimal_places("123", 2)` → True (no decimal → 0 places)
25pub 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
36/// Validate that a numeric string has at most `max` integer digits (before decimal point).
37///
38/// Ignores leading minus sign.
39pub 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
51// --- Numeric range validation ---
52
53/// Validate a numeric value against a comparison.
54///
55/// `op` is one of: "==", "!=", ">", ">=", "<", "<="
56/// An EDIFACT number is an optional sign, digits and at most one decimal mark
57/// (`.` or `,`, which the UNA may set). Anything else is no possible value and
58/// fails (`O5D2DXBG1A` is not "> 0"); only an empty value is `Unknown`.
59///
60/// Example: `validate_numeric(value, ">=", 0.0)` for "Wert >= 0"
61/// Example: `validate_numeric(value, "==", 1.0)` for "Wert = 1"
62pub 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
82/// Whether `value` is an EDIFACT number — what a data element of numeric
83/// format (`n..10`) may hold: an optional minus sign, at least one digit, and
84/// at most one decimal mark (`.` or `,`).
85pub fn is_edifact_number(value: &str) -> bool {
86    edifact_number(value).is_some()
87}
88
89/// `value` as an EDIFACT number: an optional sign, at least one digit, and at
90/// most one decimal mark (`.` or `,`). `None` for anything else (`1e3`, `NaN`).
91fn 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
108// --- DTM time/timezone validation ---
109
110/// Validate that a DTM value's HHMM portion equals the expected value.
111///
112/// DTM format 303 is CCYYMMDDHHMM (12 chars) or CCYYMMDDHHMMZZZ (15 chars with timezone).
113/// Extracts characters at positions 8..12 (HHMM) for comparison.
114///
115/// Example: `validate_hhmm_equals("202601012200+00", "2200")` → True
116pub fn validate_hhmm_equals(dtm_value: &str, expected_hhmm: &str) -> ConditionResult {
117    if dtm_value.len() < 12 {
118        // Value too short — no HHMM component present, condition is not met
119        return ConditionResult::False;
120    }
121    ConditionResult::from(&dtm_value[8..12] == expected_hhmm)
122}
123
124/// Validate that a DTM value's HHMM portion is within a range (inclusive).
125///
126/// Example: `validate_hhmm_range("202601011530+00", "0000", "2359")` → True
127pub 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
135/// Validate that a DTM value's MMDDHHMM portion equals the expected value.
136///
137/// Extracts characters at positions 4..12 for comparison.
138///
139/// Example: `validate_mmddhhmm_equals("202612312300+00", "12312300")` → True
140pub 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
147/// Validate that a DTM value's timezone portion ZZZ is "+00" (UTC).
148///
149/// The zone is the value's last three characters: format 303
150/// `CCYYMMDDHHMMZZZ` (15 chars) and 304 `CCYYMMDDHHMMSSZZZ` (17 chars) both
151/// end in it. Reading it at a fixed offset of 12 took 304's seconds for the
152/// zone and failed every 304 value.
153///
154/// Example: `validate_timezone_utc("202601012200+00")` → True
155/// Example: `validate_timezone_utc("20260101220000+00")` → True
156/// Example: `validate_timezone_utc("202601012200+01")` → False
157pub fn validate_timezone_utc(dtm_value: &str) -> ConditionResult {
158    if dtm_value.len() < 15 || !dtm_value.is_char_boundary(dtm_value.len() - 3) {
159        // Value too short — no timezone suffix present, condition is not met
160        return ConditionResult::False;
161    }
162    ConditionResult::from(&dtm_value[dtm_value.len() - 3..] == "+00")
163}
164
165// --- Contact format validation ---
166
167/// Validate email format: must contain both '@' and '.'.
168///
169/// Example: `validate_email("user@example.com")` → True
170pub 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
177/// Validate phone format: must start with '+' followed by only digits.
178///
179/// Example: `validate_phone("+4930123456")` → True
180/// Example: `validate_phone("030123456")` → False
181pub 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
191// --- ID format validation ---
192
193/// Validate Marktlokations-ID (MaLo-ID): exactly 11 digits with BDEW check digit.
194///
195/// This is **not** standard Luhn — per the BDEW "Anwendungshilfe MaLo-ID v1.0" spec
196/// and the Hochfrequenz BO4E-dotnet reference implementation
197/// (`BO4E/BO/Marktlokation.cs::GetChecksum`), digits 1–10 are numbered left-to-right
198/// (1-based), digits at even positions are multiplied by 2 and **added as the full
199/// value** (no digit-sum, no mod-by-9 step), digits at odd positions are added as-is.
200/// Check digit = `(10 - (sum mod 10)) mod 10`.
201///
202/// Example: `"51238696781"` — odd (1,3,5,7,9): 5+2+8+9+7=31; even doubled
203/// (2,4,6,8,10): 2*(1+3+6+6+8)=48; sum=79; check = (10-79%10)%10 = 1 ✓.
204pub 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        // 1-based position is i+1; even positions are doubled, odd positions as-is.
216        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
226/// Validate Transaktionsreferenz-ID (TR-ID): 1-35 alphanumeric characters.
227pub 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
234/// A BDEW location ID of the lettered kind: `prefix` followed by ten ASCII
235/// uppercase letters or digits (11 characters).
236fn 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
245/// Validate Steuerbare-Ressource-ID (SR-ID): "C" + ten alphanumerics
246/// (`C816417ST77`).
247pub fn validate_sr_id(value: &str) -> ConditionResult {
248    validate_prefixed_location_id(value, 'C')
249}
250
251/// Validate Netzlokations-ID: "E" + ten alphanumerics (`E1688117482`).
252pub fn validate_nelo_id(value: &str) -> ConditionResult {
253    validate_prefixed_location_id(value, 'E')
254}
255
256// --- OBIS code pattern matching ---
257
258/// Parse an OBIS code of the form `A-B:C.D.E[*F]` and return `(C, D)`.
259///
260/// OBIS structure (IEC 62056-61, BDEW/DVGW usage):
261/// - `A` — medium (1 = electricity, 7 = gas, 6 = heat, …)
262/// - `B` — channel
263/// - `C` — measurement type (1 = +A active energy import, 2 = -A active energy
264///   export, 3 = +R reactive import, 4 = -R reactive export, …)
265/// - `D` — measurement mode (8 = total time integral, 9 = billing-period
266///   integral, 29 = previous-billing-period partial value for interval
267///   measurements, 5 = actual/instantaneous value, …)
268/// - `E` — rate/tariff
269/// - `F` — optional billing period marker
270///
271/// Returns `None` when the value doesn't fit the shape. Whitespace-tolerant.
272pub fn parse_obis(value: &str) -> Option<(u32, u32)> {
273    let value = value.trim();
274    // Split at the colon between `A-B` and `C.D.E`.
275    let (_ab, cde) = value.split_once(':')?;
276    // Drop optional `*F` suffix.
277    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
284/// Is the OBIS code "Wirkarbeit kumuliert" — active energy as a cumulated
285/// time integral (total or per billing period)?
286///
287/// Matches BDEW convention: `C ∈ {1, 2}` (active energy import/export) and
288/// `D ∈ {8, 9}` (total time integral / billing-period integral).
289pub fn is_obis_wirkarbeit_kumuliert(value: &str) -> bool {
290    matches!(parse_obis(value), Some((1 | 2, 8 | 9)))
291}
292
293/// Is the OBIS code "Wirkarbeit 1/4 Stunde" — active energy 15-minute
294/// interval (Lastgang) measurement?
295///
296/// Matches BDEW convention for quarter-hour Lastgang: `C ∈ {1, 2}` and
297/// `D = 29` (partial value for previous billing period, the standard marker
298/// for interval-measured energy in German energy market MSCONS/UTILMD).
299pub fn is_obis_wirkarbeit_quarter_hour(value: &str) -> bool {
300    matches!(parse_obis(value), Some((1 | 2, 29)))
301}
302
303/// Validate an X.509 certificate body per BSI TR-03109-4.
304///
305/// In EDIFACT messages (e.g. ORDERS/REQOTE for Smartmeter gateway config) the
306/// certificate body is transmitted as base64-encoded DER — the PEM armoring
307/// (`-----BEGIN CERTIFICATE-----` / `-----END CERTIFICATE-----` lines) may or
308/// may not be present depending on the profile.
309///
310/// This validator performs a structural check only:
311/// - non-empty
312/// - composed exclusively of base64 characters (`A-Za-z0-9+/=`) plus
313///   whitespace (`\n\r\t` and space — PEM lines wrap at 64 chars)
314/// - decoded length plausible for a DER-encoded X.509 certificate (we allow a
315///   loose lower bound — a minimal self-signed cert is ~400 bytes, so the
316///   base64 form is ≥ ~540 chars; we use 100 as a sanity floor)
317///
318/// Cryptographic validation (signature, CA chain, TR-03109 certificate
319/// extensions) is out of scope for static AHB validation — those require a
320/// trust store and runtime context.
321pub fn validate_x509_cert_body(value: &str) -> ConditionResult {
322    let trimmed = value.trim();
323    if trimmed.is_empty() {
324        return ConditionResult::Unknown;
325    }
326    // Strip optional PEM armoring so the charset check operates on the
327    // encoded body alone.
328    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    // Minimum plausible length for a base64-encoded X.509 body. Shorter
336    // values are almost certainly not a real certificate.
337    let len_ok = body.chars().filter(|c| !c.is_whitespace()).count() >= 100;
338    ConditionResult::from(chars_ok && len_ok)
339}
340
341/// Validate Zahlpunktbezeichnung: exactly 33 alphanumeric characters.
342pub 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
349/// Validate either MaLo-ID or Zahlpunktbezeichnung format.
350pub 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
360// --- Artikelnummer pattern validation ---
361
362/// Validate a dash-separated digit pattern like "n1-n2-n1-n3".
363///
364/// `segment_lengths` defines expected digit counts per dash-separated segment.
365///
366/// Example: `validate_artikel_pattern("1-23-4-567", &[1, 2, 1, 3])` → True
367/// Example: `validate_artikel_pattern("1-23-4", &[1, 2, 1])` → True
368pub 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
385// --- General string validation ---
386
387/// Validate exact character length.
388pub 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
395/// Validate maximum character length.
396pub 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
403/// Validate that a string contains only digits (positive integer check).
404pub 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
411/// Current UTC date+time as a CCYYMMDDHHMM string (12 chars).
412pub 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    // --- Decimal places ---
421
422    #[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    // --- Numeric range ---
464
465    #[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        // Not a number is no "möglicher Wert" (mako-twin: RFF+Z60
474        // `O5D2DXBG1A` passed `[914]` "> 0").
475        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        // A comma is a decimal mark the UNA may set.
484        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    // --- DTM validation ---
490
491    #[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        // Format 304 carries seconds before the zone.
550        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    // --- Contact validation ---
561
562    #[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); // spaces not allowed
576        assert_eq!(validate_phone(""), ConditionResult::Unknown);
577    }
578
579    // --- ID validation ---
580
581    #[test]
582    fn test_malo_id() {
583        // Valid MaLo-IDs — taken directly from the BO4E-dotnet reference test
584        // suite (TestBO4E/TestMaLoMeLoId.cs), which uses the BDEW MaLo-ID spec
585        // (no digit-sum on doubled products; see `validate_malo_id` docstring).
586        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        // Negative cases from the same reference tests.
592        assert_eq!(validate_malo_id("41373559240"), ConditionResult::False); // wrong check digit
593        assert_eq!(validate_malo_id("512386967890"), ConditionResult::False); // 12 digits
594        assert_eq!(validate_malo_id("1234567890"), ConditionResult::False); // too short
595        assert_eq!(validate_malo_id("abcdefghijk"), ConditionResult::False); // not digits
596    }
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    // --- Artikelnummer pattern ---
607
608    #[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    // --- TR-ID / SR-ID validation ---
633
634    #[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))); // star suffix
650        assert_eq!(parse_obis(" 1-1:1.8.0 "), Some((1, 8))); // whitespace
651        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        // Active energy import/export, total or billing-period integral.
659        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        // Reactive energy — not Wirkarbeit.
665        assert!(!is_obis_wirkarbeit_kumuliert("1-1:3.8.0"));
666        assert!(!is_obis_wirkarbeit_kumuliert("1-1:4.8.0"));
667        // 15-min partial value — not kumuliert.
668        assert!(!is_obis_wirkarbeit_kumuliert("1-1:1.29.0"));
669        // Actual value — not kumuliert.
670        assert!(!is_obis_wirkarbeit_kumuliert("1-1:1.5.0"));
671    }
672
673    #[test]
674    fn test_obis_wirkarbeit_quarter_hour() {
675        // Active energy 15-min Lastgang.
676        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        // Cumulated — not 1/4h.
680        assert!(!is_obis_wirkarbeit_quarter_hour("1-1:1.8.0"));
681        assert!(!is_obis_wirkarbeit_quarter_hour("1-1:1.9.0"));
682        // Reactive.
683        assert!(!is_obis_wirkarbeit_quarter_hour("1-1:3.29.0"));
684    }
685
686    #[test]
687    fn test_x509_cert_body() {
688        // Valid: 600-char base64 body (well above 100-char floor).
689        let body = "A".repeat(600);
690        assert_eq!(validate_x509_cert_body(&body), ConditionResult::True);
691
692        // Valid with base64 padding and newlines (PEM-style wrapping).
693        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        // Valid with explicit PEM armoring — stripped before charset check.
697        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        // Valid: base64 chars include +, /, =
704        let with_punct = "AB+/==".to_string() + &"A".repeat(200);
705        assert_eq!(validate_x509_cert_body(&with_punct), ConditionResult::True);
706
707        // Too short — not a plausible cert.
708        assert_eq!(validate_x509_cert_body("QUJD"), ConditionResult::False);
709
710        // Non-base64 characters.
711        let invalid_chars = "A".repeat(200) + "!@#";
712        assert_eq!(
713            validate_x509_cert_body(&invalid_chars),
714            ConditionResult::False
715        );
716
717        // Empty is Unknown (consistent with other format validators).
718        assert_eq!(validate_x509_cert_body(""), ConditionResult::Unknown);
719        assert_eq!(validate_x509_cert_body("   \n  "), ConditionResult::Unknown);
720    }
721
722    /// SR-IDs are "C" + ten alphanumerics, not MaLo-shaped: every SR-ID in
723    /// `example_market_communication_bo4e_transactions/` looks like this
724    /// (`LOC+Z19+C816417ST77`), and a MaLo-ID check rejected all of them.
725    #[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    /// Netzlokations-IDs are "E" + ten alphanumerics (`LOC+Z18+E1688117482`,
740    /// `EU5UQAWW8D0` in the example transactions). The generated evaluators
741    /// checked them as MaLo-IDs, so every real one failed `[960]`.
742    #[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    // --- String validation ---
757
758    #[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}