dpcs 0.8.0

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

//! YAML and JSON parsers for DPCS documents.

mod diagnostics;
mod json;
mod yaml;

pub use json::{parse_json, parse_json_file, to_json, to_json_file};
pub use yaml::{parse_yaml, parse_yaml_file, to_yaml, to_yaml_file};

use std::path::Path;

use crate::error::{Error, Result};
use crate::model::PipelineContract;

/// Parse a Pipeline Contract from a file, dispatching on extension.
pub fn parse_file(path: impl AsRef<Path>) -> Result<PipelineContract> {
    let path = path.as_ref();
    let ext = path
        .extension()
        .and_then(|e| e.to_str())
        .map(|e| e.to_ascii_lowercase());

    match ext.as_deref() {
        Some("yaml") | Some("yml") => parse_yaml_file(path),
        Some("json") => parse_json_file(path),
        _ => Err(Error::UnsupportedFormat {
            path: path.to_path_buf(),
        }),
    }
}

/// Serialize a Pipeline Contract to a file, dispatching on extension.
pub fn to_file(contract: &PipelineContract, path: impl AsRef<Path>) -> Result<()> {
    let path = path.as_ref();
    let ext = path
        .extension()
        .and_then(|e| e.to_str())
        .map(|e| e.to_ascii_lowercase());

    match ext.as_deref() {
        Some("yaml") | Some("yml") => to_yaml_file(contract, path),
        Some("json") => to_json_file(contract, path),
        _ => Err(Error::UnsupportedFormat {
            path: path.to_path_buf(),
        }),
    }
}