fabro/lib/foundation/fabro-template/src/lib.rs
Bryan Helmkamp 467087998d
Read workflow graphs through Petri's DOT parser
Fabro's own DOT parser was left with one job after create-time compile
moved to Petri: walking a workflow's file references for the bundler and
the workflow-version store, and reading a name, a goal and two counts.
Petri's frontend parses the same language, so the parser goes and a small
crate reads the graph through Petri's.

`fabro-dot` is that crate: `WorkflowGraph::parse` over
`petri_frontend_attractor::dot` and its semantic model (defaults applied,
subgraphs flattened, chains expanded), `references(position)` as the one
walker over the static-reference vocabulary (each reference with its node
and position, file references checked to be template-free), and
`normalize_for_graphviz`, the re-emit of Fabro DOT with dotted attribute
keys quoted, which the SVG render needs. It sits beside `fabro-petri`
rather than inside it because `fabro-petri` depends on `fabro-workflow`,
which depends on `fabro-workflow-version`: the version store cannot reach
`fabro-petri` without a cycle, and the bundler should not pull the engine
in to read a graph.

Deleted: `fabro-graphviz`'s lexer, grammar, AST, semantic pass and
`parse_ast` (1,829 lines, plus the `nom` dependency); the DOT model in
`fabro-types::graph` (`Graph`, `Node`, `Edge`, `AttrValue`,
`shape_to_handler_type`), with only `ReferenceKind` kept, moved to
`fabro_types::reference`; `fabro-template`'s `visit_graph_references` and
the `GraphReference`/`GraphPosition` types, with the template-syntax rule
(`validate_static_reference`) kept there; the pull-request body's DOT
fallback summary, which was unreachable because the DOT source only
travels with the run spec whose display graph the summary already reads.
`fabro-graphviz` is now the render alone, over `fabro-dot`.

Parity: the old and new walkers were run over every `.fabro` and `.dot`
file in the repository (118) before the deletion. Every reference set is
identical. Five files differ in what Petri reads more correctly: a
backslash before a newline inside a quoted string is a line continuation
(four files, inline prompt text only), and a node named only by an edge
counts as a node (`test/edge_only_node.fabro`, 3 nodes rather than 2, so
the `fabro validate` snapshot moves). The checked-in bundles' shapes and
references are pinned by a snapshot in `fabro-dot`.

Co-Authored-By: Claude Fable 5.1 <noreply@anthropic.com>
2026-09-19 12:23:57 -04:00

1675 lines
53 KiB
Rust

