use crate::ast::{Expr, ExprKind, Literal, Name};
use crate::extensions::decimal;
use crate::validator::extension_schema::{ArgumentCheckFn, ExtensionFunctionType, ExtensionSchema};
use crate::validator::types::{self, Type};
use itertools::Itertools;
use super::eval_extension_constructor;
#[expect(clippy::panic, reason = "see `Note on safety` above")]
fn get_argument_types(fname: &Name, decimal_ty: &Type) -> Vec<types::Type> {
if !fname.as_ref().is_unqualified() {
panic!("unexpected decimal extension function name: {fname}")
}
match fname.basename().as_ref() {
"decimal" => vec![Type::primitive_string()],
"lessThan" | "lessThanOrEqual" | "greaterThan" | "greaterThanOrEqual" => {
vec![decimal_ty.clone(), decimal_ty.clone()]
}
_ => panic!("unexpected decimal extension function name: {fname}"),
}
}
#[expect(clippy::panic, reason = "see `Note on safety` above")]
fn get_return_type(fname: &Name, decimal_ty: &Type) -> Type {
if !fname.as_ref().is_unqualified() {
panic!("unexpected decimal extension function name: {fname}")
}
match fname.basename().as_ref() {
"decimal" => decimal_ty.clone(),
"lessThan" | "lessThanOrEqual" | "greaterThan" | "greaterThanOrEqual" => {
Type::primitive_boolean()
}
_ => panic!("unexpected decimal extension function name: {fname}"),
}
}
#[expect(clippy::panic, reason = "see `Note on safety` above")]
fn get_argument_check(fname: &Name) -> Option<ArgumentCheckFn> {
if !fname.as_ref().is_unqualified() {
panic!("unexpected decimal extension function name: {fname}")
}
match fname.basename().as_ref() {
"decimal" => {
let fname = fname.clone();
Some(Box::new(move |args| {
validate_decimal_string(fname.clone(), args)
}))
}
"lessThan" | "lessThanOrEqual" | "greaterThan" | "greaterThanOrEqual" => None,
_ => panic!("unexpected decimal extension function name: {fname}"),
}
}
pub fn extension_schema() -> ExtensionSchema {
let decimal_ext = decimal::extension();
let decimal_ty = Type::extension(decimal_ext.name().clone());
let fun_tys = decimal_ext.funcs().map(|f| {
let return_type = get_return_type(f.name(), &decimal_ty);
debug_assert!(f
.return_type()
.map(|ty| return_type.is_consistent_with(ty))
.unwrap_or_else(|| return_type == Type::Never));
ExtensionFunctionType::new(
f.name().clone(),
get_argument_types(f.name(), &decimal_ty),
return_type,
get_argument_check(f.name()),
false,
)
});
ExtensionSchema::new(decimal_ext.name().clone(), fun_tys, std::iter::empty())
}
fn validate_decimal_string(decimal_constructor_name: Name, exprs: &[Expr]) -> Result<(), String> {
match exprs.iter().exactly_one().map(|a| a.expr_kind()) {
Ok(ExprKind::Lit(lit_arg @ Literal::String(s))) => {
eval_extension_constructor(decimal_constructor_name, s.clone())
.map(|_| ())
.map_err(|_| format!("Failed to parse as a decimal value: `{lit_arg}`"))
}
_ => Ok(()),
}
}
#[cfg(test)]
mod test {
use super::*;
#[test]
fn extension_schema_correctness() {
let _ = extension_schema();
}
}