1use std::rc::Rc;23use jrsonnet_gcmodule::{Cc, Trace};4use jrsonnet_interner::IStr;5use jrsonnet_parser::{6 ArgsDesc, AssertStmt, BindSpec, CompSpec, Expr, FieldMember, FieldName, ForSpecData,7 IfSpecData, LiteralType, LocExpr, Member, ObjBody, ParamsDesc,8};9use jrsonnet_types::ValType;1011use self::destructure::destruct;12use crate::{13 arr::ArrValue,14 destructure::evaluate_dest,15 error::{suggest_object_fields, ErrorKind::*},16 evaluate::operator::{evaluate_add_op, evaluate_binary_op_special, evaluate_unary_op},17 function::{CallLocation, FuncDesc, FuncVal},18 throw,19 typed::Typed,20 val::{CachedUnbound, IndexableVal, StrValue, Thunk, ThunkValue},21 Context, GcHashMap, ObjValue, ObjValueBuilder, ObjectAssertion, Pending, Result, State,22 Unbound, Val,23};24pub mod destructure;25pub mod operator;2627pub fn evaluate_trivial(expr: &LocExpr) -> Option<Val> {28 fn is_trivial(expr: &LocExpr) -> bool {29 match &*expr.0 {30 Expr::Str(_)31 | Expr::Num(_)32 | Expr::Literal(LiteralType::False | LiteralType::True | LiteralType::Null) => true,33 Expr::Arr(a) => a.iter().all(is_trivial),34 Expr::Parened(e) => is_trivial(e),35 _ => false,36 }37 }38 Some(match &*expr.0 {39 Expr::Str(s) => Val::Str(StrValue::Flat(s.clone())),40 Expr::Num(n) => Val::Num(*n),41 Expr::Literal(LiteralType::False) => Val::Bool(false),42 Expr::Literal(LiteralType::True) => Val::Bool(true),43 Expr::Literal(LiteralType::Null) => Val::Null,44 Expr::Arr(n) => {45 if n.iter().any(|e| !is_trivial(e)) {46 return None;47 }48 Val::Arr(ArrValue::eager(49 n.iter()50 .map(evaluate_trivial)51 .map(|e| e.expect("checked trivial"))52 .collect(),53 ))54 }55 Expr::Parened(e) => evaluate_trivial(e)?,56 _ => return None,57 })58}5960pub fn evaluate_method(ctx: Context, name: IStr, params: ParamsDesc, body: LocExpr) -> Val {61 Val::Func(FuncVal::Normal(Cc::new(FuncDesc {62 name,63 ctx,64 params,65 body,66 })))67}6869pub fn evaluate_field_name(ctx: Context, field_name: &FieldName) -> Result<Option<IStr>> {70 Ok(match field_name {71 FieldName::Fixed(n) => Some(n.clone()),72 FieldName::Dyn(expr) => State::push(73 CallLocation::new(&expr.1),74 || "evaluating field name".to_string(),75 || {76 let value = evaluate(ctx, expr)?;77 if matches!(value, Val::Null) {78 Ok(None)79 } else {80 Ok(Some(IStr::from_untyped(value)?))81 }82 },83 )?,84 })85}8687pub fn evaluate_comp(88 ctx: Context,89 specs: &[CompSpec],90 callback: &mut impl FnMut(Context) -> Result<()>,91) -> Result<()> {92 match specs.get(0) {93 None => callback(ctx)?,94 Some(CompSpec::IfSpec(IfSpecData(cond))) => {95 if bool::from_untyped(evaluate(ctx.clone(), cond)?)? {96 evaluate_comp(ctx, &specs[1..], callback)?;97 }98 }99 Some(CompSpec::ForSpec(ForSpecData(var, expr))) => match evaluate(ctx.clone(), expr)? {100 Val::Arr(list) => {101 for item in list.iter_lazy() {102 let fctx = Pending::new();103 let mut new_bindings = GcHashMap::with_capacity(var.capacity_hint());104 destruct(var, item, fctx.clone(), &mut new_bindings)?;105 let ctx = ctx106 .clone()107 .extend(new_bindings, None, None, None)108 .into_future(fctx);109110 evaluate_comp(ctx, &specs[1..], callback)?;111 }112 }113 #[cfg(feature = "exp-object-iteration")]114 Val::Obj(obj) => {115 for field in obj.fields(116 117 #[cfg(feature = "exp-preserve-order")]118 false,119 ) {120 #[derive(Trace)]121 struct ObjectFieldThunk {122 obj: ObjValue,123 field: IStr,124 }125 impl ThunkValue for ObjectFieldThunk {126 type Output = Val;127128 fn get(self: Box<Self>) -> Result<Self::Output> {129 self.obj.get(self.field).transpose().expect(130 "field exists, as field name was obtained from object.fields()",131 )132 }133 }134135 let fctx = Pending::new();136 let mut new_bindings = GcHashMap::with_capacity(var.capacity_hint());137 let value = Thunk::evaluated(Val::Arr(ArrValue::lazy(Cc::new(vec![138 Thunk::evaluated(Val::Str(StrValue::Flat(field.clone()))),139 Thunk::new(ObjectFieldThunk {140 field: field.clone(),141 obj: obj.clone(),142 }),143 ]))));144 destruct(var, value, fctx.clone(), &mut new_bindings)?;145 let ctx = ctx146 .clone()147 .extend(new_bindings, None, None, None)148 .into_future(fctx);149150 evaluate_comp(ctx, &specs[1..], callback)?;151 }152 }153 _ => throw!(InComprehensionCanOnlyIterateOverArray),154 },155 }156 Ok(())157}158159trait CloneableUnbound<T>: Unbound<Bound = T> + Clone {}160impl<V, T> CloneableUnbound<T> for V where V: Unbound<Bound = T> + Clone {}161162fn evaluate_object_locals(163 fctx: Pending<Context>,164 locals: Rc<Vec<BindSpec>>,165) -> impl CloneableUnbound<Context> {166 #[derive(Trace, Clone)]167 struct UnboundLocals {168 fctx: Pending<Context>,169 locals: Rc<Vec<BindSpec>>,170 }171 impl Unbound for UnboundLocals {172 type Bound = Context;173174 fn bind(&self, sup: Option<ObjValue>, this: Option<ObjValue>) -> Result<Context> {175 let fctx = Context::new_future();176 let mut new_bindings =177 GcHashMap::with_capacity(self.locals.iter().map(BindSpec::capacity_hint).sum());178 for b in self.locals.iter() {179 evaluate_dest(b, fctx.clone(), &mut new_bindings)?;180 }181182 let ctx = self.fctx.unwrap();183 let new_dollar = ctx.dollar().cloned().or_else(|| this.clone());184185 let ctx = ctx186 .extend(new_bindings, new_dollar, sup, this)187 .into_future(fctx);188189 Ok(ctx)190 }191 }192193 UnboundLocals { fctx, locals }194}195196pub fn evaluate_field_member<B: Unbound<Bound = Context> + Clone>(197 builder: &mut ObjValueBuilder,198 ctx: Context,199 uctx: B,200 field: &FieldMember,201) -> Result<()> {202 let name = evaluate_field_name(ctx, &field.name)?;203 let Some(name) = name else {204 return Ok(());205 };206207 match field {208 FieldMember {209 plus,210 params: None,211 visibility,212 value,213 ..214 } => {215 #[derive(Trace)]216 struct UnboundValue<B: Trace> {217 uctx: B,218 value: LocExpr,219 name: IStr,220 }221 impl<B: Unbound<Bound = Context>> Unbound for UnboundValue<B> {222 type Bound = Val;223 fn bind(&self, sup: Option<ObjValue>, this: Option<ObjValue>) -> Result<Val> {224 evaluate_named(self.uctx.bind(sup, this)?, &self.value, self.name.clone())225 }226 }227228 builder229 .member(name.clone())230 .with_add(*plus)231 .with_visibility(*visibility)232 .with_location(value.1.clone())233 .bindable(UnboundValue {234 uctx,235 value: value.clone(),236 name,237 })?;238 }239 FieldMember {240 params: Some(params),241 visibility,242 value,243 ..244 } => {245 #[derive(Trace)]246 struct UnboundMethod<B: Trace> {247 uctx: B,248 value: LocExpr,249 params: ParamsDesc,250 name: IStr,251 }252 impl<B: Unbound<Bound = Context>> Unbound for UnboundMethod<B> {253 type Bound = Val;254 fn bind(&self, sup: Option<ObjValue>, this: Option<ObjValue>) -> Result<Val> {255 Ok(evaluate_method(256 self.uctx.bind(sup, this)?,257 self.name.clone(),258 self.params.clone(),259 self.value.clone(),260 ))261 }262 }263264 builder265 .member(name.clone())266 .with_visibility(*visibility)267 .with_location(value.1.clone())268 .bindable(UnboundMethod {269 uctx,270 value: value.clone(),271 params: params.clone(),272 name,273 })?;274 }275 }276 Ok(())277}278279#[allow(clippy::too_many_lines)]280pub fn evaluate_member_list_object(ctx: Context, members: &[Member]) -> Result<ObjValue> {281 let mut builder = ObjValueBuilder::new();282 let locals = Rc::new(283 members284 .iter()285 .filter_map(|m| match m {286 Member::BindStmt(bind) => Some(bind.clone()),287 _ => None,288 })289 .collect::<Vec<_>>(),290 );291292 let fctx = Context::new_future();293294 295 let uctx = CachedUnbound::new(evaluate_object_locals(fctx.clone(), locals));296297 for member in members.iter() {298 match member {299 Member::Field(field) => {300 evaluate_field_member(&mut builder, ctx.clone(), uctx.clone(), field)?;301 }302 Member::AssertStmt(stmt) => {303 #[derive(Trace)]304 struct ObjectAssert<B: Trace> {305 uctx: B,306 assert: AssertStmt,307 }308 impl<B: Unbound<Bound = Context>> ObjectAssertion for ObjectAssert<B> {309 fn run(&self, sup: Option<ObjValue>, this: Option<ObjValue>) -> Result<()> {310 let ctx = self.uctx.bind(sup, this)?;311 evaluate_assert(ctx, &self.assert)312 }313 }314 builder.assert(ObjectAssert {315 uctx: uctx.clone(),316 assert: stmt.clone(),317 });318 }319 Member::BindStmt(_) => {320 321 }322 }323 }324 let this = builder.build();325 fctx.fill(ctx.extend(GcHashMap::new(), None, None, Some(this.clone())));326 Ok(this)327}328329pub fn evaluate_object(ctx: Context, object: &ObjBody) -> Result<ObjValue> {330 Ok(match object {331 ObjBody::MemberList(members) => evaluate_member_list_object(ctx, members)?,332 ObjBody::ObjComp(obj) => {333 let mut builder = ObjValueBuilder::new();334 let locals = Rc::new(335 obj.pre_locals336 .iter()337 .chain(obj.post_locals.iter())338 .cloned()339 .collect::<Vec<_>>(),340 );341 let mut ctxs = vec![];342 evaluate_comp(ctx, &obj.compspecs, &mut |ctx| {343 let fctx = Context::new_future();344 ctxs.push((ctx.clone(), fctx.clone()));345 let uctx = evaluate_object_locals(fctx, locals.clone());346347 evaluate_field_member(&mut builder, ctx, uctx, &obj.field)348 })?;349350 let this = builder.build();351 for (ctx, fctx) in ctxs {352 let _ctx = ctx353 .extend(GcHashMap::new(), None, None, Some(this.clone()))354 .into_future(fctx);355 }356 this357 }358 })359}360361pub fn evaluate_apply(362 ctx: Context,363 value: &LocExpr,364 args: &ArgsDesc,365 loc: CallLocation<'_>,366 tailstrict: bool,367) -> Result<Val> {368 let value = evaluate(ctx.clone(), value)?;369 Ok(match value {370 Val::Func(f) => {371 let body = || f.evaluate(ctx, loc, args, tailstrict);372 if tailstrict {373 body()?374 } else {375 State::push(loc, || format!("function <{}> call", f.name()), body)?376 }377 }378 v => throw!(OnlyFunctionsCanBeCalledGot(v.value_type())),379 })380}381382pub fn evaluate_assert(ctx: Context, assertion: &AssertStmt) -> Result<()> {383 let value = &assertion.0;384 let msg = &assertion.1;385 let assertion_result = State::push(386 CallLocation::new(&value.1),387 || "assertion condition".to_owned(),388 || bool::from_untyped(evaluate(ctx.clone(), value)?),389 )?;390 if !assertion_result {391 State::push(392 CallLocation::new(&value.1),393 || "assertion failure".to_owned(),394 || {395 if let Some(msg) = msg {396 throw!(AssertionFailed(evaluate(ctx, msg)?.to_string()?));397 }398 throw!(AssertionFailed(Val::Null.to_string()?));399 },400 )?;401 }402 Ok(())403}404405pub fn evaluate_named(ctx: Context, expr: &LocExpr, name: IStr) -> Result<Val> {406 use Expr::*;407 let LocExpr(raw_expr, _loc) = expr;408 Ok(match &**raw_expr {409 Function(params, body) => evaluate_method(ctx, name, params.clone(), body.clone()),410 _ => evaluate(ctx, expr)?,411 })412}413414#[allow(clippy::too_many_lines)]415pub fn evaluate(ctx: Context, expr: &LocExpr) -> Result<Val> {416 use Expr::*;417418 if let Some(trivial) = evaluate_trivial(expr) {419 return Ok(trivial);420 }421 let LocExpr(expr, loc) = expr;422 Ok(match &**expr {423 Literal(LiteralType::This) => {424 Val::Obj(ctx.this().ok_or(CantUseSelfOutsideOfObject)?.clone())425 }426 Literal(LiteralType::Super) => Val::Obj(427 ctx.super_obj().ok_or(NoSuperFound)?.with_this(428 ctx.this()429 .expect("if super exists - then this should too")430 .clone(),431 ),432 ),433 Literal(LiteralType::Dollar) => {434 Val::Obj(ctx.dollar().ok_or(NoTopLevelObjectFound)?.clone())435 }436 Literal(LiteralType::True) => Val::Bool(true),437 Literal(LiteralType::False) => Val::Bool(false),438 Literal(LiteralType::Null) => Val::Null,439 Parened(e) => evaluate(ctx, e)?,440 Str(v) => Val::Str(StrValue::Flat(v.clone())),441 Num(v) => Val::new_checked_num(*v)?,442 BinaryOp(v1, o, v2) => evaluate_binary_op_special(ctx, v1, *o, v2)?,443 UnaryOp(o, v) => evaluate_unary_op(*o, &evaluate(ctx, v)?)?,444 Var(name) => State::push(445 CallLocation::new(loc),446 || format!("variable <{name}> access"),447 || ctx.binding(name.clone())?.evaluate(),448 )?,449 Index {450 indexable: LocExpr(v, _),451 index,452 #[cfg(feature = "exp-null-coaelse")]453 null_coaelse,454 } if matches!(&**v, Expr::Literal(LiteralType::Super)) => {455 let name = evaluate(ctx.clone(), index)?;456 let Val::Str(name) = name else {457 throw!(ValueIndexMustBeTypeGot(458 ValType::Obj,459 ValType::Str,460 name.value_type(),461 ))462 };463 let Some(super_obj) = ctx.super_obj() else {464 throw!(NoSuperFound)465 };466 let this = ctx467 .this()468 .expect("no this found, while super present, should not happen");469 let key = name.into_flat();470 match super_obj.get_for(key.clone(), this.clone())? {471 Some(v) => v,472 #[cfg(feature = "exp-null-coaelse")]473 None if *null_coaelse => Val::Null,474 None => {475 let suggestions = suggest_object_fields(super_obj, key.clone());476477 throw!(NoSuchField(key, suggestions))478 }479 }480 }481 Index {482 indexable,483 index,484 #[cfg(feature = "exp-null-coaelse")]485 null_coaelse,486 } => match (evaluate(ctx.clone(), indexable)?, evaluate(ctx, index)?) {487 (Val::Obj(v), Val::Str(key)) => State::push(488 CallLocation::new(loc),489 || format!("field <{key}> access"),490 || match v.get(key.clone().into_flat()) {491 Ok(Some(v)) => Ok(v),492 #[cfg(feature = "exp-null-coaelse")]493 Ok(None) if *null_coaelse => Ok(Val::Null),494 Ok(None) => {495 let suggestions = suggest_object_fields(&v, key.clone().into_flat());496497 throw!(NoSuchField(key.clone().into_flat(), suggestions))498 }499 Err(e) => Err(e),500 },501 )?,502 (Val::Obj(_), n) => throw!(ValueIndexMustBeTypeGot(503 ValType::Obj,504 ValType::Str,505 n.value_type(),506 )),507508 (Val::Arr(v), Val::Num(n)) => {509 if n.fract() > f64::EPSILON {510 throw!(FractionalIndex)511 }512 v.get(n as usize)?513 .ok_or_else(|| ArrayBoundsError(n as usize, v.len()))?514 }515 (Val::Arr(_), Val::Str(n)) => throw!(AttemptedIndexAnArrayWithString(n.into_flat())),516 (Val::Arr(_), n) => throw!(ValueIndexMustBeTypeGot(517 ValType::Arr,518 ValType::Num,519 n.value_type(),520 )),521522 (Val::Str(s), Val::Num(n)) => Val::Str({523 let v: IStr = s524 .clone()525 .into_flat()526 .chars()527 .skip(n as usize)528 .take(1)529 .collect::<String>()530 .into();531 if v.is_empty() {532 let size = s.into_flat().chars().count();533 throw!(StringBoundsError(n as usize, size))534 }535 StrValue::Flat(v)536 }),537 (Val::Str(_), n) => throw!(ValueIndexMustBeTypeGot(538 ValType::Str,539 ValType::Num,540 n.value_type(),541 )),542 #[cfg(feature = "exp-null-coaelse")]543 (Val::Null, _) if *null_coaelse => Val::Null,544545 (v, _) => throw!(CantIndexInto(v.value_type())),546 },547 LocalExpr(bindings, returned) => {548 let mut new_bindings: GcHashMap<IStr, Thunk<Val>> =549 GcHashMap::with_capacity(bindings.iter().map(BindSpec::capacity_hint).sum());550 let fctx = Context::new_future();551 for b in bindings {552 evaluate_dest(b, fctx.clone(), &mut new_bindings)?;553 }554 let ctx = ctx.extend(new_bindings, None, None, None).into_future(fctx);555 evaluate(ctx, &returned.clone())?556 }557 Arr(items) => {558 if items.is_empty() {559 Val::Arr(ArrValue::empty())560 } else if items.len() == 1 {561 #[derive(Trace)]562 struct ArrayElement {563 ctx: Context,564 item: LocExpr,565 }566 impl ThunkValue for ArrayElement {567 type Output = Val;568 fn get(self: Box<Self>) -> Result<Val> {569 evaluate(self.ctx, &self.item)570 }571 }572 Val::Arr(ArrValue::lazy(Cc::new(vec![Thunk::new(ArrayElement {573 ctx,574 item: items[0].clone(),575 })])))576 } else {577 Val::Arr(ArrValue::expr(ctx, items.iter().cloned()))578 }579 }580 ArrComp(expr, comp_specs) => {581 let mut out = Vec::new();582 evaluate_comp(ctx, comp_specs, &mut |ctx| {583 out.push(evaluate(ctx, expr)?);584 Ok(())585 })?;586 Val::Arr(ArrValue::eager(out))587 }588 Obj(body) => Val::Obj(evaluate_object(ctx, body)?),589 ObjExtend(a, b) => evaluate_add_op(590 &evaluate(ctx.clone(), a)?,591 &Val::Obj(evaluate_object(ctx, b)?),592 )?,593 Apply(value, args, tailstrict) => {594 evaluate_apply(ctx, value, args, CallLocation::new(loc), *tailstrict)?595 }596 Function(params, body) => {597 evaluate_method(ctx, "anonymous".into(), params.clone(), body.clone())598 }599 AssertExpr(assert, returned) => {600 evaluate_assert(ctx.clone(), assert)?;601 evaluate(ctx, returned)?602 }603 ErrorStmt(e) => State::push(604 CallLocation::new(loc),605 || "error statement".to_owned(),606 || throw!(RuntimeError(evaluate(ctx, e)?.to_string()?,)),607 )?,608 IfElse {609 cond,610 cond_then,611 cond_else,612 } => {613 if State::push(614 CallLocation::new(loc),615 || "if condition".to_owned(),616 || bool::from_untyped(evaluate(ctx.clone(), &cond.0)?),617 )? {618 evaluate(ctx, cond_then)?619 } else {620 match cond_else {621 Some(v) => evaluate(ctx, v)?,622 None => Val::Null,623 }624 }625 }626 Slice(value, desc) => {627 fn parse_idx<T: Typed>(628 loc: CallLocation<'_>,629 ctx: &Context,630 expr: Option<&LocExpr>,631 desc: &'static str,632 ) -> Result<Option<T>> {633 if let Some(value) = expr {634 Ok(Some(State::push(635 loc,636 || format!("slice {desc}"),637 || T::from_untyped(evaluate(ctx.clone(), value)?),638 )?))639 } else {640 Ok(None)641 }642 }643644 let indexable = evaluate(ctx.clone(), value)?;645 let loc = CallLocation::new(loc);646647 let start = parse_idx(loc, &ctx, desc.start.as_ref(), "start")?;648 let end = parse_idx(loc, &ctx, desc.end.as_ref(), "end")?;649 let step = parse_idx(loc, &ctx, desc.step.as_ref(), "step")?;650651 IndexableVal::into_untyped(indexable.into_indexable()?.slice(start, end, step)?)?652 }653 i @ (Import(path) | ImportStr(path) | ImportBin(path)) => {654 let Expr::Str(path) = &*path.0 else {655 throw!("computed imports are not supported")656 };657 let tmp = loc.clone().0;658 let s = ctx.state();659 let resolved_path = s.resolve_from(tmp.source_path(), path as &str)?;660 match i {661 Import(_) => State::push(662 CallLocation::new(loc),663 || format!("import {:?}", path.clone()),664 || s.import_resolved(resolved_path),665 )?,666 ImportStr(_) => Val::Str(StrValue::Flat(s.import_resolved_str(resolved_path)?)),667 ImportBin(_) => Val::Arr(ArrValue::bytes(s.import_resolved_bin(resolved_path)?)),668 _ => unreachable!(),669 }670 }671 })672}