dpcs 0.2.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

//! YAML and JSON parsers for DPCS documents.

mod json;
mod yaml;

pub use json::{parse_json, parse_json_file};
pub use yaml::{parse_yaml, parse_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(),
        }),
    }
}