lutra-compiler 0.5.1

Compiler for Lutra query language
Documentation
use indexmap::IndexMap;
use itertools::Itertools;

use crate::Span;
use crate::diagnostic::Diagnostic;
use crate::pr;

pub fn init_root(root_module_def: pr::ModuleDef) -> Result<pr::ModuleDef, Vec<Diagnostic>> {
    let mut root = pr::ModuleDef {
        annotations: root_module_def.annotations,
        span_content: root_module_def.span_content,
        ..pr::ModuleDef::default()
    };

    let diagnostics = root.populate_module(root_module_def.defs);
    if !diagnostics.is_empty() {
        return Err(diagnostics);
    }

    Ok(root)
}

impl pr::ModuleDef {
    /// Get definition by fully qualified ident.
    pub fn get(&self, fq_ident: &pr::Path) -> Option<&pr::Def> {
        if fq_ident.is_empty() {
            return None;
        }
        let sub_module = self.get_submodule(fq_ident.parent())?;
        sub_module.defs.get(fq_ident.last())
    }

    /// Get definition by fully qualified ident and return remaining steps into the def.
    pub fn try_get<'a, 's>(&'a self, steps: &'s [String]) -> Option<(&'a pr::Def, &'s [String])> {
        let mut curr_mod = self;
        for (index, step) in steps.iter().enumerate() {
            let def = curr_mod.defs.get(step)?;
            if let pr::DefKind::Module(sub_module) = &def.kind {
                curr_mod = sub_module;
            } else {
                return Some((def, &steps[(index + 1)..]));
            }
        }
        None
    }

    /// Get an exclusive reference to definition by fully qualified ident.
    pub fn get_mut(&mut self, ident: &pr::Path) -> Option<&mut pr::Def> {
        let module = self.get_module_mut(ident.parent())?;

        module.defs.get_mut(ident.last())
    }

    pub fn get_submodule(&self, path: &[String]) -> Option<&pr::ModuleDef> {
        let mut curr_mod = self;
        for step in path {
            let def = curr_mod.defs.get(step)?;
            curr_mod = def.kind.as_module()?;
        }
        Some(curr_mod)
    }

    pub fn get_module_mut(&mut self, path: &[String]) -> Option<&mut pr::ModuleDef> {
        let mut curr_mod = self;
        for step in path {
            let def = curr_mod.defs.get_mut(step)?;
            curr_mod = def.kind.as_module_mut()?;
        }
        Some(curr_mod)
    }

    pub fn iter_defs(&self) -> impl Iterator<Item = (&String, &pr::Def)> {
        self.defs.iter()
    }

    pub fn iter_defs_re(&self) -> impl Iterator<Item = (pr::Path, &pr::Def)> {
        let non_modules = (self.defs.iter())
            .filter(|(_, d)| !d.kind.is_module())
            .map(|(name, d)| (pr::Path::from_name(name), d));

        let sub_defs = (self.defs.iter())
            .filter(|(_, d)| d.kind.is_module())
            .flat_map(|(name, d)| {
                let sub_module = d.kind.as_module().unwrap();
                sub_module
                    .iter_defs_re()
                    .map(|(p, d)| (p.prepend(pr::Path::from_name(name)), d))
                    .collect_vec()
            });

        non_modules.chain(sub_defs)
    }

    pub(super) fn take_unresolved(&mut self, ident: &pr::Path) -> (pr::DefKind, Option<Span>) {
        let def = self.get_mut(ident).unwrap();
        let unresolved = def.kind.as_unresolved_mut().unwrap();
        (*unresolved.take().unwrap(), def.span)
    }

    pub(super) fn insert_unresolved(&mut self, ident: &pr::Path, def_kind: pr::DefKind) {
        let def = self.get_mut(ident).unwrap();
        *def.kind.as_unresolved_mut().unwrap() = Some(Box::new(def_kind));
    }

    pub(super) fn populate_module(&mut self, defs: IndexMap<String, pr::Def>) -> Vec<Diagnostic> {
        let mut diagnostics = Vec::new();

        for (name, def) in defs {
            let kind = match def.kind {
                pr::DefKind::Module(module_def) => {
                    // init new module and recurse
                    let mut new_mod = pr::ModuleDef {
                        annotations: module_def.annotations,
                        span_content: module_def.span_content,
                        ..pr::ModuleDef::default()
                    };
                    diagnostics.extend(new_mod.populate_module(module_def.defs));

                    pr::DefKind::Module(new_mod)
                }
                kind => pr::DefKind::Unresolved(Some(Box::new(kind))),
            };
            self.defs.insert(name, pr::Def { kind, ..def });
        }
        diagnostics
    }
}