use super::TypeCheckingVisitor;
use crate::DiGraphError;
use leo_ast::{Type, *};
use leo_errors::TypeCheckerError;
use leo_span::{Symbol, sym};
use itertools::Itertools;
use std::collections::{BTreeMap, HashSet};
impl ProgramVisitor for TypeCheckingVisitor<'_> {
fn visit_program(&mut self, input: &Program) {
input.stubs.iter().for_each(|(symbol, stub)| {
if symbol != &stub.stub_id.name.name {
self.emit_err(TypeCheckerError::stub_name_mismatch(
symbol,
stub.stub_id.name,
stub.stub_id.network.span,
));
}
self.visit_stub(stub)
});
self.scope_state.is_stub = false;
input.program_scopes.values().for_each(|scope| self.visit_program_scope(scope));
}
fn visit_program_scope(&mut self, input: &ProgramScope) {
let program_name = input.program_id.name;
check_name(&self.state.handler, program_name, "program");
self.scope_state.program_name = Some(program_name.name);
let record_info: BTreeMap<String, leo_span::Span> = input
.structs
.iter()
.filter(|(_, c)| c.is_record)
.map(|(_, r)| (r.name().to_string(), r.identifier.span))
.collect();
for ((prev_name, _), (curr_name, curr_span)) in record_info.iter().tuple_windows() {
if curr_name.starts_with(prev_name) {
self.state
.handler
.emit_err(TypeCheckerError::record_prefixed_by_other_record(curr_name, prev_name, *curr_span));
}
}
input.consts.iter().for_each(|(_, c)| self.visit_const(c));
input.structs.iter().for_each(|(_, function)| self.visit_struct(function));
if let Err(DiGraphError::CycleDetected(path)) = self.state.struct_graph.post_order() {
self.emit_err(TypeCheckerError::cyclic_struct_dependency(path));
}
let mut mapping_count = 0;
for (_, mapping) in input.mappings.iter() {
self.visit_mapping(mapping);
mapping_count += 1;
}
if mapping_count > self.limits.max_mappings {
self.emit_err(TypeCheckerError::too_many_mappings(
self.limits.max_mappings,
input.program_id.name.span + input.program_id.network.span,
));
}
let mut transition_count = 0;
for (_, function) in input.functions.iter() {
self.visit_function(function);
if function.variant.is_transition() {
transition_count += 1;
}
}
if let Err(DiGraphError::CycleDetected(path)) = self.state.call_graph.post_order() {
self.emit_err(TypeCheckerError::cyclic_function_dependency(path));
}
if transition_count > self.limits.max_functions {
self.emit_err(TypeCheckerError::too_many_transitions(
self.limits.max_functions,
input.program_id.name.span + input.program_id.network.span,
));
}
else if transition_count == 0 {
self.emit_err(TypeCheckerError::no_transitions(input.program_id.name.span + input.program_id.network.span));
}
}
fn visit_stub(&mut self, input: &Stub) {
self.scope_state.program_name = Some(input.stub_id.name.name);
if !input.consts.is_empty() {
self.emit_err(TypeCheckerError::stubs_cannot_have_const_declarations(input.consts.first().unwrap().1.span));
}
input.structs.iter().for_each(|(_, function)| self.visit_struct_stub(function));
input.functions.iter().for_each(|(_, function)| self.visit_function_stub(function));
}
fn visit_struct(&mut self, input: &Composite) {
let mut used = HashSet::new();
if !input.members.iter().all(|Member { identifier, type_, span, .. }| {
self.assert_type_is_valid(type_, *span);
used.insert(identifier.name)
}) {
self.emit_err(if input.is_record {
TypeCheckerError::duplicate_record_variable(input.name(), input.span())
} else {
TypeCheckerError::duplicate_struct_member(input.name(), input.span())
});
}
if input.is_record {
check_name(&self.state.handler, input.identifier, "record");
input.members.iter().for_each(|member| {
check_name(&self.state.handler, member.identifier, "record entry");
});
let check_has_field =
|need, expected_ty: Type| match input.members.iter().find_map(|Member { identifier, type_, .. }| {
(identifier.name == need).then_some((identifier, type_))
}) {
Some((_, actual_ty)) if expected_ty.eq_flat_relaxed(actual_ty) => {} Some((field, _)) => {
self.emit_err(TypeCheckerError::record_var_wrong_type(field, expected_ty, input.span()));
}
None => {
self.emit_err(TypeCheckerError::required_record_variable(need, expected_ty, input.span()));
}
};
check_has_field(sym::owner, Type::Address);
}
else if input.members.is_empty() {
self.emit_err(TypeCheckerError::empty_struct(input.span()));
}
if !(input.is_record && self.scope_state.is_stub) {
for Member { mode, identifier, type_, span, .. } in input.members.iter() {
if matches!(type_, Type::Tuple(_)) {
self.emit_err(TypeCheckerError::composite_data_type_cannot_contain_tuple(
if input.is_record { "record" } else { "struct" },
identifier.span,
));
} else if matches!(type_, Type::Future(..)) {
self.emit_err(TypeCheckerError::composite_data_type_cannot_contain_future(
if input.is_record { "record" } else { "struct" },
identifier.span,
));
}
self.assert_member_is_not_record(identifier.span, input.identifier.name, type_);
if let Type::Composite(struct_member_type) = type_ {
self.state.struct_graph.add_edge(input.identifier.name, struct_member_type.id.name);
} else if let Type::Array(array_type) = type_ {
let base_element_type = array_type.base_element_type();
if let Type::Composite(member_type) = base_element_type {
self.state.struct_graph.add_edge(input.identifier.name, member_type.id.name);
}
}
if !input.is_record && !matches!(mode, Mode::None) {
self.emit_err(TypeCheckerError::struct_cannot_have_member_mode(*span));
}
}
}
}
fn visit_mapping(&mut self, input: &Mapping) {
self.assert_type_is_valid(&input.key_type, input.span);
match input.key_type.clone() {
Type::Future(_) => self.emit_err(TypeCheckerError::invalid_mapping_type("key", "future", input.span)),
Type::Tuple(_) => self.emit_err(TypeCheckerError::invalid_mapping_type("key", "tuple", input.span)),
Type::Composite(struct_type) => {
if let Some(comp) =
self.lookup_struct(struct_type.program.or(self.scope_state.program_name), struct_type.id.name)
{
if comp.is_record {
self.emit_err(TypeCheckerError::invalid_mapping_type("key", "record", input.span));
}
} else {
self.emit_err(TypeCheckerError::undefined_type(&input.key_type, input.span));
}
}
Type::Mapping(_) => self.emit_err(TypeCheckerError::invalid_mapping_type("key", "mapping", input.span)),
_ => {}
}
self.assert_type_is_valid(&input.value_type, input.span);
match input.value_type.clone() {
Type::Future(_) => self.emit_err(TypeCheckerError::invalid_mapping_type("value", "future", input.span)),
Type::Tuple(_) => self.emit_err(TypeCheckerError::invalid_mapping_type("value", "tuple", input.span)),
Type::Composite(struct_type) => {
if let Some(comp) =
self.lookup_struct(struct_type.program.or(self.scope_state.program_name), struct_type.id.name)
{
if comp.is_record {
self.emit_err(TypeCheckerError::invalid_mapping_type("value", "record", input.span));
}
} else {
self.emit_err(TypeCheckerError::undefined_type(&input.key_type, input.span));
}
}
Type::Mapping(_) => self.emit_err(TypeCheckerError::invalid_mapping_type("value", "mapping", input.span)),
_ => {}
}
}
fn visit_function(&mut self, function: &Function) {
self.scope_state.initialize_function_state(function.variant);
for annotation in function.annotations.iter() {
if !matches!(annotation.identifier.name, sym::test | sym::should_fail) {
self.emit_err(TypeCheckerError::unknown_annotation(annotation, annotation.span))
}
}
let get = |symbol: Symbol| -> &Annotation {
function.annotations.iter().find(|ann| ann.identifier.name == symbol).unwrap()
};
let check_annotation = |symbol: Symbol, allowed_keys: &[Symbol]| -> bool {
let count = function.annotations.iter().filter(|ann| ann.identifier.name == symbol).count();
if count > 0 {
let annotation = get(symbol);
for key in annotation.map.keys() {
if !allowed_keys.contains(key) {
self.emit_err(TypeCheckerError::annotation_error(
format_args!("Invalid key `{key}` for annotation @{symbol}"),
annotation.span,
));
}
}
if count > 1 {
self.emit_err(TypeCheckerError::annotation_error(
format_args!("Duplicate annotation @{symbol}"),
annotation.span,
));
}
}
count > 0
};
let has_test = check_annotation(sym::test, &[sym::private_key]);
let has_should_fail = check_annotation(sym::should_fail, &[]);
if has_test && !self.state.is_test {
self.emit_err(TypeCheckerError::annotation_error(
format_args!("Test annotation @test appears outside of tests"),
get(sym::test).span,
));
}
if has_should_fail && !self.state.is_test {
self.emit_err(TypeCheckerError::annotation_error(
format_args!("Test annotation @should_fail appears outside of tests"),
get(sym::should_fail).span,
));
}
if has_should_fail && !has_test {
self.emit_err(TypeCheckerError::annotation_error(
format_args!("Annotation @should_fail appears without @test"),
get(sym::should_fail).span,
));
}
if has_test
&& !self.scope_state.variant.unwrap().is_script()
&& !self.scope_state.variant.unwrap().is_transition()
{
self.emit_err(TypeCheckerError::annotation_error(
format_args!("Annotation @test may appear only on scripts and transitions"),
get(sym::test).span,
));
}
if (has_test) && !function.input.is_empty() {
self.emit_err(TypeCheckerError::annotation_error(
"A test procedure cannot have inputs",
function.input[0].span,
));
}
self.in_conditional_scope(|slf| {
slf.in_scope(function.id, |slf| {
function.input.iter().for_each(|input| slf.insert_symbol_conditional_scope(input.identifier.name));
slf.scope_state.has_return = false;
slf.scope_state.function = Some(function.name());
slf.check_function_signature(function, false);
if function.variant == Variant::Function && function.input.is_empty() {
slf.emit_err(TypeCheckerError::empty_function_arglist(function.span));
}
slf.visit_block(&function.block);
if function.output_type != Type::Unit && !slf.scope_state.has_return {
slf.emit_err(TypeCheckerError::missing_return(function.span));
}
})
});
if self.scope_state.variant == Some(Variant::AsyncTransition) && !self.scope_state.has_called_finalize {
self.emit_err(TypeCheckerError::async_transition_must_call_async_function(function.span));
}
}
fn visit_function_stub(&mut self, input: &FunctionStub) {
if input.variant == Variant::Inline {
self.emit_err(TypeCheckerError::stub_functions_must_not_be_inlines(input.span));
}
if input.variant == Variant::AsyncFunction {
let finalize_input_map = &mut self.async_function_input_types;
let resolved_inputs: Vec<Type> = input
.input
.iter()
.map(|input| {
match &input.type_ {
Type::Future(f) => {
Type::Future(FutureType::new(
finalize_input_map.get(f.location.as_ref().unwrap()).unwrap().clone(),
f.location,
true,
))
}
_ => input.clone().type_,
}
})
.collect();
finalize_input_map
.insert(Location::new(self.scope_state.program_name.unwrap(), input.identifier.name), resolved_inputs);
}
self.check_function_signature(&Function::from(input.clone()), true);
}
fn visit_struct_stub(&mut self, input: &Composite) {
self.visit_struct(input);
}
}
fn check_name(handler: &leo_errors::Handler, name: Identifier, item_type: &str) {
if name.to_string().contains(&sym::aleo.to_string()) {
handler.emit_err(TypeCheckerError::illegal_name(name, item_type, sym::aleo, name.span));
}
}