use serde::{Deserialize, Serialize};
use super::issue::{Severity, ValidationCategory, ValidationIssue};
use super::level::ValidationLevel;
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct ValidationReport {
pub message_type: String,
pub pruefidentifikator: Option<String>,
pub format_version: Option<String>,
pub level: ValidationLevel,
pub issues: Vec<ValidationIssue>,
}
impl ValidationReport {
pub fn new(message_type: impl Into<String>, level: ValidationLevel) -> Self {
Self {
message_type: message_type.into(),
pruefidentifikator: None,
format_version: None,
level,
issues: Vec::new(),
}
}
pub fn with_pruefidentifikator(mut self, pid: impl Into<String>) -> Self {
self.pruefidentifikator = Some(pid.into());
self
}
pub fn with_format_version(mut self, fv: impl Into<String>) -> Self {
self.format_version = Some(fv.into());
self
}
pub fn add_issue(&mut self, issue: ValidationIssue) {
self.issues.push(issue);
}
pub fn add_issues(&mut self, issues: impl IntoIterator<Item = ValidationIssue>) {
self.issues.extend(issues);
}
pub fn is_valid(&self) -> bool {
!self.issues.iter().any(|i| i.severity == Severity::Error)
}
pub fn error_count(&self) -> usize {
self.issues
.iter()
.filter(|i| i.severity == Severity::Error)
.count()
}
pub fn warning_count(&self) -> usize {
self.issues
.iter()
.filter(|i| i.severity == Severity::Warning)
.count()
}
pub fn errors(&self) -> impl Iterator<Item = &ValidationIssue> {
self.issues.iter().filter(|i| i.severity == Severity::Error)
}
pub fn warnings(&self) -> impl Iterator<Item = &ValidationIssue> {
self.issues
.iter()
.filter(|i| i.severity == Severity::Warning)
}
pub fn infos(&self) -> impl Iterator<Item = &ValidationIssue> {
self.issues.iter().filter(|i| i.severity == Severity::Info)
}
pub fn by_category(
&self,
category: ValidationCategory,
) -> impl Iterator<Item = &ValidationIssue> {
self.issues.iter().filter(move |i| i.category() == category)
}
pub fn total_issues(&self) -> usize {
self.issues.len()
}
pub fn enrich_bo4e_paths(&mut self, resolver: impl Fn(&str, Option<&str>) -> Option<String>) {
for issue in &mut self.issues {
if let Some(ref edifact_path) = issue.field_path {
let hint = issue.expected_value.as_deref().or(issue.rule.as_deref());
issue.bo4e_path = resolver(edifact_path, hint);
}
}
}
}
#[cfg(test)]
mod tests {
use super::*;
use crate::IssueKind;
fn make_error() -> ValidationIssue {
ValidationIssue::new(
Severity::Error,
IssueKind::MissingRequiredField {
field_name: "test".into(),
},
)
}
fn make_warning() -> ValidationIssue {
ValidationIssue::new(
Severity::Warning,
IssueKind::UntSegmentCountMismatch {
declared: 1,
actual: 2,
},
)
}
fn make_info() -> ValidationIssue {
ValidationIssue::new(
Severity::Info,
IssueKind::CodeNotAllowedForPid {
value: "X".into(),
allowed: vec![],
},
)
}
#[test]
fn test_empty_report_is_valid() {
let report = ValidationReport::new("UTILMD", ValidationLevel::Full);
assert!(report.is_valid());
assert_eq!(report.error_count(), 0);
assert_eq!(report.warning_count(), 0);
assert_eq!(report.total_issues(), 0);
}
#[test]
fn test_report_with_errors_is_invalid() {
let mut report = ValidationReport::new("UTILMD", ValidationLevel::Full);
report.add_issue(make_error());
assert!(!report.is_valid());
assert_eq!(report.error_count(), 1);
}
#[test]
fn test_report_with_only_warnings_is_valid() {
let mut report = ValidationReport::new("UTILMD", ValidationLevel::Full);
report.add_issue(make_warning());
assert!(report.is_valid());
assert_eq!(report.warning_count(), 1);
assert_eq!(report.error_count(), 0);
}
#[test]
fn test_report_mixed_issues() {
let mut report = ValidationReport::new("UTILMD", ValidationLevel::Full)
.with_pruefidentifikator("11001")
.with_format_version("FV2510");
report.add_issue(make_error());
report.add_issue(make_error());
report.add_issue(make_warning());
report.add_issue(make_info());
assert!(!report.is_valid());
assert_eq!(report.error_count(), 2);
assert_eq!(report.warning_count(), 1);
assert_eq!(report.total_issues(), 4);
assert_eq!(report.errors().count(), 2);
assert_eq!(report.warnings().count(), 1);
assert_eq!(report.infos().count(), 1);
}
#[test]
fn test_report_by_category() {
let mut report = ValidationReport::new("UTILMD", ValidationLevel::Full);
report.add_issue(make_error());
report.add_issue(make_warning());
assert_eq!(report.by_category(ValidationCategory::Ahb).count(), 1);
assert_eq!(report.by_category(ValidationCategory::Structure).count(), 1);
assert_eq!(report.by_category(ValidationCategory::Format).count(), 0);
}
#[test]
fn test_report_add_issues() {
let mut report = ValidationReport::new("UTILMD", ValidationLevel::Full);
let issues = vec![make_error(), make_warning()];
report.add_issues(issues);
assert_eq!(report.total_issues(), 2);
}
#[test]
fn test_enrich_bo4e_paths() {
let mut report = ValidationReport::new("UTILMD", ValidationLevel::Full);
report.add_issue(make_error().with_field_path("SG4/SG5/LOC/C517/3225"));
report.add_issue(make_warning().with_field_path("SG2/NAD/3035"));
report.add_issue(make_error());
report.enrich_bo4e_paths(|path, _hint| match path {
"SG4/SG5/LOC/C517/3225" => Some("stammdaten.Marktlokation.marktlokationsId".into()),
"SG2/NAD/3035" => Some("stammdaten.Marktteilnehmer".into()),
_ => None,
});
assert_eq!(
report.issues[0].bo4e_path.as_deref(),
Some("stammdaten.Marktlokation.marktlokationsId")
);
assert_eq!(
report.issues[1].bo4e_path.as_deref(),
Some("stammdaten.Marktteilnehmer")
);
assert!(report.issues[2].bo4e_path.is_none());
}
#[test]
fn test_report_serialization() {
let mut report = ValidationReport::new("UTILMD", ValidationLevel::Conditions)
.with_pruefidentifikator("11001")
.with_format_version("FV2510");
report.add_issue(make_error());
let json = serde_json::to_string_pretty(&report).unwrap();
assert!(json.contains("UTILMD"));
assert!(json.contains("11001"));
assert!(json.contains("missingRequiredField"));
let deserialized: ValidationReport = serde_json::from_str(&json).unwrap();
assert_eq!(deserialized.message_type, "UTILMD");
assert_eq!(deserialized.pruefidentifikator.as_deref(), Some("11001"));
assert_eq!(deserialized.total_issues(), 1);
assert_eq!(deserialized.issues[0].code(), "AHB001");
}
}