redispatch_xml/validation/
structural.rs

1//! Structural validation — XSD-derivable constraints.
2//!
3//! These rules are pure field-level checks that require no cross-field context:
4//! - `DocumentId` / `Mrid`: 1–35 characters
5//! - `DocumentVersion`: 1–999
6//! - `MarketParticipantId`: exactly 13 decimal digits
7//! - UTC timestamps: offset must be `+00:00`
8//! - `TimeInterval`: end after start
9
10use super::{ValidationError, ValidationResult};
11use crate::parse::Document;
12use crate::types::{DocumentId, DocumentVersion, MarketParticipantId, TimeInterval, UtcDateTime};
13
14// ── Trait for per-type structural validation ──────────────────────────────────
15
16/// Types that can validate their own structural integrity.
17pub trait ValidateStructural {
18    /// Append any structural violations found to `result`.
19    fn validate_structural(&self, result: &mut ValidationResult);
20}
21
22// ── Helper validators ─────────────────────────────────────────────────────────
23
24/// Validate a [`DocumentId`] field.
25pub(crate) fn check_document_id(id: &DocumentId, result: &mut ValidationResult) {
26    let len = id.as_str().len();
27    if len == 0 || len > 35 {
28        result.errors.push(ValidationError::DocumentIdLength(len));
29    }
30}
31
32/// Validate a [`DocumentVersion`] field.
33pub(crate) fn check_document_version(v: &DocumentVersion, result: &mut ValidationResult) {
34    let n = v.get() as u32;
35    if n == 0 || n > 999 {
36        result.errors.push(ValidationError::DocumentVersionRange(n));
37    }
38}
39
40/// Validate a [`MarketParticipantId`] field.
41pub(crate) fn check_participant_id(id: &MarketParticipantId, result: &mut ValidationResult) {
42    let s = id.as_str();
43    if s.len() != 13 || !s.bytes().all(|b| b.is_ascii_digit()) {
44        result
45            .errors
46            .push(ValidationError::MarketParticipantIdFormat(s.to_string()));
47    }
48}
49
50/// Validate that a [`UtcDateTime`] has a UTC offset.
51///
52/// Since [`UtcDateTime::new`] already rejects non-UTC offsets, this is a
53/// belt-and-suspenders check for values that bypassed the constructor.
54pub(crate) fn check_utc_offset(ts: &UtcDateTime, result: &mut ValidationResult) {
55    // UtcDateTime guarantees UTC at construction; no further check needed.
56    let _ = ts;
57    let _ = result;
58}
59
60/// Validate that a [`TimeInterval`] has `end` after `start`.
61pub(crate) fn check_time_interval(interval: &TimeInterval, result: &mut ValidationResult) {
62    if interval.end <= interval.start {
63        result.errors.push(ValidationError::TimeIntervalOrder);
64    }
65}
66
67// ── Top-level dispatcher ──────────────────────────────────────────────────────
68
69/// Run structural checks on any [`Document`] variant.
70pub fn validate(doc: &Document, result: &mut ValidationResult) {
71    match doc {
72        Document::Activation(d) => validate_activation(d, result),
73        Document::PlannedResourceSchedule(d) => validate_prs(d, result),
74        Document::Acknowledgement(d) => validate_ack(d, result),
75        Document::NetworkConstraint(d) => validate_ncd(d, result),
76        Document::Kostenblatt(d) => validate_kostenblatt(d, result),
77        // IEC 62325 documents: validate identifier.
78        Document::Kaskade(d) => {
79            check_document_id(&d.m_rid, result);
80        }
81        Document::StatusRequest(d) => {
82            check_document_id(&d.m_rid, result);
83        }
84        Document::Unavailability(d) => {
85            check_document_id(&d.m_rid, result);
86        }
87        Document::Stammdaten(d) => {
88            check_document_id(&d.document_identification, result);
89            check_participant_id(&d.sender.code, result);
90            check_participant_id(&d.empfaenger.code, result);
91        }
92    }
93}
94
95use crate::documents::kostenblatt::Kostenblatt;
96use crate::documents::{
97    AcknowledgementDocument, ActivationDocument, NetworkConstraintDocument,
98    PlannedResourceScheduleDocument,
99};
100
101fn validate_activation(d: &ActivationDocument, result: &mut ValidationResult) {
102    check_document_id(&d.document_identification.v, result);
103    check_document_version(&d.document_version.v, result);
104    check_participant_id(&d.sender_identification.v, result);
105    check_participant_id(&d.receiver_identification.v, result);
106    check_utc_offset(&d.creation_date_time.v, result);
107    check_time_interval(&d.activation_time_interval.v, result);
108}
109
110fn validate_prs(d: &PlannedResourceScheduleDocument, result: &mut ValidationResult) {
111    check_document_id(&d.document_identification.v, result);
112    check_document_version(&d.document_version.v, result);
113    check_participant_id(&d.sender_identification.v, result);
114    check_participant_id(&d.receiver_identification.v, result);
115    check_utc_offset(&d.document_date_time.v, result);
116    check_time_interval(&d.time_period_covered.v, result);
117}
118
119fn validate_ack(d: &AcknowledgementDocument, result: &mut ValidationResult) {
120    check_document_id(&d.document_identification.v, result);
121    check_participant_id(&d.sender_identification.v, result);
122    check_participant_id(&d.receiver_identification.v, result);
123    check_utc_offset(&d.document_date_time.v, result);
124}
125
126fn validate_ncd(d: &NetworkConstraintDocument, result: &mut ValidationResult) {
127    check_document_id(&d.document_identification.v, result);
128    check_document_version(&d.document_version.v, result);
129    check_participant_id(&d.sender_identification.v, result);
130    check_participant_id(&d.receiver_identification.v, result);
131    check_utc_offset(&d.document_date_time.v, result);
132    check_time_interval(&d.time_period_covered.v, result);
133}
134
135fn validate_kostenblatt(d: &Kostenblatt, result: &mut ValidationResult) {
136    check_document_id(&d.document_identification.v, result);
137    check_document_version(&d.document_version.v, result);
138    check_participant_id(&d.sender_identification.v, result);
139    check_participant_id(&d.receiver_identification.v, result);
140    check_utc_offset(&d.document_date_time.v, result);
141    check_time_interval(&d.time_period_covered.v, result);
142}
redispatch_xml/validation/structural.rs

redispatch_xml/validation/
structural.rs
