dpcs 0.13.1

Reference implementation of the Data Pipeline Contract Standard (DPCS)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85

//! Governance metadata validation (SPEC Ch 25).

use crate::diagnostics::{categories, Diagnostic, ValidationReport};
use crate::model::{is_known_publication_status, GovernanceMetadata, PipelineContract};

/// Validate governance metadata when present.
pub fn validate(contract: &PipelineContract) -> ValidationReport {
    let mut report = ValidationReport::new();
    if let Some(governance) = &contract.governance {
        report.extend(validate_governance(governance));
    }
    report
}

/// Validate a [`GovernanceMetadata`] block.
pub fn validate_governance(governance: &GovernanceMetadata) -> ValidationReport {
    let mut report = ValidationReport::new();

    if governance
        .owner
        .as_ref()
        .is_some_and(|o| o.trim().is_empty())
    {
        report.push(
            Diagnostic::error(
                "DPCS-GOV-001",
                categories::GOVERNANCE,
                "governance.owner must not be empty when declared",
            )
            .with_object_ref("governance.owner"),
        );
    }

    if governance
        .governing_authority
        .as_ref()
        .is_some_and(|a| a.trim().is_empty())
    {
        report.push(
            Diagnostic::error(
                "DPCS-GOV-002",
                categories::GOVERNANCE,
                "governance.governingAuthority must not be empty when declared",
            )
            .with_object_ref("governance.governingAuthority"),
        );
    }

    if let Some(status) = &governance.publication_status {
        if status.trim().is_empty() {
            report.push(
                Diagnostic::error(
                    "DPCS-GOV-003",
                    categories::GOVERNANCE,
                    "governance.publicationStatus must not be empty when declared",
                )
                .with_object_ref("governance.publicationStatus"),
            );
        } else if !is_known_publication_status(status) {
            report.push(
                Diagnostic::warning(
                    "DPCS-GOV-004",
                    categories::GOVERNANCE,
                    format!("governance.publicationStatus `{status}` is not a recognized status"),
                )
                .with_object_ref("governance.publicationStatus")
                .with_remediation("Prefer draft, published, deprecated, retired, or unpublished"),
            );
        }
    }

    if governance.owner.is_none() && governance.governing_authority.is_none() {
        report.push(
            Diagnostic::warning(
                "DPCS-GOV-005",
                categories::GOVERNANCE,
                "governance block should identify an owner or governingAuthority",
            )
            .with_object_ref("governance")
            .with_remediation("Set governance.owner or governance.governingAuthority"),
        );
    }

    report
}