use super::dart::escape_dart;
use crate::core::config::ResolvedCrateConfig;
use crate::core::ir::{MethodDef, TypeRef};
use crate::e2e::fixture::{CallbackAction, VisitorSpec};
use heck::{ToLowerCamelCase, ToUpperCamelCase};
use std::fmt::Write as FmtWrite;
pub(super) struct DartVisitorConfig {
pub(super) trait_name: String,
pub(super) result_type: String,
pub(super) methods: Vec<String>,
}
pub(super) fn resolve_dart_visitor_config(
config: &ResolvedCrateConfig,
call_override: Option<&crate::e2e::config::CallOverride>,
type_defs: &[crate::core::ir::TypeDef],
visitor_spec: &VisitorSpec,
) -> DartVisitorConfig {
let trait_name = call_override
.and_then(|override_config| override_config.visitor_trait.clone())
.or_else(|| {
type_defs
.iter()
.find(|type_def| {
type_def.is_trait && visitor_spec.callbacks.keys().any(|name| has_method(type_def, name))
})
.map(|type_def| type_def.name.clone())
})
.unwrap_or_else(|| "Visitor".to_string());
let methods = type_defs
.iter()
.find(|type_def| type_def.name == trait_name)
.map(|type_def| type_def.methods.iter().map(|method| method.name.clone()).collect())
.unwrap_or_else(|| visitor_spec.callbacks.keys().cloned().collect());
let bridge = config
.trait_bridges
.iter()
.find(|bridge| bridge.trait_name == trait_name);
let callback_methods = callback_methods(type_defs, visitor_spec, &trait_name);
let result_type = bridge
.and_then(|bridge| bridge.result_type.clone())
.or_else(|| {
callback_methods
.iter()
.find_map(|method| named_type(&method.return_type))
})
.unwrap_or_else(|| "VisitorResult".to_string());
DartVisitorConfig {
trait_name,
result_type,
methods,
}
}
fn has_method(type_def: &crate::core::ir::TypeDef, method_name: &str) -> bool {
type_def.methods.iter().any(|method| method.name == method_name)
}
fn callback_methods<'a>(
type_defs: &'a [crate::core::ir::TypeDef],
visitor_spec: &VisitorSpec,
trait_name: &str,
) -> Vec<&'a MethodDef> {
type_defs
.iter()
.find(|type_def| type_def.name == trait_name)
.map(|type_def| {
visitor_spec
.callbacks
.keys()
.filter_map(|name| type_def.methods.iter().find(|method| method.name == *name))
.collect()
})
.unwrap_or_default()
}
fn named_type(ty: &TypeRef) -> Option<String> {
match ty {
TypeRef::Named(name) => Some(name.clone()),
TypeRef::Optional(inner) | TypeRef::Vec(inner) => named_type(inner),
TypeRef::Map(key, value) => named_type(key).or_else(|| named_type(value)),
_ => None,
}
}
pub(super) fn build_dart_visitor(
setup_lines: &mut Vec<String>,
visitor_spec: &VisitorSpec,
visitor_config: &DartVisitorConfig,
) -> String {
let mut named_args: Vec<String> = Vec::with_capacity(visitor_config.methods.len());
for method in &visitor_config.methods {
let camel = method.to_lower_camel_case();
let params = dart_visitor_params(method);
let body = match visitor_spec.callbacks.get(method.as_str()) {
Some(action) => dart_action_body(method, action, &visitor_config.result_type),
None if visitor_config.result_type != "VisitorResult" => {
dart_result_ctor(&visitor_config.result_type, "continue_", None)
}
None => format!(
"throw UnsupportedError('dart visitor fixture requires explicit e2e result-action metadata for result type {}')",
visitor_config.result_type
),
};
named_args.push(format!("{camel}: ({params}) async => {body}"));
}
let factory_name = format!("create{}", visitor_config.trait_name.to_upper_camel_case());
let mut block = format!("final _visitor = await {factory_name}(\n");
for (i, arg) in named_args.iter().enumerate() {
let sep = if i + 1 == named_args.len() { "" } else { "," };
let _ = writeln!(block, " {arg}{sep}");
}
block.push_str(" );");
setup_lines.push(block);
"_visitor".to_string()
}
fn dart_visitor_params(method: &str) -> &'static str {
match method {
"visit_text" => "ctx, text",
"visit_element_start" => "ctx",
"visit_element_end" => "ctx, output",
"visit_link" => "ctx, href, text, title",
"visit_image" => "ctx, src, alt, title",
"visit_heading" => "ctx, level, text, id",
"visit_code_block" => "ctx, lang, code",
"visit_code_inline" => "ctx, code",
"visit_list_item" => "ctx, ordered, marker, text",
"visit_list_start" => "ctx, ordered",
"visit_list_end" => "ctx, ordered, output",
"visit_table_start" => "ctx",
"visit_table_row" => "ctx, cells, isHeader",
"visit_table_end" => "ctx, output",
"visit_blockquote" => "ctx, content, depth",
"visit_strong"
| "visit_emphasis"
| "visit_strikethrough"
| "visit_underline"
| "visit_subscript"
| "visit_superscript"
| "visit_mark"
| "visit_button"
| "visit_summary"
| "visit_figcaption"
| "visit_definition_term"
| "visit_definition_description"
| "visit_definition_list_end" => "ctx, text",
"visit_line_break" | "visit_horizontal_rule" | "visit_definition_list_start" | "visit_figure_start" => "ctx",
"visit_custom_element" => "ctx, tagName, html",
"visit_form" => "ctx, action, method",
"visit_input" => "ctx, inputType, name, value",
"visit_audio" | "visit_video" | "visit_iframe" => "ctx, src",
"visit_details" => "ctx, open",
"visit_figure_end" => "ctx, output",
_ => "ctx",
}
}
fn dart_action_body(method: &str, action: &CallbackAction, result_type: &str) -> String {
if result_type == "VisitorResult" {
return format!(
"throw UnsupportedError('dart visitor fixture callback {method} requires explicit e2e result-action metadata for result type {result_type}')"
);
}
match action {
CallbackAction::Skip => dart_result_ctor(result_type, "skip", None),
CallbackAction::Continue => dart_result_ctor(result_type, "continue_", None),
CallbackAction::PreserveHtml => dart_result_ctor(result_type, "preserveHtml", None),
CallbackAction::Custom { output } => {
let args = format!("field0: '{}'", escape_dart(output));
dart_result_ctor(result_type, "custom", Some(&args))
}
CallbackAction::CustomTemplate { template, return_form } => {
let _ = return_form;
let _ = method;
let mut interpolated = String::with_capacity(template.len());
let mut chars = template.chars().peekable();
while let Some(ch) = chars.next() {
match ch {
'{' => {
let mut name = String::new();
while let Some(&peek) = chars.peek() {
if peek == '}' {
chars.next();
break;
}
name.push(peek);
chars.next();
}
interpolated.push_str("${");
interpolated.push_str(&name.to_lower_camel_case());
interpolated.push('}');
}
'\\' => interpolated.push_str("\\\\"),
'\'' => interpolated.push_str("\\'"),
'\n' => interpolated.push_str("\\n"),
'\r' => interpolated.push_str("\\r"),
'\t' => interpolated.push_str("\\t"),
other => interpolated.push(other),
}
}
let args = format!("field0: '{interpolated}'");
dart_result_ctor(result_type, "custom", Some(&args))
}
}
}
fn dart_result_ctor(result_type: &str, ctor: &str, args: Option<&str>) -> String {
format!("{result_type}.{ctor}({})", args.unwrap_or_default())
}
#[cfg(test)]
mod tests {
use super::*;
use crate::e2e::fixture::TemplateReturnForm;
use std::collections::BTreeMap;
fn spec(method: &str, action: CallbackAction) -> VisitorSpec {
let mut callbacks = BTreeMap::new();
callbacks.insert(method.to_string(), action);
VisitorSpec { callbacks }
}
fn visitor_config(methods: &[&str]) -> DartVisitorConfig {
DartVisitorConfig {
trait_name: "RenderVisitor".to_string(),
result_type: "WalkDecision".to_string(),
methods: methods.iter().map(|method| method.to_string()).collect(),
}
}
#[test]
fn build_dart_visitor_emits_visitor_variable() {
let mut lines = Vec::new();
let name = build_dart_visitor(
&mut lines,
&spec(
"visit_audio",
CallbackAction::Custom {
output: "[AUDIO]".to_string(),
},
),
&visitor_config(&["visit_audio", "visit_text"]),
);
assert_eq!(name, "_visitor");
assert_eq!(lines.len(), 1);
let block = &lines[0];
assert!(block.contains("createRenderVisitor("), "got: {block}");
assert!(block.contains("visitAudio:"), "got: {block}");
assert!(block.contains("WalkDecision.custom(field0: '[AUDIO]')"), "got: {block}");
assert!(block.contains("visitText:"), "got: {block}");
assert!(block.contains("WalkDecision.continue_()"), "got: {block}");
}
#[test]
fn build_dart_visitor_maps_skip_to_skip_variant() {
let mut lines = Vec::new();
build_dart_visitor(
&mut lines,
&spec("visit_button", CallbackAction::Skip),
&visitor_config(&["visit_button"]),
);
assert!(lines[0].contains("WalkDecision.skip()"), "got: {}", lines[0]);
}
#[test]
fn build_dart_visitor_maps_continue_to_continue_variant() {
let mut lines = Vec::new();
build_dart_visitor(
&mut lines,
&spec("visit_strong", CallbackAction::Continue),
&visitor_config(&["visit_strong"]),
);
assert!(lines[0].contains("visitStrong: (ctx, text) async => WalkDecision.continue_()"));
}
#[test]
fn build_dart_visitor_interpolates_custom_template() {
let mut lines = Vec::new();
build_dart_visitor(
&mut lines,
&spec(
"visit_link",
CallbackAction::CustomTemplate {
template: "[LINK:{text}:{href}]".to_string(),
return_form: TemplateReturnForm::Dict,
},
),
&visitor_config(&["visit_link"]),
);
assert!(
lines[0].contains("WalkDecision.custom(field0: '[LINK:${text}:${href}]')"),
"got: {}",
lines[0]
);
}
}