Skip to main content

blue_lang_runtime/
pipeline.rs

1//! The blue pipeline: **parse → check → erase → run**, in that order, once.
2//!
3//! The order is the whole reason this module exists. Each stage is available
4//! separately for tools that want one, but the *default* path is a single
5//! function, because two of the four orderings are silently wrong:
6//!
7//! - **Erase before check** discards every annotation, so a program with type
8//!   errors passes. The checker sees `(define …)` and has nothing to check.
9//! - **Run before check** reports a type error after the side effects.
10//!
11//! Neither fails loudly. Both produce a green run on a program that should
12//! have been rejected. Leaving the order to each caller means every caller
13//! is one reordering away from turning the type checker off — so the order
14//! lives here, and callers ask for a *result*, not a sequence of steps.
15
16use tatara_lisp::Sexp;
17use tatara_lisp_eval::Value;
18
19use blue_lang_check::{NameTable, Namespace};
20
21use crate::erase::erase_types;
22use crate::inputs::Inputs;
23use crate::uses::Entry;
24
25/// Why a run stopped short.
26#[derive(Debug, thiserror::Error)]
27pub enum RunError {
28    #[error("parse error: {0}")]
29    Parse(String),
30    /// The check stage rejected the program — a type error, an unbound name,
31    /// or any other error-severity rule in `blue_lang_check::RULES`. Carries
32    /// every error, not just the first: a caller fixing one wants to see the
33    /// rest. (The variant keeps its first name because it is public API on a
34    /// released crate.)
35    ///
36    /// Each one is already rendered `file:line:col: message` against the file
37    /// the offending form came from — which, in a program with imports, is
38    /// frequently not the file the user named. The rendering happens here
39    /// rather than at the consumer because here is where the file table exists;
40    /// see `uses::ResolvedProgram::locate`.
41    #[error("{} error(s) in the check stage:\n{}", .0.len(), .0.join("\n"))]
42    Types(Vec<String>),
43    /// **No longer reachable, and that is the point.** This reported "blue
44    /// emitted a tree the reader could not read back" — a failure only a
45    /// print-then-reparse hop could have. [`crate::lower_to_spanned`] deleted
46    /// the hop, so there is nothing left to fail: the tree the evaluator gets
47    /// IS the tree erasure produced, not a re-reading of its text.
48    ///
49    /// Kept rather than removed because it is public API on a released crate
50    /// and a consumer may still match on it, per ★★ MODULARIZE, DON'T DELETE.
51    /// It is retired, not orphaned — if a future stage ever serialises again
52    /// it has a typed home. **Nothing constructs it today**; do not read its
53    /// presence as evidence the pipeline can still fail this way.
54    #[error("the emitted tatara-lisp could not be read back: {0}")]
55    Lower(String),
56    /// The program ran and raised.
57    ///
58    /// Rendered `file:line:col: message`, then the blue call stack the error
59    /// unwound through, innermost first (`crate::observe::Fault`). The
60    /// position is resolved against the file of the innermost frame's
61    /// definition, so a raise inside a callee from another file names the
62    /// callee's file and line; before the stack existed that case could only
63    /// name the caller's file, with no position.
64    #[error("runtime error: {0}")]
65    Eval(Box<crate::observe::Fault>),
66    /// A `use("name")` could not be resolved.
67    ///
68    /// Its own variant rather than folded into `Parse`, because the reader's
69    /// next action is different: a parse error is in the source in front of
70    /// them, an import error is in their packaging — a missing bidama, a
71    /// BLUE_PATH that does not contain it, or no loader at all.
72    #[error("import error: {0}")]
73    Import(String),
74}
75
76/// What a run produced, plus what the checker did on the way.
77#[derive(Debug)]
78pub struct Run {
79    pub value: Value,
80    /// Nodes the type walk visited. Zero for a fully untyped program — this
81    /// is what makes "no annotations, no analysis" a *measurement* rather
82    /// than a claim.
83    pub visited: usize,
84    /// Declarations that carried an annotation.
85    pub typed_decls: usize,
86    /// Boundaries where typed code meets untyped code.
87    pub seams: usize,
88}
89
90/// Parse blue source to tatara-lisp forms.
91pub fn parse(src: &str) -> Result<Vec<Sexp>, RunError> {
92    parse_with_depth(src, blue_lang_syntax::MAX_EXPR_DEPTH)
93}
94
95/// [`parse`] with the parser's nesting bound supplied by the caller.
96///
97/// The bound exists so a stack overflow — which `catch_unwind` cannot catch —
98/// arrives as a typed `Err` instead. It is a *limit*, not a dialect: raising
99/// it changes no program's meaning, which is exactly why it is safe to expose
100/// as configuration (`blue-lang-cli`'s `config` module holds the rule).
101pub fn parse_with_depth(src: &str, max_depth: usize) -> Result<Vec<Sexp>, RunError> {
102    blue_lang_syntax::parse_program_with_depth(src, max_depth)
103        .map_err(|e| RunError::Parse(e.to_string()))
104}
105
106/// [`parse_with_depth`] keeping **every node's** source span.
107///
108/// The door for anything that will report a position to a human. It exists here,
109/// beside the spanless one, so a caller that wants spans still parses under the
110/// CONFIGURED nesting bound — a separate `blue_lang_syntax` call would be the
111/// second door `parse_with_depth`'s own docs exist to prevent, with
112/// `max_expr_depth` true of some subcommands and not others.
113pub fn parse_tree_with_depth(
114    src: &str,
115    max_depth: usize,
116) -> Result<Vec<blue_lang_syntax::Spanned>, RunError> {
117    blue_lang_syntax::parse_program_tree_with_depth(src, max_depth)
118        .map_err(|e| RunError::Parse(e.to_string()))
119}
120
121/// [`parse`] keeping **every node's** source span.
122///
123/// The spanned twin of [`parse`], at the same default bound — the door for
124/// anything downstream of a parse that will report a position, which since
125/// `use` learned to carry file identity is every path through
126/// [`run_in_surface`].
127pub fn parse_tree(src: &str) -> Result<Vec<blue_lang_syntax::Spanned>, RunError> {
128    parse_tree_with_depth(src, blue_lang_syntax::MAX_EXPR_DEPTH)
129}
130
131/// Run blue source with no build inputs.
132pub fn run(src: &str) -> Result<Run, RunError> {
133    run_with_inputs(src, Inputs::new())
134}
135
136/// Run blue source, giving the macro phase access to verified build inputs.
137///
138/// `inputs` is already verified — [`Inputs`] cannot hold bytes that do not match
139/// their declared hash — so nothing here re-checks. The capability a macro gains
140/// is exactly "these hashed bytes", never a path.
141pub fn run_with_inputs(src: &str, inputs: Inputs) -> Result<Run, RunError> {
142    run_with_loader(src, inputs, &crate::uses::NoLoader)
143}
144
145/// Run blue source with a loader, so `use("name")` can resolve.
146///
147/// Split from [`run_with_inputs`] rather than folded into it because loading a
148/// package reads a filesystem, and this crate has a `wasm32-unknown-unknown`
149/// consumer with zero host imports. The capability is injected by callers that
150/// have it — `blue_lang_pkg::LoadPath` is the real one — and absent by default,
151/// where a `use` is a typed error naming the package.
152pub fn run_with_loader(
153    src: &str,
154    inputs: Inputs,
155    loader: &dyn crate::uses::Loader,
156) -> Result<Run, RunError> {
157    run_in_surface(Entry::anonymous(src), inputs, loader, None)
158}
159
160/// Run blue source written in a `yakugo` surface.
161///
162/// The pack applies at PARSE time and nowhere else — by the time the checker
163/// sees the program it is canonical, so every stage below is identical whatever
164/// surface the author wrote in. That is what makes a surface a surface: it
165/// changes how a program is spelled and nothing about how it runs.
166///
167/// `entry` carries the source AND the file it was read from, because a type
168/// error has to be reported somewhere: a caller with a path should pass it, and
169/// one without ([`Entry::anonymous`]) gets diagnostics that say so rather than
170/// diagnostics that guess. Imported packages name themselves through the
171/// loader either way.
172///
173/// # Errors
174///
175/// As [`run_with_loader`].
176pub fn run_in_surface(
177    entry: Entry<'_>,
178    inputs: Inputs,
179    loader: &dyn crate::uses::Loader,
180    surface: Option<&blue_lang_syntax::yakugo::Yakugo>,
181) -> Result<Run, RunError> {
182    // The interpreter is built BEFORE the check stage, because it is the check
183    // stage's name oracle: every builtin, macro and special form a program may
184    // name is read off the interpreter that will run it, never off a list.
185    // Building it is not a stage; nothing is evaluated until `eval_prepared`.
186    let mut interp = crate::interpreter_hostless();
187    crate::inputs::install_input_primitives(&mut interp, inputs);
188    let prepared = prepare(entry, loader, surface, &builtin_names(&interp))?;
189    let mut value = eval_prepared(&mut interp, &prepared, &mut ())?;
190    if let Some(v) = call_main(&mut interp, &prepared, &mut ())? {
191        value = v;
192    }
193    Ok(Run {
194        value,
195        visited: prepared.visited,
196        typed_decls: prepared.typed_decls,
197        seams: prepared.seams,
198    })
199}
200
201/// A run watched by a call observer, and the definitions the observer was
202/// built over.
203pub struct Observed {
204    pub definitions: std::sync::Arc<crate::observe::Definitions>,
205    /// The run itself: its value, or the error it stopped on.
206    pub outcome: Result<Run, RunError>,
207}
208
209/// [`run_in_surface`] with a call observer installed for the evaluation.
210/// `watch` builds the observer from the program's definitions once every stage
211/// before evaluation has passed; the profiler, the tracer and coverage are
212/// all built this way (`crate::observe::Recorder`).
213///
214/// # Errors
215///
216/// A parse, import or check error, which leaves nothing to run. A runtime
217/// error is the [`Observed::outcome`], so what ran before it is still read.
218pub fn run_observed(
219    entry: Entry<'_>,
220    inputs: Inputs,
221    loader: &dyn crate::uses::Loader,
222    surface: Option<&blue_lang_syntax::yakugo::Yakugo>,
223    watch: impl FnOnce(
224        &std::sync::Arc<crate::observe::Definitions>,
225    ) -> std::sync::Arc<dyn crate::observe::CallObserver>,
226) -> Result<Observed, RunError> {
227    let mut interp = crate::interpreter_hostless();
228    crate::inputs::install_input_primitives(&mut interp, inputs);
229    let prepared = prepare(entry, loader, surface, &builtin_names(&interp))?;
230    let definitions = std::sync::Arc::new(crate::observe::Definitions::of(
231        &prepared.program,
232        &prepared.erased,
233    ));
234    interp.set_call_observer(Some(watch(&definitions)));
235    let outcome = eval_prepared(&mut interp, &prepared, &mut ())
236        .and_then(|value| Ok(call_main(&mut interp, &prepared, &mut ())?.unwrap_or(value)))
237        .map(|value| Run {
238            value,
239            visited: prepared.visited,
240            typed_decls: prepared.typed_decls,
241            seams: prepared.seams,
242        });
243    interp.set_call_observer(None);
244    Ok(Observed {
245        definitions,
246        outcome,
247    })
248}
249
250/// A program past every stage before evaluation: parsed, its imports
251/// resolved, type-checked and erased. What [`run_in_surface`] and
252/// [`crate::hosted::load_hosted`] both evaluate, so the stage order this
253/// module exists to own is written once for both.
254pub(crate) struct Prepared {
255    program: crate::uses::ResolvedProgram,
256    erased: Vec<tatara_lisp::Spanned>,
257    visited: usize,
258    typed_decls: usize,
259    seams: usize,
260}
261
262impl Prepared {
263    /// The forms the evaluator will run: every file's, resolved and erased.
264    pub(crate) fn erased(&self) -> &[tatara_lisp::Spanned] {
265        &self.erased
266    }
267
268    /// The entry file's namespace.
269    pub(crate) fn entry_namespace(&self) -> Namespace {
270        let first = (0..self.program.forms().len())
271            .find(|i| self.program.owner_of(*i) == Some(crate::uses::ResolvedProgram::ENTRY));
272        match first {
273            Some(i) => namespace_of(&self.program, i),
274            None => match self
275                .program
276                .file(crate::uses::ResolvedProgram::ENTRY)
277                .and_then(|f| f.package.clone())
278            {
279                Some(p) => Namespace::Bidama(p),
280                None => Namespace::File(String::new()),
281            },
282        }
283    }
284}
285
286/// Parse, resolve, check and erase, in that order.
287///
288/// `builtins` is the name table of the interpreter that will evaluate the
289/// result ([`builtin_names`]); the check stage resolves the program's names
290/// against it.
291pub(crate) fn prepare(
292    entry: Entry<'_>,
293    loader: &dyn crate::uses::Loader,
294    surface: Option<&blue_lang_syntax::yakugo::Yakugo>,
295    builtins: &NameTable,
296) -> Result<Prepared, RunError> {
297    let mut program = parse_and_resolve(entry, loader, surface)?;
298
299    // `test` blocks are declarations for the harness, not code to run.
300    //
301    // Dropped here rather than in `resolve_uses`, because `blue test` calls
302    // the resolver and then NEEDS the entry file's blocks — so the two
303    // callers want different things and the split has to live at this level.
304    //
305    // Without this, `blue run` on a file containing its own tests fails with
306    // `unbound symbol: deftest`: every package in the bidama distribution
307    // carries tests, so every one of them was unrunnable.
308    //
309    // Through `retain`, which drops each form's owner with it. A plain filter
310    // over the forms alone would slide every later form onto the wrong file.
311    program.retain(|f| !crate::uses::is_test_form(f));
312
313    // CHECK, on the annotated tree — the only tree that has annotations.
314    //
315    // **On the REAL spanned tree, including every imported package's.** This
316    // was the one caller that checked a spanless lift, because `resolve_uses`
317    // flattened the entry file and its imports into one list and `Span` is a
318    // byte range with no file identity — so a real span here would have
319    // reported an imported package's error at that offset in the ENTRY file, a
320    // precise-looking answer pointing at unrelated code.
321    //
322    // The fix is not a wider `Span` (that type is upstream, and its own docs
323    // put file identity on the caller: spans "are meaningful only relative to
324    // the string that produced them, which the caller is responsible for
325    // holding onto"). blue holds onto it BESIDE the span, per top-level form —
326    // see `uses::ResolvedProgram`.
327    let (outcome, names) = check_stage(&program, builtins, false);
328    if !outcome.ok() {
329        return Err(RunError::Types(
330            outcome
331                .errors()
332                // `file:line:col: error[CODE]: message`, resolved against the
333                // file the form actually came from, then its help line.
334                .map(|d| render(&program, d))
335                .collect(),
336        ));
337    }
338
339    // ERASE, so the interpreter never sees a type — **on the spanned tree,
340    // and back out as one.**
341    //
342    // This used to be `erase_types(&program.sexps())` followed by a
343    // `lower_to_spanned` that stamped `Span::synthetic()` over every node, and
344    // the comment here said carrying real positions through was "a larger
345    // piece and is NOT built". It was not larger: erasure only ever DELETES
346    // nodes — the single node it invents is the `define` replacing
347    // `define-typed` — so there was never anything for a synthetic span to
348    // stand in for. See `crate::erase`.
349    //
350    // No lowering step follows. The tree the evaluator receives IS the tree the
351    // parser built, minus annotations, with the author's byte offsets intact.
352    let erased = erase_types(&lower(&program, &names));
353
354    Ok(Prepared {
355        program,
356        erased,
357        visited: outcome.stats.visited,
358        typed_decls: outcome.stats.typed_decls,
359        seams: outcome.seams.len(),
360    })
361}
362
363/// Parse the entry (in `surface`, if one is given) and splice in its imports.
364pub(crate) fn parse_and_resolve(
365    entry: Entry<'_>,
366    loader: &dyn crate::uses::Loader,
367    surface: Option<&blue_lang_syntax::yakugo::Yakugo>,
368) -> Result<crate::uses::ResolvedProgram, RunError> {
369    let forms = match surface {
370        Some(pack) => blue_lang_syntax::parse_program_tree_in(entry.text, pack)
371            .map_err(|e| RunError::Parse(e.to_string()))?,
372        None => loader
373            .parse(entry.text)
374            .map_err(|e| RunError::Parse(e.to_string()))?,
375    };
376
377    // RESOLVE imports first, so everything below sees ONE program.
378    //
379    // Before the check on purpose: imported code is type-checked at the point
380    // its consumer imports it, rather than at whatever later moment its code
381    // first runs. A package that does not typecheck should break its importer's
382    // build, not their production run.
383    //
384    // One program, but not one FILE: the result records which file each
385    // top-level form came from, which is what lets a diagnostic below name a
386    // place instead of only a problem.
387    crate::uses::resolve_uses(forms, entry, loader).map_err(RunError::Import)
388}
389
390/// **The check stage**: every rule in `blue_lang_check::RULES`, over a
391/// resolved program, with waivers applied.
392///
393/// One function, called by every door — `run`, the hosted loader, `blue test`
394/// and `blue check` — so a rule added to the registry is enforced by all of
395/// them at once. That is what makes an architecture rule a pipeline error
396/// rather than an optional report: there is no door that skips it.
397///
398/// Warnings (unused bindings, unused waivers) are reported for the ENTRY
399/// file only; an imported package's warnings belong to its author. Errors
400/// are reported for every file, because an imported package with one is
401/// broken for its importer.
402pub(crate) fn check_stage(
403    program: &crate::uses::ResolvedProgram,
404    builtins: &NameTable,
405    with_tests: bool,
406) -> (blue_lang_check::Outcome, NameTable) {
407    use crate::uses::ResolvedProgram;
408    let forms = program.forms();
409    let is_entry = |i: usize| program.owner_of(i) == Some(ResolvedProgram::ENTRY);
410
411    // Rules B0003–B0005: the typing ladder.
412    let mut outcome = blue_lang_check::check_program(forms);
413
414    // Rules B0001–B0002: names. The program's own scopes come first (the
415    // entry file, then each bidama in import order), then the interpreter's.
416    let table = program_names(program, builtins);
417    let whole = |i: usize| with_tests && is_entry(i);
418    let (names, resolved) = blue_lang_check::names::check_names_whole(
419        forms,
420        &table,
421        &|i| namespace_of(program, i),
422        &is_entry,
423        &whole,
424    );
425    let stored = program
426        .file(ResolvedProgram::ENTRY)
427        .is_some_and(|f| f.path.is_some());
428    outcome.diagnostics.extend(names);
429    outcome.stats.names_resolved = resolved;
430    if stored {
431        let script = program
432            .file(ResolvedProgram::ENTRY)
433            .is_some_and(|f| f.package.is_none());
434        let found = blue_lang_check::form_rules::check(forms, &is_entry, script);
435        let silenced: Vec<tatara_lisp::Span> = found
436            .iter()
437            .filter(|d| d.code == blue_lang_check::Code::B0038)
438            .map(|d| d.span)
439            .collect();
440        outcome
441            .diagnostics
442            .retain(|d| !(d.code == blue_lang_check::Code::B0002 && silenced.contains(&d.span)));
443        outcome.diagnostics.extend(found);
444    }
445
446    // Waivers, per file: B0007 for a malformed one, B0008 for one that
447    // suppresses nothing.
448    let mut waivers = Vec::new();
449    for file in program.files() {
450        let spans: Vec<(usize, tatara_lisp::Span)> = forms
451            .iter()
452            .enumerate()
453            .filter(|(i, _)| program.owner_of(*i) == Some(file.id))
454            .map(|(i, f)| (i, f.span))
455            .collect();
456        let (found, malformed) = blue_lang_check::waiver::collect(&file.text, &spans);
457        waivers.extend(found);
458        outcome.diagnostics.extend(malformed);
459    }
460    outcome.waived = blue_lang_check::waiver::apply(&mut outcome.diagnostics, waivers, &is_entry);
461    if !stored {
462        outcome.diagnostics.retain(|d| {
463            !matches!(
464                d.code,
465                blue_lang_check::Code::B0023
466                    | blue_lang_check::Code::B0036
467                    | blue_lang_check::Code::B0037
468            )
469        });
470    }
471    // A rule whose census has not reached zero is computed, and counted, but
472    // not enforced: its findings move to `census` (see `RULES`' `ratchet`).
473    let (enforced, census): (Vec<_>, Vec<_>) = std::mem::take(&mut outcome.diagnostics)
474        .into_iter()
475        .partition(|d| d.code.rule().active());
476    outcome.diagnostics = enforced;
477    outcome.census = census;
478    outcome
479        .diagnostics
480        .sort_by_key(|d| (d.top_level, d.span.start, d.code));
481    (outcome, table)
482}
483
484/// The whole name table the check stage resolves against: the program's
485/// own scopes (each file and bidama, by namespace) followed by `builtins`.
486///
487/// **A top-level call to a builtin macro can define names**: `defflow(slug,
488/// trim, downcase)` expands to `(define slug …)`, and nothing in the source
489/// spells `define`. Such a call is expanded here, on a hostless fork, and what
490/// its expansion defines is bound in the calling file's namespace. Only
491/// BUILTIN macros are expanded: their bodies are the runtime's own
492/// templates. A program's own `defmacro` is not run at check time — checking a
493/// file (and an editor checking on every keystroke) must not execute the code
494/// it checks — so names a program macro generates are not seen; none of the
495/// corpus's macros generates one (measured 2026-09-29).
496#[must_use]
497pub fn program_names(program: &crate::uses::ResolvedProgram, builtins: &NameTable) -> NameTable {
498    use blue_lang_check::Binding;
499    let mut table = NameTable::new();
500    table.add_program(program.forms(), |i| namespace_of(program, i));
501    let builtin_macro = |head: &str| {
502        builtins
503            .scopes()
504            .iter()
505            .any(|s| s.namespace == Namespace::Macro && s.get(head).is_some())
506    };
507    let mut expander: Option<tatara_lisp_eval::Interpreter<()>> = None;
508    for (i, form) in program.forms().iter().enumerate() {
509        let Some(head) = form
510            .as_list()
511            .and_then(|items| items.first())
512            .and_then(tatara_lisp::Spanned::as_symbol)
513        else {
514            continue;
515        };
516        if !builtin_macro(head) {
517            continue;
518        }
519        let interp = expander.get_or_insert_with(crate::interpreter_hostless);
520        // A failed expansion defines nothing here; the evaluator will report
521        // it, with its position, when the form runs.
522        let Ok(expanded) = interp.fully_expand(form, &mut ()) else {
523            continue;
524        };
525        let nullary = blue_lang_syntax::scope::nullary_definition(&expanded);
526        for (name, span, kind) in blue_lang_check::names::definitions_of(&expanded) {
527            table.define(
528                namespace_of(program, i),
529                Binding {
530                    nullary: nullary == Some(name.as_str()),
531                    name,
532                    kind,
533                    span: Some(span),
534                    top_level: Some(i),
535                },
536            );
537        }
538    }
539    for scope in builtins.scopes() {
540        table.push(scope.clone());
541    }
542    table.spell_bare_like(builtins);
543    let form_file: Vec<usize> = (0..program.forms().len())
544        .map(|i| program.owner_of(i).map_or(usize::MAX, |f| f.index()))
545        .collect();
546    let mut imports: std::collections::BTreeMap<usize, blue_lang_check::names::FileImports> =
547        std::collections::BTreeMap::new();
548    for (file, import) in program.imports() {
549        let entry = imports.entry(file.index()).or_default();
550        entry.add(&import.package, import.names.iter().map(|(n, _)| n.clone()));
551        let at = import.span.start;
552        entry.use_at = Some(entry.use_at.map_or(at, |a| a.min(at)));
553    }
554    // A FACADE — a bidama that defines nothing and `use`s others (zenbu) —
555    // exists so a consumer can depend on "everything": `use("zenbu")` makes
556    // every member's QUALIFIER reachable (`toukei::median`), never a bare
557    // name. Followed to a fixpoint, so a facade of facades works too.
558    let facade_uses =
559        |pkg: &str,
560         imports: &std::collections::BTreeMap<usize, blue_lang_check::names::FileImports>| {
561            let defines = table.bidama(pkg).is_some_and(|s| !s.is_empty());
562            if defines {
563                return std::collections::BTreeSet::new();
564            }
565            program
566                .files()
567                .iter()
568                .filter(|f| f.package.as_deref() == Some(pkg))
569                .filter_map(|f| imports.get(&f.id.index()))
570                .flat_map(|i| i.uses.iter().cloned())
571                .collect::<std::collections::BTreeSet<String>>()
572        };
573    loop {
574        let mut grew = false;
575        let files: Vec<usize> = imports.keys().copied().collect();
576        for f in files {
577            let used: Vec<String> = imports[&f].uses.iter().cloned().collect();
578            for p in used {
579                for member in facade_uses(&p, &imports) {
580                    if let Some(i) = imports.get_mut(&f) {
581                        if i.uses.insert(member.clone()) {
582                            i.via.insert(member, p.clone());
583                            grew = true;
584                        }
585                    }
586                }
587            }
588        }
589        if !grew {
590            break;
591        }
592    }
593    let mut pkg_uses: std::collections::BTreeMap<String, std::collections::BTreeSet<String>> =
594        std::collections::BTreeMap::new();
595    for (file, import) in program.imports() {
596        if let Some(p) = program.file(*file).and_then(|f| f.package.clone()) {
597            pkg_uses
598                .entry(p)
599                .or_default()
600                .insert(import.package.clone());
601        }
602    }
603    table.attach_files(form_file, imports);
604    table.attach_package_uses(pkg_uses);
605    table.attach_needs(program.needs().clone());
606    // Where each file lives and which distribution each bidama ships in: a
607    // bridge reference (B0021) is an error inside the bidama's own
608    // distribution and a warning outside it.
609    let canonical = |p: &std::path::Path| {
610        std::fs::canonicalize(p)
611            .unwrap_or_else(|_| p.to_path_buf())
612            .display()
613            .to_string()
614    };
615    let mut file_paths = std::collections::BTreeMap::new();
616    let mut pkg_roots = std::collections::BTreeMap::new();
617    for f in program.files() {
618        if let Some(path) = &f.path {
619            file_paths.insert(f.id.index(), canonical(path));
620            if let (Some(pkg), Some(root)) =
621                (&f.package, path.parent().and_then(std::path::Path::parent))
622            {
623                pkg_roots
624                    .entry(pkg.clone())
625                    .or_insert_with(|| canonical(root));
626            }
627        }
628    }
629    table.attach_paths(file_paths, pkg_roots);
630    let versions = program.versions().clone();
631    table.apply_legacy(program.forms(), &|i| namespace_of(program, i), &|p| {
632        versions.get(p).cloned()
633    });
634    table
635}
636
637/// The forms the evaluator runs, from a checked program: every `use`
638/// declaration inert (`nil`, so each index still names its top-level form)
639/// and every name at the key it runs under — the RESOLVED tree under
640/// per-bidama namespaces (`blue_lang_check::names::Resolved::resolved_tree`).
641///
642/// A definition runs as `retsu/first` (a script's as `%root/f`), a
643/// reference to it as the same key, and a builtin as its bare name. Keys
644/// cannot collide across namespaces, so a bidama's `first` no longer
645/// replaces the builtin for anyone who did not import it, and an importer's
646/// `helper` no longer replaces a bidama's own: the runtime binds exactly what
647/// the check stage resolved.
648#[must_use]
649pub fn lower(
650    program: &crate::uses::ResolvedProgram,
651    names: &NameTable,
652) -> Vec<tatara_lisp::Spanned> {
653    lower_with(program, names, true)
654}
655
656#[must_use]
657pub fn lower_with(
658    program: &crate::uses::ResolvedProgram,
659    names: &NameTable,
660    simplify_chains: bool,
661) -> Vec<tatara_lisp::Spanned> {
662    let mut resolved = blue_lang_check::names::resolve_program(program.forms(), names, &|i| {
663        namespace_of(program, i)
664    });
665    let simplified = if simplify_chains {
666        chain_simplified(program.forms(), &resolved)
667    } else {
668        None
669    };
670    let forms: &[tatara_lisp::Spanned] = simplified.as_deref().unwrap_or(program.forms());
671    if simplified.is_some() {
672        resolved =
673            blue_lang_check::names::resolve_program(forms, names, &|i| namespace_of(program, i));
674    }
675    resolved
676        .resolved_tree(forms, blue_lang_check::names::Rule::Namespaced)
677        .into_iter()
678        .zip(forms)
679        .enumerate()
680        .map(|(i, (resolved, written))| {
681            if crate::uses::use_target(written).is_some()
682                || blue_lang_syntax::scope::legacy_target(written).is_some()
683            {
684                tatara_lisp::Spanned::new(written.span, tatara_lisp::SpannedForm::Nil)
685            } else {
686                let file = program.owner_of(i).and_then(|id| program.file(id));
687                match file {
688                    Some(f) => locate_raises(&resolved, &raise_site(f)),
689                    None => resolved,
690                }
691            }
692        })
693        .collect()
694}
695
696fn chain_simplified(
697    forms: &[tatara_lisp::Spanned],
698    resolved: &blue_lang_check::names::Resolved,
699) -> Option<Vec<tatara_lisp::Spanned>> {
700    let respell: std::collections::HashMap<usize, blue_lang_check::respell::Respelling> = resolved
701        .respellings
702        .iter()
703        .filter(|(_, r)| matches!(r.respell, blue_lang_check::respell::Respell::Chain(_)))
704        .cloned()
705        .collect();
706    if respell.is_empty() {
707        return None;
708    }
709    let bare = std::collections::HashSet::new();
710    let canon = Canon {
711        bare: &bare,
712        respell: &respell,
713    };
714    Some(forms.iter().map(|f| canon.form(f)).collect())
715}
716
717fn raise_site(file: &crate::uses::SourceFile) -> impl Fn(tatara_lisp::Span) -> String + '_ {
718    move |span| {
719        let (line, _) =
720            blue_lang_syntax::Span::line_col(&file.text, span.start.min(file.text.len()));
721        let shown = file
722            .path
723            .as_ref()
724            .map_or_else(|| "<source>".to_string(), |p| p.display().to_string());
725        format!("{shown}:{line}")
726    }
727}
728
729fn locate_raises(
730    form: &tatara_lisp::Spanned,
731    site: &dyn Fn(tatara_lisp::Span) -> String,
732) -> tatara_lisp::Spanned {
733    use tatara_lisp::{Atom, Spanned, SpannedForm};
734    let inner = match &form.form {
735        SpannedForm::List(items) => {
736            let mut out: Vec<Spanned> = items.iter().map(|i| locate_raises(i, site)).collect();
737            let raising = items.first().and_then(Spanned::as_symbol) == Some("raise")
738                && (3..=4).contains(&items.len());
739            if raising {
740                out[0] = Spanned::new(
741                    items[0].span,
742                    SpannedForm::Atom(Atom::Symbol(crate::errors::RAISE_AT.to_string())),
743                );
744                out.insert(
745                    1,
746                    Spanned::new(items[0].span, SpannedForm::Atom(Atom::Str(site(form.span)))),
747                );
748            }
749            SpannedForm::List(out)
750        }
751        SpannedForm::Quote(_) | SpannedForm::Quasiquote(_) => return form.clone(),
752        other => other.clone(),
753    };
754    Spanned::new(form.span, inner)
755}
756
757/// The namespace top-level form `i` of `program` defines into.
758#[must_use]
759pub fn namespace_of(program: &crate::uses::ResolvedProgram, i: usize) -> Namespace {
760    let file = program.owner_of(i).and_then(|id| program.file(id));
761    match file {
762        Some(f) => match &f.package {
763            Some(p) => Namespace::Bidama(p.clone()),
764            None => Namespace::File(
765                f.path
766                    .as_ref()
767                    .map_or_else(|| "<anonymous>".to_string(), |p| p.display().to_string()),
768            ),
769        },
770        None => Namespace::File("<unknown file>".to_string()),
771    }
772}
773
774/// Names only the test harness binds.
775///
776/// In scope for EVERY check, not only for test blocks. A bidama may carry a
777/// test helper — a plain `def` that asserts, called only from its `test`
778/// blocks (`heni`'s `hn_end_to_end` is one) — and every program importing that
779/// bidama would otherwise be refused for a function it never calls. The
780/// refusal would be scoped to the importer's whole program, not to the fault.
781/// The cost, stated: an `assert` outside any test that `blue run` actually
782/// reaches is caught at runtime (`blue-assert` is unbound there), not here.
783///
784/// `blue-lang-test` registers these on its own interpreter, and this crate
785/// cannot depend on it (it depends on this one), so the list lives beside the
786/// only name in it: the lowered `assert`, which `blue-lang-syntax` owns.
787pub const HARNESS_NAMES: &[&str] = &[blue_lang_syntax::LOWERED_ASSERT];
788
789/// The check stage's builtin scopes, read off the interpreter that will run
790/// the program: the test harness's names ([`HARNESS_NAMES`]), then its special
791/// forms, its macros, and every value it binds — the last three in the order
792/// the evaluator consults for a head.
793///
794/// Read from a live interpreter rather than a list, for the reason
795/// `Interpreter::resolve_head` gives: a list is a second copy of the truth and
796/// goes stale on the next installer that lands. An embedder's own
797/// primitives are in scope here because the embedder installs them first.
798#[must_use]
799pub fn builtin_names<H: 'static>(interp: &tatara_lisp_eval::Interpreter<H>) -> NameTable {
800    builtin_names_with(interp, &[])
801}
802
803#[must_use]
804pub fn builtin_names_with<H: 'static>(
805    interp: &tatara_lisp_eval::Interpreter<H>,
806    host: &[crate::host_surface::HostName],
807) -> NameTable {
808    use blue_lang_check::{Binding, Scope, ScopeKind};
809    use tatara_lisp_eval::HeadBinding;
810    let mut special = Scope::new(Namespace::SpecialForm);
811    let mut macros = Scope::new(Namespace::Macro);
812    let mut values = Scope::new(Namespace::Builtin);
813    // `reserved_head_names` reads the ROOT frame only, so a name installed on
814    // a fork (the input primitives, on every `run`) is invisible to it; those
815    // are asked about by name instead, which `resolve_head` answers through
816    // every frame.
817    let mut names: Vec<std::sync::Arc<str>> = interp.reserved_head_names().into_iter().collect();
818    names.extend(
819        crate::inputs::INPUT_PRIMITIVES
820            .iter()
821            .filter(|n| interp.resolve_head(n).is_some())
822            .map(|n| std::sync::Arc::from(*n)),
823    );
824    for name in names {
825        let (scope, kind) = match interp.resolve_head(&name) {
826            Some(HeadBinding::SpecialForm) => (&mut special, ScopeKind::SpecialForm),
827            Some(HeadBinding::Macro) => (&mut macros, ScopeKind::Macro),
828            _ => (&mut values, ScopeKind::Value),
829        };
830        let nullary = kind == ScopeKind::Value
831            && interp.lookup_global(&name).is_some_and(|v| {
832                nullary_value(&v)
833                    || (crate::docs::doc_of(&name).is_some_and(|d| d.signature == &*name)
834                        && matches!(
835                            v,
836                            tatara_lisp_eval::Value::NativeFn(_)
837                                | tatara_lisp_eval::Value::Closure(_)
838                        ))
839            });
840        scope.bind(Binding {
841            name: name.to_string(),
842            kind,
843            span: None,
844            top_level: None,
845            nullary,
846        });
847    }
848    for h in host {
849        values.bind(Binding {
850            name: h.name.clone(),
851            kind: ScopeKind::Value,
852            span: None,
853            top_level: None,
854            nullary: h.nullary(),
855        });
856    }
857    let mut table = NameTable::new();
858    let mut harness = Scope::new(Namespace::Harness);
859    for n in HARNESS_NAMES {
860        harness.bind(Binding {
861            name: (*n).to_string(),
862            kind: ScopeKind::Value,
863            span: None,
864            top_level: None,
865            nullary: false,
866        });
867    }
868    table.push(harness);
869    table.push(special);
870    table.push(macros);
871    table.push(values);
872    table.spell_bare_only(
873        crate::docs::NAMES
874            .iter()
875            .filter(|d| d.signature == d.name)
876            .map(|d| d.name.to_string())
877            .chain(host.iter().filter(|h| h.nullary()).map(|h| h.name.clone()))
878            .collect(),
879    );
880    table
881}
882
883#[must_use]
884pub fn nullary_value(value: &tatara_lisp_eval::Value) -> bool {
885    match value {
886        tatara_lisp_eval::Value::NativeFn(f) => {
887            matches!(f.arity, tatara_lisp_eval::ffi::Arity::Exact(0))
888        }
889        tatara_lisp_eval::Value::Closure(c) => c.params.is_empty() && c.rest.is_none(),
890        _ => false,
891    }
892}
893
894/// A diagnostic as a person reads it: `file:line:col: error[B0001]: message`,
895/// then an indented `help:` line when it has one.
896#[must_use]
897pub fn render(program: &crate::uses::ResolvedProgram, d: &blue_lang_check::Diagnostic) -> String {
898    let head = d.to_string();
899    let mut out = program.locate(d.top_level, d.span, &head).to_string();
900    if let Some(help) = &d.help {
901        out.push_str("\n  help: ");
902        out.push_str(help);
903    }
904    out
905}
906
907/// What [`check_entry`] checks.
908#[derive(Clone, Copy, Debug, PartialEq, Eq)]
909pub enum Checking {
910    /// The program `blue run` would evaluate: test blocks dropped.
911    Program,
912    /// The program plus the entry file's test blocks, as `blue test` and
913    /// `blue check` see it.
914    WithTests,
915}
916
917/// A program through the check stage, with everything the stage found.
918pub struct Checked {
919    pub program: crate::uses::ResolvedProgram,
920    pub outcome: blue_lang_check::Outcome,
921    /// The name table the stage resolved against: every program scope, then
922    /// the builtins. What an editor completes from.
923    pub names: NameTable,
924}
925
926impl Checked {
927    /// The forms an evaluator runs: [`lower`]ed, then erased — the tree
928    /// `run` evaluates, for a door that brings its own evaluator (the VM).
929    #[must_use]
930    pub fn erased(&self) -> Vec<tatara_lisp::Spanned> {
931        erase_types(&lower(&self.program, &self.names))
932    }
933
934    /// What `blue test` hands the harness: the program [`lower`]ed, spans
935    /// projected away.
936    #[must_use]
937    pub fn evaluable(&self) -> Vec<tatara_lisp::Sexp> {
938        lower(&self.program, &self.names)
939            .iter()
940            .map(tatara_lisp::Spanned::to_sexp)
941            .collect()
942    }
943
944    /// Every non-local reference, resolved under both rules — today's flat
945    /// one and per-bidama namespaces — and the resolved trees built from them
946    /// (`blue ast --resolved`).
947    #[must_use]
948    pub fn resolve(&self) -> blue_lang_check::names::Resolved {
949        blue_lang_check::names::resolve_program(self.program.forms(), &self.names, &|i| {
950            namespace_of(&self.program, i)
951        })
952    }
953}
954
955impl Checked {
956    #[must_use]
957    pub fn call_explicit_forms(&self) -> Vec<tatara_lisp::Spanned> {
958        self.resolve().call_explicit_tree(self.program.forms())
959    }
960
961    #[must_use]
962    pub fn canonical_entry(&self, src: &str) -> Option<Vec<tatara_lisp::Spanned>> {
963        use crate::uses::ResolvedProgram;
964        let program = &self.program;
965        let entry: Vec<&tatara_lisp::Spanned> = program
966            .forms()
967            .iter()
968            .enumerate()
969            .filter(|(i, _)| program.owner_of(*i) == Some(ResolvedProgram::ENTRY))
970            .map(|(_, f)| f)
971            .collect();
972        let written = blue_lang_syntax::parse_program_tree(src).ok()?;
973        let same = written.len() == entry.len()
974            && written
975                .iter()
976                .zip(&entry)
977                .all(|(w, e)| w.to_sexp() == e.to_sexp() && w.span == e.span);
978        if !same {
979            return None;
980        }
981        let resolved = self.resolve();
982        let bare: std::collections::HashSet<usize> = resolved
983            .parenthesized_nullary_calls()
984            .into_iter()
985            .filter(|r| program.owner_of(r.top_level) == Some(ResolvedProgram::ENTRY))
986            .map(blue_lang_check::names::Reference::node_address)
987            .collect();
988        let waived: Vec<tatara_lisp::Span> = self
989            .outcome
990            .waived
991            .iter()
992            .map(|w| w.diagnostic.span)
993            .collect();
994        let respell: std::collections::HashMap<usize, blue_lang_check::respell::Respelling> =
995            resolved
996                .respellings
997                .iter()
998                .filter(|(_, r)| !waived.contains(&r.span))
999                .cloned()
1000                .collect();
1001        let canon = Canon {
1002            bare: &bare,
1003            respell: &respell,
1004        };
1005        let forms: Vec<tatara_lisp::Spanned> = entry.into_iter().map(|f| canon.form(f)).collect();
1006        let script = program
1007            .file(ResolvedProgram::ENTRY)
1008            .is_some_and(|f| f.package.is_none());
1009        let forms = if script {
1010            blue_lang_check::form_rules::without_prefix(&forms).unwrap_or(forms)
1011        } else {
1012            forms
1013        };
1014        let forms = blue_lang_check::form_rules::without_main_guard(&forms).unwrap_or(forms);
1015        Some(blue_lang_check::form_rules::eta_reduced(&forms).unwrap_or(forms))
1016    }
1017}
1018
1019struct Canon<'a> {
1020    bare: &'a std::collections::HashSet<usize>,
1021    respell: &'a std::collections::HashMap<usize, blue_lang_check::respell::Respelling>,
1022}
1023
1024impl Canon<'_> {
1025    fn form(&self, form: &tatara_lisp::Spanned) -> tatara_lisp::Spanned {
1026        use tatara_lisp::{Spanned, SpannedForm};
1027        let inner = match &form.form {
1028            SpannedForm::List(items) => match items.as_slice() {
1029                [head] if self.bare.contains(&(std::ptr::from_ref(head) as usize)) => {
1030                    return Spanned::new(form.span, head.form.clone());
1031                }
1032                [head, ..]
1033                    if self
1034                        .respell
1035                        .contains_key(&(std::ptr::from_ref(head) as usize)) =>
1036                {
1037                    let r = &self.respell[&(std::ptr::from_ref(head) as usize)];
1038                    let walked: Vec<Spanned> = items.iter().map(|i| self.form(i)).collect();
1039                    return blue_lang_check::respell::apply(form, &walked, r);
1040                }
1041                _ => SpannedForm::List(items.iter().map(|i| self.form(i)).collect()),
1042            },
1043            SpannedForm::Quote(i) => SpannedForm::Quote(Box::new(self.form(i))),
1044            SpannedForm::Quasiquote(i) => SpannedForm::Quasiquote(Box::new(self.form(i))),
1045            SpannedForm::Unquote(i) => SpannedForm::Unquote(Box::new(self.form(i))),
1046            SpannedForm::UnquoteSplice(i) => SpannedForm::UnquoteSplice(Box::new(self.form(i))),
1047            other => other.clone(),
1048        };
1049        Spanned::new(form.span, inner)
1050    }
1051}
1052
1053/// Parse, resolve and CHECK, without running: the door for `blue check`,
1054/// `blue test` and the language server.
1055///
1056/// Returns every diagnostic, errors and warnings alike, rather than failing on
1057/// the first error: a reader fixing a file wants the whole list, and an agent
1058/// repairing one wants it in one pass. Whether errors stop anything is the
1059/// caller's decision — `blue test` refuses to run tests over a program with
1060/// one, exactly as `run` refuses to evaluate it.
1061///
1062/// The name oracle is the interpreter `blue run` would build: hostless plus
1063/// input primitives.
1064///
1065/// # Errors
1066///
1067/// A parse or import error, which leaves no program to check.
1068pub fn check_entry(
1069    entry: Entry<'_>,
1070    loader: &dyn crate::uses::Loader,
1071    surface: Option<&blue_lang_syntax::yakugo::Yakugo>,
1072    checking: Checking,
1073) -> Result<Checked, RunError> {
1074    let mut program = parse_and_resolve(entry, loader, surface)?;
1075    if checking == Checking::Program {
1076        program.retain(|f| !crate::uses::is_test_form(f));
1077    }
1078    let host = match entry.path {
1079        Some(path) => crate::host_surface::near(path)
1080            .map_err(|e| RunError::Import(e.to_string()))?
1081            .map(|s| s.functions)
1082            .unwrap_or_default(),
1083        None => Vec::new(),
1084    };
1085    let mut interp = crate::interpreter_hostless();
1086    crate::inputs::install_input_primitives(&mut interp, Inputs::new());
1087    let builtins = builtin_names_with(&interp, &host);
1088    let (outcome, names) = check_stage(&program, &builtins, checking == Checking::WithTests);
1089    Ok(Checked {
1090        program,
1091        outcome,
1092        names,
1093    })
1094}
1095
1096#[must_use]
1097pub fn spelling_code(spelling: blue_lang_syntax::Spelling) -> blue_lang_check::Code {
1098    use blue_lang_check::Code;
1099    use blue_lang_syntax::Spelling;
1100    match spelling {
1101        Spelling::LogicalSymbol => Code::B0025,
1102        Spelling::Unless => Code::B0026,
1103        Spelling::ElseIf => Code::B0027,
1104        Spelling::CallForm => Code::B0028,
1105        Spelling::KeywordRocket => Code::B0029,
1106        Spelling::ParameterList => Code::B0030,
1107        Spelling::OperatorSpelling => Code::B0031,
1108        Spelling::TrailingComma => Code::B0032,
1109        Spelling::NegatedComparison => Code::B0034,
1110        Spelling::ElseNil => Code::B0035,
1111        Spelling::TryCatch => Code::B0037,
1112        Spelling::Apply => Code::B0042,
1113        Spelling::MapPun => Code::B0046,
1114    }
1115}
1116
1117#[must_use]
1118pub fn form_diagnostics(text: &str) -> Vec<blue_lang_check::Diagnostic> {
1119    match blue_lang_fmt::format_source_lossless(text) {
1120        Ok(formatted) => form_diagnostics_against(text, &formatted),
1121        Err(_) => Vec::new(),
1122    }
1123}
1124
1125#[must_use]
1126pub fn form_diagnostics_against(text: &str, formatted: &str) -> Vec<blue_lang_check::Diagnostic> {
1127    use blue_lang_check::{Code, Diagnostic};
1128    if formatted.trim_end() == text.trim_end() {
1129        return Vec::new();
1130    }
1131    let help = "`blue fmt --write` writes it; `blue run`, `blue test` and `blue check` rewrite a writable file before compiling it";
1132    let mut out: Vec<Diagnostic> = blue_lang_syntax::spelling_notes(text)
1133        .unwrap_or_default()
1134        .into_iter()
1135        .map(|n| {
1136            let message = if n.canonical.is_empty() {
1137                format!("`{}` is not written", n.written)
1138            } else {
1139                format!("`{}` is written `{}`", n.written, n.canonical)
1140            };
1141            Diagnostic::new(spelling_code(n.spelling), message, n.span)
1142                .at_top_level(0)
1143                .with_help(help)
1144        })
1145        .collect();
1146    out.extend(
1147        literal_diagnostics(text)
1148            .into_iter()
1149            .map(|d| d.with_help(help)),
1150    );
1151    if out.is_empty() {
1152        let at = text
1153            .lines()
1154            .zip(formatted.lines())
1155            .position(|(a, b)| a != b)
1156            .unwrap_or_else(|| text.lines().count().min(formatted.lines().count()));
1157        let start: usize = text.lines().take(at).map(|l| l.len() + 1).sum();
1158        let start = start.min(text.len());
1159        let end = text[start..].find('\n').map_or(text.len(), |e| start + e);
1160        out.push(
1161            Diagnostic::new(
1162                Code::B0024,
1163                format!("line {} is not laid out as blue writes it", at + 1),
1164                tatara_lisp::Span::new(start, end),
1165            )
1166            .at_top_level(0)
1167            .with_help(help),
1168        );
1169    }
1170    out.sort_by_key(|d| (d.span.start, d.code));
1171    out
1172}
1173
1174fn literal_diagnostics(text: &str) -> Vec<blue_lang_check::Diagnostic> {
1175    use blue_lang_syntax::{Atom, TokenKind};
1176    let Ok(toks) = blue_lang_syntax::lex(text) else {
1177        return Vec::new();
1178    };
1179    toks.iter()
1180        .filter_map(|t| {
1181            let atom = match &t.kind {
1182                TokenKind::Int(v) => Atom::Int(*v),
1183                TokenKind::Float(v) => Atom::Float(*v),
1184                TokenKind::Str(v) => Atom::Str(v.clone()),
1185                _ => return None,
1186            };
1187            let written = text.get(t.span.start..t.span.end)?;
1188            let canonical = blue_lang_fmt::render_literal(&atom);
1189            (written != canonical).then(|| {
1190                blue_lang_check::Diagnostic::new(
1191                    blue_lang_check::Code::B0033,
1192                    format!("`{written}` is written `{canonical}`"),
1193                    t.span,
1194                )
1195                .at_top_level(0)
1196            })
1197        })
1198        .collect()
1199}
1200
1201/// A syntax error in `text` as a [`B0006`](blue_lang_check::Code::B0006)
1202/// diagnostic, so a tool reading `--format json` gets a parse failure in the
1203/// same shape as every other finding. `None` when `text` parses.
1204#[must_use]
1205pub fn syntax_diagnostic(text: &str) -> Option<blue_lang_check::Diagnostic> {
1206    let e = blue_lang_syntax::parse_program_tree(text).err()?;
1207    Some(
1208        blue_lang_check::Diagnostic::new(blue_lang_check::Code::B0006, e.message, e.span)
1209            .at_top_level(0),
1210    )
1211}
1212
1213/// A runtime message as the author wrote the names in it: a definition runs
1214/// under its key (`retsu/first`, `%root/f`), and a message naming one in
1215/// backticks names it `retsu::first`, or `f` for the author's own script.
1216#[must_use]
1217pub fn display_keys(message: &str) -> String {
1218    let mut out = String::with_capacity(message.len());
1219    let mut parts = message.split('`');
1220    if let Some(first) = parts.next() {
1221        out.push_str(first);
1222    }
1223    for (i, part) in parts.enumerate() {
1224        out.push('`');
1225        // Odd pieces (0-based here) are inside backticks.
1226        if i % 2 == 0 {
1227            out.push_str(&crate::observe::display_key(part));
1228        } else {
1229            out.push_str(part);
1230        }
1231    }
1232    out
1233}
1234
1235/// Evaluate a prepared program's top-level forms into `interp`, with `host`.
1236pub(crate) fn eval_prepared<H: 'static>(
1237    interp: &mut tatara_lisp_eval::Interpreter<H>,
1238    prepared: &Prepared,
1239    host: &mut H,
1240) -> Result<Value, RunError> {
1241    let Prepared {
1242        program, erased, ..
1243    } = prepared;
1244
1245    // RUN, one top-level form at a time, **counting them**.
1246    //
1247    // This is literally the loop `Interpreter::eval_program` runs internally
1248    // (tatara-lisp-eval `eval.rs`) — unrolled here for exactly one reason: the
1249    // INDEX. `resolve_uses` flattens N files into one form list and a `Span` is
1250    // a byte range with no file identity, so an offset alone is ambiguous
1251    // across files — 66 means something in every one of them. The index is the
1252    // join key back to `ResolvedProgram`'s file table, and `eval_program`
1253    // consumes it internally and hands back only the error.
1254    //
1255    // The same key, the same renderer and the same file table the type errors
1256    // above already use. A runtime error was the one diagnostic in this
1257    // function still reporting a bare message.
1258    let mut value = Value::Nil;
1259    for (top_level, form) in erased.iter().enumerate() {
1260        value = interp.eval_top_form(form, host).map_err(|e| {
1261            // The message, its position and the blue call stack, read off the
1262            // frames the error unwound through (`observe::Fault`). The message
1263            // is `short_message` rather than upstream's `Display`, whose
1264            // trailing ` at {span}` is a bare byte range with no file, through
1265            // `messages::describe`, which names the function a wrong argument
1266            // count was called on.
1267            RunError::Eval(Box::new(crate::observe::Fault::of(
1268                program,
1269                erased,
1270                top_level,
1271                &e,
1272                &interp.take_trace(),
1273            )))
1274        })?;
1275    }
1276    Ok(value)
1277}
1278
1279pub const MAIN: &str = "main";
1280
1281#[must_use]
1282pub fn entry_main(program: &crate::uses::ResolvedProgram) -> Option<(usize, tatara_lisp::Span)> {
1283    use crate::uses::ResolvedProgram;
1284    let stored = program
1285        .file(ResolvedProgram::ENTRY)
1286        .is_some_and(|f| f.path.is_some());
1287    if !stored {
1288        return None;
1289    }
1290    program.forms().iter().enumerate().find_map(|(i, f)| {
1291        if program.owner_of(i) != Some(ResolvedProgram::ENTRY) {
1292            return None;
1293        }
1294        let items = f.as_list()?;
1295        let sig = items.get(1)?.as_list()?;
1296        let named_main = matches!(
1297            items.first().and_then(tatara_lisp::Spanned::as_symbol),
1298            Some("define" | "define-typed")
1299        ) && sig.len() == 1
1300            && sig[0].as_symbol() == Some(MAIN);
1301        named_main.then_some((i, sig[0].span))
1302    })
1303}
1304
1305pub(crate) fn call_main<H: 'static>(
1306    interp: &mut tatara_lisp_eval::Interpreter<H>,
1307    prepared: &Prepared,
1308    host: &mut H,
1309) -> Result<Option<Value>, RunError> {
1310    let Some((top_level, span)) = entry_main(&prepared.program) else {
1311        return Ok(None);
1312    };
1313    let ns = namespace_of(&prepared.program, top_level);
1314    let call = tatara_lisp::Spanned::new(
1315        span,
1316        tatara_lisp::SpannedForm::List(vec![tatara_lisp::Spanned::new(
1317            span,
1318            tatara_lisp::SpannedForm::Atom(tatara_lisp::Atom::Symbol(blue_lang_check::names::key(
1319                &ns, MAIN,
1320            ))),
1321        )]),
1322    );
1323    interp.eval_top_form(&call, host).map(Some).map_err(|e| {
1324        RunError::Eval(Box::new(crate::observe::Fault::of(
1325            &prepared.program,
1326            &prepared.erased,
1327            top_level,
1328            &e,
1329            &interp.take_trace(),
1330        )))
1331    })
1332}
1333
1334/// **A runtime error names a place.** The gates for the last stage that
1335/// reported a bare message.
1336///
1337/// Each fixture is sized so that resolving the failing span against ANY file
1338/// but the right one lands somewhere else — a different path and a different
1339/// line — so a green run here is evidence about the join and not about the
1340/// renderer being called at all.
1341///
1342/// **Each raise is an unbound name, WAIVED.** Since the check stage resolves
1343/// names (B0001), an unbound call no longer reaches the evaluator; these
1344/// fixtures need exactly that runtime raise, so each carries
1345/// `# waive B0001: …` above the definition holding it — the one escape hatch,
1346/// used for what it is for. The waiver adds a line above each failing call,
1347/// which is why the positions below are one line later than their red runs
1348/// (recorded against the unwaived fixtures) show.
1349#[cfg(test)]
1350mod position_tests {
1351    use super::*;
1352    use crate::uses::{Entry, Loader};
1353    use std::collections::BTreeMap;
1354    use std::path::Path;
1355
1356    struct MemLoader(BTreeMap<&'static str, &'static str>);
1357
1358    impl Loader for MemLoader {
1359        fn load(&self, name: &str) -> Result<Vec<(String, String)>, String> {
1360            self.0
1361                .get(name)
1362                .map(|s| vec![(format!("{name}.b"), (*s).to_owned())])
1363                .ok_or_else(|| format!("no bidama named \"{name}\""))
1364        }
1365    }
1366
1367    /// A package whose OWN top-level code raises, deep inside a file that is
1368    /// deliberately taller than either of the other two.
1369    ///
1370    /// Byte 66 — where `kore_wa_sonzai_shinai` starts — is past the end of the
1371    /// entry file (30 bytes) and past the end of `kotae.b` (21 bytes). So the
1372    /// only file this span can honestly resolve against is this one, and the
1373    /// other two now refuse to answer rather than walking off their ends.
1374    const BAKUHATSU: &str = "\
1375def tsukawanai_a()
1376  1
1377end
1378
1379def tsukawanai_b()
1380  2
1381end
1382
1383# waive B0001: the fixture needs a raise at runtime
1384def bakuhatsu()
1385  kore_wa_sonzai_shinai()
1386end
1387
1388bakuhatsu";
1389
1390    const KOTAE: &str = "def kotae()\n  42\nend";
1391
1392    /// The same failing call, but only ever reached by a CALLER in another
1393    /// file — the shape the call stack resolved (the last position test).
1394    const BAKUHATSU2: &str =
1395        "# waive B0001: a raise at runtime\ndef yobu()\n  kore_wa_sonzai_shinai()\nend";
1396
1397    fn loader() -> MemLoader {
1398        MemLoader(BTreeMap::from([
1399            ("kotae", KOTAE),
1400            ("bakuhatsu", BAKUHATSU),
1401            ("bakuhatsu2", BAKUHATSU2),
1402        ]))
1403    }
1404
1405    fn run_named(path: &str, src: &str) -> RunError {
1406        run_in_surface(
1407            Entry {
1408                path: Some(Path::new(path)),
1409                text: src,
1410            },
1411            Inputs::new(),
1412            &loader(),
1413            None,
1414        )
1415        .expect_err("the fixture must raise")
1416    }
1417
1418    /// **The load-bearing gate: a raise inside an IMPORTED package reports the
1419    /// IMPORTED file's path and line.**
1420    ///
1421    /// Hand-computed. In `bakuhatsu.b` the failing call sits on line 11 at
1422    /// column 3, and the whole point of the fixture's height is that no other
1423    /// file in the program can produce that pair: the entry file has 2 lines
1424    /// and `kotae.b` has 3, so *any* mis-attribution is visible as a different
1425    /// path AND a different position, never as a coincidence.
1426    ///
1427    /// **Three red runs, one per edit this change makes** — each isolates a
1428    /// different half of the mechanism, which is what stops the gate being a
1429    /// tautology over "some renderer ran".
1430    ///
1431    /// 1. `eval_program` + `.map_err(|e| RunError::Eval(e.to_string()))`
1432    ///    restored (the pre-change code):
1433    ///    ```text
1434    ///    left:  "runtime error: unbound symbol: kore_wa_sonzai_shinai at 74..95"
1435    ///    right: "runtime error: bakuhatsu.b:10:3: unbound symbol `kore_wa_sonzai_shinai`"
1436    ///    ```
1437    ///    No place at all — the state this change is fixing — and the trailing
1438    ///    `at 74..95` is upstream's `Display`, an offset with no file, which is
1439    ///    why the loop renders `short_message` instead.
1440    ///
1441    /// 2. The loop kept, but `0` passed to `locate` in place of `top_level`:
1442    ///    ```text
1443    ///    left:  "runtime error: kotae.b: unbound symbol `kore_wa_sonzai_shinai`"
1444    ///    right: "runtime error: bakuhatsu.b:10:3: unbound symbol `kore_wa_sonzai_shinai`"
1445    ///    ```
1446    ///    **This is the one that proves the INDEX is load-bearing** rather than
1447    ///    the renderer: form 0 belongs to `kotae.b`, so the wrong file is named
1448    ///    — and named without a position, because the guard in `locate` sees
1449    ///    that byte 74 is not a range in a 21-byte file and declines to invent
1450    ///    one. A fixture with one imported package could not tell these apart.
1451    ///
1452    /// 3. `crate::lower_to_spanned(&crate::to_sexps(&erased))` reinstated
1453    ///    between erasure and the loop:
1454    ///    ```text
1455    ///    left:  "runtime error: bakuhatsu.b: unbound symbol `kore_wa_sonzai_shinai`"
1456    ///    right: "runtime error: bakuhatsu.b:10:3: unbound symbol `kore_wa_sonzai_shinai`"
1457    ///    ```
1458    ///    The right FILE with no position — which is exactly the shape of the
1459    ///    bug: the index survived the lift and every span did not.
1460    /// kotae loads first so bakuhatsu's forms do not start at index 0: the
1461    /// order is the fixture, and the waiver says so (B0015 wants them sorted).
1462    const TWO_IMPORTS: &str =
1463        "use(\"kotae\")\n# waive B0015: kotae loads first on purpose\nuse(\"bakuhatsu\")\n";
1464
1465    #[test]
1466    fn a_raise_inside_an_imported_package_names_that_package() {
1467        let err = run_named("entry.b", TWO_IMPORTS);
1468        assert_eq!(
1469            err.to_string(),
1470            "runtime error: bakuhatsu.b:11:3: unbound symbol `kore_wa_sonzai_shinai`\n  \
1471             at bakuhatsu::bakuhatsu (bakuhatsu.b:11:3)\n  \
1472             at <top level> (bakuhatsu.b:14:1)"
1473        );
1474    }
1475
1476    /// Anti-vacuity for the fixture itself: the position asserted above is a
1477    /// FACT ABOUT `bakuhatsu.b`, checked against the source text rather than
1478    /// against the thing that produced it.
1479    ///
1480    /// Without this, `11:3` is just a number that happened to come out of the
1481    /// code under test, and a change that moved every reported line by one
1482    /// would move this assertion with it.
1483    #[test]
1484    fn line_11_column_3_of_the_fixture_is_the_failing_call() {
1485        let line = BAKUHATSU.lines().nth(10).expect("line 11 exists");
1486        assert_eq!(line, "  kore_wa_sonzai_shinai()");
1487        assert_eq!(
1488            &line[2..],
1489            "kore_wa_sonzai_shinai()",
1490            "column 3 (1-indexed) is where the call starts"
1491        );
1492        // And the other two files cannot reach that far, which is what makes a
1493        // mis-attribution loud instead of plausible.
1494        let offset = BAKUHATSU.find("kore_wa_sonzai_shinai").expect("in fixture");
1495        assert!(
1496            offset > KOTAE.len(),
1497            "kotae.b could answer for byte {offset}"
1498        );
1499        assert!(
1500            offset > TWO_IMPORTS.len(),
1501            "the entry file could answer for byte {offset}"
1502        );
1503    }
1504
1505    /// **The `FileId(0)` path: a raise in the ENTRY file reports the entry
1506    /// file.** The single-file case, which is every program that imports
1507    /// nothing — and the one where the index and the span cannot disagree.
1508    ///
1509    /// **Red run** (2026-08-12), `eval_program` +
1510    /// `.map_err(|e| RunError::Eval(e.to_string()))` restored:
1511    /// ```text
1512    /// left:  "runtime error: unbound symbol: nani_mo_nai at 17..28"
1513    /// right: "runtime error: honmono.b:5:1: unbound symbol `nani_mo_nai`"
1514    /// ```
1515    ///
1516    /// **Second red run**, `lower_to_spanned` reinstated after erasure — the
1517    /// one that isolates the SPAN half from the index half, since a
1518    /// single-file program cannot get its file wrong:
1519    /// ```text
1520    /// left:  "runtime error: honmono.b: unbound symbol `nani_mo_nai`"
1521    /// right: "runtime error: honmono.b:5:1: unbound symbol `nani_mo_nai`"
1522    /// ```
1523    #[test]
1524    fn a_raise_in_the_entry_file_names_the_entry_file() {
1525        let err = run_named(
1526            "honmono.b",
1527            "def f()\n  1\nend\n\n# waive B0001: a raise at runtime\nnani_mo_nai()\n",
1528        );
1529        assert_eq!(
1530            err.to_string(),
1531            "runtime error: honmono.b:6:1: unbound symbol `nani_mo_nai`"
1532        );
1533    }
1534
1535    /// A raise from a form that came through the SURFACE-level erasure still
1536    /// reports a real position — the annotated path, where erasure rewrites
1537    /// the node rather than passing it through.
1538    ///
1539    /// Separate from the two above because the erasure rewrite is the only
1540    /// place a node is built rather than kept, and a synthetic span there
1541    /// would be invisible to a fixture whose failing form is untouched.
1542    ///
1543    /// **Red run** (2026-08-12), `lower_to_spanned` reinstated after erasure:
1544    /// ```text
1545    /// left:  "runtime error: chuu.b: unbound symbol `mada_nai`"
1546    /// right: "runtime error: chuu.b:2:3: unbound symbol `mada_nai`"
1547    /// ```
1548    #[test]
1549    fn a_raise_inside_an_annotated_def_still_names_its_line() {
1550        let err = run_named(
1551            "chuu.b",
1552            "# waive B0001: a raise at runtime\ndef f(a: Int) -> Int\n  mada_nai(a)\nend\n\nf(1)\n",
1553        );
1554        assert_eq!(
1555            err.to_string(),
1556            "runtime error: chuu.b:3:3: unbound symbol `mada_nai`\n  \
1557             at f (chuu.b:3:3)\n  \
1558             at <top level> (chuu.b:6:1)"
1559        );
1560    }
1561
1562    /// **The limit this module used to state, closed by the call stack.**
1563    ///
1564    /// A top-level form in the entry file calls a function defined in an
1565    /// imported one, and the raise happens inside the callee. The executing
1566    /// form is the entry's and the span is the callee's bytes, so until the
1567    /// evaluator reported the frames an error unwound through, the best blue
1568    /// could do was name the caller's file with no position (the guard in
1569    /// `uses::ResolvedProgram::locate` refusing an offset it could not
1570    /// justify). The innermost frame's definition now names the file the
1571    /// offsets belong to, and the stack shows the call that led there.
1572    ///
1573    /// **Red run** (2026-10-10): `Fault::of` locating against the executing
1574    /// top-level form instead of the innermost frame's definition:
1575    /// ```text
1576    /// left:  "runtime error: yobidashi.b: unbound symbol `kore_wa_sonzai_shinai`\n  at bakuhatsu2::yobu (bakuhatsu2.b:3:3)\n  at <top level> (yobidashi.b:3:1)"
1577    /// ```
1578    /// The old answer, kept by the guard: the caller's file and no position.
1579    #[test]
1580    fn a_raise_in_a_callee_from_another_file_names_the_callees_file() {
1581        // The comment is padding, and load-bearing: `bakuhatsu2.b`'s failing
1582        // call starts at byte 47 (after its waiver line) and ends at 70, and
1583        // this file is 57 bytes, so the start is in range here and the end is
1584        // not — a mis-attribution would still be refused rather than placed.
1585        let err = run_named(
1586            "yobidashi.b",
1587            "use(\"bakuhatsu2\")\n# pad: 47's in range\nbakuhatsu2::yobu\n",
1588        );
1589        assert_eq!(
1590            err.to_string(),
1591            "runtime error: bakuhatsu2.b:3:3: unbound symbol `kore_wa_sonzai_shinai`\n  \
1592             at bakuhatsu2::yobu (bakuhatsu2.b:3:3)\n  \
1593             at <top level> (yobidashi.b:3:1)"
1594        );
1595    }
1596}
1597
1598#[cfg(test)]
1599mod tests {
1600    use super::*;
1601
1602    fn int(src: &str) -> i64 {
1603        match run(src).unwrap_or_else(|e| panic!("{src:?}: {e}")).value {
1604            Value::Int(v) => v,
1605            other => panic!("{src:?} produced {other:?}"),
1606        }
1607    }
1608
1609    /// **The sliding scale, as one assertion.** Annotating changes the
1610    /// analysis and nothing else.
1611    #[test]
1612    fn annotating_buys_analysis_and_changes_nothing_else() {
1613        let plain = run("def add(a, b)\n  a + b\nend\nadd(2, 3)").expect("plain");
1614        let typed = run("def add(a: Int, b: Int) -> Int\n  a + b\nend\nadd(2, 3)").expect("typed");
1615
1616        assert!(matches!(plain.value, Value::Int(5)));
1617        assert!(
1618            matches!(typed.value, Value::Int(5)),
1619            "the annotated program must compute the same answer"
1620        );
1621        assert_eq!(plain.visited, 0, "no annotations means no analysis");
1622        assert!(
1623            typed.visited > 0,
1624            "an annotation must actually buy analysis, not just decorate"
1625        );
1626        assert_eq!(plain.typed_decls, 0);
1627        assert_eq!(typed.typed_decls, 1);
1628    }
1629
1630    /// **Checking happens before erasure.** This is the test that catches the
1631    /// reordering: a program with a declared-type violation must be rejected,
1632    /// and it can only be rejected while the annotations still exist.
1633    #[test]
1634    fn a_type_error_is_reported_and_the_program_does_not_run() {
1635        let err = run("def add(a: Int, b: Int) -> Str\n  a + b\nend\nadd(1, 2)")
1636            .expect_err("a declared Str return from an Int body must be rejected");
1637        assert!(
1638            matches!(err, RunError::Types(ref d) if !d.is_empty()),
1639            "expected type diagnostics, got {err}"
1640        );
1641    }
1642
1643    /// And the untyped version of the same program runs, so the rejection
1644    /// above is the annotation's doing rather than a parse failure.
1645    #[test]
1646    fn the_same_program_without_annotations_runs() {
1647        assert_eq!(int("def add(a, b)\n  a + b\nend\nadd(1, 2)"), 3);
1648    }
1649
1650    #[test]
1651    fn a_parse_error_is_reported_as_one() {
1652        assert!(matches!(run("def (").unwrap_err(), RunError::Parse(_)));
1653    }
1654
1655    /// Every stage reports in its own vocabulary, so a failure names which
1656    /// stage failed rather than surfacing as a generic error.
1657    #[test]
1658    fn a_runtime_error_is_reported_as_one() {
1659        let err = run("throw(error(\"boom\"))").expect_err("a raise");
1660        assert!(matches!(err, RunError::Eval(_)), "got {err}");
1661    }
1662
1663    /// Stdlib and primitives are both reachable through the pipeline — the
1664    /// gap that made `6 % 3` fail.
1665    #[test]
1666    fn the_pipeline_reaches_both_runtime_layers() {
1667        assert_eq!(int("6 % 3"), 0);
1668        assert_eq!(int("7 % 3"), 1);
1669        assert_eq!(int("2 + 3 * 4"), 14);
1670    }
1671
1672    /// **The deleted hop was a no-op on everything blue emits — so removing it
1673    /// is a swap, not a behaviour change.**
1674    ///
1675    /// The old lowering printed the erased tree and read it back through
1676    /// `tatara_lisp::read_spanned`. This walks a corpus and asserts the two
1677    /// paths land on the same tree, which is the equivalence the swap rests on.
1678    /// It is stated as a *measurement over this corpus*, not as a theorem:
1679    /// the round trip is not identity in general (that is precisely why it had
1680    /// to go), it merely happened to be identity for the bytes blue emits.
1681    #[test]
1682    fn the_deleted_round_trip_agreed_with_the_direct_lowering() {
1683        let corpus = [
1684            "def add(a, b)\n  a + b\nend\nadd(2, 3)",
1685            "def fact(n)\n  if n < 2\n    1\n  else\n    n * fact(n - 1)\n  end\nend\nfact(5)",
1686            "def f(a, b)\n  c = a + b\n  c * 2\nend\nf(1, 2)",
1687            "defmacro sq(e)\n  quote\n    unquote(e) * unquote(e)\n  end\nend\nsq(2 + 3)",
1688            "\"a string with spaces, a ( and a )\"",
1689            "def g(a: Int) -> Int\n  a + 1\nend\ng(1)",
1690            "6 % 3",
1691            "1.5 + 2.25",
1692        ];
1693        for src in corpus {
1694            // Projected to `Sexp` because that is what the deleted hop
1695            // operated on. Erasure itself no longer goes near it.
1696            let erased = crate::to_sexps(&erase_types(&parse_tree(src).expect("parse")));
1697
1698            let direct: Vec<Sexp> = crate::lower_to_spanned(&erased)
1699                .iter()
1700                .map(tatara_lisp::Spanned::to_sexp)
1701                .collect();
1702            assert_eq!(direct, erased, "the direct lowering must be the identity");
1703
1704            let text = erased
1705                .iter()
1706                .map(ToString::to_string)
1707                .collect::<Vec<_>>()
1708                .join("\n");
1709            let round_tripped: Vec<Sexp> = tatara_lisp::read_spanned(&text)
1710                .unwrap_or_else(|e| panic!("{src:?}: the old path could not read back: {e:?}"))
1711                .iter()
1712                .map(tatara_lisp::Spanned::to_sexp)
1713                .collect();
1714            assert_eq!(
1715                round_tripped, erased,
1716                "{src:?}: the old print-and-reparse path changed the tree"
1717            );
1718        }
1719    }
1720
1721    /// Anti-vacuity for the test above: the round trip really is *not* the
1722    /// identity in general, so agreeing on the corpus was a property of what
1723    /// blue happens to emit rather than a property of the reader.
1724    ///
1725    /// **`Atom::Symbol`'s `Display` writes the name raw, with no escaping.**
1726    /// `Atom::Str` escapes and its docs explain at length why; the symbol arm
1727    /// is `f.write_str(s)`. So print-then-read is not inverse over the symbol
1728    /// domain, and the failure is *silent*: a symbol containing a space prints
1729    /// as two tokens, reads back as two symbols, and the result is a perfectly
1730    /// well-formed tree with a different meaning. No error, nothing to catch.
1731    ///
1732    /// Measured 2026-08-02 across the separators: `a b` and `x'y` come back
1733    /// `Ok` with a different tree; `x)y`, `x"y` and `x;y` come back `Err`;
1734    /// `x{y` and `x[y` DO round-trip at this level — those two are one symbol
1735    /// in and one symbol out, so the brace-fusion reported in tatara *source*
1736    /// is not what bites a printed tree. The silent pair is what makes this a
1737    /// miscompile class rather than a noisy one.
1738    #[test]
1739    fn the_round_trip_is_not_the_identity_in_general() {
1740        let tree = Sexp::List(vec![
1741            Sexp::Atom(tatara_lisp::Atom::Symbol("f".into())),
1742            Sexp::Atom(tatara_lisp::Atom::Symbol("a b".into())),
1743        ]);
1744        let text = tree.to_string();
1745        let back: Vec<Sexp> = tatara_lisp::read_spanned(&text)
1746            .expect("it reads back cleanly — that IS the problem")
1747            .iter()
1748            .map(tatara_lisp::Spanned::to_sexp)
1749            .collect();
1750        assert_ne!(
1751            back,
1752            vec![tree.clone()],
1753            "if print-then-read became inverse over symbols, the class would be \
1754             closed upstream and this test should be deleted rather than relaxed"
1755        );
1756        // …and the direct lowering is unaffected by any of it.
1757        let direct: Vec<Sexp> = crate::lower_to_spanned(std::slice::from_ref(&tree))
1758            .iter()
1759            .map(tatara_lisp::Spanned::to_sexp)
1760            .collect();
1761        assert_eq!(direct, vec![tree]);
1762    }
1763}
1764
1765#[cfg(test)]
1766mod macro_tests {
1767    use super::*;
1768
1769    fn int(src: &str) -> i64 {
1770        match run(src).unwrap_or_else(|e| panic!("{src:?}: {e}")).value {
1771            Value::Int(v) => v,
1772            other => panic!("{src:?} produced {other:?}"),
1773        }
1774    }
1775
1776    /// **A blue macro expands and runs.** Tenet 2's surface, end to end.
1777    #[test]
1778    fn a_macro_expands_and_runs() {
1779        assert_eq!(
1780            int("defmacro double(x)\n  quote\n    unquote(x) + unquote(x)\n  end\nend\ndouble(21)"),
1781            42
1782        );
1783    }
1784
1785    /// A macro receives *source forms*, not values — so it can duplicate its
1786    /// argument, which a function cannot do without re-evaluating it.
1787    #[test]
1788    fn a_macro_operates_on_syntax_not_values() {
1789        assert_eq!(
1790            int("defmacro sq(e)\n  quote\n    unquote(e) * unquote(e)\n  end\nend\nsq(2 + 3)"),
1791            25,
1792            "the argument form `2 + 3` must be substituted twice"
1793        );
1794    }
1795
1796    /// **A runaway macro is a typed error, not a dead compiler.** This is the
1797    /// property that makes the metaprogramming surface safe to hand to a user.
1798    ///
1799    /// The assertion was `contains("expansion limit")` and now reads
1800    /// `contains("expansion")`, because the pipeline renders `short_message`
1801    /// rather than `Display`: upstream words the same fact as "exceeded 256
1802    /// expansion steps" instead of "exceeded the expansion limit of 256
1803    /// rewrites". The PROPERTY is unchanged and still asserted — the macro is
1804    /// named, and the failure is attributed to expansion rather than to
1805    /// evaluation. **This reword was the whole measured blast radius of that
1806    /// switch**, one test in the workspace.
1807    ///
1808    /// The number is deliberately NOT pinned. It is upstream's constant, this
1809    /// test owns none of it, and matching it would turn an upstream bump into
1810    /// a red run here that proves nothing about blue.
1811    ///
1812    /// The third clause is new capability rather than repair: the message now
1813    /// carries `<anonymous>:6:1`, so a runaway macro says WHERE it ran away.
1814    #[test]
1815    fn a_runaway_macro_fails_the_compilation_rather_than_the_process() {
1816        let err =
1817            run("defmacro forever(x)\n  quote\n    forever(unquote(x))\n  end\nend\nforever(1)")
1818                .expect_err("a self-referential macro must be rejected");
1819        let msg = err.to_string();
1820        assert!(
1821            msg.contains("forever") && msg.contains("expansion"),
1822            "the error must name the macro and the limit it hit: {msg}"
1823        );
1824        assert!(
1825            msg.contains("<anonymous>:6:1"),
1826            "and must place the call that ran away — line 6 is `forever(1)`: {msg}"
1827        );
1828    }
1829}
1830
1831#[cfg(test)]
1832mod input_tests {
1833    use super::*;
1834    use crate::inputs::{Declaration, Inputs};
1835
1836    /// A schema a macro will generate code from.
1837    const SCHEMA: &[u8] = b"3";
1838
1839    fn with_schema(src: &str) -> Result<Run, RunError> {
1840        let hash = Inputs::hash_of(SCHEMA);
1841        let mut inputs = Inputs::new();
1842        inputs
1843            .bind(
1844                &Declaration {
1845                    name: "schema".to_string(),
1846                    hash,
1847                },
1848                SCHEMA.to_vec(),
1849            )
1850            .expect("bind");
1851        run_with_inputs(src, inputs)
1852    }
1853
1854    fn decl_line() -> String {
1855        let mut s = String::from("definput(\"schema\", \"");
1856        s.push_str(&Inputs::hash_of(SCHEMA));
1857        s.push_str("\")\n");
1858        s
1859    }
1860
1861    /// **A macro reads a declared build input.** This is §VI OPEN #6 closed —
1862    /// the spec names it as gating blue's whole "stronger than Ruby's
1863    /// metaprogramming" claim, because a macro that cannot read a schema cannot
1864    /// generate code from one.
1865    #[test]
1866    fn a_macro_can_read_a_declared_build_input() {
1867        let src = decl_line() + "input(\"schema\")";
1868        let out = with_schema(&src).expect("run");
1869        assert!(
1870            matches!(out.value, Value::Str(ref s) if &**s == "3"),
1871            "got {:?}",
1872            out.value
1873        );
1874    }
1875
1876    /// **An undeclared input is an error, not a file read and not nil.**
1877    /// Returning nil is how a macro generates an empty table and nobody notices
1878    /// until runtime.
1879    #[test]
1880    fn an_undeclared_input_is_an_error() {
1881        let err = with_schema("input(\"not_declared\")").expect_err("must fail");
1882        let msg = err.to_string();
1883        assert!(msg.contains("not_declared"), "must name it: {msg}");
1884        assert!(msg.contains("definput"), "and say how to declare it: {msg}");
1885    }
1886
1887    /// **There is no path-based read at all.** The capability is the absence of
1888    /// the primitive, not a check inside one — so this is an unbound symbol.
1889    ///
1890    /// Holds for the DEFAULT surface — the one every embedder gets. The `sys`
1891    /// cargo feature (CLI only) is the one declared exception: it is the
1892    /// operator's own trusted host surface, and is asserted in
1893    /// `sys_read_file_is_the_trusted_cli_only_exception` below.
1894    #[cfg(not(feature = "sys"))]
1895    #[test]
1896    fn there_is_no_ambient_file_read() {
1897        for attempt in [
1898            "read_file(\"/etc/passwd\")",
1899            "File(\"/etc/passwd\")",
1900            "slurp(\"/etc/passwd\")",
1901            "open(\"/etc/passwd\")",
1902        ] {
1903            let err = with_schema(attempt).expect_err("must not resolve");
1904            assert!(
1905                err.to_string().contains("unbound"),
1906                "{attempt} must be UNBOUND — a capability removed by absence, \
1907                 not guarded by a check: {err}"
1908            );
1909        }
1910    }
1911
1912    /// With the `sys` feature compiled in, `read_file` IS bound — that is the
1913    /// point of the feature. The doctrine does not move: this is the operator's
1914    /// own machine (the CLI), not an embedder's sandbox. Pin the boundary so a
1915    /// future default-build change is heard, and assert that `input()` still
1916    /// works beside it.
1917    #[cfg(feature = "sys")]
1918    #[test]
1919    fn sys_read_file_is_the_trusted_cli_only_exception() {
1920        let err = with_schema("definitely_not_a_primitive(\"x\")").expect_err("must not resolve");
1921        assert!(err.to_string().contains("unbound"), "{err}");
1922        assert!(
1923            with_schema("read_file(\"/etc/passwd\")").is_ok(),
1924            "with `sys` on, read_file is the trusted CLI surface"
1925        );
1926        let out = with_schema("input(\"schema\")").expect("run");
1927        assert!(
1928            matches!(out.value, Value::Str(ref s) if &**s == "3"),
1929            "input() still binds beside the sys surface: {:?}",
1930            out.value
1931        );
1932    }
1933
1934    /// Anti-vacuity: with no inputs supplied at all, even a declared name fails
1935    /// — so the success above is the binding's doing.
1936    #[test]
1937    fn a_declared_input_with_no_bytes_supplied_fails() {
1938        let src = decl_line() + "input(\"schema\")";
1939        assert!(run(&src).is_err(), "no bytes were supplied");
1940    }
1941}
1942
1943#[cfg(test)]
1944mod tier2_tests {
1945    use super::*;
1946    use crate::inputs::{Declaration, Inputs};
1947
1948    /// **The Tier-2 conversion §V.6.3 said was gated: a macro that emits real
1949    /// declarations FROM A SCHEMA.**
1950    ///
1951    /// `theory/BLUE.md` §VI OPEN #6 states the blocker plainly — "tenet 2
1952    /// installs a `NoLoader`, so a macro cannot read a schema — which gates
1953    /// every Tier-2 conversion in §V.6 and therefore blue's whole 'stronger than
1954    /// Ruby's metaprogramming' claim."
1955    ///
1956    /// Here the schema supplies a *value the generated code depends on*, read at
1957    /// expansion time. Ruby and Elixir can both do this — with the whole
1958    /// filesystem open. blue does it through a name bound to a content hash.
1959    #[test]
1960    fn a_macro_generates_code_from_a_schema() {
1961        let schema = b"7";
1962        let mut inputs = Inputs::new();
1963        inputs
1964            .bind(
1965                &Declaration {
1966                    name: "arity".to_string(),
1967                    hash: Inputs::hash_of(schema),
1968                },
1969                schema.to_vec(),
1970            )
1971            .expect("bind");
1972
1973        // The macro reads the input at EXPANSION time and splices the value it
1974        // found into the code it emits.
1975        let mut src = String::from("definput(\"arity\", \"");
1976        src.push_str(&Inputs::hash_of(schema));
1977        src.push_str("\")\n");
1978        src.push_str(
1979            "defmacro from_schema()\n  quote\n    unquote(to_int(input(\"arity\")))\n  end\nend\n\
1980             from_schema() * 6",
1981        );
1982
1983        let out = run_with_inputs(&src, inputs).expect("run");
1984        assert!(
1985            matches!(out.value, Value::Int(42)),
1986            "the schema's 7 must reach the generated code: got {:?}",
1987            out.value
1988        );
1989    }
1990}