difftreelog
refactor(evaluator) error handling cleanup
in: master
6 files changed
crates/jsonnet-evaluator/src/ctx.rsdiffbeforeafterboth--- a/crates/jsonnet-evaluator/src/ctx.rs
+++ b/crates/jsonnet-evaluator/src/ctx.rs
@@ -54,11 +54,11 @@
}
pub fn binding(&self, name: Rc<str>) -> Result<LazyVal> {
- self.0.bindings.get(&name).cloned().ok_or_else(|| {
- create_error::<()>(Error::UnknownVariable(name))
- .err()
- .unwrap()
- })
+ self.0
+ .bindings
+ .get(&name)
+ .cloned()
+ .ok_or_else(|| create_error(Error::UnknownVariable(name)))
}
pub fn into_future(self, ctx: FutureContext) -> Context {
{
crates/jsonnet-evaluator/src/evaluate.rsdiffbeforeafterboth--- a/crates/jsonnet-evaluator/src/evaluate.rs
+++ b/crates/jsonnet-evaluator/src/evaluate.rs
@@ -1,7 +1,7 @@
use crate::{
- context_creator, create_error, escape_string_json, future_wrapper, lazy_val, manifest_json_ex,
- parse_args, push, with_state, Context, ContextCreator, Error, FuncDesc, LazyBinding, LazyVal,
- ObjMember, ObjValue, Result, Val, ValType,
+ context_creator, create_error, create_error_result, escape_string_json, future_wrapper,
+ lazy_val, manifest_json_ex, parse_args, push, with_state, Context, ContextCreator, Error,
+ FuncDesc, LazyBinding, LazyVal, ObjMember, ObjValue, Result, Val, ValType,
};
use closure::closure;
use jsonnet_parser::{
@@ -74,7 +74,7 @@
(UnaryOpType::Not, Val::Bool(v)) => Val::Bool(!v),
(UnaryOpType::Minus, Val::Num(n)) => Val::Num(-*n),
(UnaryOpType::BitNot, Val::Num(n)) => Val::Num(!(*n as i32) as f64),
- (op, o) => create_error(Error::UnaryOperatorDoesNotOperateOnType(
+ (op, o) => create_error_result(Error::UnaryOperatorDoesNotOperateOnType(
op,
o.value_type()?,
))?,
@@ -95,7 +95,7 @@
(Val::Obj(v1), Val::Obj(v2)) => Val::Obj(v2.with_super(v1.clone())),
(Val::Arr(a), Val::Arr(b)) => Val::Arr(Rc::new([&a[..], &b[..]].concat())),
(Val::Num(v1), Val::Num(v2)) => Val::Num(v1 + v2),
- _ => create_error(Error::BinaryOperatorDoesNotOperateOnValues(
+ _ => create_error_result(Error::BinaryOperatorDoesNotOperateOnValues(
BinaryOpType::Add,
a.value_type()?,
b.value_type()?,
@@ -140,7 +140,7 @@
(Val::Num(v1), BinaryOpType::Mul, Val::Num(v2)) => Val::Num(v1 * v2),
(Val::Num(v1), BinaryOpType::Div, Val::Num(v2)) => {
if *v2 <= f64::EPSILON {
- create_error(crate::Error::DivisionByZero)?
+ create_error_result(crate::Error::DivisionByZero)?
}
Val::Num(v1 / v2)
}
@@ -168,7 +168,7 @@
Val::Num(((*v1 as i32) >> (*v2 as i32)) as f64)
}
- _ => create_error(Error::BinaryOperatorDoesNotOperateOnValues(
+ _ => create_error_result(Error::BinaryOperatorDoesNotOperateOnValues(
op,
a.value_type()?,
b.value_type()?,
@@ -367,7 +367,7 @@
},
);
}
- v => create_error(Error::FieldMustBeStringGot(v.value_type()?))?,
+ v => create_error_result(Error::FieldMustBeStringGot(v.value_type()?))?,
}
}
@@ -423,10 +423,10 @@
} else if let Some(Val::Str(n)) = v.get("__intristic_namespace__".into())? {
Val::Intristic(n, s)
} else {
- create_error(crate::Error::NoSuchField(s))?
+ create_error_result(crate::Error::NoSuchField(s))?
}
}
- (Val::Obj(_), n) => create_error(crate::Error::ValueIndexMustBeTypeGot(
+ (Val::Obj(_), n) => create_error_result(crate::Error::ValueIndexMustBeTypeGot(
ValType::Obj,
ValType::Str,
n.value_type()?,
@@ -434,17 +434,19 @@
(Val::Arr(v), Val::Num(n)) => {
if n.fract() > f64::EPSILON {
- create_error(crate::Error::FractionalIndex)?
+ create_error_result(crate::Error::FractionalIndex)?
}
v.get(n as usize)
- .unwrap_or_else(|| panic!("out of bounds"))
+ .ok_or_else(|| {
+ create_error(crate::Error::ArrayBoundsError(n as usize, v.len()))
+ })?
.clone()
.unwrap_if_lazy()?
}
(Val::Arr(_), Val::Str(n)) => {
- create_error(crate::Error::AttemptedIndexAnArrayWithString(n))?
+ create_error_result(crate::Error::AttemptedIndexAnArrayWithString(n))?
}
- (Val::Arr(_), n) => create_error(crate::Error::ValueIndexMustBeTypeGot(
+ (Val::Arr(_), n) => create_error_result(crate::Error::ValueIndexMustBeTypeGot(
ValType::Arr,
ValType::Num,
n.value_type()?,
@@ -457,13 +459,13 @@
.collect::<String>()
.into(),
),
- (Val::Str(_), n) => create_error(crate::Error::ValueIndexMustBeTypeGot(
+ (Val::Str(_), n) => create_error_result(crate::Error::ValueIndexMustBeTypeGot(
ValType::Str,
ValType::Num,
n.value_type()?,
))?,
- (v, _) => create_error(crate::Error::CantIndexInto(v.value_type()?))?,
+ (v, _) => create_error_result(crate::Error::CantIndexInto(v.value_type()?))?,
}
}
LocalExpr(bindings, returned) => {
@@ -623,11 +625,7 @@
0, x: [Val::Str]!!Val::Str, vec![ValType::Str];
], {
with_state(|s| s.0.ext_vars.borrow().get(&x).cloned()).ok_or_else(
- || {
- create_error::<()>(crate::Error::UndefinedExternalVariable(x))
- .err()
- .unwrap()
- },
+ || create_error(crate::Error::UndefinedExternalVariable(x)),
)?
}),
("std", "filter") => parse_args!(context, "std.filter", args, 2, [
@@ -728,7 +726,7 @@
Val::Str(manifest_json_ex(&value, &indent)?.into())
})
}
- (ns, name) => create_error(crate::error::Error::IntristicNotFound(
+ (ns, name) => create_error_result(crate::Error::IntristicNotFound(
ns.into(),
name.into(),
))?,
@@ -741,7 +739,7 @@
push(loc, "function call", body)?
}
}
- v => create_error(crate::error::Error::OnlyFunctionsCanBeCalledGot(
+ v => create_error_result(crate::Error::OnlyFunctionsCanBeCalledGot(
v.value_type()?,
))?,
}
@@ -764,7 +762,7 @@
panic!("assertion failed ({:?}): no message", value);
}
}
- Error(e) => create_error(crate::Error::RuntimeError(
+ Error(e) => create_error_result(crate::Error::RuntimeError(
evaluate(context, e)?.try_cast_str("error text should be string")?,
))?,
IfElse {
@@ -801,6 +799,8 @@
import_location.pop();
Val::Str(with_state(|s| s.import_file_str(&import_location, path))?)
}
- Literal(LiteralType::Super) => return create_error(crate::error::Error::StandaloneSuper),
+ Literal(LiteralType::Super) => {
+ return create_error_result(crate::Error::StandaloneSuper)
+ }
})
}
crates/jsonnet-evaluator/src/function.rsdiffbeforeafterboth1use crate::{create_error, evaluate, lazy_val, resolved_lazy_val, Context, Error, Result, Val};2use closure::closure;3use jsonnet_parser::{ArgsDesc, ParamsDesc};4use std::collections::HashMap;56/// Creates correct [context](Context) for function body evaluation, returning error on invalid call7///8/// * `ctx` used for passed argument expressions execution, and for body execution (if `body_ctx` is not set)9/// * `body_ctx` used for default parameter values execution, and for body execution (if set)10/// * `params` function parameters definition11/// * `args` passed function arguments12/// * `tailstruct` if true - function arguments is eager executed, otherwise - lazy13pub fn parse_function_call(14 ctx: Context,15 body_ctx: Option<Context>,16 params: &ParamsDesc,17 args: &ArgsDesc,18 tailstrict: bool,19) -> Result<Context> {20 let mut out = HashMap::new();21 let mut positioned_args = vec![None; params.0.len()];22 for (id, arg) in args.iter().enumerate() {23 let idx = if let Some(name) = &arg.0 {24 params.iter().position(|p| *p.0 == *name).ok_or_else(|| {25 create_error::<()>(Error::UnknownFunctionParameter(name.clone()))26 .err()27 .unwrap()28 })?29 } else {30 id31 };3233 if idx >= params.len() {34 create_error(Error::TooManyArgsFunctionHas(params.len()))?;35 }36 if positioned_args[idx].is_some() {37 create_error(Error::BindingParameterASecondTime(params[idx].0.clone()))?;38 }39 positioned_args[idx] = Some(arg.1.clone());40 }41 // Fill defaults42 for (id, p) in params.iter().enumerate() {43 let (ctx, expr) = if let Some(arg) = &positioned_args[id] {44 (ctx.clone(), arg)45 } else if let Some(default) = &p.1 {46 (47 body_ctx48 .clone()49 .expect("no default context set for call with defined default parameter value"),50 default,51 )52 } else {53 create_error(Error::FunctionParameterNotBoundInCall(p.0.clone()))?;54 unreachable!()55 };56 let val = if tailstrict {57 resolved_lazy_val!(evaluate(ctx, expr)?)58 } else {59 lazy_val!(closure!(clone ctx, clone expr, ||evaluate(ctx.clone(), &expr)))60 };61 out.insert(p.0.clone(), val);62 }6364 Ok(body_ctx.unwrap_or(ctx).extend(out, None, None, None)?)65}6667pub(crate) fn place_args(68 ctx: Context,69 body_ctx: Option<Context>,70 params: &ParamsDesc,71 args: &[Val],72) -> Result<Context> {73 let mut out = HashMap::new();74 let mut positioned_args = vec![None; params.0.len()];75 for (id, arg) in args.iter().enumerate() {76 if id >= params.len() {77 create_error(Error::TooManyArgsFunctionHas(params.len()))?;78 }79 positioned_args[id] = Some(arg);80 }81 // Fill defaults82 for (id, p) in params.iter().enumerate() {83 let val = if let Some(arg) = &positioned_args[id] {84 (*arg).clone()85 } else if let Some(default) = &p.1 {86 evaluate(ctx.clone(), default)?87 } else {88 create_error(Error::FunctionParameterNotBoundInCall(p.0.clone()))?;89 unreachable!()90 };91 out.insert(p.0.clone(), resolved_lazy_val!(val));92 }9394 Ok(body_ctx.unwrap_or(ctx).extend(out, None, None, None)?)95}9697#[macro_export]98macro_rules! parse_args {99 ($ctx: expr, $fn_name: expr, $args: expr, $total_args: expr, [100 $($id: expr, $name: ident $(: [$($p: path)|+] $(!! $a: path)?)?, $nt: expr);+ $(;)?101 ], $handler:block) => {{102 use crate::error::Error;103 let args = $args;104 if args.len() > $total_args {105 create_error(Error::TooManyArgsFunctionHas($total_args))?;106 }107 $(108 if args.len() <= $id {109 create_error(Error::FunctionParameterNotBoundInCall(stringify!($name).into()))?;110 }111 let $name = &args[$id];112 if $name.0.is_some() {113 if $name.0.as_ref().unwrap() != stringify!($name) {114 create_error(Error::IntristicArgumentReorderingIsNotSupportedYet)?;115 }116 }117 let $name = evaluate($ctx.clone(), &$name.1)?;118 $(119 match $name {120 $($p(_))|+ => {},121 _ => create_error(Error::TypeMismatch(concat!($fn_name, " ", stringify!($id), "nd argument"), $nt, $name.value_type()?))?,122 };123 $(124 let $name = match $name {125 $a(v) => v,126 _ => create_error(Error::TypeMismatch(concat!($fn_name, " ", stringify!($id), "nd argument"), $nt, $name.value_type()?))?,127 };128 )*129 )*130 )+131 $handler132 }};133}134135#[test]136fn test() -> Result<()> {137 use jsonnet_parser::*;138 use crate::val::ValType;139 let state = crate::EvaluationState::default();140 let evaluator = state.with_stdlib();141 let ctx = evaluator.create_default_context()?;142 evaluator.run_in_state(|| {143 parse_args!(ctx, "test", ArgsDesc(vec![144 Arg(None, el!(Expr::Num(2.0))),145 Arg(Some("b".into()), el!(Expr::Num(1.0))),146 ]), 2, [147 0, a: [Val::Num]!!Val::Num, vec![ValType::Num];148 1, b: [Val::Num]!!Val::Num, vec![ValType::Num];149 ], {150 assert!((a - 2.0).abs() <= f64::EPSILON);151 assert!((b - 1.0).abs() <= f64::EPSILON);152 });153 Ok(())154 })155}1use crate::{2 create_error, create_error_result, evaluate, lazy_val, resolved_lazy_val, Context, Error,3 Result, Val,4};5use closure::closure;6use jsonnet_parser::{ArgsDesc, ParamsDesc};7use std::collections::HashMap;89/// Creates correct [context](Context) for function body evaluation, returning error on invalid call10///11/// * `ctx` used for passed argument expressions execution, and for body execution (if `body_ctx` is not set)12/// * `body_ctx` used for default parameter values execution, and for body execution (if set)13/// * `params` function parameters definition14/// * `args` passed function arguments15/// * `tailstruct` if true - function arguments is eager executed, otherwise - lazy16pub fn parse_function_call(17 ctx: Context,18 body_ctx: Option<Context>,19 params: &ParamsDesc,20 args: &ArgsDesc,21 tailstrict: bool,22) -> Result<Context> {23 let mut out = HashMap::new();24 let mut positioned_args = vec![None; params.0.len()];25 for (id, arg) in args.iter().enumerate() {26 let idx = if let Some(name) = &arg.0 {27 params28 .iter()29 .position(|p| *p.0 == *name)30 .ok_or_else(|| create_error(Error::UnknownFunctionParameter(name.clone())))?31 } else {32 id33 };3435 if idx >= params.len() {36 create_error_result(Error::TooManyArgsFunctionHas(params.len()))?;37 }38 if positioned_args[idx].is_some() {39 create_error_result(Error::BindingParameterASecondTime(params[idx].0.clone()))?;40 }41 positioned_args[idx] = Some(arg.1.clone());42 }43 // Fill defaults44 for (id, p) in params.iter().enumerate() {45 let (ctx, expr) = if let Some(arg) = &positioned_args[id] {46 (ctx.clone(), arg)47 } else if let Some(default) = &p.1 {48 (49 body_ctx50 .clone()51 .expect("no default context set for call with defined default parameter value"),52 default,53 )54 } else {55 create_error_result(Error::FunctionParameterNotBoundInCall(p.0.clone()))?;56 unreachable!()57 };58 let val = if tailstrict {59 resolved_lazy_val!(evaluate(ctx, expr)?)60 } else {61 lazy_val!(closure!(clone ctx, clone expr, ||evaluate(ctx.clone(), &expr)))62 };63 out.insert(p.0.clone(), val);64 }6566 Ok(body_ctx.unwrap_or(ctx).extend(out, None, None, None)?)67}6869pub(crate) fn place_args(70 ctx: Context,71 body_ctx: Option<Context>,72 params: &ParamsDesc,73 args: &[Val],74) -> Result<Context> {75 let mut out = HashMap::new();76 let mut positioned_args = vec![None; params.0.len()];77 for (id, arg) in args.iter().enumerate() {78 if id >= params.len() {79 create_error_result(Error::TooManyArgsFunctionHas(params.len()))?;80 }81 positioned_args[id] = Some(arg);82 }83 // Fill defaults84 for (id, p) in params.iter().enumerate() {85 let val = if let Some(arg) = &positioned_args[id] {86 (*arg).clone()87 } else if let Some(default) = &p.1 {88 evaluate(ctx.clone(), default)?89 } else {90 create_error_result(Error::FunctionParameterNotBoundInCall(p.0.clone()))?;91 unreachable!()92 };93 out.insert(p.0.clone(), resolved_lazy_val!(val));94 }9596 Ok(body_ctx.unwrap_or(ctx).extend(out, None, None, None)?)97}9899#[macro_export]100macro_rules! parse_args {101 ($ctx: expr, $fn_name: expr, $args: expr, $total_args: expr, [102 $($id: expr, $name: ident $(: [$($p: path)|+] $(!! $a: path)?)?, $nt: expr);+ $(;)?103 ], $handler:block) => {{104 use crate::Error;105 let args = $args;106 if args.len() > $total_args {107 create_error_result(Error::TooManyArgsFunctionHas($total_args))?;108 }109 $(110 if args.len() <= $id {111 create_error_result(Error::FunctionParameterNotBoundInCall(stringify!($name).into()))?;112 }113 let $name = &args[$id];114 if $name.0.is_some() {115 if $name.0.as_ref().unwrap() != stringify!($name) {116 create_error_result(Error::IntristicArgumentReorderingIsNotSupportedYet)?;117 }118 }119 let $name = evaluate($ctx.clone(), &$name.1)?;120 $(121 match $name {122 $($p(_))|+ => {},123 _ => create_error_result(Error::TypeMismatch(concat!($fn_name, " ", stringify!($id), "nd argument"), $nt, $name.value_type()?))?,124 };125 $(126 let $name = match $name {127 $a(v) => v,128 _ => create_error_result(Error::TypeMismatch(concat!($fn_name, " ", stringify!($id), "nd argument"), $nt, $name.value_type()?))?,129 };130 )*131 )*132 )+133 $handler134 }};135}136137#[test]138fn test() -> Result<()> {139 use jsonnet_parser::*;140 use crate::val::ValType;141 let state = crate::EvaluationState::default();142 let evaluator = state.with_stdlib();143 let ctx = evaluator.create_default_context()?;144 evaluator.run_in_state(|| {145 parse_args!(ctx, "test", ArgsDesc(vec![146 Arg(None, el!(Expr::Num(2.0))),147 Arg(Some("b".into()), el!(Expr::Num(1.0))),148 ]), 2, [149 0, a: [Val::Num]!!Val::Num, vec![ValType::Num];150 1, b: [Val::Num]!!Val::Num, vec![ValType::Num];151 ], {152 assert!((a - 2.0).abs() <= f64::EPSILON);153 assert!((b - 1.0).abs() <= f64::EPSILON);154 });155 Ok(())156 })157}crates/jsonnet-evaluator/src/import.rsdiffbeforeafterboth--- a/crates/jsonnet-evaluator/src/import.rs
+++ b/crates/jsonnet-evaluator/src/import.rs
@@ -1,5 +1,8 @@
-use crate::create_error;
-use crate::error::{Error, Result};
+use crate::create_error_result;
+use crate::{
+ create_error,
+ error::{Error, Result},
+};
use fs::File;
use std::fs;
use std::io::Read;
@@ -13,7 +16,7 @@
pub struct DummyImportResolver;
impl ImportResolver for DummyImportResolver {
fn resolve_file(&self, from: &PathBuf, path: &PathBuf) -> Result<Rc<PathBuf>> {
- create_error(Error::ImportNotSupported(from.clone(), path.clone()))
+ create_error_result(Error::ImportNotSupported(from.clone(), path.clone()))
}
fn load_file_contents(&self, _resolved: &PathBuf) -> Result<Rc<str>> {
// Can be only caused by library direct consumer, not by supplied jsonnet
@@ -43,21 +46,15 @@
return Ok(Rc::new(cloned));
}
}
- create_error(Error::ImportFileNotFound(from.clone(), path.clone()))
+ create_error_result(Error::ImportFileNotFound(from.clone(), path.clone()))
}
}
fn load_file_contents(&self, id: &PathBuf) -> Result<Rc<str>> {
- let mut file = File::open(id).map_err(|_e| {
- create_error::<()>(Error::ResolvedFileNotFound(id.clone()))
- .err()
- .unwrap()
- })?;
+ let mut file =
+ File::open(id).map_err(|_e| create_error(Error::ResolvedFileNotFound(id.clone())))?;
let mut out = String::new();
- file.read_to_string(&mut out).map_err(|_e| {
- create_error::<()>(Error::ImportBadFileUtf8(id.clone()))
- .err()
- .unwrap()
- })?;
+ file.read_to_string(&mut out)
+ .map_err(|_e| create_error(Error::ImportBadFileUtf8(id.clone())))?;
Ok(out.into())
}
}
crates/jsonnet-evaluator/src/lib.rsdiffbeforeafterboth--- a/crates/jsonnet-evaluator/src/lib.rs
+++ b/crates/jsonnet-evaluator/src/lib.rs
@@ -87,9 +87,12 @@
pub(crate) fn with_state<T>(f: impl FnOnce(&EvaluationState) -> T) -> T {
EVAL_STATE.with(|s| f(s.borrow().as_ref().unwrap()))
}
-pub(crate) fn create_error<T>(err: Error) -> Result<T> {
+pub(crate) fn create_error(err: Error) -> LocError {
with_state(|s| s.error(err))
}
+pub(crate) fn create_error_result<T>(err: Error) -> Result<T> {
+ Err(with_state(|s| s.error(err)))
+}
pub(crate) fn push<T>(
e: &Option<ExprLocation>,
comment: &str,
@@ -187,9 +190,7 @@
}
let contents = self.0.import_resolver.load_file_contents(&file_path)?;
self.add_file(file_path.clone(), contents).map_err(|e| {
- create_error::<()>(Error::ImportSyntaxError(e))
- .err()
- .unwrap()
+ create_error(Error::ImportSyntaxError(e))
})?;
self.evaluate_file(&file_path)
}
@@ -292,7 +293,7 @@
let mut stack = self.0.stack.borrow_mut();
if stack.len() > self.0.settings.max_stack_frames {
drop(stack);
- return self.error(Error::StackOverflow);
+ return Err(self.error(Error::StackOverflow));
} else {
stack.push(StackTraceElement(e, comment));
}
@@ -318,8 +319,8 @@
.collect(),
)
}
- pub fn error<T>(&self, err: Error) -> Result<T> {
- Err(LocError(err, self.stack_trace()))
+ pub fn error(&self, err: Error) -> LocError {
+ LocError(err, self.stack_trace())
}
pub fn run_in_state<T>(&self, f: impl FnOnce() -> T) -> T {
crates/jsonnet-evaluator/src/val.rsdiffbeforeafterboth--- a/crates/jsonnet-evaluator/src/val.rs
+++ b/crates/jsonnet-evaluator/src/val.rs
@@ -1,5 +1,5 @@
use crate::{
- create_error, evaluate,
+ create_error_result, evaluate,
function::{parse_function_call, place_args},
Context, Error, ObjValue, Result,
};
@@ -137,7 +137,7 @@
pub fn assert_type(&self, context: &'static str, val_type: ValType) -> Result<()> {
let this_type = self.value_type()?;
if this_type != val_type {
- create_error(Error::TypeMismatch(context, vec![val_type], this_type))
+ create_error_result(Error::TypeMismatch(context, vec![val_type], this_type))
} else {
Ok(())
}