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    let resolved = blue_lang_check::names::resolve_program(program.forms(), names, &|i| {
654        namespace_of(program, i)
655    });
656    resolved
657        .resolved_tree(program.forms(), blue_lang_check::names::Rule::Namespaced)
658        .into_iter()
659        .zip(program.forms())
660        .enumerate()
661        .map(|(i, (resolved, written))| {
662            if crate::uses::use_target(written).is_some()
663                || blue_lang_syntax::scope::legacy_target(written).is_some()
664            {
665                tatara_lisp::Spanned::new(written.span, tatara_lisp::SpannedForm::Nil)
666            } else {
667                let file = program.owner_of(i).and_then(|id| program.file(id));
668                match file {
669                    Some(f) => locate_raises(&resolved, &raise_site(f)),
670                    None => resolved,
671                }
672            }
673        })
674        .collect()
675}
676
677fn raise_site(file: &crate::uses::SourceFile) -> impl Fn(tatara_lisp::Span) -> String + '_ {
678    move |span| {
679        let (line, _) = blue_lang_syntax::Span::line_col(&file.text, span.start.min(file.text.len()));
680        let shown = file
681            .path
682            .as_ref()
683            .map_or_else(|| "<source>".to_string(), |p| p.display().to_string());
684        format!("{shown}:{line}")
685    }
686}
687
688fn locate_raises(
689    form: &tatara_lisp::Spanned,
690    site: &dyn Fn(tatara_lisp::Span) -> String,
691) -> tatara_lisp::Spanned {
692    use tatara_lisp::{Atom, Spanned, SpannedForm};
693    let inner = match &form.form {
694        SpannedForm::List(items) => {
695            let mut out: Vec<Spanned> = items.iter().map(|i| locate_raises(i, site)).collect();
696            let raising = items.first().and_then(Spanned::as_symbol) == Some("raise")
697                && (3..=4).contains(&items.len());
698            if raising {
699                out[0] = Spanned::new(
700                    items[0].span,
701                    SpannedForm::Atom(Atom::Symbol(crate::errors::RAISE_AT.to_string())),
702                );
703                out.insert(
704                    1,
705                    Spanned::new(items[0].span, SpannedForm::Atom(Atom::Str(site(form.span)))),
706                );
707            }
708            SpannedForm::List(out)
709        }
710        SpannedForm::Quote(_) | SpannedForm::Quasiquote(_) => return form.clone(),
711        other => other.clone(),
712    };
713    Spanned::new(form.span, inner)
714}
715
716/// The namespace top-level form `i` of `program` defines into.
717#[must_use]
718pub fn namespace_of(program: &crate::uses::ResolvedProgram, i: usize) -> Namespace {
719    let file = program.owner_of(i).and_then(|id| program.file(id));
720    match file {
721        Some(f) => match &f.package {
722            Some(p) => Namespace::Bidama(p.clone()),
723            None => Namespace::File(
724                f.path
725                    .as_ref()
726                    .map_or_else(|| "<anonymous>".to_string(), |p| p.display().to_string()),
727            ),
728        },
729        None => Namespace::File("<unknown file>".to_string()),
730    }
731}
732
733/// Names only the test harness binds.
734///
735/// In scope for EVERY check, not only for test blocks. A bidama may carry a
736/// test helper — a plain `def` that asserts, called only from its `test`
737/// blocks (`heni`'s `hn_end_to_end` is one) — and every program importing that
738/// bidama would otherwise be refused for a function it never calls. The
739/// refusal would be scoped to the importer's whole program, not to the fault.
740/// The cost, stated: an `assert` outside any test that `blue run` actually
741/// reaches is caught at runtime (`blue-assert` is unbound there), not here.
742///
743/// `blue-lang-test` registers these on its own interpreter, and this crate
744/// cannot depend on it (it depends on this one), so the list lives beside the
745/// only name in it: the lowered `assert`, which `blue-lang-syntax` owns.
746pub const HARNESS_NAMES: &[&str] = &[blue_lang_syntax::LOWERED_ASSERT];
747
748/// The check stage's builtin scopes, read off the interpreter that will run
749/// the program: the test harness's names ([`HARNESS_NAMES`]), then its special
750/// forms, its macros, and every value it binds — the last three in the order
751/// the evaluator consults for a head.
752///
753/// Read from a live interpreter rather than a list, for the reason
754/// `Interpreter::resolve_head` gives: a list is a second copy of the truth and
755/// goes stale on the next installer that lands. An embedder's own
756/// primitives are in scope here because the embedder installs them first.
757#[must_use]
758pub fn builtin_names<H: 'static>(interp: &tatara_lisp_eval::Interpreter<H>) -> NameTable {
759    use blue_lang_check::{Binding, Scope, ScopeKind};
760    use tatara_lisp_eval::HeadBinding;
761    let mut special = Scope::new(Namespace::SpecialForm);
762    let mut macros = Scope::new(Namespace::Macro);
763    let mut values = Scope::new(Namespace::Builtin);
764    // `reserved_head_names` reads the ROOT frame only, so a name installed on
765    // a fork (the input primitives, on every `run`) is invisible to it; those
766    // are asked about by name instead, which `resolve_head` answers through
767    // every frame.
768    let mut names: Vec<std::sync::Arc<str>> = interp.reserved_head_names().into_iter().collect();
769    names.extend(
770        crate::inputs::INPUT_PRIMITIVES
771            .iter()
772            .filter(|n| interp.resolve_head(n).is_some())
773            .map(|n| std::sync::Arc::from(*n)),
774    );
775    for name in names {
776        let (scope, kind) = match interp.resolve_head(&name) {
777            Some(HeadBinding::SpecialForm) => (&mut special, ScopeKind::SpecialForm),
778            Some(HeadBinding::Macro) => (&mut macros, ScopeKind::Macro),
779            _ => (&mut values, ScopeKind::Value),
780        };
781        let nullary = kind == ScopeKind::Value
782            && interp.lookup_global(&name).is_some_and(|v| {
783                nullary_value(&v)
784                    || (crate::docs::doc_of(&name).is_some_and(|d| d.signature == &*name)
785                        && matches!(
786                            v,
787                            tatara_lisp_eval::Value::NativeFn(_)
788                                | tatara_lisp_eval::Value::Closure(_)
789                        ))
790            });
791        scope.bind(Binding {
792            name: name.to_string(),
793            kind,
794            span: None,
795            top_level: None,
796            nullary,
797        });
798    }
799    let mut table = NameTable::new();
800    let mut harness = Scope::new(Namespace::Harness);
801    for n in HARNESS_NAMES {
802        harness.bind(Binding {
803            name: (*n).to_string(),
804            kind: ScopeKind::Value,
805            span: None,
806            top_level: None,
807            nullary: false,
808        });
809    }
810    table.push(harness);
811    table.push(special);
812    table.push(macros);
813    table.push(values);
814    table.spell_bare_only(
815        crate::docs::NAMES
816            .iter()
817            .filter(|d| d.signature == d.name)
818            .map(|d| d.name.to_string())
819            .collect(),
820    );
821    table
822}
823
824#[must_use]
825pub fn nullary_value(value: &tatara_lisp_eval::Value) -> bool {
826    match value {
827        tatara_lisp_eval::Value::NativeFn(f) => {
828            matches!(f.arity, tatara_lisp_eval::ffi::Arity::Exact(0))
829        }
830        tatara_lisp_eval::Value::Closure(c) => c.params.is_empty() && c.rest.is_none(),
831        _ => false,
832    }
833}
834
835/// A diagnostic as a person reads it: `file:line:col: error[B0001]: message`,
836/// then an indented `help:` line when it has one.
837#[must_use]
838pub fn render(program: &crate::uses::ResolvedProgram, d: &blue_lang_check::Diagnostic) -> String {
839    let head = d.to_string();
840    let mut out = program.locate(d.top_level, d.span, &head).to_string();
841    if let Some(help) = &d.help {
842        out.push_str("\n  help: ");
843        out.push_str(help);
844    }
845    out
846}
847
848/// What [`check_entry`] checks.
849#[derive(Clone, Copy, Debug, PartialEq, Eq)]
850pub enum Checking {
851    /// The program `blue run` would evaluate: test blocks dropped.
852    Program,
853    /// The program plus the entry file's test blocks, as `blue test` and
854    /// `blue check` see it.
855    WithTests,
856}
857
858/// A program through the check stage, with everything the stage found.
859pub struct Checked {
860    pub program: crate::uses::ResolvedProgram,
861    pub outcome: blue_lang_check::Outcome,
862    /// The name table the stage resolved against: every program scope, then
863    /// the builtins. What an editor completes from.
864    pub names: NameTable,
865}
866
867impl Checked {
868    /// The forms an evaluator runs: [`lower`]ed, then erased — the tree
869    /// `run` evaluates, for a door that brings its own evaluator (the VM).
870    #[must_use]
871    pub fn erased(&self) -> Vec<tatara_lisp::Spanned> {
872        erase_types(&lower(&self.program, &self.names))
873    }
874
875    /// What `blue test` hands the harness: the program [`lower`]ed, spans
876    /// projected away.
877    #[must_use]
878    pub fn evaluable(&self) -> Vec<tatara_lisp::Sexp> {
879        lower(&self.program, &self.names)
880            .iter()
881            .map(tatara_lisp::Spanned::to_sexp)
882            .collect()
883    }
884
885    /// Every non-local reference, resolved under both rules — today's flat
886    /// one and per-bidama namespaces — and the resolved trees built from them
887    /// (`blue ast --resolved`).
888    #[must_use]
889    pub fn resolve(&self) -> blue_lang_check::names::Resolved {
890        blue_lang_check::names::resolve_program(self.program.forms(), &self.names, &|i| {
891            namespace_of(&self.program, i)
892        })
893    }
894}
895
896impl Checked {
897    #[must_use]
898    pub fn call_explicit_forms(&self) -> Vec<tatara_lisp::Spanned> {
899        self.resolve().call_explicit_tree(self.program.forms())
900    }
901
902    #[must_use]
903    pub fn canonical_entry(&self, src: &str) -> Option<Vec<tatara_lisp::Spanned>> {
904        use crate::uses::ResolvedProgram;
905        let program = &self.program;
906        let entry: Vec<&tatara_lisp::Spanned> = program
907            .forms()
908            .iter()
909            .enumerate()
910            .filter(|(i, _)| program.owner_of(*i) == Some(ResolvedProgram::ENTRY))
911            .map(|(_, f)| f)
912            .collect();
913        let written = blue_lang_syntax::parse_program_tree(src).ok()?;
914        let same = written.len() == entry.len()
915            && written
916                .iter()
917                .zip(&entry)
918                .all(|(w, e)| w.to_sexp() == e.to_sexp() && w.span == e.span);
919        if !same {
920            return None;
921        }
922        let resolved = self.resolve();
923        let bare: std::collections::HashSet<usize> = resolved
924            .parenthesized_nullary_calls()
925            .into_iter()
926            .filter(|r| program.owner_of(r.top_level) == Some(ResolvedProgram::ENTRY))
927            .map(blue_lang_check::names::Reference::node_address)
928            .collect();
929        let waived: Vec<tatara_lisp::Span> = self
930            .outcome
931            .waived
932            .iter()
933            .map(|w| w.diagnostic.span)
934            .collect();
935        let respell: std::collections::HashMap<usize, blue_lang_check::respell::Respelling> =
936            resolved
937                .respellings
938                .iter()
939                .filter(|(_, r)| !waived.contains(&r.span))
940                .cloned()
941                .collect();
942        let canon = Canon { bare: &bare, respell: &respell };
943        let forms: Vec<tatara_lisp::Spanned> = entry.into_iter().map(|f| canon.form(f)).collect();
944        let script = program
945            .file(ResolvedProgram::ENTRY)
946            .is_some_and(|f| f.package.is_none());
947        let forms = if script {
948            blue_lang_check::form_rules::without_prefix(&forms).unwrap_or(forms)
949        } else {
950            forms
951        };
952        Some(blue_lang_check::form_rules::without_main_guard(&forms).unwrap_or(forms))
953    }
954}
955
956struct Canon<'a> {
957    bare: &'a std::collections::HashSet<usize>,
958    respell: &'a std::collections::HashMap<usize, blue_lang_check::respell::Respelling>,
959}
960
961impl Canon<'_> {
962    fn form(&self, form: &tatara_lisp::Spanned) -> tatara_lisp::Spanned {
963        use tatara_lisp::{Spanned, SpannedForm};
964        let inner = match &form.form {
965            SpannedForm::List(items) => match items.as_slice() {
966                [head] if self.bare.contains(&(std::ptr::from_ref(head) as usize)) => {
967                    return Spanned::new(form.span, head.form.clone());
968                }
969                [head, ..] if self.respell.contains_key(&(std::ptr::from_ref(head) as usize)) => {
970                    let r = &self.respell[&(std::ptr::from_ref(head) as usize)];
971                    let walked: Vec<Spanned> = items.iter().map(|i| self.form(i)).collect();
972                    return blue_lang_check::respell::apply(form, &walked, r);
973                }
974                _ => SpannedForm::List(items.iter().map(|i| self.form(i)).collect()),
975            },
976            SpannedForm::Quote(i) => SpannedForm::Quote(Box::new(self.form(i))),
977            SpannedForm::Quasiquote(i) => SpannedForm::Quasiquote(Box::new(self.form(i))),
978            SpannedForm::Unquote(i) => SpannedForm::Unquote(Box::new(self.form(i))),
979            SpannedForm::UnquoteSplice(i) => SpannedForm::UnquoteSplice(Box::new(self.form(i))),
980            other => other.clone(),
981        };
982        Spanned::new(form.span, inner)
983    }
984}
985
986/// Parse, resolve and CHECK, without running: the door for `blue check`,
987/// `blue test` and the language server.
988///
989/// Returns every diagnostic, errors and warnings alike, rather than failing on
990/// the first error: a reader fixing a file wants the whole list, and an agent
991/// repairing one wants it in one pass. Whether errors stop anything is the
992/// caller's decision — `blue test` refuses to run tests over a program with
993/// one, exactly as `run` refuses to evaluate it.
994///
995/// The name oracle is the interpreter `blue run` would build: hostless plus
996/// input primitives.
997///
998/// # Errors
999///
1000/// A parse or import error, which leaves no program to check.
1001pub fn check_entry(
1002    entry: Entry<'_>,
1003    loader: &dyn crate::uses::Loader,
1004    surface: Option<&blue_lang_syntax::yakugo::Yakugo>,
1005    checking: Checking,
1006) -> Result<Checked, RunError> {
1007    let mut program = parse_and_resolve(entry, loader, surface)?;
1008    if checking == Checking::Program {
1009        program.retain(|f| !crate::uses::is_test_form(f));
1010    }
1011    let mut interp = crate::interpreter_hostless();
1012    crate::inputs::install_input_primitives(&mut interp, Inputs::new());
1013    let builtins = builtin_names(&interp);
1014    let (outcome, names) = check_stage(&program, &builtins, checking == Checking::WithTests);
1015    Ok(Checked {
1016        program,
1017        outcome,
1018        names,
1019    })
1020}
1021
1022#[must_use]
1023pub fn spelling_code(spelling: blue_lang_syntax::Spelling) -> blue_lang_check::Code {
1024    use blue_lang_check::Code;
1025    use blue_lang_syntax::Spelling;
1026    match spelling {
1027        Spelling::LogicalSymbol => Code::B0025,
1028        Spelling::Unless => Code::B0026,
1029        Spelling::ElseIf => Code::B0027,
1030        Spelling::CallForm => Code::B0028,
1031        Spelling::KeywordRocket => Code::B0029,
1032        Spelling::ParameterList => Code::B0030,
1033        Spelling::OperatorSpelling => Code::B0031,
1034        Spelling::TrailingComma => Code::B0032,
1035        Spelling::NegatedComparison => Code::B0034,
1036        Spelling::ElseNil => Code::B0035,
1037        Spelling::TryCatch => Code::B0037,
1038        Spelling::Apply => Code::B0042,
1039    }
1040}
1041
1042#[must_use]
1043pub fn form_diagnostics(text: &str) -> Vec<blue_lang_check::Diagnostic> {
1044    match blue_lang_fmt::format_source_lossless(text) {
1045        Ok(formatted) => form_diagnostics_against(text, &formatted),
1046        Err(_) => Vec::new(),
1047    }
1048}
1049
1050#[must_use]
1051pub fn form_diagnostics_against(text: &str, formatted: &str) -> Vec<blue_lang_check::Diagnostic> {
1052    use blue_lang_check::{Code, Diagnostic};
1053    if formatted.trim_end() == text.trim_end() {
1054        return Vec::new();
1055    }
1056    let help = "`blue fmt --write` writes it; `blue run`, `blue test` and `blue check` rewrite a writable file before compiling it";
1057    let mut out: Vec<Diagnostic> = blue_lang_syntax::spelling_notes(text)
1058        .unwrap_or_default()
1059        .into_iter()
1060        .map(|n| {
1061            let message = if n.canonical.is_empty() {
1062                format!("`{}` is not written", n.written)
1063            } else {
1064                format!("`{}` is written `{}`", n.written, n.canonical)
1065            };
1066            Diagnostic::new(spelling_code(n.spelling), message, n.span)
1067                .at_top_level(0)
1068                .with_help(help)
1069        })
1070        .collect();
1071    out.extend(literal_diagnostics(text).into_iter().map(|d| d.with_help(help)));
1072    if out.is_empty() {
1073        let at = text
1074            .lines()
1075            .zip(formatted.lines())
1076            .position(|(a, b)| a != b)
1077            .unwrap_or_else(|| text.lines().count().min(formatted.lines().count()));
1078        let start: usize = text.lines().take(at).map(|l| l.len() + 1).sum();
1079        let start = start.min(text.len());
1080        let end = text[start..].find('\n').map_or(text.len(), |e| start + e);
1081        out.push(
1082            Diagnostic::new(
1083                Code::B0024,
1084                format!("line {} is not laid out as blue writes it", at + 1),
1085                tatara_lisp::Span::new(start, end),
1086            )
1087            .at_top_level(0)
1088            .with_help(help),
1089        );
1090    }
1091    out.sort_by_key(|d| (d.span.start, d.code));
1092    out
1093}
1094
1095fn literal_diagnostics(text: &str) -> Vec<blue_lang_check::Diagnostic> {
1096    use blue_lang_syntax::{Atom, TokenKind};
1097    let Ok(toks) = blue_lang_syntax::lex(text) else {
1098        return Vec::new();
1099    };
1100    toks.iter()
1101        .filter_map(|t| {
1102            let atom = match &t.kind {
1103                TokenKind::Int(v) => Atom::Int(*v),
1104                TokenKind::Float(v) => Atom::Float(*v),
1105                TokenKind::Str(v) => Atom::Str(v.clone()),
1106                _ => return None,
1107            };
1108            let written = text.get(t.span.start..t.span.end)?;
1109            let canonical = blue_lang_fmt::render_literal(&atom);
1110            (written != canonical).then(|| {
1111                blue_lang_check::Diagnostic::new(
1112                    blue_lang_check::Code::B0033,
1113                    format!("`{written}` is written `{canonical}`"),
1114                    t.span,
1115                )
1116                .at_top_level(0)
1117            })
1118        })
1119        .collect()
1120}
1121
1122/// A syntax error in `text` as a [`B0006`](blue_lang_check::Code::B0006)
1123/// diagnostic, so a tool reading `--format json` gets a parse failure in the
1124/// same shape as every other finding. `None` when `text` parses.
1125#[must_use]
1126pub fn syntax_diagnostic(text: &str) -> Option<blue_lang_check::Diagnostic> {
1127    let e = blue_lang_syntax::parse_program_tree(text).err()?;
1128    Some(
1129        blue_lang_check::Diagnostic::new(blue_lang_check::Code::B0006, e.message, e.span)
1130            .at_top_level(0),
1131    )
1132}
1133
1134/// A runtime message as the author wrote the names in it: a definition runs
1135/// under its key (`retsu/first`, `%root/f`), and a message naming one in
1136/// backticks names it `retsu::first`, or `f` for the author's own script.
1137#[must_use]
1138pub fn display_keys(message: &str) -> String {
1139    let mut out = String::with_capacity(message.len());
1140    let mut parts = message.split('`');
1141    if let Some(first) = parts.next() {
1142        out.push_str(first);
1143    }
1144    for (i, part) in parts.enumerate() {
1145        out.push('`');
1146        // Odd pieces (0-based here) are inside backticks.
1147        if i % 2 == 0 {
1148            out.push_str(&crate::observe::display_key(part));
1149        } else {
1150            out.push_str(part);
1151        }
1152    }
1153    out
1154}
1155
1156/// Evaluate a prepared program's top-level forms into `interp`, with `host`.
1157pub(crate) fn eval_prepared<H: 'static>(
1158    interp: &mut tatara_lisp_eval::Interpreter<H>,
1159    prepared: &Prepared,
1160    host: &mut H,
1161) -> Result<Value, RunError> {
1162    let Prepared {
1163        program, erased, ..
1164    } = prepared;
1165
1166    // RUN, one top-level form at a time, **counting them**.
1167    //
1168    // This is literally the loop `Interpreter::eval_program` runs internally
1169    // (tatara-lisp-eval `eval.rs`) — unrolled here for exactly one reason: the
1170    // INDEX. `resolve_uses` flattens N files into one form list and a `Span` is
1171    // a byte range with no file identity, so an offset alone is ambiguous
1172    // across files — 66 means something in every one of them. The index is the
1173    // join key back to `ResolvedProgram`'s file table, and `eval_program`
1174    // consumes it internally and hands back only the error.
1175    //
1176    // The same key, the same renderer and the same file table the type errors
1177    // above already use. A runtime error was the one diagnostic in this
1178    // function still reporting a bare message.
1179    let mut value = Value::Nil;
1180    for (top_level, form) in erased.iter().enumerate() {
1181        value = interp.eval_top_form(form, host).map_err(|e| {
1182            // The message, its position and the blue call stack, read off the
1183            // frames the error unwound through (`observe::Fault`). The message
1184            // is `short_message` rather than upstream's `Display`, whose
1185            // trailing ` at {span}` is a bare byte range with no file, through
1186            // `messages::describe`, which names the function a wrong argument
1187            // count was called on.
1188            RunError::Eval(Box::new(crate::observe::Fault::of(
1189                program,
1190                erased,
1191                top_level,
1192                &e,
1193                &interp.take_trace(),
1194            )))
1195        })?;
1196    }
1197    Ok(value)
1198}
1199
1200pub const MAIN: &str = "main";
1201
1202#[must_use]
1203pub fn entry_main(program: &crate::uses::ResolvedProgram) -> Option<(usize, tatara_lisp::Span)> {
1204    use crate::uses::ResolvedProgram;
1205    let stored = program
1206        .file(ResolvedProgram::ENTRY)
1207        .is_some_and(|f| f.path.is_some());
1208    if !stored {
1209        return None;
1210    }
1211    program.forms().iter().enumerate().find_map(|(i, f)| {
1212        if program.owner_of(i) != Some(ResolvedProgram::ENTRY) {
1213            return None;
1214        }
1215        let items = f.as_list()?;
1216        let sig = items.get(1)?.as_list()?;
1217        let named_main = matches!(items.first().and_then(tatara_lisp::Spanned::as_symbol), Some("define" | "define-typed"))
1218            && sig.len() == 1
1219            && sig[0].as_symbol() == Some(MAIN);
1220        named_main.then_some((i, sig[0].span))
1221    })
1222}
1223
1224pub(crate) fn call_main<H: 'static>(
1225    interp: &mut tatara_lisp_eval::Interpreter<H>,
1226    prepared: &Prepared,
1227    host: &mut H,
1228) -> Result<Option<Value>, RunError> {
1229    let Some((top_level, span)) = entry_main(&prepared.program) else {
1230        return Ok(None);
1231    };
1232    let ns = namespace_of(&prepared.program, top_level);
1233    let call = tatara_lisp::Spanned::new(
1234        span,
1235        tatara_lisp::SpannedForm::List(vec![tatara_lisp::Spanned::new(
1236            span,
1237            tatara_lisp::SpannedForm::Atom(tatara_lisp::Atom::Symbol(blue_lang_check::names::key(&ns, MAIN))),
1238        )]),
1239    );
1240    interp.eval_top_form(&call, host).map(Some).map_err(|e| {
1241        RunError::Eval(Box::new(crate::observe::Fault::of(
1242            &prepared.program,
1243            &prepared.erased,
1244            top_level,
1245            &e,
1246            &interp.take_trace(),
1247        )))
1248    })
1249}
1250
1251/// **A runtime error names a place.** The gates for the last stage that
1252/// reported a bare message.
1253///
1254/// Each fixture is sized so that resolving the failing span against ANY file
1255/// but the right one lands somewhere else — a different path and a different
1256/// line — so a green run here is evidence about the join and not about the
1257/// renderer being called at all.
1258///
1259/// **Each raise is an unbound name, WAIVED.** Since the check stage resolves
1260/// names (B0001), an unbound call no longer reaches the evaluator; these
1261/// fixtures need exactly that runtime raise, so each carries
1262/// `# waive B0001: …` above the definition holding it — the one escape hatch,
1263/// used for what it is for. The waiver adds a line above each failing call,
1264/// which is why the positions below are one line later than their red runs
1265/// (recorded against the unwaived fixtures) show.
1266#[cfg(test)]
1267mod position_tests {
1268    use super::*;
1269    use crate::uses::{Entry, Loader};
1270    use std::collections::BTreeMap;
1271    use std::path::Path;
1272
1273    struct MemLoader(BTreeMap<&'static str, &'static str>);
1274
1275    impl Loader for MemLoader {
1276        fn load(&self, name: &str) -> Result<Vec<(String, String)>, String> {
1277            self.0
1278                .get(name)
1279                .map(|s| vec![(format!("{name}.b"), (*s).to_owned())])
1280                .ok_or_else(|| format!("no bidama named \"{name}\""))
1281        }
1282    }
1283
1284    /// A package whose OWN top-level code raises, deep inside a file that is
1285    /// deliberately taller than either of the other two.
1286    ///
1287    /// Byte 66 — where `kore_wa_sonzai_shinai` starts — is past the end of the
1288    /// entry file (30 bytes) and past the end of `kotae.b` (21 bytes). So the
1289    /// only file this span can honestly resolve against is this one, and the
1290    /// other two now refuse to answer rather than walking off their ends.
1291    const BAKUHATSU: &str = "\
1292def tsukawanai_a()
1293  1
1294end
1295
1296def tsukawanai_b()
1297  2
1298end
1299
1300# waive B0001: the fixture needs a raise at runtime
1301def bakuhatsu()
1302  kore_wa_sonzai_shinai()
1303end
1304
1305bakuhatsu";
1306
1307    const KOTAE: &str = "def kotae()\n  42\nend";
1308
1309    /// The same failing call, but only ever reached by a CALLER in another
1310    /// file — the shape the call stack resolved (the last position test).
1311    const BAKUHATSU2: &str =
1312        "# waive B0001: a raise at runtime\ndef yobu()\n  kore_wa_sonzai_shinai()\nend";
1313
1314    fn loader() -> MemLoader {
1315        MemLoader(BTreeMap::from([
1316            ("kotae", KOTAE),
1317            ("bakuhatsu", BAKUHATSU),
1318            ("bakuhatsu2", BAKUHATSU2),
1319        ]))
1320    }
1321
1322    fn run_named(path: &str, src: &str) -> RunError {
1323        run_in_surface(
1324            Entry {
1325                path: Some(Path::new(path)),
1326                text: src,
1327            },
1328            Inputs::new(),
1329            &loader(),
1330            None,
1331        )
1332        .expect_err("the fixture must raise")
1333    }
1334
1335    /// **The load-bearing gate: a raise inside an IMPORTED package reports the
1336    /// IMPORTED file's path and line.**
1337    ///
1338    /// Hand-computed. In `bakuhatsu.b` the failing call sits on line 11 at
1339    /// column 3, and the whole point of the fixture's height is that no other
1340    /// file in the program can produce that pair: the entry file has 2 lines
1341    /// and `kotae.b` has 3, so *any* mis-attribution is visible as a different
1342    /// path AND a different position, never as a coincidence.
1343    ///
1344    /// **Three red runs, one per edit this change makes** — each isolates a
1345    /// different half of the mechanism, which is what stops the gate being a
1346    /// tautology over "some renderer ran".
1347    ///
1348    /// 1. `eval_program` + `.map_err(|e| RunError::Eval(e.to_string()))`
1349    ///    restored (the pre-change code):
1350    ///    ```text
1351    ///    left:  "runtime error: unbound symbol: kore_wa_sonzai_shinai at 74..95"
1352    ///    right: "runtime error: bakuhatsu.b:10:3: unbound symbol `kore_wa_sonzai_shinai`"
1353    ///    ```
1354    ///    No place at all — the state this change is fixing — and the trailing
1355    ///    `at 74..95` is upstream's `Display`, an offset with no file, which is
1356    ///    why the loop renders `short_message` instead.
1357    ///
1358    /// 2. The loop kept, but `0` passed to `locate` in place of `top_level`:
1359    ///    ```text
1360    ///    left:  "runtime error: kotae.b: unbound symbol `kore_wa_sonzai_shinai`"
1361    ///    right: "runtime error: bakuhatsu.b:10:3: unbound symbol `kore_wa_sonzai_shinai`"
1362    ///    ```
1363    ///    **This is the one that proves the INDEX is load-bearing** rather than
1364    ///    the renderer: form 0 belongs to `kotae.b`, so the wrong file is named
1365    ///    — and named without a position, because the guard in `locate` sees
1366    ///    that byte 74 is not a range in a 21-byte file and declines to invent
1367    ///    one. A fixture with one imported package could not tell these apart.
1368    ///
1369    /// 3. `crate::lower_to_spanned(&crate::to_sexps(&erased))` reinstated
1370    ///    between erasure and the loop:
1371    ///    ```text
1372    ///    left:  "runtime error: bakuhatsu.b: unbound symbol `kore_wa_sonzai_shinai`"
1373    ///    right: "runtime error: bakuhatsu.b:10:3: unbound symbol `kore_wa_sonzai_shinai`"
1374    ///    ```
1375    ///    The right FILE with no position — which is exactly the shape of the
1376    ///    bug: the index survived the lift and every span did not.
1377    /// kotae loads first so bakuhatsu's forms do not start at index 0: the
1378    /// order is the fixture, and the waiver says so (B0015 wants them sorted).
1379    const TWO_IMPORTS: &str =
1380        "use(\"kotae\")\n# waive B0015: kotae loads first on purpose\nuse(\"bakuhatsu\")\n";
1381
1382    #[test]
1383    fn a_raise_inside_an_imported_package_names_that_package() {
1384        let err = run_named("entry.b", TWO_IMPORTS);
1385        assert_eq!(
1386            err.to_string(),
1387            "runtime error: bakuhatsu.b:11:3: unbound symbol `kore_wa_sonzai_shinai`\n  \
1388             at bakuhatsu::bakuhatsu (bakuhatsu.b:11:3)\n  \
1389             at <top level> (bakuhatsu.b:14:1)"
1390        );
1391    }
1392
1393    /// Anti-vacuity for the fixture itself: the position asserted above is a
1394    /// FACT ABOUT `bakuhatsu.b`, checked against the source text rather than
1395    /// against the thing that produced it.
1396    ///
1397    /// Without this, `11:3` is just a number that happened to come out of the
1398    /// code under test, and a change that moved every reported line by one
1399    /// would move this assertion with it.
1400    #[test]
1401    fn line_11_column_3_of_the_fixture_is_the_failing_call() {
1402        let line = BAKUHATSU.lines().nth(10).expect("line 11 exists");
1403        assert_eq!(line, "  kore_wa_sonzai_shinai()");
1404        assert_eq!(
1405            &line[2..],
1406            "kore_wa_sonzai_shinai()",
1407            "column 3 (1-indexed) is where the call starts"
1408        );
1409        // And the other two files cannot reach that far, which is what makes a
1410        // mis-attribution loud instead of plausible.
1411        let offset = BAKUHATSU.find("kore_wa_sonzai_shinai").expect("in fixture");
1412        assert!(
1413            offset > KOTAE.len(),
1414            "kotae.b could answer for byte {offset}"
1415        );
1416        assert!(
1417            offset > TWO_IMPORTS.len(),
1418            "the entry file could answer for byte {offset}"
1419        );
1420    }
1421
1422    /// **The `FileId(0)` path: a raise in the ENTRY file reports the entry
1423    /// file.** The single-file case, which is every program that imports
1424    /// nothing — and the one where the index and the span cannot disagree.
1425    ///
1426    /// **Red run** (2026-08-12), `eval_program` +
1427    /// `.map_err(|e| RunError::Eval(e.to_string()))` restored:
1428    /// ```text
1429    /// left:  "runtime error: unbound symbol: nani_mo_nai at 17..28"
1430    /// right: "runtime error: honmono.b:5:1: unbound symbol `nani_mo_nai`"
1431    /// ```
1432    ///
1433    /// **Second red run**, `lower_to_spanned` reinstated after erasure — the
1434    /// one that isolates the SPAN half from the index half, since a
1435    /// single-file program cannot get its file wrong:
1436    /// ```text
1437    /// left:  "runtime error: honmono.b: unbound symbol `nani_mo_nai`"
1438    /// right: "runtime error: honmono.b:5:1: unbound symbol `nani_mo_nai`"
1439    /// ```
1440    #[test]
1441    fn a_raise_in_the_entry_file_names_the_entry_file() {
1442        let err = run_named(
1443            "honmono.b",
1444            "def f()\n  1\nend\n\n# waive B0001: a raise at runtime\nnani_mo_nai()\n",
1445        );
1446        assert_eq!(
1447            err.to_string(),
1448            "runtime error: honmono.b:6:1: unbound symbol `nani_mo_nai`"
1449        );
1450    }
1451
1452    /// A raise from a form that came through the SURFACE-level erasure still
1453    /// reports a real position — the annotated path, where erasure rewrites
1454    /// the node rather than passing it through.
1455    ///
1456    /// Separate from the two above because the erasure rewrite is the only
1457    /// place a node is built rather than kept, and a synthetic span there
1458    /// would be invisible to a fixture whose failing form is untouched.
1459    ///
1460    /// **Red run** (2026-08-12), `lower_to_spanned` reinstated after erasure:
1461    /// ```text
1462    /// left:  "runtime error: chuu.b: unbound symbol `mada_nai`"
1463    /// right: "runtime error: chuu.b:2:3: unbound symbol `mada_nai`"
1464    /// ```
1465    #[test]
1466    fn a_raise_inside_an_annotated_def_still_names_its_line() {
1467        let err = run_named(
1468            "chuu.b",
1469            "# waive B0001: a raise at runtime\ndef f(a: Int) -> Int\n  mada_nai(a)\nend\n\nf(1)\n",
1470        );
1471        assert_eq!(
1472            err.to_string(),
1473            "runtime error: chuu.b:3:3: unbound symbol `mada_nai`\n  \
1474             at f (chuu.b:3:3)\n  \
1475             at <top level> (chuu.b:6:1)"
1476        );
1477    }
1478
1479    /// **The limit this module used to state, closed by the call stack.**
1480    ///
1481    /// A top-level form in the entry file calls a function defined in an
1482    /// imported one, and the raise happens inside the callee. The executing
1483    /// form is the entry's and the span is the callee's bytes, so until the
1484    /// evaluator reported the frames an error unwound through, the best blue
1485    /// could do was name the caller's file with no position (the guard in
1486    /// `uses::ResolvedProgram::locate` refusing an offset it could not
1487    /// justify). The innermost frame's definition now names the file the
1488    /// offsets belong to, and the stack shows the call that led there.
1489    ///
1490    /// **Red run** (2026-10-10): `Fault::of` locating against the executing
1491    /// top-level form instead of the innermost frame's definition:
1492    /// ```text
1493    /// 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)"
1494    /// ```
1495    /// The old answer, kept by the guard: the caller's file and no position.
1496    #[test]
1497    fn a_raise_in_a_callee_from_another_file_names_the_callees_file() {
1498        // The comment is padding, and load-bearing: `bakuhatsu2.b`'s failing
1499        // call starts at byte 47 (after its waiver line) and ends at 70, and
1500        // this file is 57 bytes, so the start is in range here and the end is
1501        // not — a mis-attribution would still be refused rather than placed.
1502        let err = run_named(
1503            "yobidashi.b",
1504            "use(\"bakuhatsu2\")\n# pad: 47's in range\nbakuhatsu2::yobu\n",
1505        );
1506        assert_eq!(
1507            err.to_string(),
1508            "runtime error: bakuhatsu2.b:3:3: unbound symbol `kore_wa_sonzai_shinai`\n  \
1509             at bakuhatsu2::yobu (bakuhatsu2.b:3:3)\n  \
1510             at <top level> (yobidashi.b:3:1)"
1511        );
1512    }
1513}
1514
1515#[cfg(test)]
1516mod tests {
1517    use super::*;
1518
1519    fn int(src: &str) -> i64 {
1520        match run(src).unwrap_or_else(|e| panic!("{src:?}: {e}")).value {
1521            Value::Int(v) => v,
1522            other => panic!("{src:?} produced {other:?}"),
1523        }
1524    }
1525
1526    /// **The sliding scale, as one assertion.** Annotating changes the
1527    /// analysis and nothing else.
1528    #[test]
1529    fn annotating_buys_analysis_and_changes_nothing_else() {
1530        let plain = run("def add(a, b)\n  a + b\nend\nadd(2, 3)").expect("plain");
1531        let typed = run("def add(a: Int, b: Int) -> Int\n  a + b\nend\nadd(2, 3)").expect("typed");
1532
1533        assert!(matches!(plain.value, Value::Int(5)));
1534        assert!(
1535            matches!(typed.value, Value::Int(5)),
1536            "the annotated program must compute the same answer"
1537        );
1538        assert_eq!(plain.visited, 0, "no annotations means no analysis");
1539        assert!(
1540            typed.visited > 0,
1541            "an annotation must actually buy analysis, not just decorate"
1542        );
1543        assert_eq!(plain.typed_decls, 0);
1544        assert_eq!(typed.typed_decls, 1);
1545    }
1546
1547    /// **Checking happens before erasure.** This is the test that catches the
1548    /// reordering: a program with a declared-type violation must be rejected,
1549    /// and it can only be rejected while the annotations still exist.
1550    #[test]
1551    fn a_type_error_is_reported_and_the_program_does_not_run() {
1552        let err = run("def add(a: Int, b: Int) -> Str\n  a + b\nend\nadd(1, 2)")
1553            .expect_err("a declared Str return from an Int body must be rejected");
1554        assert!(
1555            matches!(err, RunError::Types(ref d) if !d.is_empty()),
1556            "expected type diagnostics, got {err}"
1557        );
1558    }
1559
1560    /// And the untyped version of the same program runs, so the rejection
1561    /// above is the annotation's doing rather than a parse failure.
1562    #[test]
1563    fn the_same_program_without_annotations_runs() {
1564        assert_eq!(int("def add(a, b)\n  a + b\nend\nadd(1, 2)"), 3);
1565    }
1566
1567    #[test]
1568    fn a_parse_error_is_reported_as_one() {
1569        assert!(matches!(run("def (").unwrap_err(), RunError::Parse(_)));
1570    }
1571
1572    /// Every stage reports in its own vocabulary, so a failure names which
1573    /// stage failed rather than surfacing as a generic error.
1574    #[test]
1575    fn a_runtime_error_is_reported_as_one() {
1576        let err = run("throw(error(\"boom\"))").expect_err("a raise");
1577        assert!(matches!(err, RunError::Eval(_)), "got {err}");
1578    }
1579
1580    /// Stdlib and primitives are both reachable through the pipeline — the
1581    /// gap that made `6 % 3` fail.
1582    #[test]
1583    fn the_pipeline_reaches_both_runtime_layers() {
1584        assert_eq!(int("6 % 3"), 0);
1585        assert_eq!(int("7 % 3"), 1);
1586        assert_eq!(int("2 + 3 * 4"), 14);
1587    }
1588
1589    /// **The deleted hop was a no-op on everything blue emits — so removing it
1590    /// is a swap, not a behaviour change.**
1591    ///
1592    /// The old lowering printed the erased tree and read it back through
1593    /// `tatara_lisp::read_spanned`. This walks a corpus and asserts the two
1594    /// paths land on the same tree, which is the equivalence the swap rests on.
1595    /// It is stated as a *measurement over this corpus*, not as a theorem:
1596    /// the round trip is not identity in general (that is precisely why it had
1597    /// to go), it merely happened to be identity for the bytes blue emits.
1598    #[test]
1599    fn the_deleted_round_trip_agreed_with_the_direct_lowering() {
1600        let corpus = [
1601            "def add(a, b)\n  a + b\nend\nadd(2, 3)",
1602            "def fact(n)\n  if n < 2\n    1\n  else\n    n * fact(n - 1)\n  end\nend\nfact(5)",
1603            "def f(a, b)\n  c = a + b\n  c * 2\nend\nf(1, 2)",
1604            "defmacro sq(e)\n  quote\n    unquote(e) * unquote(e)\n  end\nend\nsq(2 + 3)",
1605            "\"a string with spaces, a ( and a )\"",
1606            "def g(a: Int) -> Int\n  a + 1\nend\ng(1)",
1607            "6 % 3",
1608            "1.5 + 2.25",
1609        ];
1610        for src in corpus {
1611            // Projected to `Sexp` because that is what the deleted hop
1612            // operated on. Erasure itself no longer goes near it.
1613            let erased = crate::to_sexps(&erase_types(&parse_tree(src).expect("parse")));
1614
1615            let direct: Vec<Sexp> = crate::lower_to_spanned(&erased)
1616                .iter()
1617                .map(tatara_lisp::Spanned::to_sexp)
1618                .collect();
1619            assert_eq!(direct, erased, "the direct lowering must be the identity");
1620
1621            let text = erased
1622                .iter()
1623                .map(ToString::to_string)
1624                .collect::<Vec<_>>()
1625                .join("\n");
1626            let round_tripped: Vec<Sexp> = tatara_lisp::read_spanned(&text)
1627                .unwrap_or_else(|e| panic!("{src:?}: the old path could not read back: {e:?}"))
1628                .iter()
1629                .map(tatara_lisp::Spanned::to_sexp)
1630                .collect();
1631            assert_eq!(
1632                round_tripped, erased,
1633                "{src:?}: the old print-and-reparse path changed the tree"
1634            );
1635        }
1636    }
1637
1638    /// Anti-vacuity for the test above: the round trip really is *not* the
1639    /// identity in general, so agreeing on the corpus was a property of what
1640    /// blue happens to emit rather than a property of the reader.
1641    ///
1642    /// **`Atom::Symbol`'s `Display` writes the name raw, with no escaping.**
1643    /// `Atom::Str` escapes and its docs explain at length why; the symbol arm
1644    /// is `f.write_str(s)`. So print-then-read is not inverse over the symbol
1645    /// domain, and the failure is *silent*: a symbol containing a space prints
1646    /// as two tokens, reads back as two symbols, and the result is a perfectly
1647    /// well-formed tree with a different meaning. No error, nothing to catch.
1648    ///
1649    /// Measured 2026-08-02 across the separators: `a b` and `x'y` come back
1650    /// `Ok` with a different tree; `x)y`, `x"y` and `x;y` come back `Err`;
1651    /// `x{y` and `x[y` DO round-trip at this level — those two are one symbol
1652    /// in and one symbol out, so the brace-fusion reported in tatara *source*
1653    /// is not what bites a printed tree. The silent pair is what makes this a
1654    /// miscompile class rather than a noisy one.
1655    #[test]
1656    fn the_round_trip_is_not_the_identity_in_general() {
1657        let tree = Sexp::List(vec![
1658            Sexp::Atom(tatara_lisp::Atom::Symbol("f".into())),
1659            Sexp::Atom(tatara_lisp::Atom::Symbol("a b".into())),
1660        ]);
1661        let text = tree.to_string();
1662        let back: Vec<Sexp> = tatara_lisp::read_spanned(&text)
1663            .expect("it reads back cleanly — that IS the problem")
1664            .iter()
1665            .map(tatara_lisp::Spanned::to_sexp)
1666            .collect();
1667        assert_ne!(
1668            back,
1669            vec![tree.clone()],
1670            "if print-then-read became inverse over symbols, the class would be \
1671             closed upstream and this test should be deleted rather than relaxed"
1672        );
1673        // …and the direct lowering is unaffected by any of it.
1674        let direct: Vec<Sexp> = crate::lower_to_spanned(std::slice::from_ref(&tree))
1675            .iter()
1676            .map(tatara_lisp::Spanned::to_sexp)
1677            .collect();
1678        assert_eq!(direct, vec![tree]);
1679    }
1680}
1681
1682#[cfg(test)]
1683mod macro_tests {
1684    use super::*;
1685
1686    fn int(src: &str) -> i64 {
1687        match run(src).unwrap_or_else(|e| panic!("{src:?}: {e}")).value {
1688            Value::Int(v) => v,
1689            other => panic!("{src:?} produced {other:?}"),
1690        }
1691    }
1692
1693    /// **A blue macro expands and runs.** Tenet 2's surface, end to end.
1694    #[test]
1695    fn a_macro_expands_and_runs() {
1696        assert_eq!(
1697            int("defmacro double(x)\n  quote\n    unquote(x) + unquote(x)\n  end\nend\ndouble(21)"),
1698            42
1699        );
1700    }
1701
1702    /// A macro receives *source forms*, not values — so it can duplicate its
1703    /// argument, which a function cannot do without re-evaluating it.
1704    #[test]
1705    fn a_macro_operates_on_syntax_not_values() {
1706        assert_eq!(
1707            int("defmacro sq(e)\n  quote\n    unquote(e) * unquote(e)\n  end\nend\nsq(2 + 3)"),
1708            25,
1709            "the argument form `2 + 3` must be substituted twice"
1710        );
1711    }
1712
1713    /// **A runaway macro is a typed error, not a dead compiler.** This is the
1714    /// property that makes the metaprogramming surface safe to hand to a user.
1715    ///
1716    /// The assertion was `contains("expansion limit")` and now reads
1717    /// `contains("expansion")`, because the pipeline renders `short_message`
1718    /// rather than `Display`: upstream words the same fact as "exceeded 256
1719    /// expansion steps" instead of "exceeded the expansion limit of 256
1720    /// rewrites". The PROPERTY is unchanged and still asserted — the macro is
1721    /// named, and the failure is attributed to expansion rather than to
1722    /// evaluation. **This reword was the whole measured blast radius of that
1723    /// switch**, one test in the workspace.
1724    ///
1725    /// The number is deliberately NOT pinned. It is upstream's constant, this
1726    /// test owns none of it, and matching it would turn an upstream bump into
1727    /// a red run here that proves nothing about blue.
1728    ///
1729    /// The third clause is new capability rather than repair: the message now
1730    /// carries `<anonymous>:6:1`, so a runaway macro says WHERE it ran away.
1731    #[test]
1732    fn a_runaway_macro_fails_the_compilation_rather_than_the_process() {
1733        let err =
1734            run("defmacro forever(x)\n  quote\n    forever(unquote(x))\n  end\nend\nforever(1)")
1735                .expect_err("a self-referential macro must be rejected");
1736        let msg = err.to_string();
1737        assert!(
1738            msg.contains("forever") && msg.contains("expansion"),
1739            "the error must name the macro and the limit it hit: {msg}"
1740        );
1741        assert!(
1742            msg.contains("<anonymous>:6:1"),
1743            "and must place the call that ran away — line 6 is `forever(1)`: {msg}"
1744        );
1745    }
1746}
1747
1748#[cfg(test)]
1749mod input_tests {
1750    use super::*;
1751    use crate::inputs::{Declaration, Inputs};
1752
1753    /// A schema a macro will generate code from.
1754    const SCHEMA: &[u8] = b"3";
1755
1756    fn with_schema(src: &str) -> Result<Run, RunError> {
1757        let hash = Inputs::hash_of(SCHEMA);
1758        let mut inputs = Inputs::new();
1759        inputs
1760            .bind(
1761                &Declaration {
1762                    name: "schema".to_string(),
1763                    hash,
1764                },
1765                SCHEMA.to_vec(),
1766            )
1767            .expect("bind");
1768        run_with_inputs(src, inputs)
1769    }
1770
1771    fn decl_line() -> String {
1772        let mut s = String::from("definput(\"schema\", \"");
1773        s.push_str(&Inputs::hash_of(SCHEMA));
1774        s.push_str("\")\n");
1775        s
1776    }
1777
1778    /// **A macro reads a declared build input.** This is §VI OPEN #6 closed —
1779    /// the spec names it as gating blue's whole "stronger than Ruby's
1780    /// metaprogramming" claim, because a macro that cannot read a schema cannot
1781    /// generate code from one.
1782    #[test]
1783    fn a_macro_can_read_a_declared_build_input() {
1784        let src = decl_line() + "input(\"schema\")";
1785        let out = with_schema(&src).expect("run");
1786        assert!(
1787            matches!(out.value, Value::Str(ref s) if &**s == "3"),
1788            "got {:?}",
1789            out.value
1790        );
1791    }
1792
1793    /// **An undeclared input is an error, not a file read and not nil.**
1794    /// Returning nil is how a macro generates an empty table and nobody notices
1795    /// until runtime.
1796    #[test]
1797    fn an_undeclared_input_is_an_error() {
1798        let err = with_schema("input(\"not_declared\")").expect_err("must fail");
1799        let msg = err.to_string();
1800        assert!(msg.contains("not_declared"), "must name it: {msg}");
1801        assert!(msg.contains("definput"), "and say how to declare it: {msg}");
1802    }
1803
1804    /// **There is no path-based read at all.** The capability is the absence of
1805    /// the primitive, not a check inside one — so this is an unbound symbol.
1806    ///
1807    /// Holds for the DEFAULT surface — the one every embedder gets. The `sys`
1808    /// cargo feature (CLI only) is the one declared exception: it is the
1809    /// operator's own trusted host surface, and is asserted in
1810    /// `sys_read_file_is_the_trusted_cli_only_exception` below.
1811    #[cfg(not(feature = "sys"))]
1812    #[test]
1813    fn there_is_no_ambient_file_read() {
1814        for attempt in [
1815            "read_file(\"/etc/passwd\")",
1816            "File(\"/etc/passwd\")",
1817            "slurp(\"/etc/passwd\")",
1818            "open(\"/etc/passwd\")",
1819        ] {
1820            let err = with_schema(attempt).expect_err("must not resolve");
1821            assert!(
1822                err.to_string().contains("unbound"),
1823                "{attempt} must be UNBOUND — a capability removed by absence, \
1824                 not guarded by a check: {err}"
1825            );
1826        }
1827    }
1828
1829    /// With the `sys` feature compiled in, `read_file` IS bound — that is the
1830    /// point of the feature. The doctrine does not move: this is the operator's
1831    /// own machine (the CLI), not an embedder's sandbox. Pin the boundary so a
1832    /// future default-build change is heard, and assert that `input()` still
1833    /// works beside it.
1834    #[cfg(feature = "sys")]
1835    #[test]
1836    fn sys_read_file_is_the_trusted_cli_only_exception() {
1837        let err = with_schema("definitely_not_a_primitive(\"x\")").expect_err("must not resolve");
1838        assert!(err.to_string().contains("unbound"), "{err}");
1839        assert!(
1840            with_schema("read_file(\"/etc/passwd\")").is_ok(),
1841            "with `sys` on, read_file is the trusted CLI surface"
1842        );
1843        let out = with_schema("input(\"schema\")").expect("run");
1844        assert!(
1845            matches!(out.value, Value::Str(ref s) if &**s == "3"),
1846            "input() still binds beside the sys surface: {:?}",
1847            out.value
1848        );
1849    }
1850
1851    /// Anti-vacuity: with no inputs supplied at all, even a declared name fails
1852    /// — so the success above is the binding's doing.
1853    #[test]
1854    fn a_declared_input_with_no_bytes_supplied_fails() {
1855        let src = decl_line() + "input(\"schema\")";
1856        assert!(run(&src).is_err(), "no bytes were supplied");
1857    }
1858}
1859
1860#[cfg(test)]
1861mod tier2_tests {
1862    use super::*;
1863    use crate::inputs::{Declaration, Inputs};
1864
1865    /// **The Tier-2 conversion §V.6.3 said was gated: a macro that emits real
1866    /// declarations FROM A SCHEMA.**
1867    ///
1868    /// `theory/BLUE.md` §VI OPEN #6 states the blocker plainly — "tenet 2
1869    /// installs a `NoLoader`, so a macro cannot read a schema — which gates
1870    /// every Tier-2 conversion in §V.6 and therefore blue's whole 'stronger than
1871    /// Ruby's metaprogramming' claim."
1872    ///
1873    /// Here the schema supplies a *value the generated code depends on*, read at
1874    /// expansion time. Ruby and Elixir can both do this — with the whole
1875    /// filesystem open. blue does it through a name bound to a content hash.
1876    #[test]
1877    fn a_macro_generates_code_from_a_schema() {
1878        let schema = b"7";
1879        let mut inputs = Inputs::new();
1880        inputs
1881            .bind(
1882                &Declaration {
1883                    name: "arity".to_string(),
1884                    hash: Inputs::hash_of(schema),
1885                },
1886                schema.to_vec(),
1887            )
1888            .expect("bind");
1889
1890        // The macro reads the input at EXPANSION time and splices the value it
1891        // found into the code it emits.
1892        let mut src = String::from("definput(\"arity\", \"");
1893        src.push_str(&Inputs::hash_of(schema));
1894        src.push_str("\")\n");
1895        src.push_str(
1896            "defmacro from_schema()\n  quote\n    unquote(to_int(input(\"arity\")))\n  end\nend\n\
1897             from_schema() * 6",
1898        );
1899
1900        let out = run_with_inputs(&src, inputs).expect("run");
1901        assert!(
1902            matches!(out.value, Value::Int(42)),
1903            "the schema's 7 must reach the generated code: got {:?}",
1904            out.value
1905        );
1906    }
1907}