diff --git a/src/error.rs b/src/error.rs new file mode 100644 index 0000000..8888e73 --- /dev/null +++ b/src/error.rs @@ -0,0 +1,62 @@ +use thiserror::Error; + +/// Crate-specific error enum. +#[derive(Debug, Error)] +pub enum Error { + /// [boon::CompileError] + #[error(transparent)] + BoonCompile(#[from] boon::CompileError), + + /// [geozero::error::GeozeroError] + #[error(transparent)] + Geozero(#[from] geozero::error::GeozeroError), + + /// Invalid CQL2 text + #[error("invalid cql2-text: {0}")] + InvalidCql2Text(String), + + /// Invalid number of arguments for the expression + #[error("invalid number of arguments for {name}: {actual} (expected {expected})")] + InvalidNumberOfArguments { + name: String, + actual: usize, + expected: usize, + }, + + /// [std::io::Error] + #[error(transparent)] + Io(#[from] std::io::Error), + + /// Missing argument from a function that requires one. + #[error("function {0} is missing a required argument")] + MissingArgument(&'static str), + + /// [std::str::ParseBoolError] + #[error(transparent)] + ParseBool(#[from] std::str::ParseBoolError), + + /// [std::num::ParseFloatError] + #[error(transparent)] + ParseFloat(#[from] std::num::ParseFloatError), + + /// [std::num::ParseIntError] + #[error(transparent)] + ParseInt(#[from] std::num::ParseIntError), + + /// [pest::error::Error] + #[error(transparent)] + Pest(#[from] Box>), + + /// [serde_json::Error] + #[error(transparent)] + SerdeJson(#[from] serde_json::Error), + + /// A validation error. + /// + /// This holds a [serde_json::Value] that is the output from a + /// [boon::ValidationError]. We can't hold the validation error itself + /// becuase it contains references to both the validated object and the + /// validator's data. + #[error("validation error")] + Validation(serde_json::Value), +} diff --git a/src/expr.rs b/src/expr.rs new file mode 100644 index 0000000..b4931db --- /dev/null +++ b/src/expr.rs @@ -0,0 +1,291 @@ +use crate::{Error, SqlQuery, Validator}; +use geozero::{geojson::GeoJsonString, ToWkt}; +use serde::{Deserialize, Serialize}; +use serde_json::Value; +use std::str::FromStr; + +/// A CQL2 expression. +/// +/// # Examples +/// +/// [Expr] implements [FromStr]: +/// +/// ``` +/// use cql2::Expr; +/// +/// let expr: Expr = "landsat:scene_id = 'LC82030282019133LGN00'".parse().unwrap(); +/// ``` +/// +/// Use [Expr::to_text], [Expr::to_json], and [Expr::to_sql] to use the CQL2, +/// and use [Expr::is_valid] to check validity. +#[derive(Debug, Serialize, Deserialize, Clone)] +#[serde(untagged)] +pub enum Expr { + Operation { op: String, args: Vec> }, + Interval { interval: Vec> }, + Timestamp { timestamp: Box }, + Date { date: Box }, + Property { property: String }, + BBox { bbox: Vec> }, + Float(f64), + Literal(String), + Bool(bool), + Array(Vec>), + Geometry(serde_json::Value), +} + +impl Expr { + /// Converts this expression to CQL2 text. + /// + /// # Examples + /// + /// ``` + /// use cql2::Expr; + /// + /// let expr = Expr::Bool(true); + /// assert_eq!(expr.to_text().unwrap(), "true"); + /// ``` + pub fn to_text(&self) -> Result { + macro_rules! check_len { + ($name:expr, $args:expr, $len:expr, $text:expr) => { + if $args.len() == $len { + Ok($text) + } else { + Err(Error::InvalidNumberOfArguments { + name: $name.to_string(), + actual: $args.len(), + expected: $len, + }) + } + }; + } + + match self { + Expr::Bool(v) => Ok(v.to_string()), + Expr::Float(v) => Ok(v.to_string()), + Expr::Literal(v) => Ok(format!("'{}'", v)), + Expr::Property { property } => Ok(format!("\"{property}\"")), + Expr::Interval { interval } => { + check_len!( + "interval", + interval, + 2, + format!( + "INTERVAL({},{})", + interval[0].to_text()?, + interval[1].to_text()? + ) + ) + } + Expr::Date { date } => Ok(format!("DATE({})", date.to_text()?)), + Expr::Timestamp { timestamp } => Ok(format!("TIMESTAMP({})", timestamp.to_text()?)), + Expr::Geometry(v) => { + let gj = GeoJsonString(v.to_string()); + gj.to_wkt().map_err(Error::from) + } + Expr::Array(v) => { + let array_els: Vec = + v.iter().map(|a| a.to_text()).collect::>()?; + Ok(format!("({})", array_els.join(", "))) + } + Expr::Operation { op, args } => { + let a: Vec = args.iter().map(|x| x.to_text()).collect::>()?; + match op.as_str() { + "and" => Ok(format!("({})", a.join(" AND "))), + "or" => Ok(format!("({})", a.join(" OR "))), + "between" => { + check_len!( + "between", + a, + 3, + format!("({} BETWEEN {} AND {})", a[0], a[1], a[2]) + ) + } + "not" => { + check_len!("not", a, 1, format!("(NOT {})", a[0])) + } + "is null" => { + check_len!("is null", a, 1, format!("({} IS NULL)", a[0])) + } + "+" | "-" | "*" | "/" | "%" | "^" | "=" | "<=" | "<" | "<>" | ">" | ">=" => { + check_len!(op, a, 2, format!("({} {} {})", a[0], op, a[1])) + } + _ => Ok(format!("{}({})", op, a.join(", "))), + } + } + Expr::BBox { bbox } => { + let array_els: Vec = + bbox.iter().map(|a| a.to_text()).collect::>()?; + Ok(format!("BBOX({})", array_els.join(", "))) + } + } + } + + /// Converts this expression to a [SqlQuery] struct with parameters + /// separated to use with parameter binding. + /// + /// # Examples + /// + /// ``` + /// use cql2::Expr; + /// + /// let expr = Expr::Bool(true); + /// let s = expr.to_sql().unwrap(); + /// ``` + pub fn to_sql(&self) -> Result { + let params: &mut Vec = &mut vec![]; + let query = self.to_sql_inner(params)?; + Ok(SqlQuery { + query, + params: params.to_vec(), + }) + } + + fn to_sql_inner( + &self, + params: &mut Vec, + ) -> Result { + Ok(match self { + Expr::Bool(v) => { + params.push(v.to_string()); + format!("${}", params.len()) + } + Expr::Float(v) => { + params.push(v.to_string()); + format!("${}", params.len()) + } + Expr::Literal(v) => { + params.push(v.to_string()); + format!("${}", params.len()) + } + Expr::Date { date } => date.to_sql_inner(params)?, + Expr::Timestamp { timestamp } => timestamp.to_sql_inner(params)?, + + Expr::Interval { interval } => { + let a: Vec = interval + .iter() + .map(|x| x.to_sql_inner(params)) + .collect::>()?; + format!("TSTZRANGE({},{})", a[0], a[1],) + } + Expr::Geometry(v) => { + let gj = GeoJsonString(v.to_string()); + params.push(format!("EPSG:4326;{}", gj.to_wkt()?)); + format!("${}", params.len()) + } + Expr::Array(v) => { + let array_els: Vec = v + .iter() + .map(|a| a.to_sql_inner(params)) + .collect::>()?; + format!("[{}]", array_els.join(", ")) + } + Expr::Property { property } => format!("\"{property}\""), + Expr::Operation { op, args } => { + let a: Vec = args + .iter() + .map(|x| x.to_sql_inner(params)) + .collect::>()?; + match op.as_str() { + "and" => format!("({})", a.join(" AND ")), + "or" => format!("({})", a.join(" OR ")), + "between" => format!("({} BETWEEN {} AND {})", a[0], a[1], a[2]), + "not" => format!("(NOT {})", a[0]), + "is null" => format!("({} IS NULL)", a[0]), + "+" | "-" | "*" | "/" | "%" | "^" | "=" | "<=" | "<" | "<>" | ">" | ">=" => { + format!("({} {} {})", a[0], op, a[1]) + } + _ => format!("{}({})", op, a.join(", ")), + } + } + Expr::BBox { bbox } => { + let array_els: Vec = bbox + .iter() + .map(|a| a.to_sql_inner(params)) + .collect::>()?; + format!("[{}]", array_els.join(", ")) + } + }) + } + + /// Converts this expression to a JSON string. + /// + /// # Examples + /// + /// ``` + /// use cql2::Expr; + /// + /// let expr = Expr::Bool(true); + /// let s = expr.to_json().unwrap(); + /// ``` + pub fn to_json(&self) -> Result { + serde_json::to_string(&self) + } + + /// Converts this expression to a pretty JSON string. + /// + /// # Examples + /// + /// ``` + /// use cql2::Expr; + /// + /// let expr = Expr::Bool(true); + /// let s = expr.to_json_pretty().unwrap(); + /// ``` + pub fn to_json_pretty(&self) -> Result { + serde_json::to_string_pretty(&self) + } + + /// Converts this expression to a [serde_json::Value]. + /// + /// # Examples + /// + /// ``` + /// use cql2::Expr; + /// + /// let expr = Expr::Bool(true); + /// let value = expr.to_value().unwrap(); + /// ``` + pub fn to_value(&self) -> Result { + serde_json::to_value(self) + } + + /// Returns true if this expression is valid CQL2. + /// + /// For detailed error reporting, use [Validator::validate] in conjunction with [Expr::to_value]. + /// + /// # Examples + /// + /// ``` + /// use cql2::Expr; + /// + /// let expr = Expr::Bool(true); + /// assert!(expr.is_valid()); + /// ``` + /// + /// # Panics + /// + /// Panics if the default validator can't be created. + pub fn is_valid(&self) -> bool { + let value = serde_json::to_value(self); + match &value { + Ok(value) => { + let validator = Validator::new().expect("Could not create default validator"); + validator.validate(value).is_ok() + } + _ => false, + } + } +} + +impl FromStr for Expr { + type Err = Error; + + fn from_str(s: &str) -> Result { + if s.starts_with('{') { + crate::parse_json(s).map_err(Error::from) + } else { + crate::parse_text(s) + } + } +} diff --git a/src/lib.rs b/src/lib.rs index 1a68575..b1404e1 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -2,158 +2,14 @@ #![deny(unused_crate_dependencies)] -use boon::{Compiler, SchemaIndex, Schemas, ValidationError}; -use geozero::{ - geojson::{GeoJsonString, GeoJsonWriter}, - wkt::Wkt, - CoordDimensions, GeozeroGeometry, ToJson, ToWkt, -}; -use pest::{ - iterators::{Pair, Pairs}, - pratt_parser::PrattParser, - Parser, -}; +mod error; +mod expr; +mod parser; +mod validator; + use serde_derive::{Deserialize, Serialize}; -use serde_json::Value; use std::{fs, io::Read, path::Path}; -use thiserror::Error; - -/// Crate-specific error enum. -#[derive(Debug, Error)] -pub enum Error { - /// [boon::CompileError] - #[error(transparent)] - BoonCompile(#[from] boon::CompileError), - - /// [geozero::error::GeozeroError] - #[error(transparent)] - Geozero(#[from] geozero::error::GeozeroError), - - /// Invalid CQL2 text - #[error("invalid cql2-text: {0}")] - InvalidCql2Text(String), - - /// Invalid number of arguments for the expression - #[error("invalid number of arguments for {name}: {actual} (expected {expected})")] - InvalidNumberOfArguments { - name: String, - actual: usize, - expected: usize, - }, - - /// [std::io::Error] - #[error(transparent)] - Io(#[from] std::io::Error), - - /// Missing argument from a function that requires one. - #[error("function {0} is missing a required argument")] - MissingArgument(&'static str), - - /// [std::str::ParseBoolError] - #[error(transparent)] - ParseBool(#[from] std::str::ParseBoolError), - - /// [std::num::ParseFloatError] - #[error(transparent)] - ParseFloat(#[from] std::num::ParseFloatError), - - /// [std::num::ParseIntError] - #[error(transparent)] - ParseInt(#[from] std::num::ParseIntError), - - /// [pest::error::Error] - #[error(transparent)] - Pest(#[from] Box>), - - /// [serde_json::Error] - #[error(transparent)] - SerdeJson(#[from] serde_json::Error), - - /// A validation error. - /// - /// This holds a [serde_json::Value] that is the output from a - /// [boon::ValidationError]. We can't hold the validation error itself - /// becuase it contains references to both the validated object and the - /// validator's data. - #[error("validation error")] - Validation(Value), -} - -/// A re-usable json-schema validator for CQL2. -pub struct Validator { - schemas: Schemas, - index: SchemaIndex, -} - -impl Validator { - /// Creates a new validator. - /// - /// # Examples - /// - /// ``` - /// use cql2::Validator; - /// - /// let validator = Validator::new().unwrap(); - /// ``` - pub fn new() -> Result { - let mut schemas = Schemas::new(); - let mut compiler = Compiler::new(); - let schema_json = serde_json::from_str(include_str!("cql2.json"))?; - compiler.add_resource("/tmp/cql2.json", schema_json)?; - let index = compiler.compile("/tmp/cql2.json", &mut schemas)?; - Ok(Validator { schemas, index }) - } - - /// Validates a [serde_json::Value]. - /// - /// # Examples - /// - /// ``` - /// use cql2::Validator; - /// use serde_json::json; - /// - /// let validator = Validator::new().unwrap(); - /// - /// let valid = json!({ - /// "op": "=", - /// "args": [ - /// { "property": "landsat:scene_id" }, - /// "LC82030282019133LGN00" - /// ] - /// }); - /// validator.validate(&valid).unwrap(); - /// - /// let invalid = json!({ - /// "op": "not an operator!", - /// }); - /// validator.validate(&invalid).unwrap_err(); - /// ``` - pub fn validate<'a, 'b>(&'a self, value: &'b Value) -> Result<(), ValidationError<'a, 'b>> { - self.schemas.validate(value, self.index) - } -} - -/// [pest] parser for CQL2. -#[derive(pest_derive::Parser)] -#[grammar = "cql2.pest"] -pub struct CQL2Parser; - -/// A CQL2 expression. -#[derive(Debug, Serialize, Deserialize, Clone)] -#[serde(untagged)] -pub enum Expr { - Operation { op: String, args: Vec> }, - Interval { interval: Vec> }, - Timestamp { timestamp: Box }, - Date { date: Box }, - Property { property: String }, - BBox { bbox: Vec> }, - Float(f64), - Literal(String), - Bool(bool), - Array(Vec>), - Geometry(serde_json::Value), -} +pub use {error::Error, expr::Expr, parser::parse_text, validator::Validator}; /// A SQL query, broken into the query and parameters. #[derive(Debug, Serialize, Deserialize, Clone)] @@ -162,533 +18,6 @@ pub struct SqlQuery { params: Vec, } -impl Expr { - /// Converts this expression to CQL2 text. - /// - /// # Examples - /// - /// ``` - /// use cql2::Expr; - /// - /// let expr = Expr::Bool(true); - /// assert_eq!(expr.to_text().unwrap(), "true"); - /// ``` - pub fn to_text(&self) -> Result { - macro_rules! check_len { - ($name:expr, $args:expr, $len:expr, $text:expr) => { - if $args.len() == $len { - Ok($text) - } else { - Err(Error::InvalidNumberOfArguments { - name: $name.to_string(), - actual: $args.len(), - expected: $len, - }) - } - }; - } - - match self { - Expr::Bool(v) => Ok(v.to_string()), - Expr::Float(v) => Ok(v.to_string()), - Expr::Literal(v) => Ok(format!("'{}'", v)), - Expr::Property { property } => Ok(format!("\"{property}\"")), - Expr::Interval { interval } => { - check_len!( - "interval", - interval, - 2, - format!( - "INTERVAL({},{})", - interval[0].to_text()?, - interval[1].to_text()? - ) - ) - } - Expr::Date { date } => Ok(format!("DATE({})", date.to_text()?)), - Expr::Timestamp { timestamp } => Ok(format!("TIMESTAMP({})", timestamp.to_text()?)), - Expr::Geometry(v) => { - let gj = GeoJsonString(v.to_string()); - gj.to_wkt().map_err(Error::from) - } - Expr::Array(v) => { - let array_els: Vec = - v.iter().map(|a| a.to_text()).collect::>()?; - Ok(format!("({})", array_els.join(", "))) - } - Expr::Operation { op, args } => { - let a: Vec = args.iter().map(|x| x.to_text()).collect::>()?; - match op.as_str() { - "and" => Ok(format!("({})", a.join(" AND "))), - "or" => Ok(format!("({})", a.join(" OR "))), - "between" => { - check_len!( - "between", - a, - 3, - format!("({} BETWEEN {} AND {})", a[0], a[1], a[2]) - ) - } - "not" => { - check_len!("not", a, 1, format!("(NOT {})", a[0])) - } - "is null" => { - check_len!("is null", a, 1, format!("({} IS NULL)", a[0])) - } - "+" | "-" | "*" | "/" | "%" | "^" | "=" | "<=" | "<" | "<>" | ">" | ">=" => { - check_len!(op, a, 2, format!("({} {} {})", a[0], op, a[1])) - } - _ => Ok(format!("{}({})", op, a.join(", "))), - } - } - Expr::BBox { bbox } => { - let array_els: Vec = - bbox.iter().map(|a| a.to_text()).collect::>()?; - Ok(format!("BBOX({})", array_els.join(", "))) - } - } - } - - /// Converts this expression to a [SqlQuery] struct with parameters - /// separated to use with parameter binding. - /// - /// # Examples - /// - /// ``` - /// use cql2::Expr; - /// - /// let expr = Expr::Bool(true); - /// let s = expr.to_sql().unwrap(); - /// ``` - pub fn to_sql(&self) -> Result { - let params: &mut Vec = &mut vec![]; - let query = self.to_sql_inner(params)?; - Ok(SqlQuery { - query, - params: params.to_vec(), - }) - } - - fn to_sql_inner( - &self, - params: &mut Vec, - ) -> Result { - Ok(match self { - Expr::Bool(v) => { - params.push(v.to_string()); - format!("${}", params.len()) - } - Expr::Float(v) => { - params.push(v.to_string()); - format!("${}", params.len()) - } - Expr::Literal(v) => { - params.push(v.to_string()); - format!("${}", params.len()) - } - Expr::Date { date } => date.to_sql_inner(params)?, - Expr::Timestamp { timestamp } => timestamp.to_sql_inner(params)?, - - Expr::Interval { interval } => { - let a: Vec = interval - .iter() - .map(|x| x.to_sql_inner(params)) - .collect::>()?; - format!("TSTZRANGE({},{})", a[0], a[1],) - } - Expr::Geometry(v) => { - let gj = GeoJsonString(v.to_string()); - params.push(format!("EPSG:4326;{}", gj.to_wkt()?)); - format!("${}", params.len()) - } - Expr::Array(v) => { - let array_els: Vec = v - .iter() - .map(|a| a.to_sql_inner(params)) - .collect::>()?; - format!("[{}]", array_els.join(", ")) - } - Expr::Property { property } => format!("\"{property}\""), - Expr::Operation { op, args } => { - let a: Vec = args - .iter() - .map(|x| x.to_sql_inner(params)) - .collect::>()?; - match op.as_str() { - "and" => format!("({})", a.join(" AND ")), - "or" => format!("({})", a.join(" OR ")), - "between" => format!("({} BETWEEN {} AND {})", a[0], a[1], a[2]), - "not" => format!("(NOT {})", a[0]), - "is null" => format!("({} IS NULL)", a[0]), - "+" | "-" | "*" | "/" | "%" | "^" | "=" | "<=" | "<" | "<>" | ">" | ">=" => { - format!("({} {} {})", a[0], op, a[1]) - } - _ => format!("{}({})", op, a.join(", ")), - } - } - Expr::BBox { bbox } => { - let array_els: Vec = bbox - .iter() - .map(|a| a.to_sql_inner(params)) - .collect::>()?; - format!("[{}]", array_els.join(", ")) - } - }) - } - - /// Converts this expression to a JSON string. - /// - /// # Examples - /// - /// ``` - /// use cql2::Expr; - /// - /// let expr = Expr::Bool(true); - /// let s = expr.to_json().unwrap(); - /// ``` - pub fn to_json(&self) -> Result { - serde_json::to_string(&self) - } - - /// Converts this expression to a pretty JSON string. - /// - /// # Examples - /// - /// ``` - /// use cql2::Expr; - /// - /// let expr = Expr::Bool(true); - /// let s = expr.to_json_pretty().unwrap(); - /// ``` - pub fn to_json_pretty(&self) -> Result { - serde_json::to_string_pretty(&self) - } - - /// Converts this expression to a [serde_json::Value]. - /// - /// # Examples - /// - /// ``` - /// use cql2::Expr; - /// - /// let expr = Expr::Bool(true); - /// let value = expr.to_value().unwrap(); - /// ``` - pub fn to_value(&self) -> Result { - serde_json::to_value(self) - } - - /// Returns true if this expression is valid CQL2. - /// - /// For detailed error reporting, use [Validator::validate] in conjunction with [Expr::to_value]. - /// - /// # Examples - /// - /// ``` - /// use cql2::Expr; - /// - /// let expr = Expr::Bool(true); - /// assert!(expr.is_valid()); - /// ``` - /// - /// # Panics - /// - /// Panics if the default validator can't be created. - pub fn is_valid(&self) -> bool { - let value = serde_json::to_value(self); - match &value { - Ok(value) => { - let validator = Validator::new().expect("Could not create default validator"); - validator.validate(value).is_ok() - } - _ => false, - } - } -} - -lazy_static::lazy_static! { - static ref PRATT_PARSER: PrattParser = { - use pest::pratt_parser::{Assoc::*, Op}; - use Rule::*; - PrattParser::new() - .op(Op::infix(Or, Left)) - .op(Op::infix(Between, Left)) - .op(Op::infix(And, Left)) - .op(Op::prefix(UnaryNot)) - .op(Op::infix(Eq, Right)) - .op( - Op::infix(NotEq, Right) | - Op::infix(Gt, Right) | - Op::infix(GtEq, Right) | - Op::infix(Lt, Right) | - Op::infix(LtEq, Right) - ) - .op(Op::infix(Like, Right)) - .op(Op::infix(In, Left)) - .op(Op::postfix(IsNullPostfix)) - .op(Op::infix(Is, Right)) - .op( - Op::infix(Add, Left) | - Op::infix(Subtract, Left) - ) - .op( - Op::infix(Multiply, Left) | - Op::infix(Divide, Left) | - Op::infix(Modulo, Left) - ) - .op(Op::infix(Power, Left)) - .op(Op::prefix(Negative)) - }; -} - -fn normalize_op(op: &str) -> String { - let op = op.to_lowercase(); - if op == "eq" { - "=".to_string() - } else { - op - } -} - -fn strip_quotes(s: &str) -> &str { - if (s.starts_with('"') && s.ends_with('"')) || (s.starts_with('\'') && s.ends_with('\'')) { - &s[1..s.len() - 1] - } else { - s - } -} - -fn opstr(op: Pair) -> String { - return normalize_op(op.as_str()); -} - -fn parse_expr(expression_pairs: Pairs<'_, Rule>) -> Result { - PRATT_PARSER - .map_primary(|primary| match primary.as_rule() { - Rule::Expr | Rule::ExpressionInParentheses => parse_expr(primary.into_inner()), - Rule::Unsigned => Ok(Expr::Float(primary.as_str().parse::()?)), - Rule::DECIMAL => Ok(Expr::Float(primary.as_str().parse::()?)), - Rule::SingleQuotedString => { - Ok(Expr::Literal(strip_quotes(primary.as_str()).to_string())) - } - Rule::True | Rule::False => { - let bool_value = primary.as_str().to_lowercase().parse::()?; - Ok(Expr::Bool(bool_value)) - } - Rule::Identifier => Ok(Expr::Property { - property: strip_quotes(primary.as_str()).to_string(), - }), - Rule::GEOMETRY => { - let geom_wkt = Wkt(primary.as_str()); - let mut out: Vec = Vec::new(); - let mut p = GeoJsonWriter::with_dims(&mut out, CoordDimensions::xyz()); - let _ = geom_wkt.process_geom(&mut p); - Ok(Expr::Geometry(serde_json::from_str(&geom_wkt.to_json()?)?)) - } - Rule::Function => { - let mut pairs = primary.into_inner(); - let op = strip_quotes( - pairs - .next() - .expect("the grammar guarantees that there is always an op") - .as_str(), - ) - .to_lowercase(); - let mut args = Vec::new(); - for pair in pairs { - args.push(Box::new(parse_expr(pair.into_inner())?)) - } - match op.as_str() { - "interval" => Ok(Expr::Interval { interval: args }), - "date" => Ok(Expr::Date { - date: args - .into_iter() - .next() - .ok_or(Error::MissingArgument("date"))?, - }), - "timestamp" => Ok(Expr::Timestamp { - timestamp: args - .into_iter() - .next() - .ok_or(Error::MissingArgument("timestamp"))?, - }), - _ => Ok(Expr::Operation { op, args }), - } - } - Rule::Array => { - let pairs = primary.into_inner(); - let mut array_elements = Vec::new(); - for pair in pairs { - array_elements.push(Box::new(parse_expr(pair.into_inner())?)) - } - Ok(Expr::Array(array_elements)) - } - - rule => unreachable!("Expr::parse expected atomic rule, found {:?}", rule), - }) - .map_infix(|lhs, op, rhs| { - let lhs = lhs?; - let rhs = rhs?; - let mut opstring = opstr(op); - - let mut notflag: bool = false; - if opstring.starts_with("not") { - opstring = opstring.replace("not ", ""); - notflag = true; - } - - let origargs = vec![Box::new(lhs.clone()), Box::new(rhs.clone())]; - let mut retexpr: Expr; - let mut lhsclone = lhs.clone(); - let rhsclone = rhs.clone(); - - let mut lhsargs: Vec> = Vec::new(); - let mut rhsargs: Vec> = Vec::new(); - let mut betweenargs: Vec> = Vec::new(); - - if opstring == "between" { - match &lhsclone { - Expr::Operation { op, args } if op == "and" => { - lhsargs = args.to_vec(); - lhsclone = *lhsargs.pop().unwrap(); - } - _ => (), - } - - match &lhsclone { - Expr::Operation { op, args } if op == "not" => { - lhsargs = args.to_vec(); - lhsclone = *lhsargs.pop().unwrap(); - notflag = true; - } - _ => (), - } - let betweenleft = lhsclone.to_owned(); - betweenargs.push(Box::new(betweenleft)); - - match &rhs { - Expr::Operation { op, args } if op == "and" => { - for a in args { - betweenargs.push(a.clone()); - } - rhsargs = betweenargs.split_off(3); - } - _ => (), - } - - retexpr = Expr::Operation { - op: "between".to_string(), - args: betweenargs, - }; - - if notflag { - retexpr = Expr::Operation { - op: "not".to_string(), - args: vec![Box::new(retexpr)], - }; - }; - - if lhsargs.is_empty() || rhsargs.is_empty() { - return Ok(retexpr); - } - - let mut andargs: Vec> = Vec::new(); - - if !lhsargs.is_empty() { - for a in lhsargs.into_iter() { - andargs.push(a); - } - } - andargs.push(Box::new(retexpr)); - - if !rhsargs.is_empty() { - for a in rhsargs.into_iter() { - andargs.push(a); - } - } - - return Ok(Expr::Operation { - op: "and".to_string(), - args: andargs, - }); - } else { - let mut outargs: Vec> = Vec::new(); - - match lhsclone { - Expr::Operation { ref op, ref args } if op == "and" => { - for arg in args.iter() { - outargs.push(arg.clone()); - } - outargs.push(Box::new(rhsclone)); - return Ok(Expr::Operation { - op: "and".to_string(), - args: outargs, - }); - } - _ => (), - } - retexpr = Expr::Operation { - op: opstring, - args: origargs, - }; - } - - if notflag { - return Ok(Expr::Operation { - op: "not".to_string(), - args: vec![Box::new(retexpr)], - }); - } - Ok(retexpr) - }) - .map_prefix(|op, child| { - let child = child?; - match op.as_rule() { - Rule::UnaryNot => Ok(Expr::Operation { - op: "not".to_string(), - args: vec![Box::new(child)], - }), - Rule::Negative => Ok(Expr::Operation { - op: "*".to_string(), - args: vec![Box::new(Expr::Float(-1.0)), Box::new(child)], - }), - rule => unreachable!("Expr::parse expected prefix operator, found {:?}", rule), - } - }) - .map_postfix(|child, op| { - let child = child?; - match op.as_rule() { - Rule::IsNullPostfix => Ok(Expr::Operation { - op: "isNull".to_string(), - args: vec![Box::new(child)], - }), - rule => unreachable!("Expr::parse expected postfix operator, found {:?}", rule), - } - }) - .parse(expression_pairs) -} - -/// Parses a string into a CQL2 expression. -/// -/// The string can be cql2-text or cql2-json — the type will be auto-detected. -/// Use [parse_text] and [parse_json] if you already know the CQL2 type of the -/// string. -/// -/// # Examples -/// -/// ``` -/// let s = "landsat:scene_id = 'LC82030282019133LGN00'"; -/// let expr = cql2::parse(s); -/// ``` -pub fn parse(cql2: &str) -> Result { - // TODO impl FromStr - if cql2.starts_with('{') { - parse_json(cql2).map_err(Error::from) - } else { - parse_text(cql2) - } -} - /// Parses a cql2-json string into a CQL2 expression. /// /// # Examples @@ -697,29 +26,8 @@ pub fn parse(cql2: &str) -> Result { /// let s = include_str!("../tests/fixtures/json/example01.json"); /// let expr = cql2::parse_json(s); /// ``` -pub fn parse_json(cql2: &str) -> Result { - serde_json::from_str(cql2) -} - -/// Parses a cql2-text string into a CQL2 expression. -/// -/// # Examples -/// -/// ``` -/// let s = "landsat:scene_id = 'LC82030282019133LGN00'"; -/// let expr = cql2::parse_text(s); -/// ``` -pub fn parse_text(cql2: &str) -> Result { - let mut pairs = CQL2Parser::parse(Rule::Expr, cql2).map_err(Box::new)?; - if let Some(pair) = pairs.next() { - if pairs.next().is_some() { - Err(Error::InvalidCql2Text(cql2.to_string())) - } else { - parse_expr(pair.into_inner()) - } - } else { - Err(Error::InvalidCql2Text(cql2.to_string())) - } +pub fn parse_json(s: &str) -> Result { + serde_json::from_str(s) } /// Reads a file and returns its contents as a CQL2 expression; @@ -730,8 +38,8 @@ pub fn parse_text(cql2: &str) -> Result { /// let expr = cql2::parse_file("tests/fixtures/json/example01.json"); /// ``` pub fn parse_file(path: impl AsRef) -> Result { - let cql2 = fs::read_to_string(path)?; - parse(&cql2) + let s = fs::read_to_string(path)?; + s.parse() } fn get_stdin() -> Result { @@ -753,7 +61,7 @@ fn get_stdin() -> Result { Ok(buffer) } -fn parse_stderr(cql2: &str) -> Result { +fn parse_stderr(s: &str) -> Result { let debug_level: u8 = std::env::var("CQL2_DEBUG_LEVEL") .ok() .map(|s| s.parse()) @@ -761,7 +69,7 @@ fn parse_stderr(cql2: &str) -> Result { .unwrap_or(1); let validator = Validator::new().unwrap(); - let parsed: Expr = parse(cql2)?; + let parsed: Expr = s.parse()?; let value = serde_json::to_value(&parsed)?; let validation = validator.validate(&value); diff --git a/src/parser.rs b/src/parser.rs new file mode 100644 index 0000000..d040c0f --- /dev/null +++ b/src/parser.rs @@ -0,0 +1,294 @@ +use crate::{Error, Expr}; +use geozero::{geojson::GeoJsonWriter, wkt::Wkt, CoordDimensions, GeozeroGeometry, ToJson}; +use pest::{ + iterators::{Pair, Pairs}, + pratt_parser::PrattParser, + Parser, +}; + +/// Parses a cql2-text string into a CQL2 expression. +/// +/// # Examples +/// +/// ``` +/// let s = "landsat:scene_id = 'LC82030282019133LGN00'"; +/// let expr = cql2::parse_text(s); +/// ``` +pub fn parse_text(s: &str) -> Result { + let mut pairs = CQL2Parser::parse(Rule::Expr, s).map_err(Box::new)?; + if let Some(pair) = pairs.next() { + if pairs.next().is_some() { + Err(Error::InvalidCql2Text(s.to_string())) + } else { + parse_expr(pair.into_inner()) + } + } else { + Err(Error::InvalidCql2Text(s.to_string())) + } +} + +#[derive(pest_derive::Parser)] +#[grammar = "cql2.pest"] +struct CQL2Parser; + +lazy_static::lazy_static! { + static ref PRATT_PARSER: PrattParser = { + use pest::pratt_parser::{Assoc::*, Op}; + use Rule::*; + PrattParser::new() + .op(Op::infix(Or, Left)) + .op(Op::infix(Between, Left)) + .op(Op::infix(And, Left)) + .op(Op::prefix(UnaryNot)) + .op(Op::infix(Eq, Right)) + .op( + Op::infix(NotEq, Right) | + Op::infix(Gt, Right) | + Op::infix(GtEq, Right) | + Op::infix(Lt, Right) | + Op::infix(LtEq, Right) + ) + .op(Op::infix(Like, Right)) + .op(Op::infix(In, Left)) + .op(Op::postfix(IsNullPostfix)) + .op(Op::infix(Is, Right)) + .op( + Op::infix(Add, Left) | + Op::infix(Subtract, Left) + ) + .op( + Op::infix(Multiply, Left) | + Op::infix(Divide, Left) | + Op::infix(Modulo, Left) + ) + .op(Op::infix(Power, Left)) + .op(Op::prefix(Negative)) + }; +} + +fn normalize_op(op: &str) -> String { + let op = op.to_lowercase(); + if op == "eq" { + "=".to_string() + } else { + op + } +} + +fn strip_quotes(s: &str) -> &str { + if (s.starts_with('"') && s.ends_with('"')) || (s.starts_with('\'') && s.ends_with('\'')) { + &s[1..s.len() - 1] + } else { + s + } +} + +fn opstr(op: Pair) -> String { + return normalize_op(op.as_str()); +} + +fn parse_expr(expression_pairs: Pairs<'_, Rule>) -> Result { + PRATT_PARSER + .map_primary(|primary| match primary.as_rule() { + Rule::Expr | Rule::ExpressionInParentheses => parse_expr(primary.into_inner()), + Rule::Unsigned => Ok(Expr::Float(primary.as_str().parse::()?)), + Rule::DECIMAL => Ok(Expr::Float(primary.as_str().parse::()?)), + Rule::SingleQuotedString => { + Ok(Expr::Literal(strip_quotes(primary.as_str()).to_string())) + } + Rule::True | Rule::False => { + let bool_value = primary.as_str().to_lowercase().parse::()?; + Ok(Expr::Bool(bool_value)) + } + Rule::Identifier => Ok(Expr::Property { + property: strip_quotes(primary.as_str()).to_string(), + }), + Rule::GEOMETRY => { + let geom_wkt = Wkt(primary.as_str()); + let mut out: Vec = Vec::new(); + let mut p = GeoJsonWriter::with_dims(&mut out, CoordDimensions::xyz()); + let _ = geom_wkt.process_geom(&mut p); + Ok(Expr::Geometry(serde_json::from_str(&geom_wkt.to_json()?)?)) + } + Rule::Function => { + let mut pairs = primary.into_inner(); + let op = strip_quotes( + pairs + .next() + .expect("the grammar guarantees that there is always an op") + .as_str(), + ) + .to_lowercase(); + let mut args = Vec::new(); + for pair in pairs { + args.push(Box::new(parse_expr(pair.into_inner())?)) + } + match op.as_str() { + "interval" => Ok(Expr::Interval { interval: args }), + "date" => Ok(Expr::Date { + date: args + .into_iter() + .next() + .ok_or(Error::MissingArgument("date"))?, + }), + "timestamp" => Ok(Expr::Timestamp { + timestamp: args + .into_iter() + .next() + .ok_or(Error::MissingArgument("timestamp"))?, + }), + _ => Ok(Expr::Operation { op, args }), + } + } + Rule::Array => { + let pairs = primary.into_inner(); + let mut array_elements = Vec::new(); + for pair in pairs { + array_elements.push(Box::new(parse_expr(pair.into_inner())?)) + } + Ok(Expr::Array(array_elements)) + } + + rule => unreachable!("Expr::parse expected atomic rule, found {:?}", rule), + }) + .map_infix(|lhs, op, rhs| { + let lhs = lhs?; + let rhs = rhs?; + let mut opstring = opstr(op); + + let mut notflag: bool = false; + if opstring.starts_with("not") { + opstring = opstring.replace("not ", ""); + notflag = true; + } + + let origargs = vec![Box::new(lhs.clone()), Box::new(rhs.clone())]; + let mut retexpr: Expr; + let mut lhsclone = lhs.clone(); + let rhsclone = rhs.clone(); + + let mut lhsargs: Vec> = Vec::new(); + let mut rhsargs: Vec> = Vec::new(); + let mut betweenargs: Vec> = Vec::new(); + + if opstring == "between" { + match &lhsclone { + Expr::Operation { op, args } if op == "and" => { + lhsargs = args.to_vec(); + lhsclone = *lhsargs.pop().unwrap(); + } + _ => (), + } + + match &lhsclone { + Expr::Operation { op, args } if op == "not" => { + lhsargs = args.to_vec(); + lhsclone = *lhsargs.pop().unwrap(); + notflag = true; + } + _ => (), + } + let betweenleft = lhsclone.to_owned(); + betweenargs.push(Box::new(betweenleft)); + + match &rhs { + Expr::Operation { op, args } if op == "and" => { + for a in args { + betweenargs.push(a.clone()); + } + rhsargs = betweenargs.split_off(3); + } + _ => (), + } + + retexpr = Expr::Operation { + op: "between".to_string(), + args: betweenargs, + }; + + if notflag { + retexpr = Expr::Operation { + op: "not".to_string(), + args: vec![Box::new(retexpr)], + }; + }; + + if lhsargs.is_empty() || rhsargs.is_empty() { + return Ok(retexpr); + } + + let mut andargs: Vec> = Vec::new(); + + if !lhsargs.is_empty() { + for a in lhsargs.into_iter() { + andargs.push(a); + } + } + andargs.push(Box::new(retexpr)); + + if !rhsargs.is_empty() { + for a in rhsargs.into_iter() { + andargs.push(a); + } + } + + return Ok(Expr::Operation { + op: "and".to_string(), + args: andargs, + }); + } else { + let mut outargs: Vec> = Vec::new(); + + match lhsclone { + Expr::Operation { ref op, ref args } if op == "and" => { + for arg in args.iter() { + outargs.push(arg.clone()); + } + outargs.push(Box::new(rhsclone)); + return Ok(Expr::Operation { + op: "and".to_string(), + args: outargs, + }); + } + _ => (), + } + retexpr = Expr::Operation { + op: opstring, + args: origargs, + }; + } + + if notflag { + return Ok(Expr::Operation { + op: "not".to_string(), + args: vec![Box::new(retexpr)], + }); + } + Ok(retexpr) + }) + .map_prefix(|op, child| { + let child = child?; + match op.as_rule() { + Rule::UnaryNot => Ok(Expr::Operation { + op: "not".to_string(), + args: vec![Box::new(child)], + }), + Rule::Negative => Ok(Expr::Operation { + op: "*".to_string(), + args: vec![Box::new(Expr::Float(-1.0)), Box::new(child)], + }), + rule => unreachable!("Expr::parse expected prefix operator, found {:?}", rule), + } + }) + .map_postfix(|child, op| { + let child = child?; + match op.as_rule() { + Rule::IsNullPostfix => Ok(Expr::Operation { + op: "isNull".to_string(), + args: vec![Box::new(child)], + }), + rule => unreachable!("Expr::parse expected postfix operator, found {:?}", rule), + } + }) + .parse(expression_pairs) +} diff --git a/src/validator.rs b/src/validator.rs new file mode 100644 index 0000000..4f382a6 --- /dev/null +++ b/src/validator.rs @@ -0,0 +1,57 @@ +use crate::Error; +use boon::{Compiler, SchemaIndex, Schemas, ValidationError}; +use serde_json::Value; + +/// A re-usable json-schema validator for CQL2. +pub struct Validator { + schemas: Schemas, + index: SchemaIndex, +} + +impl Validator { + /// Creates a new validator. + /// + /// # Examples + /// + /// ``` + /// use cql2::Validator; + /// + /// let validator = Validator::new().unwrap(); + /// ``` + pub fn new() -> Result { + let mut schemas = Schemas::new(); + let mut compiler = Compiler::new(); + let schema_json = serde_json::from_str(include_str!("cql2.json"))?; + compiler.add_resource("/tmp/cql2.json", schema_json)?; + let index = compiler.compile("/tmp/cql2.json", &mut schemas)?; + Ok(Validator { schemas, index }) + } + + /// Validates a [serde_json::Value]. + /// + /// # Examples + /// + /// ``` + /// use cql2::Validator; + /// use serde_json::json; + /// + /// let validator = Validator::new().unwrap(); + /// + /// let valid = json!({ + /// "op": "=", + /// "args": [ + /// { "property": "landsat:scene_id" }, + /// "LC82030282019133LGN00" + /// ] + /// }); + /// validator.validate(&valid).unwrap(); + /// + /// let invalid = json!({ + /// "op": "not an operator!", + /// }); + /// validator.validate(&invalid).unwrap_err(); + /// ``` + pub fn validate<'a, 'b>(&'a self, value: &'b Value) -> Result<(), ValidationError<'a, 'b>> { + self.schemas.validate(value, self.index) + } +} diff --git a/tests/ogc_tests.rs b/tests/ogc_tests.rs index d4c7c6b..804995d 100644 --- a/tests/ogc_tests.rs +++ b/tests/ogc_tests.rs @@ -5,12 +5,12 @@ use serde_json::json; use std::path::{Path, PathBuf}; fn validate_str(s: &str) -> Expr { - let expr = cql2::parse(s).unwrap(); + let expr: Expr = s.parse().unwrap(); assert!(expr.is_valid()); - let expr_from_txt = cql2::parse(&expr.to_text().unwrap()).unwrap(); + let expr_from_txt: Expr = expr.to_text().unwrap().parse().unwrap(); assert!(expr_from_txt.is_valid()); let json = expr.to_json().unwrap(); - let expr_from_json = cql2::parse(&json).unwrap(); + let expr_from_json: Expr = json.parse().unwrap(); assert_json_eq!(json!(json), json!(expr_from_json.to_json().unwrap())); expr }