use crate::abilities::{AbilitiesStore, ImplKey, PendingAbilitiesStore, ResolvedImpl}; use crate::annotation::{canonicalize_annotation, AnnotationFor}; use crate::def::{canonicalize_defs, Def}; use crate::effect_module::HostedGeneratedFunctions; use crate::env::Env; use crate::expr::{ClosureData, Declarations, ExpectLookup, Expr, Output, PendingDerives}; use crate::pattern::{BindingsFromPattern, Pattern}; use crate::scope::Scope; use bumpalo::Bump; use roc_collections::{MutMap, SendMap, VecMap, VecSet}; use roc_error_macros::internal_error; use roc_module::ident::Ident; use roc_module::ident::Lowercase; use roc_module::symbol::{IdentIds, IdentIdsByModule, ModuleId, ModuleIds, Symbol}; use roc_parse::ast::{Defs, TypeAnnotation}; use roc_parse::header::HeaderFor; use roc_parse::pattern::PatternType; use roc_problem::can::{Problem, RuntimeError}; use roc_region::all::{Loc, Region}; use roc_types::subs::{ExposedTypesStorageSubs, Subs, VarStore, Variable}; use roc_types::types::{AbilitySet, Alias, AliasKind, AliasVar, Type}; /// The types of all exposed values/functions of a collection of modules #[derive(Clone, Debug, Default)] pub struct ExposedByModule { exposed: MutMap, } impl ExposedByModule { pub fn insert(&mut self, module_id: ModuleId, exposed: ExposedModuleTypes) { self.exposed.insert(module_id, exposed); } pub fn get(&self, module_id: &ModuleId) -> Option<&ExposedModuleTypes> { self.exposed.get(module_id) } /// Convenient when you need mutable access to the StorageSubs in the ExposedModuleTypes pub fn get_mut(&mut self, module_id: &ModuleId) -> Option<&mut ExposedModuleTypes> { self.exposed.get_mut(module_id) } /// Create a clone of `self` that has just a subset of the modules /// /// Useful when we know what modules a particular module imports, and want just /// the exposed types for those exposed modules. pub fn retain_modules<'a>(&self, it: impl Iterator) -> Self { let mut output = Self::default(); for module_id in it { match self.exposed.get(module_id) { None => { internal_error!("Module {:?} did not register its exposed values", module_id) } Some(exposed_types) => { output.exposed.insert(*module_id, exposed_types.clone()); } } } output } pub fn iter_all(&self) -> impl Iterator { self.exposed.iter() } /// # Safety /// /// May only be called when the exposed types of a modules are no longer needed, or may be /// transitioned into another context. pub unsafe fn remove(&mut self, module_id: &ModuleId) -> Option { self.exposed.remove(module_id) } } #[derive(Clone, Debug, Default)] pub struct ExposedForModule { pub exposed_by_module: ExposedByModule, pub imported_values: Vec, } impl ExposedForModule { pub fn new<'a>( it: impl Iterator, exposed_by_module: ExposedByModule, ) -> Self { let mut imported_values = Vec::new(); for symbol in it { let module = exposed_by_module.exposed.get(&symbol.module_id()); if let Some(ExposedModuleTypes { .. }) = module { imported_values.push(*symbol); } else { continue; } } Self { imported_values, exposed_by_module, } } } /// During type solving and monomorphization, a module must know how its imported ability /// implementations are resolved - are they derived, or have a concrete implementation? /// /// Unfortunately we cannot keep this information opaque, as it's important for properly /// restoring specialization lambda sets. As such, we need to export implementation information, /// which is the job of this structure. pub type ResolvedImplementations = VecMap; /// The types of all exposed values/functions of a module. This includes ability member /// specializations. #[derive(Clone, Debug)] pub struct ExposedModuleTypes { pub exposed_types_storage_subs: ExposedTypesStorageSubs, pub resolved_implementations: ResolvedImplementations, } #[derive(Debug)] pub struct Module { pub module_id: ModuleId, pub exposed_imports: MutMap, pub exposed_symbols: VecSet, pub referenced_values: VecSet, pub referenced_types: VecSet, /// all aliases. `bool` indicates whether it is exposed pub aliases: MutMap, pub rigid_variables: RigidVariables, pub abilities_store: PendingAbilitiesStore, pub loc_expects: VecMap>, } #[derive(Debug, Default)] pub struct RigidVariables { pub named: MutMap, pub able: MutMap, pub wildcards: VecSet, } #[derive(Debug)] pub struct ModuleOutput { pub aliases: MutMap, pub rigid_variables: RigidVariables, pub declarations: Declarations, pub exposed_imports: MutMap, pub problems: Vec, pub referenced_values: VecSet, pub referenced_types: VecSet, pub symbols_from_requires: Vec<(Loc, Loc)>, pub pending_derives: PendingDerives, pub scope: Scope, pub loc_expects: VecMap>, } fn validate_generate_with<'a>( generate_with: &'a [Loc>], ) -> (HostedGeneratedFunctions, Vec>) { let mut functions = HostedGeneratedFunctions::default(); let mut unknown = Vec::new(); for generated in generate_with { match generated.value.as_str() { "after" => functions.after = true, "map" => functions.map = true, "always" => functions.always = true, "loop" => functions.loop_ = true, "forever" => functions.forever = true, other => { // we don't know how to generate this function let ident = Ident::from(other); unknown.push(Loc::at(generated.region, ident)); } } } (functions, unknown) } #[derive(Debug)] enum GeneratedInfo { Hosted { effect_symbol: Symbol, generated_functions: HostedGeneratedFunctions, }, Builtin, NotSpecial, } impl GeneratedInfo { fn from_header_for<'a>( env: &mut Env, scope: &mut Scope, var_store: &mut VarStore, header_for: &HeaderFor<'a>, ) -> Self { match header_for { HeaderFor::Hosted { generates, generates_with, } => { let name: &str = generates.into(); let (generated_functions, unknown_generated) = validate_generate_with(generates_with); for unknown in unknown_generated { env.problem(Problem::UnknownGeneratesWith(unknown)); } let effect_symbol = scope.introduce(name.into(), Region::zero()).unwrap(); { let a_var = var_store.fresh(); let actual = crate::effect_module::build_effect_actual(Type::Variable(a_var), var_store); scope.add_alias( effect_symbol, Region::zero(), vec![Loc::at_zero(AliasVar::unbound("a".into(), a_var))], vec![], actual, AliasKind::Opaque, ); } GeneratedInfo::Hosted { effect_symbol, generated_functions, } } HeaderFor::Builtin { generates_with } => { debug_assert!(generates_with.is_empty()); GeneratedInfo::Builtin } _ => GeneratedInfo::NotSpecial, } } } fn has_no_implementation(expr: &Expr) -> bool { match expr { Expr::RuntimeError(RuntimeError::NoImplementationNamed { .. }) => true, Expr::Closure(closure_data) if matches!( closure_data.loc_body.value, Expr::RuntimeError(RuntimeError::NoImplementationNamed { .. }) ) => { true } _ => false, } } // TODO trim these down #[allow(clippy::too_many_arguments)] pub fn canonicalize_module_defs<'a>( arena: &'a Bump, loc_defs: &'a mut Defs<'a>, header_for: &roc_parse::header::HeaderFor, home: ModuleId, module_ids: &'a ModuleIds, exposed_ident_ids: IdentIds, dep_idents: &'a IdentIdsByModule, aliases: MutMap, imported_abilities_state: PendingAbilitiesStore, exposed_imports: MutMap, exposed_symbols: &VecSet, symbols_from_requires: &[(Loc, Loc>)], var_store: &mut VarStore, ) -> ModuleOutput { let mut can_exposed_imports = MutMap::default(); let mut scope = Scope::new(home, exposed_ident_ids, imported_abilities_state); let mut env = Env::new(arena, home, dep_idents, module_ids); for (name, alias) in aliases.into_iter() { scope.add_alias( name, alias.region, alias.type_variables, alias.infer_ext_in_output_variables, alias.typ, alias.kind, ); } let generated_info = GeneratedInfo::from_header_for(&mut env, &mut scope, var_store, header_for); // Desugar operators (convert them to Apply calls, taking into account // operator precedence and associativity rules), before doing other canonicalization. // // If we did this *during* canonicalization, then each time we // visited a BinOp node we'd recursively try to apply this to each of its nested // operators, and then again on *their* nested operators, ultimately applying the // rules multiple times unnecessarily. crate::operator::desugar_defs(arena, loc_defs); let mut rigid_variables = RigidVariables::default(); // Exposed values are treated like defs that appear before any others, e.g. // // imports [Foo.{ bar, baz }] // // ...is basically the same as if we'd added these extra defs at the start of the module: // // bar = Foo.bar // baz = Foo.baz // // Here we essentially add those "defs" to "the beginning of the module" // by canonicalizing them right before we canonicalize the actual ast::Def nodes. for (ident, (symbol, region)) in exposed_imports { let first_char = ident.as_inline_str().as_str().chars().next().unwrap(); if first_char.is_lowercase() { match scope.import(ident, symbol, region) { Ok(()) => { // Add an entry to exposed_imports using the current module's name // as the key; e.g. if this is the Foo module and we have // exposes [Bar.{ baz }] then insert Foo.baz as the key, so when // anything references `baz` in this Foo module, it will resolve to Bar.baz. can_exposed_imports.insert(symbol, region); } Err((_shadowed_symbol, _region)) => { panic!("TODO gracefully handle shadowing in imports.") } } } else if [Symbol::LIST_LIST, Symbol::STR_STR, Symbol::BOX_BOX_TYPE].contains(&symbol) { // These are not aliases but Apply's and we make sure they are always in scope } else { // This is a type alias or ability // the symbol should already be added to the scope when this module is canonicalized debug_assert!( scope.contains_alias(symbol) || scope.abilities_store.is_ability(symbol), "The {:?} is not a type alias or ability known in {:?}", symbol, home ); // but now we know this symbol by a different identifier, so we still need to add it to // the scope match scope.import(ident, symbol, region) { Ok(()) => { // here we do nothing special } Err((shadowed_symbol, _region)) => { panic!( "TODO gracefully handle shadowing in imports, {:?} is shadowed.", shadowed_symbol ) } } } } let (defs, output, symbols_introduced) = canonicalize_defs( &mut env, Output::default(), var_store, &mut scope, loc_defs, PatternType::TopLevelDef, ); let pending_derives = output.pending_derives; // See if any of the new idents we defined went unused. // If any were unused and also not exposed, report it. for (symbol, region) in symbols_introduced { if !output.references.has_type_or_value_lookup(symbol) && !exposed_symbols.contains(&symbol) && !scope.abilities_store.is_specialization_name(symbol) && !symbol.is_exposed_for_builtin_derivers() { env.problem(Problem::UnusedDef(symbol, region)); } } for named in output.introduced_variables.named { rigid_variables.named.insert(named.variable, named.name); } for able in output.introduced_variables.able { rigid_variables .able .insert(able.variable, (able.name, able.abilities)); } for var in output.introduced_variables.wildcards { rigid_variables.wildcards.insert(var.value); } let mut referenced_values = VecSet::default(); let mut referenced_types = VecSet::default(); // Gather up all the symbols that were referenced across all the defs' lookups. referenced_values.extend(output.references.value_lookups().copied()); referenced_types.extend(output.references.type_lookups().copied()); // Gather up all the symbols that were referenced across all the defs' calls. referenced_values.extend(output.references.calls().copied()); // Gather up all the symbols that were referenced from other modules. referenced_values.extend(env.qualified_value_lookups.iter().copied()); referenced_types.extend(env.qualified_type_lookups.iter().copied()); // NOTE previously we inserted builtin defs into the list of defs here // this is now done later, in file.rs. // assume all exposed symbols are not actually defined in the module // then as we walk the module and encounter the definitions, remove // symbols from this set let mut exposed_but_not_defined = exposed_symbols.clone(); let new_output = Output { aliases: output.aliases, ..Default::default() }; let (mut declarations, mut output) = crate::def::sort_can_defs_new(&mut scope, var_store, defs, new_output); debug_assert!( output.pending_derives.is_empty(), "I thought pending derives are only found during def introduction" ); let symbols_from_requires = symbols_from_requires .iter() .map(|(symbol, loc_ann)| { // We've already canonicalized the module, so there are no pending abilities. let pending_abilities_in_scope = &Default::default(); let ann = canonicalize_annotation( &mut env, &mut scope, &loc_ann.value, loc_ann.region, var_store, pending_abilities_in_scope, AnnotationFor::Value, ); ann.add_to( &mut output.aliases, &mut output.references, &mut output.introduced_variables, ); ( *symbol, Loc { value: ann.typ, region: loc_ann.region, }, ) }) .collect(); if let GeneratedInfo::Hosted { effect_symbol, generated_functions, } = generated_info { let mut exposed_symbols = VecSet::default(); // NOTE this currently builds all functions, not just the ones that the user requested crate::effect_module::build_effect_builtins( &mut scope, effect_symbol, var_store, &mut exposed_symbols, &mut declarations, generated_functions, ); } for index in 0..declarations.len() { use crate::expr::DeclarationTag::*; let tag = declarations.declarations[index]; match tag { Value => { let symbol = &declarations.symbols[index].value; // Remove this from exposed_symbols, // so that at the end of the process, // we can see if there were any // exposed symbols which did not have // corresponding defs. exposed_but_not_defined.remove(symbol); // Temporary hack: we don't know exactly what symbols are hosted symbols, // and which are meant to be normal definitions without a body. So for now // we just assume they are hosted functions (meant to be provided by the platform) if has_no_implementation(&declarations.expressions[index].value) { match generated_info { GeneratedInfo::Builtin => { match crate::builtins::builtin_defs_map(*symbol, var_store) { None => { panic!("A builtin module contains a signature without implementation for {:?}", symbol) } Some(replacement_def) => { declarations.update_builtin_def(index, replacement_def); } } } GeneratedInfo::Hosted { effect_symbol, .. } => { let ident_id = symbol.ident_id(); let ident = scope .locals .ident_ids .get_name(ident_id) .unwrap() .to_string(); let def_annotation = declarations.annotations[index].clone().unwrap(); let annotation = crate::annotation::Annotation { typ: def_annotation.signature, introduced_variables: def_annotation.introduced_variables, references: Default::default(), aliases: Default::default(), }; let hosted_def = crate::effect_module::build_host_exposed_def( &mut scope, *symbol, &ident, effect_symbol, var_store, annotation, ); declarations.update_builtin_def(index, hosted_def); } _ => (), } } } Function(_) | Recursive(_) | TailRecursive(_) => { let symbol = &declarations.symbols[index].value; // Remove this from exposed_symbols, // so that at the end of the process, // we can see if there were any // exposed symbols which did not have // corresponding defs. exposed_but_not_defined.remove(symbol); // Temporary hack: we don't know exactly what symbols are hosted symbols, // and which are meant to be normal definitions without a body. So for now // we just assume they are hosted functions (meant to be provided by the platform) if has_no_implementation(&declarations.expressions[index].value) { match generated_info { GeneratedInfo::Builtin => { match crate::builtins::builtin_defs_map(*symbol, var_store) { None => { panic!("A builtin module contains a signature without implementation for {:?}", symbol) } Some(replacement_def) => { declarations.update_builtin_def(index, replacement_def); } } } GeneratedInfo::Hosted { effect_symbol, .. } => { let ident_id = symbol.ident_id(); let ident = scope .locals .ident_ids .get_name(ident_id) .unwrap() .to_string(); let def_annotation = declarations.annotations[index].clone().unwrap(); let annotation = crate::annotation::Annotation { typ: def_annotation.signature, introduced_variables: def_annotation.introduced_variables, references: Default::default(), aliases: Default::default(), }; let hosted_def = crate::effect_module::build_host_exposed_def( &mut scope, *symbol, &ident, effect_symbol, var_store, annotation, ); declarations.update_builtin_def(index, hosted_def); } _ => (), } } } Destructure(d_index) => { let destruct_def = &declarations.destructs[d_index.index()]; for (symbol, _) in BindingsFromPattern::new(&destruct_def.loc_pattern) { exposed_but_not_defined.remove(&symbol); } } MutualRecursion { .. } => { // the declarations of this group will be treaded individually by later iterations } Expectation => { /* ignore */ } ExpectationFx => { /* ignore */ } } } let mut aliases = MutMap::default(); if let GeneratedInfo::Hosted { effect_symbol, .. } = generated_info { // Remove this from exposed_symbols, // so that at the end of the process, // we can see if there were any // exposed symbols which did not have // corresponding defs. exposed_but_not_defined.remove(&effect_symbol); let hosted_alias = scope.lookup_alias(effect_symbol).unwrap().clone(); aliases.insert(effect_symbol, hosted_alias); } for (symbol, alias) in output.aliases { // Remove this from exposed_symbols, // so that at the end of the process, // we can see if there were any // exposed symbols which did not have // corresponding defs. exposed_but_not_defined.remove(&symbol); aliases.insert(symbol, alias); } for (ability, members) in scope .abilities_store .iter_abilities() .filter(|(ab, _)| ab.module_id() == home) { exposed_but_not_defined.remove(&ability); members.iter().for_each(|member| { debug_assert!(member.module_id() == home); exposed_but_not_defined.remove(member); }); } // By this point, all exposed symbols should have been removed from // exposed_symbols and added to exposed_vars_by_symbol. If any were // not, that means they were declared as exposed but there was // no actual declaration with that name! for symbol in exposed_but_not_defined { env.problem(Problem::ExposedButNotDefined(symbol)); // In case this exposed value is referenced by other modules, // create a decl for it whose implementation is a runtime error. let mut pattern_vars = SendMap::default(); pattern_vars.insert(symbol, var_store.fresh()); let runtime_error = RuntimeError::ExposedButNotDefined(symbol); let def = Def { loc_pattern: Loc::at(Region::zero(), Pattern::Identifier(symbol)), loc_expr: Loc::at(Region::zero(), Expr::RuntimeError(runtime_error)), expr_var: var_store.fresh(), pattern_vars, annotation: None, }; declarations.push_def(def); } // Incorporate any remaining output.lookups entries into references. referenced_values.extend(output.references.value_lookups().copied()); referenced_types.extend(output.references.type_lookups().copied()); // Incorporate any remaining output.calls entries into references. referenced_values.extend(output.references.calls().copied()); // Gather up all the symbols that were referenced from other modules. referenced_values.extend(env.qualified_value_lookups.iter().copied()); referenced_types.extend(env.qualified_type_lookups.iter().copied()); let mut fix_closures_no_capture_symbols = VecSet::default(); let mut fix_closures_closure_captures = VecMap::default(); for index in 0..declarations.len() { use crate::expr::DeclarationTag::*; // For each declaration, we need to fixup the closures inside its def. // Reuse the fixup buffer allocations from the previous iteration. fix_closures_no_capture_symbols.clear(); fix_closures_closure_captures.clear(); match declarations.declarations[index] { Value => { // def pattern has no default expressions, so skip let loc_expr = &mut declarations.expressions[index]; fix_values_captured_in_closure_expr( &mut loc_expr.value, &mut fix_closures_no_capture_symbols, &mut fix_closures_closure_captures, ); } Function(f_index) | Recursive(f_index) | TailRecursive(f_index) => { let name = declarations.symbols[index].value; let function_def = &mut declarations.function_bodies[f_index.index()].value; let loc_expr = &mut declarations.expressions[index]; function_def.captured_symbols.retain(|(s, _)| *s != name); let mut no_capture_symbols = VecSet::default(); if function_def.captured_symbols.is_empty() { no_capture_symbols.insert(name); } // patterns can contain default expressions, so must go over them too! for (_, _, loc_pat) in function_def.arguments.iter_mut() { fix_values_captured_in_closure_pattern( &mut loc_pat.value, &mut fix_closures_no_capture_symbols, &mut fix_closures_closure_captures, ); } fix_values_captured_in_closure_expr( &mut loc_expr.value, &mut fix_closures_no_capture_symbols, &mut fix_closures_closure_captures, ); } Destructure(d_index) => { let destruct_def = &mut declarations.destructs[d_index.index()]; let loc_pat = &mut destruct_def.loc_pattern; let loc_expr = &mut declarations.expressions[index]; fix_values_captured_in_closure_pattern( &mut loc_pat.value, &mut fix_closures_no_capture_symbols, &mut fix_closures_closure_captures, ); fix_values_captured_in_closure_expr( &mut loc_expr.value, &mut fix_closures_no_capture_symbols, &mut fix_closures_closure_captures, ); } MutualRecursion { .. } => { // the declarations of this group will be treaded individually by later iterations } Expectation => { let loc_expr = &mut declarations.expressions[index]; fix_values_captured_in_closure_expr( &mut loc_expr.value, &mut fix_closures_no_capture_symbols, &mut fix_closures_closure_captures, ); } ExpectationFx => { let loc_expr = &mut declarations.expressions[index]; fix_values_captured_in_closure_expr( &mut loc_expr.value, &mut fix_closures_no_capture_symbols, &mut fix_closures_closure_captures, ); } } } let loc_expects = declarations.expects(); ModuleOutput { scope, aliases, rigid_variables, declarations, referenced_values, referenced_types, exposed_imports: can_exposed_imports, problems: env.problems, symbols_from_requires, pending_derives, loc_expects, } } fn fix_values_captured_in_closure_def( def: &mut crate::def::Def, no_capture_symbols: &mut VecSet, closure_captures: &mut VecMap>, ) { // patterns can contain default expressions, so much go over them too! fix_values_captured_in_closure_pattern( &mut def.loc_pattern.value, no_capture_symbols, closure_captures, ); fix_values_captured_in_closure_expr( &mut def.loc_expr.value, no_capture_symbols, closure_captures, ); } fn fix_values_captured_in_closure_defs( defs: &mut [crate::def::Def], no_capture_symbols: &mut VecSet, closure_captures: &mut VecMap>, ) { // recursive defs cannot capture each other for def in defs.iter() { no_capture_symbols.extend( crate::traverse::symbols_introduced_from_pattern(&def.loc_pattern).map(|ls| ls.value), ); } for def in defs.iter_mut() { fix_values_captured_in_closure_def(def, no_capture_symbols, closure_captures); } // Mutually recursive functions should both capture the union of all their capture sets // // Really unfortunate we make a lot of clones here, can this be done more efficiently? let mut total_capture_set = Vec::default(); for def in defs.iter_mut() { if let Expr::Closure(ClosureData { captured_symbols, .. }) = &def.loc_expr.value { total_capture_set.extend(captured_symbols.iter().copied()); } } total_capture_set.sort_by_key(|(sym, _)| *sym); total_capture_set.dedup_by_key(|(sym, _)| *sym); for def in defs.iter_mut() { if let Expr::Closure(ClosureData { captured_symbols, .. }) = &mut def.loc_expr.value { *captured_symbols = total_capture_set.clone(); } } } fn fix_values_captured_in_closure_pattern( pattern: &mut crate::pattern::Pattern, no_capture_symbols: &mut VecSet, closure_captures: &mut VecMap>, ) { use crate::pattern::Pattern::*; match pattern { AppliedTag { arguments: loc_args, .. } => { for (_, loc_arg) in loc_args.iter_mut() { fix_values_captured_in_closure_pattern( &mut loc_arg.value, no_capture_symbols, closure_captures, ); } } UnwrappedOpaque { argument, .. } => { let (_, loc_arg) = &mut **argument; fix_values_captured_in_closure_pattern( &mut loc_arg.value, no_capture_symbols, closure_captures, ); } RecordDestructure { destructs, .. } => { for loc_destruct in destructs.iter_mut() { use crate::pattern::DestructType::*; match &mut loc_destruct.value.typ { Required => {} Optional(_, loc_expr) => fix_values_captured_in_closure_expr( &mut loc_expr.value, no_capture_symbols, closure_captures, ), Guard(_, loc_pattern) => fix_values_captured_in_closure_pattern( &mut loc_pattern.value, no_capture_symbols, closure_captures, ), } } } List { patterns, .. } => { for loc_pat in patterns.patterns.iter_mut() { fix_values_captured_in_closure_pattern( &mut loc_pat.value, no_capture_symbols, closure_captures, ); } } Identifier(_) | NumLiteral(..) | IntLiteral(..) | FloatLiteral(..) | StrLiteral(_) | SingleQuote(..) | Underscore | Shadowed(..) | MalformedPattern(_, _) | UnsupportedPattern(_) | OpaqueNotInScope(..) | AbilityMemberSpecialization { .. } => (), } } fn fix_values_captured_in_closure_expr( expr: &mut crate::expr::Expr, no_capture_symbols: &mut VecSet, closure_captures: &mut VecMap>, ) { use crate::expr::Expr::*; match expr { LetNonRec(def, loc_expr) => { // LetNonRec(Box, Box>, Variable, Aliases), fix_values_captured_in_closure_def(def, no_capture_symbols, closure_captures); fix_values_captured_in_closure_expr( &mut loc_expr.value, no_capture_symbols, closure_captures, ); } LetRec(defs, loc_expr, _) => { // LetRec(Vec, Box>, Variable, Aliases), fix_values_captured_in_closure_defs(defs, no_capture_symbols, closure_captures); fix_values_captured_in_closure_expr( &mut loc_expr.value, no_capture_symbols, closure_captures, ); } Expect { loc_condition, loc_continuation, lookups_in_cond: _, } => { fix_values_captured_in_closure_expr( &mut loc_condition.value, no_capture_symbols, closure_captures, ); fix_values_captured_in_closure_expr( &mut loc_continuation.value, no_capture_symbols, closure_captures, ); } ExpectFx { loc_condition, loc_continuation, lookups_in_cond: _, } => { fix_values_captured_in_closure_expr( &mut loc_condition.value, no_capture_symbols, closure_captures, ); fix_values_captured_in_closure_expr( &mut loc_continuation.value, no_capture_symbols, closure_captures, ); } Closure(ClosureData { captured_symbols, name, arguments, loc_body, .. }) => { captured_symbols.retain(|(s, _)| !no_capture_symbols.contains(s)); captured_symbols.retain(|(s, _)| s != name); let original_captures_len = captured_symbols.len(); let mut num_visited = 0; let mut i = 0; while num_visited < original_captures_len { // If we've captured a capturing closure, replace the captured closure symbol with // the symbols of its captures. That way, we can construct the closure with the // captures it needs inside our body. // // E.g. // x = "" // inner = \{} -> x // outer = \{} -> inner {} // // initially `outer` captures [inner], but this is then replaced with just [x]. let (captured_symbol, _) = captured_symbols[i]; if let Some(captures) = closure_captures.get(&captured_symbol) { debug_assert!(!captures.is_empty()); captured_symbols.swap_remove(i); captured_symbols.extend(captures); // Jump two, because the next element is now one of the newly-added captures, // which we don't need to check. i += 2; } else { i += 1; } num_visited += 1; } if captured_symbols.len() > original_captures_len { // Re-sort, since we've added new captures. captured_symbols.sort_by_key(|(sym, _)| *sym); } if captured_symbols.is_empty() { no_capture_symbols.insert(*name); } else { closure_captures.insert(*name, captured_symbols.to_vec()); } // patterns can contain default expressions, so much go over them too! for (_, _, loc_pat) in arguments.iter_mut() { fix_values_captured_in_closure_pattern( &mut loc_pat.value, no_capture_symbols, closure_captures, ); } fix_values_captured_in_closure_expr( &mut loc_body.value, no_capture_symbols, closure_captures, ); } Num(..) | Int(..) | Float(..) | Str(_) | SingleQuote(..) | Var(..) | AbilityMember(..) | EmptyRecord | TypedHole { .. } | RuntimeError(_) | ZeroArgumentTag { .. } | Accessor { .. } => {} List { loc_elems, .. } => { for elem in loc_elems.iter_mut() { fix_values_captured_in_closure_expr( &mut elem.value, no_capture_symbols, closure_captures, ); } } When { loc_cond, branches, .. } => { fix_values_captured_in_closure_expr( &mut loc_cond.value, no_capture_symbols, closure_captures, ); for branch in branches.iter_mut() { fix_values_captured_in_closure_expr( &mut branch.value.value, no_capture_symbols, closure_captures, ); // patterns can contain default expressions, so much go over them too! for loc_pat in branch.patterns.iter_mut() { fix_values_captured_in_closure_pattern( &mut loc_pat.pattern.value, no_capture_symbols, closure_captures, ); } if let Some(guard) = &mut branch.guard { fix_values_captured_in_closure_expr( &mut guard.value, no_capture_symbols, closure_captures, ); } } } If { branches, final_else, .. } => { for (loc_cond, loc_then) in branches.iter_mut() { fix_values_captured_in_closure_expr( &mut loc_cond.value, no_capture_symbols, closure_captures, ); fix_values_captured_in_closure_expr( &mut loc_then.value, no_capture_symbols, closure_captures, ); } fix_values_captured_in_closure_expr( &mut final_else.value, no_capture_symbols, closure_captures, ); } Call(function, arguments, _) => { fix_values_captured_in_closure_expr( &mut function.1.value, no_capture_symbols, closure_captures, ); for (_, loc_arg) in arguments.iter_mut() { fix_values_captured_in_closure_expr( &mut loc_arg.value, no_capture_symbols, closure_captures, ); } } RunLowLevel { args, .. } | ForeignCall { args, .. } => { for (_, arg) in args.iter_mut() { fix_values_captured_in_closure_expr(arg, no_capture_symbols, closure_captures); } } Record { fields, .. } | Update { updates: fields, .. } => { for (_, field) in fields.iter_mut() { fix_values_captured_in_closure_expr( &mut field.loc_expr.value, no_capture_symbols, closure_captures, ); } } Access { loc_expr, .. } => { fix_values_captured_in_closure_expr( &mut loc_expr.value, no_capture_symbols, closure_captures, ); } Tag { arguments, .. } => { for (_, loc_arg) in arguments.iter_mut() { fix_values_captured_in_closure_expr( &mut loc_arg.value, no_capture_symbols, closure_captures, ); } } OpaqueRef { argument, .. } => { let (_, loc_arg) = &mut **argument; fix_values_captured_in_closure_expr( &mut loc_arg.value, no_capture_symbols, closure_captures, ); } OpaqueWrapFunction(_) => {} } } /// Type state for a single module. #[derive(Debug)] pub struct TypeState { pub subs: Subs, pub exposed_vars_by_symbol: Vec<(Symbol, Variable)>, pub abilities: AbilitiesStore, pub solved_implementations: ResolvedImplementations, } impl TypeState { pub fn serialize(&self, writer: &mut impl std::io::Write) -> std::io::Result { let Self { subs, exposed_vars_by_symbol, abilities, solved_implementations, } = self; let written_subs = subs.serialize(exposed_vars_by_symbol, writer)?; let written_ab = abilities.serialize(writer)?; let written_solved_impls = crate::abilities::serialize_solved_implementations(solved_implementations, writer)?; Ok(written_subs + written_ab + written_solved_impls) } pub fn deserialize(bytes: &[u8]) -> (Self, usize) { let ((subs, exposed_vars_by_symbol), len_subs) = Subs::deserialize(bytes); let bytes = &bytes[len_subs..]; let (abilities, len_abilities) = AbilitiesStore::deserialize(bytes); let bytes = &bytes[len_abilities..]; let (solved_implementations, len_solved_impls) = crate::abilities::deserialize_solved_implementations(bytes); let total_offset = len_subs + len_abilities + len_solved_impls; ( Self { subs, exposed_vars_by_symbol: exposed_vars_by_symbol.to_vec(), abilities, solved_implementations, }, total_offset, ) } }