use std::collections::HashMap;
use std::fmt;
use std::sync::{Arc, Mutex};
use fabro_types::ManifestPath;
use miette::{LabeledSpan, NamedSource, SourceCode, SourceSpan};
use minijinja::value::{Object, Value};
use minijinja::{AutoEscape, Environment, ErrorKind, UndefinedBehavior};
mod dependency;
mod static_reference;
mod store;
pub use dependency::{
ExtractedTemplateDependencies, TemplateDependency, TemplateDependencyClosure,
TemplateDependencyKind, TemplateDiscoveryError, discover_static_dependency_closure,
extract_template_dependencies,
};
pub use static_reference::{StaticReferenceError, validate_static_reference};
pub use store::{
BundleTemplateStore, CachedTemplateStore, FilesystemTemplateStore, RecordingTemplateStore,
TemplateIncludeResolver, TemplateLoadError, TemplateSource, TemplateSourceOrigin,
TemplateStore,
};
pub type TemplateLoader = Arc<dyn Fn(&str) -> Option<String> + Send + Sync>;
#[derive(Clone, Copy, Debug, PartialEq, Eq)]
pub enum TemplateRenderMode {
Strict,
Lenient,
}
impl TemplateRenderMode {
fn undefined_behavior(self) -> UndefinedBehavior {
match self {
Self::Strict => UndefinedBehavior::Strict,
Self::Lenient => UndefinedBehavior::Chainable,
}
}
}
#[derive(Clone, Debug, Default, PartialEq, Eq)]
pub struct TemplateErrorLocation {
pub source_name: Option<String>,
pub line: Option<u32>,
pub column: Option<u32>,
pub span_start: Option<usize>,
pub span_len: Option<usize>,
}
#[derive(Debug, Clone)]
pub struct TemplateContext {
goal: Option<String>,
inputs: Value,
vars: Value,
}
impl Default for TemplateContext {
fn default() -> Self {
Self {
goal: None,
inputs: Value::from_serialize(HashMap::<String, toml::Value>::new()),
vars: Value::from_serialize(HashMap::<String, String>::new()),
}
}
}
impl TemplateContext {
#[must_use]
pub fn new() -> Self {
Self::default()
}
#[must_use]
pub fn with_goal(mut self, goal: impl Into<String>) -> Self {
self.goal = Some(goal.into());
self
}
#[must_use]
pub fn with_inputs(mut self, inputs: HashMap<String, toml::Value>) -> Self {
self.inputs = Value::from_serialize(inputs);
self
}
/// Run-scoped `{{ vars.* }}` available to prompts and goals.
#[must_use]
pub fn with_vars(mut self, vars: HashMap<String, String>) -> Self {
self.vars = Value::from_serialize(vars);
self
}
/// Context exposed to a graph `model_stylesheet` template.
///
/// Stylesheets can use typed run inputs and run-scoped variables, but they
/// cannot read the rendered graph goal. Keep this as an explicit
/// projection so callers do not depend on when the goal enters the wider
/// workflow template context.
#[must_use]
pub fn for_model_stylesheet(&self) -> Self {
Self {
goal: None,
inputs: self.inputs.clone(),
vars: self.vars.clone(),
}
}
/// Context that interpolates inputs but leaves `{{ goal }}` as a literal
/// pass-through — used for structural pre-rendering before the goal is
/// known (e.g. manifest scanning, import resolution).
#[must_use]
pub fn for_input_scan(inputs: HashMap<String, toml::Value>) -> Self {
Self::new().with_goal("{{ goal }}").with_inputs(inputs)
}
/// The rendered goal `{{ goal }}` resolves to, or `None` before the goal
/// is known.
#[must_use]
pub fn goal(&self) -> Option<&str> {
self.goal.as_deref()
}
/// The text `{{ inputs.NAME }}` renders to, or `None` when unbound.
///
/// Non-template consumers — currently command node `script` interpolation,
/// which uses `InterpString` tokens rather than MiniJinja — read values
/// through here so an input produces the same text in a script as it does
/// in a prompt.
#[must_use]
pub fn input(&self, name: &str) -> Option<String> {
Self::rendered_member(&self.inputs, name)
}
/// The text `{{ vars.NAME }}` renders to, or `None` when unset.
#[must_use]
pub fn var(&self, name: &str) -> Option<String> {
Self::rendered_member(&self.vars, name)
}
fn rendered_member(container: &Value, name: &str) -> Option<String> {
let member = container.get_attr(name).ok()?;
(!member.is_undefined()).then(|| member.to_string())
}
fn into_value(self) -> Value {
let goal = self.goal.map(Value::from);
let inputs = self.inputs;
let vars = self.vars;
Value::from_object(RenderContext { goal, inputs, vars })
}
}
#[derive(Debug, Clone)]
struct RenderContext {
goal: Option<Value>,
inputs: Value,
vars: Value,
}
impl Object for RenderContext {
fn get_value_by_str(self: &Arc<Self>, key: &str) -> Option<Value> {
match key {
"goal" => self.goal.clone(),
"inputs" => Some(self.inputs.clone()),
"vars" => Some(self.vars.clone()),
_ => None,
}
}
}
/// Errors from rendering a template. Each variant carries the typed fields
/// MiniJinja knows about (offending expression, line) plus the original
/// `minijinja::Error` as `#[source]`, so the cause chain is preserved across
/// boundaries that walk `Error::source()` (anyhow, miette, `collect_chain`).
#[derive(Debug)]
pub enum TemplateError {
LoaderDependentString {
source_name: Option<String>,
tag: TemplateDependencyKind,
},
Load {
source_name: Option<String>,
source: Box<TemplateLoadError>,
},
Syntax {
line: Option<u32>,
source_name: Option<String>,
source_text: Option<Arc<str>>,
span: Option<SourceSpan>,
source_code: Option<Box<NamedSource<Arc<str>>>>,
source: Box<minijinja::Error>,
},
UndefinedVariable {
expression: Option<String>,
line: Option<u32>,
source_name: Option<String>,
source_text: Option<Arc<str>>,
span: Option<SourceSpan>,
source_code: Option<Box<NamedSource<Arc<str>>>>,
source: Box<minijinja::Error>,
},
Render {
line: Option<u32>,
source_name: Option<String>,
source_text: Option<Arc<str>>,
span: Option<SourceSpan>,
source_code: Option<Box<NamedSource<Arc<str>>>>,
source: Box<minijinja::Error>,
},
}
impl fmt::Display for TemplateError {
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
match self {
Self::LoaderDependentString { tag, .. } => {
write!(
f,
"loader-dependent template tag `{tag:?}` requires a rooted template source"
)
}
Self::Load { .. } => write!(f, "template load error"),
Self::Syntax { line, .. } => {
write!(f, "template syntax error{}", fmt_location(*line))
}
Self::UndefinedVariable {
expression, line, ..
} => write!(
f,
"undefined template variable{}{}",
fmt_expr(expression.as_deref()),
fmt_location(*line)
),
Self::Render { line, .. } => {
write!(f, "template render error{}", fmt_location(*line))
}
}
}
}
impl std::error::Error for TemplateError {
fn source(&self) -> Option<&(dyn std::error::Error + 'static)> {
match self {
Self::LoaderDependentString { .. } => None,
Self::Load { source, .. } => Some(source.as_ref()),
Self::Syntax { source, .. }
| Self::UndefinedVariable { source, .. }
| Self::Render { source, .. } => Some(source.as_ref()),
}
}
}
fn fmt_expr(expression: Option<&str>) -> String {
expression.map(|e| format!(" `{e}`")).unwrap_or_default()
}
fn fmt_location(line: Option<u32>) -> String {
line.map(|l| format!(" at line {l}")).unwrap_or_default()
}
/// Extract the failing expression from the template source using the byte
/// range MiniJinja attaches to errors when debug mode is on.
fn extract_expression(error: &minijinja::Error) -> Option<String> {
let range = error.range()?;
let source = error.template_source()?;
Some(source.get(range)?.trim().to_owned())
}
struct MiniJinjaErrorDetails {
line: Option<u32>,
source_name: Option<String>,
source_text: Option<Arc<str>>,
span: Option<SourceSpan>,
source_code: Option<Box<NamedSource<Arc<str>>>>,
}
impl MiniJinjaErrorDetails {
fn from_error(error: &minijinja::Error, origin: Option<&TemplateSourceOrigin>) -> Self {
let source_name = error.name().map(str::to_owned);
let mut source_text = error.template_source().map(Arc::<str>::from);
let mut line = error.line().and_then(|n| u32::try_from(n).ok());
let mut span_start = None;
let mut span_len = None;
if let Some(range) = error.range() {
let start = range.start;
let len = range.end.checked_sub(range.start);
if let Some(len) = len {
span_start = Some(start);
span_len = Some(len);
}
}
if let (Some(origin), Some(fragment_start), Some(len)) = (origin, span_start, span_len) {
if let Some(start) = origin.fragment_start().checked_add(fragment_start) {
if let Some((origin_line, _)) = source_position(origin.source_text(), start) {
source_text = Some(origin.clone_source_text());
line = Some(origin_line);
span_start = Some(start);
span_len = Some(len);
}
}
}
let span = span_start
.zip(span_len)
.map(|(start, len)| (start, len).into());
let source_code = source_name
.as_ref()
.zip(source_text.as_ref())
.map(|(name, source)| Box::new(NamedSource::new(name.clone(), Arc::clone(source))));
Self {
line,
source_name,
source_text,
span,
source_code,
}
}
}
fn source_position(source_text: &str, offset: usize) -> Option<(u32, u32)> {
if offset > source_text.len() || !source_text.is_char_boundary(offset) {
return None;
}
let line = source_text[..offset]
.bytes()
.filter(|byte| *byte == b'\n')
.count()
+ 1;
let line_start = source_text[..offset]
.rfind('\n')
.map_or(0, |index| index + 1);
let column = source_text[line_start..offset].chars().count() + 1;
Some((u32::try_from(line).ok()?, u32::try_from(column).ok()?))
}
fn primary_template_error(error: &minijinja::Error) -> &minijinja::Error {
let mut selected = matches!(
error.kind(),
ErrorKind::SyntaxError | ErrorKind::UndefinedError
)
.then_some(error);
let mut current = error as &(dyn std::error::Error + 'static);
while let Some(source) = current.source() {
if let Some(template_error) = source.downcast_ref::<minijinja::Error>() {
if matches!(
template_error.kind(),
ErrorKind::SyntaxError | ErrorKind::UndefinedError
) {
selected = Some(template_error);
}
}
current = source;
}
selected.unwrap_or(error)
}
/// Converts a MiniJinja error into Fabro's template boundary error.
///
/// MiniJinja wraps semantic failures with operation-specific errors for
/// include/import/extends rendering. Fabro classifies by the deepest semantic
/// MiniJinja cause while storing the original outer error as the source, so
/// renderers that walk the chain still show wrapper context.
impl From<minijinja::Error> for TemplateError {
fn from(error: minijinja::Error) -> Self {
Self::from_minijinja(error, None)
}
}
impl TemplateError {
fn from_minijinja(
error: minijinja::Error,
origin: Option<(&str, &TemplateSourceOrigin)>,
) -> Self {
let primary = primary_template_error(&error);
let primary_origin = origin.and_then(|(source_name, origin)| {
(primary.name() == Some(source_name)).then_some(origin)
});
let details = MiniJinjaErrorDetails::from_error(primary, primary_origin);
match primary.kind() {
ErrorKind::SyntaxError => Self::Syntax {
line: details.line,
source_name: details.source_name,
source_text: details.source_text,
span: details.span,
source_code: details.source_code,
source: Box::new(error),
},
ErrorKind::UndefinedError => {
let expression = extract_expression(primary);
Self::UndefinedVariable {
expression,
line: details.line,
source_name: details.source_name,
source_text: details.source_text,
span: details.span,
source_code: details.source_code,
source: Box::new(error),
}
}
_ => {
let render_origin = origin.and_then(|(source_name, origin)| {
(error.name() == Some(source_name)).then_some(origin)
});
let details = MiniJinjaErrorDetails::from_error(&error, render_origin);
Self::Render {
line: details.line,
source_name: details.source_name,
source_text: details.source_text,
span: details.span,
source_code: details.source_code,
source: Box::new(error),
}
}
}
}
#[must_use]
pub fn expression(&self) -> Option<&str> {
match self {
Self::UndefinedVariable { expression, .. } => expression.as_deref(),
Self::LoaderDependentString { .. }
| Self::Load { .. }
| Self::Syntax { .. }
| Self::Render { .. } => None,
}
}
#[must_use]
pub fn location(&self) -> TemplateErrorLocation {
let span = self.span();
TemplateErrorLocation {
source_name: self.source_name().map(ToOwned::to_owned),
line: self.line(),
column: self.column(),
span_start: span.map(|span| span.offset()),
span_len: span.map(|span| span.len()),
}
}
#[must_use]
pub fn line(&self) -> Option<u32> {
match self {
Self::LoaderDependentString { .. } | Self::Load { .. } => None,
Self::Syntax { line, .. }
| Self::UndefinedVariable { line, .. }
| Self::Render { line, .. } => *line,
}
}
#[must_use]
pub fn source_name(&self) -> Option<&str> {
match self {
Self::LoaderDependentString { source_name, .. } | Self::Load { source_name, .. } => {
source_name.as_deref()
}
Self::Syntax { source_name, .. }
| Self::UndefinedVariable { source_name, .. }
| Self::Render { source_name, .. } => source_name.as_deref(),
}
}
#[must_use]
pub fn source_text(&self) -> Option<&str> {
match self {
Self::LoaderDependentString { .. } | Self::Load { .. } => None,
Self::Syntax { source_text, .. }
| Self::UndefinedVariable { source_text, .. }
| Self::Render { source_text, .. } => source_text.as_deref(),
}
}
#[must_use]
pub fn span(&self) -> Option<SourceSpan> {
match self {
Self::LoaderDependentString { .. } | Self::Load { .. } => None,
Self::Syntax { span, .. }
| Self::UndefinedVariable { span, .. }
| Self::Render { span, .. } => *span,
}
}
#[must_use]
pub fn column(&self) -> Option<u32> {
let source_text = self.source_text()?;
let offset = self.span()?.offset();
source_position(source_text, offset).map(|(_, column)| column)
}
fn source_code_ref(&self) -> Option<&NamedSource<Arc<str>>> {
match self {
Self::LoaderDependentString { .. } | Self::Load { .. } => None,
Self::Syntax { source_code, .. }
| Self::UndefinedVariable { source_code, .. }
| Self::Render { source_code, .. } => source_code.as_deref(),
}
}
}
impl miette::Diagnostic for TemplateError {
fn code<'a>(&'a self) -> Option<Box<dyn fmt::Display + 'a>> {
let code = match self {
Self::LoaderDependentString { .. } => "fabro::template::loader_dependent_string",
Self::Load { .. } => "fabro::template::load",
Self::Syntax { .. } => "fabro::template::syntax",
Self::UndefinedVariable { .. } => "fabro::template::undefined_variable",
Self::Render { .. } => "fabro::template::render",
};
Some(Box::new(code))
}
fn source_code(&self) -> Option<&dyn SourceCode> {
self.source_code_ref()
.map(|source| source as &dyn SourceCode)
}
fn labels(&self) -> Option<Box<dyn Iterator<Item = LabeledSpan> + '_>> {
let span = self.span()?;
let label = match self {
Self::LoaderDependentString { .. } => "loader-dependent tag".to_string(),
Self::Load { .. } => "template load".to_string(),
Self::UndefinedVariable { expression, .. } => expression.as_ref().map_or_else(
|| "undefined variable".to_string(),
|expr| format!("`{expr}`"),
),
Self::Syntax { .. } => "syntax error".to_string(),
Self::Render { .. } => "render error".to_string(),
};
Some(Box::new(
vec![LabeledSpan::new_primary_with_span(Some(label), span)].into_iter(),
))
}
}
/// Returns `true` when the string contains MiniJinja delimiter syntax.
#[must_use]
pub fn contains_template_syntax(template: &str) -> bool {
template.contains("{{") || template.contains("{%") || template.contains("{#")
}
/// Whether `template` references `name` as a top-level variable.
///
/// Used by the goal self-reference lint: a graph `goal` may not reference
/// itself. Returns `false` for templates that fail to parse — syntax errors
/// surface through the normal render path with proper diagnostics.
#[must_use]
pub fn references_top_level_variable(template: &str, name: &str) -> bool {
if is_plain_text(template) || !template.contains(name) {
return false;
}
let mut env = Environment::new();
if env.add_template("__variable_scan__", template).is_err() {
return false;
}
env.get_template("__variable_scan__")
.is_ok_and(|tmpl| tmpl.undeclared_variables(false).contains(name))
}
/// Returns `true` when the string contains no MiniJinja delimiters and can
/// be returned as-is without paying for a full template parse+render cycle.
fn is_plain_text(template: &str) -> bool {
!contains_template_syntax(template)
}
pub fn render(template: &str, ctx: &TemplateContext) -> Result<String, TemplateError> {
render_with(None, template, ctx, UndefinedBehavior::Strict, None, None)
}
pub fn render_named(
name: impl Into<String>,
template: &str,
ctx: &TemplateContext,
) -> Result<String, TemplateError> {
render_named_with_origin(name, template, ctx, TemplateRenderMode::Strict, None)
}
pub fn render_named_fragment(
name: impl Into<String>,
template: &str,
origin: &TemplateSourceOrigin,
ctx: &TemplateContext,
) -> Result<String, TemplateError> {
render_named_with_origin(
name,
template,
ctx,
TemplateRenderMode::Strict,
Some(origin),
)
}
pub fn render_named_with_origin(
name: impl Into<String>,
template: &str,
ctx: &TemplateContext,
mode: TemplateRenderMode,
origin: Option<&TemplateSourceOrigin>,
) -> Result<String, TemplateError> {
let name = name.into();
render_with(
Some(&name),
template,
ctx,
mode.undefined_behavior(),
None,
origin,
)
}
pub fn render_named_with_loader(
name: impl Into<String>,
template: &str,
ctx: &TemplateContext,
loader: &TemplateLoader,
) -> Result<String, TemplateError> {
let name = name.into();
render_with(
Some(&name),
template,
ctx,
UndefinedBehavior::Strict,
Some(loader),
None,
)
}
/// Render with chainable undefined handling: undefined variables and attribute
/// chains render as empty strings instead of erroring. Use for structural
/// passes (e.g. manifest scanning, `fabro validate` on a bare `.fabro`) where
/// the user has not yet bound inputs — strict checking happens elsewhere.
pub fn render_lenient(template: &str, ctx: &TemplateContext) -> Result<String, TemplateError> {
render_with(
None,
template,
ctx,
UndefinedBehavior::Chainable,
None,
None,
)
}
pub fn render_lenient_named(
name: impl Into<String>,
template: &str,
ctx: &TemplateContext,
) -> Result<String, TemplateError> {
render_named_with_origin(name, template, ctx, TemplateRenderMode::Lenient, None)
}
pub fn render_lenient_named_fragment(
name: impl Into<String>,
template: &str,
origin: &TemplateSourceOrigin,
ctx: &TemplateContext,
) -> Result<String, TemplateError> {
render_named_with_origin(
name,
template,
ctx,
TemplateRenderMode::Lenient,
Some(origin),
)
}
pub fn render_lenient_named_with_loader(
name: impl Into<String>,
template: &str,
ctx: &TemplateContext,
loader: &TemplateLoader,
) -> Result<String, TemplateError> {
let name = name.into();
render_with(
Some(&name),
template,
ctx,
UndefinedBehavior::Chainable,
Some(loader),
None,
)
}
fn render_with(
name: Option<&str>,
template: &str,
ctx: &TemplateContext,
undefined: UndefinedBehavior,
loader: Option<&TemplateLoader>,
origin: Option<&TemplateSourceOrigin>,
) -> Result<String, TemplateError> {
if is_plain_text(template) {
return Ok(template.to_owned());
}
if loader.is_none() {
reject_loader_dependent_string(name, template)?;
}
let mut env = Environment::new();
env.set_undefined_behavior(undefined);
env.set_auto_escape_callback(|_| AutoEscape::None);
env.set_debug(true);
if let Some(loader) = loader {
let loader = Arc::clone(loader);
env.set_loader(move |name| Ok(loader(name)));
}
let origin = name.zip(origin);
match name {
Some(name) => env.render_named_str(name, template, ctx.clone().into_value()),
None => env.render_str(template, ctx.clone().into_value()),
}
.map_err(|error| TemplateError::from_minijinja(error, origin))
}
pub fn render_source(
source: &TemplateSource,
ctx: &TemplateContext,
store: Arc<dyn TemplateStore>,
mode: TemplateRenderMode,
) -> Result<String, TemplateError> {
render_rooted_source(source, ctx, store, mode.undefined_behavior())
}
fn render_rooted_source(
source: &TemplateSource,
ctx: &TemplateContext,
store: Arc<dyn TemplateStore>,
undefined: UndefinedBehavior,
) -> Result<String, TemplateError> {
if is_plain_text(&source.content) {
return Ok(source.content.clone());
}
let mut env = Environment::new();
env.set_undefined_behavior(undefined);
env.set_auto_escape_callback(|_| AutoEscape::None);
env.set_debug(true);
let root = source.root.clone();
env.set_path_join_callback(move |name, parent| {
joined_template_path(&root, name, parent).into()
});
let load_error = Arc::new(Mutex::new(None));
let loader_error = Arc::clone(&load_error);
let loader_parent = TemplateSource::new(
ManifestPath::from_wire(".").expect("root manifest path should parse"),
source.root.clone(),
String::new(),
);
env.set_loader(move |name| match store.load(&loader_parent, name) {
Ok(source) => Ok(source.map(|source| source.content)),
Err(error) => {
*loader_error
.lock()
.expect("template load error mutex should not be poisoned") = Some(error);
Err(minijinja::Error::new(
ErrorKind::InvalidOperation,
"template load failed",
))
}
});
let source_name = source.path.to_string();
let origin = source
.origin
.as_ref()
.map(|origin| (source_name.as_str(), origin));
env.render_named_str(&source_name, &source.content, ctx.clone().into_value())
.map_err(|error| {
if let Some(error) = load_error
.lock()
.expect("template load error mutex should not be poisoned")
.take()
{
TemplateError::Load {
source_name: Some(source.path.to_string()),
source: Box::new(error),
}
} else {
TemplateError::from_minijinja(error, origin)
}
})
}
fn joined_template_path(root: &ManifestPath, name: &str, parent: &str) -> String {
let Some(parent) = ManifestPath::from_wire(parent) else {
return name.to_owned();
};
TemplateIncludeResolver::new(root.clone())
.resolve(&parent, name)
.map_or_else(|_| name.to_owned(), |path| path.to_string())
}
fn reject_loader_dependent_string(name: Option<&str>, template: &str) -> Result<(), TemplateError> {
let source_name = name.unwrap_or("string");
if let Some(tag) = dependency::has_loader_dependent_tags(source_name, template)? {
return Err(TemplateError::LoaderDependentString {
source_name: name.map(ToOwned::to_owned),
tag,
});
}
Ok(())
}
#[cfg(test)]
mod tests {
use std::collections::HashMap;
use fabro_util::error;
use toml::map::Map;
use super::*;
fn manifest_path(value: &str) -> ManifestPath {
ManifestPath::from_wire(value).expect("path should parse")
}
fn bundle_store(files: &[(&str, &str)]) -> Arc<dyn TemplateStore> {
Arc::new(BundleTemplateStore::new(
files
.iter()
.map(|(path, content)| (manifest_path(path), (*content).to_string()))
.collect(),
))
}
#[test]
fn renders_simple_goal_variable() {
let ctx = TemplateContext::new().with_goal("Fix bugs");
let rendered = render("Goal: {{ goal }}", &ctx).unwrap();
assert_eq!(rendered, "Goal: Fix bugs");
}
#[test]
fn workflow_values_return_none_when_unbound() {
let ctx = TemplateContext::new();
assert_eq!(ctx.goal(), None);
assert_eq!(ctx.input("missing"), None);
assert_eq!(ctx.var("MISSING"), None);
}
#[test]
fn goal_returns_the_rendered_value() {
let ctx = TemplateContext::new().with_goal("Ship it");
assert_eq!(ctx.goal(), Some("Ship it"));
}
/// `input`/`var` exist so non-template consumers render a value the same
/// way a prompt does. Pin that equivalence across the scalar TOML types.
#[test]
fn input_matches_what_a_template_renders() {
let ctx = TemplateContext::new().with_inputs(HashMap::from([
("name".to_string(), toml::Value::String("fabro".into())),
("attempts".to_string(), toml::Value::Integer(3)),
("ratio".to_string(), toml::Value::Float(1.5)),
("fast".to_string(), toml::Value::Boolean(true)),
]));
for name in ["name", "attempts", "ratio", "fast"] {
let rendered = render(&format!("{{{{ inputs.{name} }}}}"), &ctx).unwrap();
assert_eq!(ctx.input(name), Some(rendered), "mismatch for `{name}`");
}
}
#[test]
fn var_matches_what_a_template_renders() {
let ctx = TemplateContext::new().with_vars(HashMap::from([(
"STAGE".to_string(),
"staging".to_string(),
)]));
assert_eq!(ctx.var("STAGE").as_deref(), Some("staging"));
assert_eq!(
ctx.var("STAGE"),
Some(render("{{ vars.STAGE }}", &ctx).unwrap())
);
}
#[test]
fn model_stylesheet_context_exposes_only_inputs_and_vars() {
let ctx = TemplateContext::new()
.with_goal("Ship it")
.with_inputs(HashMap::from([(
"policy".to_string(),
toml::Value::Table(Map::from_iter([(
"effort".to_string(),
toml::Value::String("high".to_string()),
)])),
)]))
.with_vars(HashMap::from([("MODEL".to_string(), "sonnet".to_string())]));
let stylesheet_ctx = ctx.for_model_stylesheet();
assert_eq!(
render(
"{{ inputs.policy.effort }} {{ vars.MODEL }}",
&stylesheet_ctx,
)
.unwrap(),
"high sonnet"
);
assert!(matches!(
render("{{ goal }}", &stylesheet_ctx),
Err(TemplateError::UndefinedVariable { .. })
));
}
#[test]
fn model_stylesheet_context_preserves_template_locals_and_control_flow() {
let ctx = TemplateContext::new().for_model_stylesheet();
let template = "{% set efforts = ['low', 'high'] %}{% for effort in efforts %}{{ loop.index }}={{ effort }}{% if not loop.last %};{% endif %}{% endfor %}";
assert_eq!(render(template, &ctx).unwrap(), "1=low;2=high");
}
#[test]
fn references_top_level_variable_detects_goal_self_reference() {
assert!(references_top_level_variable("Do {{ goal }} now", "goal"));
assert!(references_top_level_variable("{{ goal.title }}", "goal"));
assert!(!references_top_level_variable(
"Fix {{ inputs.bug }}",
"goal"
));
assert!(!references_top_level_variable(
"plain text, no goal token",
"goal"
));
assert!(!references_top_level_variable(
"{# {{ goal }} is commented out #}",
"goal"
));
}
#[test]
fn renders_vars_variable() {
let ctx = TemplateContext::new().with_vars(HashMap::from([(
"SERVICE".to_string(),
"billing".to_string(),
)]));
let rendered = render("Service: {{ vars.SERVICE }}", &ctx).unwrap();
assert_eq!(rendered, "Service: billing");
}
#[test]
fn unknown_vars_member_is_strict_error() {
let ctx = TemplateContext::new().with_vars(HashMap::from([(
"SERVICE".to_string(),
"billing".to_string(),
)]));
let err = render("{{ vars.MISSING }}", &ctx).unwrap_err();
assert!(err.to_string().to_lowercase().contains("undefined"));
}
#[test]
fn renders_typed_input_values() {
let ctx = TemplateContext::new().with_inputs(HashMap::from([
("enabled".to_string(), toml::Value::Boolean(true)),
("count".to_string(), toml::Value::Integer(3)),
]));
let rendered = render(
"{% if inputs.enabled %}count={{ inputs.count }}{% endif %}",
&ctx,
)
.unwrap();
assert_eq!(rendered, "count=3");
}
#[test]
fn renders_nested_input_variable() {
let ctx = TemplateContext::new().with_inputs(HashMap::from([(
"repo".to_string(),
toml::Value::Table(Map::from_iter([(
"name".to_string(),
toml::Value::String("fabro".to_string()),
)])),
)]));
let rendered = render("Repo {{ inputs.repo.name }}", &ctx).unwrap();
assert_eq!(rendered, "Repo fabro");
}
#[test]
fn render_lenient_treats_undefined_as_empty() {
let ctx = TemplateContext::new();
let rendered = render_lenient("before [{{ inputs.app_dir }}] after", &ctx).unwrap();
assert_eq!(rendered, "before [] after");
}
#[test]
fn render_lenient_still_errors_on_syntax_problems() {
let ctx = TemplateContext::new();
let err = render_lenient("{{ unterminated", &ctx).unwrap_err();
assert!(matches!(err, TemplateError::Syntax { .. }));
}
#[test]
fn render_named_reports_source_name_expression_and_span() {
let ctx = TemplateContext::new();
let err = render_named("prompts/test.md", "Hello {{ inputs.foo }}", &ctx).unwrap_err();
let TemplateError::UndefinedVariable {
expression,
line,
source_name,
span,
..
} = err
else {
panic!("expected undefined variable error");
};
assert_eq!(expression.as_deref(), Some("inputs.foo"));
assert_eq!(line, Some(1));
assert_eq!(source_name.as_deref(), Some("prompts/test.md"));
assert!(span.is_some());
}
#[test]
fn render_named_with_loader_supports_include() {
let ctx = TemplateContext::new();
let loader: TemplateLoader =
Arc::new(|name| (name == "partial.md").then(|| "included content".to_string()));
let rendered =
render_named_with_loader("prompt.md", r#"{% include "partial.md" %}"#, &ctx, &loader)
.unwrap();
assert_eq!(rendered, "included content");
}
#[test]
fn render_source_supports_rooted_include() {
let ctx = TemplateContext::new();
let source = TemplateSource::new(
manifest_path("prompts/main.md"),
manifest_path("prompts"),
r#"{% include "partial.md" %}"#,
);
let rendered = render_source(
&source,
&ctx,
bundle_store(&[("prompts/partial.md", "included content")]),
TemplateRenderMode::Strict,
)
.unwrap();
assert_eq!(rendered, "included content");
}
fn assert_semantic_undefined_error(
err: &TemplateError,
expected_source: &str,
expected_source_text: &str,
) {
let TemplateError::UndefinedVariable { expression, .. } = err else {
panic!("expected undefined variable error, got {err:?}");
};
assert_eq!(expression.as_deref(), Some("inputs.hello"));
let location = err.location();
assert_eq!(location.source_name.as_deref(), Some(expected_source));
assert_eq!(location.line, Some(1));
assert_eq!(
location.span_start,
expected_source_text.find("inputs.hello")
);
assert_eq!(location.span_len, Some("inputs.hello".len()));
let chain = error::collect_chain(err);
assert!(
chain.iter().any(|cause| cause.contains("undefined value")),
"missing undefined cause in source chain: {chain:?}"
);
assert!(
chain
.iter()
.skip(1)
.any(|cause| cause.contains(expected_source)),
"missing source context in source chain: {chain:?}"
);
}
#[test]
fn render_source_reports_undefined_variable_from_include() {
let ctx = TemplateContext::new();
let source = TemplateSource::new(
manifest_path("prompts/main.md"),
manifest_path("prompts"),
r#"{% include "partial.md" %}"#,
);
let err = render_source(
&source,
&ctx,
bundle_store(&[("prompts/partial.md", "{{ inputs.hello }}")]),
TemplateRenderMode::Strict,
)
.unwrap_err();
assert_semantic_undefined_error(&err, "prompts/partial.md", "{{ inputs.hello }}");
}
#[test]
fn render_source_reports_undefined_variable_from_imported_macro() {
let ctx = TemplateContext::new();
let source = TemplateSource::new(
manifest_path("prompts/main.md"),
manifest_path("prompts"),
r#"{% import "macros.md" as macros %}{{ macros.greet() }}"#,
);
let err = render_source(
&source,
&ctx,
bundle_store(&[(
"prompts/macros.md",
r"{% macro greet() %}{{ inputs.hello }}{% endmacro %}",
)]),
TemplateRenderMode::Strict,
)
.unwrap_err();
assert_semantic_undefined_error(
&err,
"prompts/macros.md",
r"{% macro greet() %}{{ inputs.hello }}{% endmacro %}",
);
}
#[test]
fn render_source_reports_undefined_variable_from_from_imported_macro() {
let ctx = TemplateContext::new();
let source = TemplateSource::new(
manifest_path("prompts/main.md"),
manifest_path("prompts"),
r#"{% from "macros.md" import greet %}{{ greet() }}"#,
);
let err = render_source(
&source,
&ctx,
bundle_store(&[(
"prompts/macros.md",
r"{% macro greet() %}{{ inputs.hello }}{% endmacro %}",
)]),
TemplateRenderMode::Strict,
)
.unwrap_err();
assert_semantic_undefined_error(
&err,
"prompts/macros.md",
r"{% macro greet() %}{{ inputs.hello }}{% endmacro %}",
);
}
#[test]
fn render_source_reports_undefined_variable_from_extended_layout() {
let ctx = TemplateContext::new();
let source = TemplateSource::new(
manifest_path("pages/main.md"),
manifest_path("pages"),
r#"{% extends "layout.md" %}{% block body %}Body{% endblock %}"#,
);
let err = render_source(
&source,
&ctx,
bundle_store(&[(
"pages/layout.md",
"{{ inputs.hello }}:{% block body %}{% endblock %}",
)]),
TemplateRenderMode::Strict,
)
.unwrap_err();
assert_semantic_undefined_error(
&err,
"pages/layout.md",
"{{ inputs.hello }}:{% block body %}{% endblock %}",
);
}
#[test]
fn render_named_fragment_reports_location_in_full_source() {
let ctx = TemplateContext::new();
let source_text = "digraph {\n plan [prompt=\"Hello {{ inputs.name }}\"]\n}\n";
let fragment = "Hello {{ inputs.name }}";
let origin = TemplateSourceOrigin::from_first_fragment_match(source_text, fragment)
.expect("fragment should be present in source");
let err = render_named_fragment("workflow.fabro", fragment, &origin, &ctx).unwrap_err();
let location = err.location();
assert_eq!(location.source_name.as_deref(), Some("workflow.fabro"));
assert_eq!(location.line, Some(2));
assert_eq!(location.column, Some(26));
assert_eq!(location.span_start, source_text.find("inputs.name"));
assert_eq!(location.span_len, Some("inputs.name".len()));
assert_eq!(
err.span().map(|span| span.offset()),
source_text.find("inputs.name")
);
}
#[test]
fn render_source_supports_nested_include() {
let ctx = TemplateContext::new();
let source = TemplateSource::new(
manifest_path("prompts/main.md"),
manifest_path("prompts"),
r#"{% include "partial.md" %}"#,
);
let rendered = render_source(
&source,
&ctx,
bundle_store(&[
("prompts/partial.md", r#"{% include "nested.md" %}"#),
("prompts/nested.md", "nested content"),
]),
TemplateRenderMode::Strict,
)
.unwrap();
assert_eq!(rendered, "nested content");
}
#[test]
fn render_source_supports_extends() {
let ctx = TemplateContext::new();
let source = TemplateSource::new(
manifest_path("pages/main.md"),
manifest_path("pages"),
r#"{% extends "layout.md" %}{% block body %}Body{% endblock %}"#,
);
let rendered = render_source(
&source,
&ctx,
bundle_store(&[(
"pages/layout.md",
"prefix:{% block body %}{% endblock %}:suffix",
)]),
TemplateRenderMode::Strict,
)
.unwrap();
assert_eq!(rendered, "prefix:Body:suffix");
}
#[test]
fn render_source_supports_import() {
let ctx = TemplateContext::new();
let source = TemplateSource::new(
manifest_path("prompts/main.md"),
manifest_path("prompts"),
r#"{% import "macros.md" as macros %}{{ macros.greet("Ada") }}"#,
);
let rendered = render_source(
&source,
&ctx,
bundle_store(&[(
"prompts/macros.md",
r"{% macro greet(name) %}hi {{ name }}{% endmacro %}",
)]),
TemplateRenderMode::Strict,
)
.unwrap();
assert_eq!(rendered, "hi Ada");
}
#[test]
fn render_source_supports_from_import() {
let ctx = TemplateContext::new();
let source = TemplateSource::new(
manifest_path("prompts/main.md"),
manifest_path("prompts"),
r#"{% from "macros.md" import greet %}{{ greet("Ada") }}"#,
);
let rendered = render_source(
&source,
&ctx,
bundle_store(&[(
"prompts/macros.md",
r"{% macro greet(name) %}hi {{ name }}{% endmacro %}",
)]),
TemplateRenderMode::Strict,
)
.unwrap();
assert_eq!(rendered, "hi Ada");
}
#[test]
fn render_source_rejects_unsafe_include() {
let ctx = TemplateContext::new();
let source = TemplateSource::new(
manifest_path("prompts/main.md"),
manifest_path("prompts"),
r#"{% include "../outside.md" %}"#,
);
let store: Arc<dyn TemplateStore> = Arc::new(BundleTemplateStore::new(HashMap::new()));
let err = render_source(&source, &ctx, store, TemplateRenderMode::Strict).unwrap_err();
assert!(matches!(
err,
TemplateError::Load {
source,
..
} if matches!(*source, TemplateLoadError::EscapesRoot { .. })
));
}
#[test]
fn render_source_uses_source_root_for_sibling_include() {
let ctx = TemplateContext::new();
let source = TemplateSource::new(
manifest_path("prompts/audits/audit.prompt.md"),
manifest_path("prompts"),
r#"{% include "../partials/audit.partial.tpl" %}"#,
);
let rendered = render_source(
&source,
&ctx,
Arc::new(BundleTemplateStore::new(HashMap::from([(
manifest_path("prompts/partials/audit.partial.tpl"),
"shared partial".to_string(),
)]))),
TemplateRenderMode::Strict,
)
.unwrap();
assert_eq!(rendered, "shared partial");
}
#[test]
fn render_named_rejects_loader_dependent_tags_without_root() {
let ctx = TemplateContext::new();
let err = render_named("main.md", r#"{% include "partial.md" %}"#, &ctx).unwrap_err();
assert!(matches!(err, TemplateError::LoaderDependentString { .. }));
}
#[test]
fn extractor_ignores_comments_raw_blocks_and_plain_text() {
let source = r#"
{# {% include "comment.md" %} #}
{% raw %}{% include "raw.md" %}{% endraw %}
text {% include "text.md" %}
"#;
let dependencies = extract_template_dependencies("test.md", source).unwrap();
assert_eq!(dependencies.static_references, vec![TemplateDependency {
kind: TemplateDependencyKind::Include,
reference: "text.md".to_string(),
}]);
assert!(dependencies.dynamic_references.is_empty());
}
#[test]
fn static_dependency_closure_collects_both_branches() {
let source = TemplateSource::new(
manifest_path("main.md"),
manifest_path("."),
r#"{% if inputs.use_a %}{% include "a.md" %}{% else %}{% include "b.md" %}{% endif %}"#,
);
let closure = discover_static_dependency_closure(
[source],
bundle_store(&[("a.md", "A"), ("b.md", "B")]).as_ref(),
)
.unwrap();
assert!(closure.sources.contains_key(&manifest_path("a.md")));
assert!(closure.sources.contains_key(&manifest_path("b.md")));
}
#[test]
fn static_dependency_closure_collects_unused_macro_body_dependencies() {
let source = TemplateSource::new(
manifest_path("main.md"),
manifest_path("."),
r#"{% from "helpers.md" import render_advanced_prompt %}"#,
);
let closure = discover_static_dependency_closure(
[source],
bundle_store(&[
(
"helpers.md",
r#"{% macro render_advanced_prompt() %}{% include "advanced.md" %}{% endmacro %}"#,
),
("advanced.md", "advanced"),
])
.as_ref(),
)
.unwrap();
assert!(closure.sources.contains_key(&manifest_path("helpers.md")));
assert!(closure.sources.contains_key(&manifest_path("advanced.md")));
}
#[test]
fn static_dependency_closure_rejects_dynamic_include() {
let source = TemplateSource::new(
manifest_path("main.md"),
manifest_path("."),
r"{% include inputs.partial %}",
);
let err =
discover_static_dependency_closure([source], bundle_store(&[]).as_ref()).unwrap_err();
assert!(matches!(err, TemplateDiscoveryError::Dynamic { .. }));
}
#[test]
fn static_dependency_closure_visits_colliding_root_occurrences() {
let roots = [
TemplateSource::new(manifest_path("workflow.fabro"), manifest_path("."), "valid"),
TemplateSource::new(
manifest_path("workflow.fabro"),
manifest_path("."),
r"{% include inputs.partial %}",
),
];
let error =
discover_static_dependency_closure(roots, bundle_store(&[]).as_ref()).unwrap_err();
assert!(matches!(
error,
TemplateDiscoveryError::Dynamic { parent }
if parent == manifest_path("workflow.fabro")
));
}
#[test]
fn static_dependency_closure_parses_dependencies_shadowed_by_root_paths() {
// An inline root anchored at its graph file's path must not shadow the
// file itself when another template includes it: the loaded file
// content still gets parsed.
let roots = [
TemplateSource::new(manifest_path("workflow.fabro"), manifest_path("."), "valid"),
TemplateSource::new(
manifest_path("goal.md"),
manifest_path("."),
r#"{% include "workflow.fabro" %}"#,
),
];
let error = discover_static_dependency_closure(
roots,
bundle_store(&[("workflow.fabro", r#"{% include "missing.md" %}"#)]).as_ref(),
)
.unwrap_err();
assert!(matches!(
error,
TemplateDiscoveryError::Missing { parent, reference }
if parent == manifest_path("workflow.fabro") && reference == "missing.md"
));
}
#[test]
fn static_dependency_closure_parses_identical_root_occurrences_once() {
struct CountingStore {
inner: Arc<dyn TemplateStore>,
loads: std::sync::atomic::AtomicUsize,
}
impl TemplateStore for CountingStore {
fn load(
&self,
parent: &TemplateSource,
reference: &str,
) -> Result<Option<TemplateSource>, TemplateLoadError> {
self.loads
.fetch_add(1, std::sync::atomic::Ordering::Relaxed);
self.inner.load(parent, reference)
}
}
let root = TemplateSource::new(
manifest_path("main.md"),
manifest_path("."),
r#"{% include "shared.md" %}"#,
);
let store = CountingStore {
inner: bundle_store(&[("shared.md", "shared")]),
loads: std::sync::atomic::AtomicUsize::new(0),
};
let closure = discover_static_dependency_closure([root.clone(), root], &store).unwrap();
assert!(closure.sources.contains_key(&manifest_path("shared.md")));
assert_eq!(store.loads.load(std::sync::atomic::Ordering::Relaxed), 1);
}
#[test]
fn static_dependency_closure_deduplicates_loaded_dependencies_across_roots() {
let roots = [
TemplateSource::new(
manifest_path("first.md"),
manifest_path("."),
r#"{% include "shared.md" %}"#,
),
TemplateSource::new(
manifest_path("second.md"),
manifest_path("."),
r#"{% include "shared.md" %}"#,
),
];
let closure = discover_static_dependency_closure(
roots,
bundle_store(&[
("shared.md", r#"{% include "nested.md" %}"#),
("nested.md", "nested"),
])
.as_ref(),
)
.unwrap();
assert_eq!(
closure.paths(),
["first.md", "second.md", "shared.md", "nested.md"]
.into_iter()
.map(manifest_path)
.collect()
);
}
#[test]
fn render_lenient_named_preserves_source_name_for_syntax_errors() {
let ctx = TemplateContext::new();
let err = render_lenient_named("workflow.fabro", "{{ unterminated", &ctx).unwrap_err();
let TemplateError::Syntax { source_name, .. } = err else {
panic!("expected syntax error");
};
assert_eq!(source_name.as_deref(), Some("workflow.fabro"));
}
#[test]
fn rejects_undefined_variables_in_strict_mode() {
let ctx = TemplateContext::new();
let err = render("{{ missing }}", &ctx).unwrap_err();
assert!(matches!(err, TemplateError::UndefinedVariable { .. }));
}
#[test]
fn undefined_variable_error_captures_expression_and_line() {
let ctx = TemplateContext::new();
let err = render("hi\n{{ inputs.app_dir }}", &ctx).unwrap_err();
let TemplateError::UndefinedVariable {
expression, line, ..
} = &err
else {
panic!("expected UndefinedVariable, got {err:?}");
};
assert_eq!(expression.as_deref(), Some("inputs.app_dir"));
assert_eq!(*line, Some(2));
}
#[test]
fn undefined_variable_error_display_includes_expression_and_line() {
let ctx = TemplateContext::new();
let err = render("hi\n{{ inputs.app_dir }}", &ctx).unwrap_err();
let rendered = err.to_string();
assert!(
rendered.contains("inputs.app_dir"),
"missing variable name in: {rendered}"
);
assert!(rendered.contains("line 2"), "missing line in: {rendered}");
}
#[test]
fn template_error_preserves_minijinja_source_chain() {
use std::error::Error as _;
let ctx = TemplateContext::new();
let err = render("{{ missing }}", &ctx).unwrap_err();
let source = err.source().expect("source should be present");
assert!(
source.is::<minijinja::Error>(),
"expected minijinja::Error as source, got {source:?}"
);
}
#[test]
fn supports_partial_interpolation() {
let ctx = TemplateContext::new().with_goal("ship it");
let rendered = render("Please {{ goal }} today", &ctx).unwrap();
assert_eq!(rendered, "Please ship it today");
}
#[test]
fn preserves_passthrough_goal_literal() {
let ctx = TemplateContext::new().with_goal("{{ goal }}");
let rendered = render("{{ goal }}", &ctx).unwrap();
assert_eq!(rendered, "{{ goal }}");
}
#[test]
fn renders_empty_goal() {
let ctx = TemplateContext::new().with_goal("");
let rendered = render("Goal={{ goal }}", &ctx).unwrap();
assert_eq!(rendered, "Goal=");
}
#[test]
fn leaves_dollar_signs_untouched() {
let ctx = TemplateContext::new().with_goal("ignored");
let rendered = render("price is $5", &ctx).unwrap();
assert_eq!(rendered, "price is $5");
}
#[test]
fn passes_through_plain_text() {
let ctx = TemplateContext::new();
let rendered = render("just text", &ctx).unwrap();
assert_eq!(rendered, "just text");
}
#[test]
fn supports_raw_block_escape() {
let ctx = TemplateContext::new();
let rendered = render("{% raw %}{{ goal }}{% endraw %}", &ctx).unwrap();
assert_eq!(rendered, "{{ goal }}");
}
}