wpl/eval/value/parser/
factory.rs

1use orion_error::ErrorWith;
2use orion_error::OperationContext;
3use orion_error::runtime::ContextRecord;
4use orion_error::traits_ext::ToStructError;
5
6use crate::eval::value::parse_def::{Hold, ParserHold};
7use crate::eval::value::parser::base::digit::{DigitP, FloatP};
8use crate::eval::value::parser::base::hex::HexDigitP;
9use crate::eval::value::parser::base::*;
10use crate::eval::value::parser::compute::device::SnP;
11use crate::eval::value::parser::network::http;
12use crate::eval::value::parser::network::net::{IpNetP, IpPSR};
13use crate::eval::value::parser::physical::time::{
14    TimeCLF, TimeISOP, TimeP, TimeRFC2822, TimeRFC3339, TimeStampPSR,
15};
16use crate::eval::value::parser::protocol::array::ArrayP;
17use crate::eval::value::parser::protocol::base64::Base64P;
18use crate::eval::value::parser::protocol::json::JsonP;
19use crate::eval::value::parser::protocol::json_exact::ExactJsonP;
20use crate::eval::value::parser::protocol::keyval::KeyValP;
21use crate::eval::value::parser::protocol::kvarr::KvArrP;
22use crate::eval::value::parser::protocol::proto_text::ProtoTextP;
23use crate::parser::error::{WplCodeError, WplCodeReason, WplCodeResult};
24use wp_model_core::model::DataType;
25
26use super::auto::CombinedParser;
27#[derive(Default)]
28pub struct ParserFactory {}
29
30impl ParserFactory {
31    pub fn crate_auto() -> WplCodeResult<ParserHold> {
32        let mut parse = CombinedParser::new();
33        parse.ps.push(ParserFactory::create(&DataType::Json)?);
34        parse.ps.push(ParserFactory::create(&DataType::Time)?);
35        parse.ps.push(ParserFactory::create(&DataType::IP)?);
36        parse.ps.push(ParserFactory::create(&DataType::KV)?);
37        parse.ps.push(ParserFactory::create(&DataType::Float)?);
38        parse.ps.push(ParserFactory::create(&DataType::Digit)?);
39        parse.ps.push(ParserFactory::create(&DataType::Hex)?);
40        parse.ps.push(ParserFactory::create(&DataType::Chars)?);
41        Ok(Hold::new(parse))
42    }
43
44    pub fn create_simple(meta: &DataType) -> Option<ParserHold> {
45        match *meta {
46            DataType::Bool => Some(Hold::new(BoolP::default())),
47            DataType::Chars => Some(Hold::new(CharsP::default())),
48            DataType::Symbol => Some(Hold::new(SymbolP::default())),
49            DataType::PeekSymbol => Some(Hold::new(PeekSymbolP::default())),
50            DataType::Digit => Some(Hold::new(DigitP::default())),
51            DataType::Float => Some(Hold::new(FloatP::default())),
52            DataType::Ignore => Some(Hold::new(IgnoreP::default())),
53            DataType::Time => Some(Hold::new(TimeP::default())),
54            DataType::TimeCLF => Some(Hold::new(TimeCLF::default())),
55            DataType::TimeISO => Some(Hold::new(TimeISOP::default())),
56            DataType::TimeRFC3339 => Some(Hold::new(TimeRFC3339::default())),
57            DataType::TimeRFC2822 => Some(Hold::new(TimeRFC2822::default())),
58            DataType::TimeTIMESTAMP => Some(Hold::new(TimeStampPSR::default())),
59            DataType::IP => Some(Hold::new(IpPSR::default())),
60            DataType::IpNet => Some(Hold::new(IpNetP::default())),
61            DataType::Port => Some(Hold::new(DigitP::default())),
62            DataType::SN => Some(Hold::new(SnP::default())),
63            DataType::Hex => Some(Hold::new(HexDigitP::default())),
64            DataType::Base64 => Some(Hold::new(Base64P::default())),
65            DataType::KvArr => Some(Hold::new(KvArrP::default())),
66            DataType::KV => Some(Hold::new(KeyValP::default())),
67            DataType::Json => Some(Hold::new(JsonP::default())),
68            DataType::ExactJson => Some(Hold::new(ExactJsonP::default())),
69            DataType::HttpRequest => Some(Hold::new(http::RequestP::default())),
70            DataType::HttpStatus => Some(Hold::new(http::StatusP::default())),
71            DataType::HttpAgent => Some(Hold::new(http::AgentP::default())),
72            DataType::HttpMethod => Some(Hold::new(http::MethodP::default())),
73            DataType::ProtoText => Some(Hold::new(ProtoTextP::default())),
74            _ => None,
75        }
76    }
77
78    fn create_l1(meta: &DataType) -> WplCodeResult<ParserHold> {
79        let mut ctx = OperationContext::doing("create parser");
80        ctx.record("meta", meta.to_string());
81        if let Some(hold) = Self::create_simple(meta) {
82            return Ok(hold);
83        } else if DataType::Auto == *meta {
84            return Self::crate_auto();
85        }
86        Err(WplCodeError::builder(WplCodeReason::UnSupport)
87            .detail(meta.to_string())
88            .finish())
89        .with_context(&ctx)
90    }
91
92    pub fn create(meta: &DataType) -> WplCodeResult<ParserHold> {
93        let mut ctx = OperationContext::doing("create parser");
94        ctx.record("meta", meta.to_string());
95        if let DataType::Array(next_name) = meta {
96            let sub_meta = DataType::from(next_name.as_str())
97                .map_err(|e| {
98                    WplCodeReason::UnSupport
99                        .to_err()
100                        .with_detail(format!("unsupported data type: {}: {}", next_name, e))
101                    //.finish()
102                })
103                .with_context(&ctx)?;
104
105            /*
106            let sub_meta = DataType::from(next_name.as_str()).map_err(|e| {
107                StructError::builder(WplCodeReason::UnSupport)
108                    .detail(format!("unsupported data type: {}: {}", next_name, e))
109                    .finish()
110            }).with_context(&ctx)?;
111            */
112            match Self::create(&sub_meta) {
113                Ok(_) => Ok(Hold::new(ArrayP::new())),
114                Err(e) => Err(e),
115            }
116        } else {
117            Self::create_l1(meta)
118        }
119    }
120}
wpl/eval/value/parser/factory.rs

wpl/eval/value/parser/
factory.rs
