mirror of
https://github.com/fabro-sh/fabro.git
synced 2026-10-15 04:21:44 +00:00
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>
1675 lines
53 KiB
Rust
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 }}");
|
|
}
|
|
}
|