sdf-parser-host 0.14.0

Host binding for YAML parser
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

use anyhow::{Context, Result};
use sdf_metadata::wit::dataflow::DataflowDefinition;
use tracing::debug;

use sdf_metadata::wit::package_interface::PackageDefinition;

use crate::bindings::sdf::parser::yaml_parser::Host as ParserHost;
/// Host based parser
pub struct HostParser {}

impl Default for HostParser {
    fn default() -> Self {
        Self::new()
    }
}

impl HostParser {
    pub fn new() -> Self {
        Self {}
    }

    pub fn parse_dataflow(&mut self, config_string: &str) -> Result<DataflowDefinition> {
        debug!("parsing dataflow");

        let config = sdf_parser_df::parse(config_string)?;
        debug!("parsed dataflow");
        config
            .try_into()
            .with_context(|| "failed to convert dataflow into WIT dataflow")
    }

    pub fn parse_package(&mut self, config_string: &str) -> Result<PackageDefinition> {
        debug!("parsing package");

        let config = sdf_parser_package::parse_package(config_string)?;
        debug!("parsed dataflow");
        config
            .try_into()
            .with_context(|| "failed to convert package into WIT package")
    }
}

impl ParserHost for HostParser {
    fn parse_dataflow(&mut self, config_string: String) -> Result<DataflowDefinition, String> {
        self.parse_dataflow(&config_string)
            .map_err(|err| err.to_string())
    }

    fn parse_package(&mut self, config_string: String) -> Result<PackageDefinition, String> {
        self.parse_package(&config_string)
            .map_err(|err| err.to_string())
    }
}