git.delta.rocks / jrsonnet / refs/commits / 7eb32146c8af

difftreelog

refactor(evaluator) error handling cleanup

Лач2020-06-27parent: #41ef1e2.patch.diff
in: master

6 files changed

modifiedcrates/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 {
 		{
modifiedcrates/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)
+		}
 	})
 }
modifiedcrates/jsonnet-evaluator/src/function.rsdiffbeforeafterboth
before · crates/jsonnet-evaluator/src/function.rs
1use 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}
after · crates/jsonnet-evaluator/src/function.rs
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}
modifiedcrates/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())
 	}
 }
modifiedcrates/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 {
modifiedcrates/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(())
 		}