use rustc_hash::FxHashSet as HashSet;
use syntax::ast::{Expression, StructFieldAssignment, StructSpread};
use syntax::program::{Definition, DefinitionBody};
use syntax::types::{CompoundKind, SimpleKind, Type, unqualified_name};
use crate::Emitter;
use crate::definitions::enum_layout;
use crate::expressions::context::ExpressionContext;
use crate::expressions::emission::EmittedExpression;
use crate::go_name;
use crate::types::coercion::{Coercion, CoercionDirection};
use crate::utils::observable_after_mutation;
use crate::write_line;
struct StructCallContext {
go_type: String,
enum_ctx: Option<EnumCallContext>,
is_prelude: bool,
}
struct EnumCallContext {
enum_id: String,
variant_name: String,
tag_constant: String,
pointer_fields: HashSet<String>,
}
impl Emitter<'_> {
pub(crate) fn emit_struct_call(
&mut self,
output: &mut String,
name: &str,
field_assignments: &[StructFieldAssignment],
spread: &StructSpread,
ty: &Type,
expression_ctx: ExpressionContext<'_>,
) -> String {
let ctx = self.analyze_struct_call(name, ty);
let tag_field = ctx.enum_ctx.as_ref().map(|e| {
(
enum_layout::ENUM_TAG_FIELD.to_string(),
e.tag_constant.clone(),
)
});
let is_go_struct = Self::is_go_imported_type(ty);
let kept = self.kept_struct_call_fields(field_assignments, spread, ty, is_go_struct);
let stages: Vec<EmittedExpression> = kept
.iter()
.map(|f| self.stage_composite(&f.value, ExpressionContext::value()))
.collect();
let emitted_values = self.sequence(output, stages, "_field");
let mut field_names: Vec<String> = Vec::new();
let mut field_values: Vec<String> = Vec::new();
for (slot, f) in kept.iter().enumerate() {
let field_name = self.resolve_struct_call_field_name(&f.name, ty, &ctx);
let mut value = emitted_values[slot].clone();
value = self.wrap_recursive_enum_field(output, value, f, &ctx);
let value_ty = f.value.get_type();
let field_ty = self.lookup_struct_field_ty(ty, &f.name);
if is_go_struct {
let target_ty = field_ty.as_ref().unwrap_or(&value_ty);
let coercion =
Coercion::resolve(self, &value_ty, target_ty, CoercionDirection::ToGoBoundary);
value = coercion.apply(self, output, value);
}
if let Some(field_ty) = field_ty.as_ref() {
let coercion =
Coercion::resolve(self, &value_ty, field_ty, CoercionDirection::Internal);
value = coercion.apply(self, output, value);
}
field_names.push(field_name);
field_values.push(value);
}
let mut field_pairs: Vec<(String, String)> =
field_names.into_iter().zip(field_values).collect();
if let Some(tag) = tag_field {
field_pairs.insert(0, tag);
}
match spread {
StructSpread::From(base) => {
if base.get_type().is_never() {
self.emit_statement(output, base);
return format!("{}{{}}", ctx.go_type);
}
let mut field_side_effects: Vec<bool> = Vec::new();
if ctx.enum_ctx.is_some() {
field_side_effects.push(false); }
field_side_effects.extend(
field_assignments
.iter()
.map(|f| observable_after_mutation(&f.value)),
);
self.emit_struct_update(output, base, &field_pairs, &field_side_effects)
}
StructSpread::ZeroFill { .. } if !is_go_struct => {
let assigned: HashSet<&str> =
field_assignments.iter().map(|f| f.name.as_str()).collect();
let unspecified =
self.lookup_unspecified_fields(ty, name, ctx.enum_ctx.as_ref(), &assigned);
if let Some(unspecified) = unspecified {
for (field_name, field_ty) in unspecified {
if field_ty.is_slice() {
continue;
}
let go_field_name =
self.resolve_struct_call_field_name(&field_name, ty, &ctx);
let zero = self.lisette_zero(&field_ty);
field_pairs.push((go_field_name, zero));
}
}
self.emit_struct_literal(&ctx.go_type, &field_pairs, expression_ctx)
}
StructSpread::ZeroFill { .. } | StructSpread::None => {
self.emit_struct_literal(&ctx.go_type, &field_pairs, expression_ctx)
}
}
}
fn kept_struct_call_fields<'a>(
&self,
field_assignments: &'a [StructFieldAssignment],
spread: &StructSpread,
ty: &Type,
is_go_struct: bool,
) -> Vec<&'a StructFieldAssignment> {
let can_omit_slices = !is_go_struct
&& !matches!(spread, StructSpread::From(_))
&& field_assignments
.iter()
.any(|f| f.value.is_empty_collection());
if !can_omit_slices {
return field_assignments.iter().collect();
}
field_assignments
.iter()
.filter(|f| {
!(f.value.is_empty_collection()
&& self
.lookup_struct_field_ty(ty, &f.name)
.as_ref()
.is_some_and(Type::is_slice))
})
.collect()
}
fn lookup_unspecified_fields(
&self,
ty: &Type,
name: &str,
enum_ctx: Option<&EnumCallContext>,
assigned: &HashSet<&str>,
) -> Option<Vec<(ecow::EcoString, Type)>> {
let params = match ty.strip_refs() {
Type::Nominal { params, .. } => params,
_ => Vec::new(),
};
if let Some(enum_ctx) = enum_ctx {
let Some(Definition {
body:
DefinitionBody::Enum {
variants, generics, ..
},
..
}) = self.facts.definition(enum_ctx.enum_id.as_str())
else {
return None;
};
let variant_name = unqualified_name(name);
let variant = variants.iter().find(|v| v.name == variant_name)?;
let map = generics_substitution(generics.iter().map(|g| g.name.clone()), ¶ms);
return Some(unspecified_pairs(
variant.fields.iter().map(|f| (&f.name, &f.ty)),
assigned,
&map,
));
}
let Type::Nominal { id, .. } = ty.strip_refs() else {
return None;
};
let Some(Definition {
ty: def_ty,
body: DefinitionBody::Struct { fields, .. },
..
}) = self.facts.definition(id.as_str())
else {
return None;
};
let map = forall_substitution(def_ty, ¶ms);
Some(unspecified_pairs(
fields.iter().map(|f| (&f.name, &f.ty)),
assigned,
&map,
))
}
fn go_imported_zero(&mut self, ty: &Type, id: &str) -> String {
if self.facts.is_interface(ty) || self.facts.resolve_to_function_type(ty).is_some() {
return "nil".to_string();
}
let go_ty = self.go_type_as_string(ty);
let is_struct_like = matches!(
self.facts.definition(id).map(|d| &d.body),
Some(DefinitionBody::Struct { .. })
) || matches!(
self.facts.definition(id).map(|d| &d.body),
Some(DefinitionBody::TypeAlias { annotation, .. }) if annotation.is_opaque()
);
if is_struct_like {
format!("{}{{}}", go_ty)
} else {
format!("*new({})", go_ty)
}
}
pub(crate) fn lisette_zero(&mut self, ty: &Type) -> String {
match ty {
Type::Simple(kind) => match kind {
SimpleKind::Bool => "false".to_string(),
SimpleKind::String => "\"\"".to_string(),
SimpleKind::Unit => "struct{}{}".to_string(),
_ => "0".to_string(),
},
Type::Compound { kind, args } => match kind {
CompoundKind::Slice => {
let inner = args
.first()
.map(|a| self.go_type_as_string(a))
.unwrap_or_else(|| "any".to_string());
format!("([]{})(nil)", inner)
}
CompoundKind::Map => {
let key = args
.first()
.map(|a| self.go_type_as_string(a))
.unwrap_or_else(|| "any".to_string());
let val = args
.get(1)
.map(|a| self.go_type_as_string(a))
.unwrap_or_else(|| "any".to_string());
format!("map[{}]{}{{}}", key, val)
}
_ => format!("{}{{}}", self.go_type_as_string(ty)),
},
Type::Nominal { id, params, .. } => {
if id.as_str() == "prelude.Option" {
let inner = params
.first()
.map(|a| self.go_type_as_string(a))
.unwrap_or_else(|| "any".to_string());
self.requirements.require_stdlib();
return format!("{}.MakeOptionNone[{}]()", go_name::GO_STDLIB_PKG, inner);
}
if go_name::is_go_import(id.as_str()) {
return self.go_imported_zero(ty, id.as_str());
}
if let Some(fields) =
self.lookup_unspecified_fields(ty, "", None, &HashSet::default())
{
let go_ty = self.go_type_as_string(ty);
let pairs: Vec<(String, String)> = fields
.into_iter()
.filter(|(_, field_ty)| !field_ty.is_slice())
.map(|(name, field_ty)| {
let go_name = if self.field_is_public(ty, &name) {
go_name::make_exported(&name)
} else {
go_name::escape_keyword(&name).into_owned()
};
(go_name, self.lisette_zero(&field_ty))
})
.collect();
return self.emit_struct_literal(&go_ty, &pairs, ExpressionContext::value());
}
if let Some(underlying) = ty.get_underlying() {
return self.lisette_zero(underlying);
}
format!("{}{{}}", self.go_type_as_string(ty))
}
Type::Tuple(elements) => {
let go_ty = self.go_type_as_string(ty);
let parts: Vec<String> = elements.iter().map(|e| self.lisette_zero(e)).collect();
format!("{}{{{}}}", go_ty, parts.join(", "))
}
_ => format!("{}{{}}", self.go_type_as_string(ty)),
}
}
fn wrap_recursive_enum_field(
&mut self,
output: &mut String,
value: String,
field: &StructFieldAssignment,
ctx: &StructCallContext,
) -> String {
let needs_pointer = ctx
.enum_ctx
.as_ref()
.is_some_and(|e| e.pointer_fields.contains(field.name.as_str()));
if !needs_pointer {
return value;
}
if matches!(*field.value, Expression::Reference { .. }) || field.value.get_type().is_ref() {
return value;
}
let temp = self.hoist_tmp_value(output, "ptr", &value);
format!("&{}", temp)
}
fn analyze_struct_call(&mut self, name: &str, ty: &Type) -> StructCallContext {
let is_prelude = self.is_from_prelude(ty);
let enum_id = self.as_enum(ty);
let go_type = self.compute_struct_call_go_type(name, ty, is_prelude, enum_id.is_some());
if let Some(ref id) = enum_id {
self.add_enum_imports_if_needed(name, id);
}
let enum_ctx = enum_id.map(|id| self.compute_enum_call_context(name, &id));
StructCallContext {
go_type,
enum_ctx,
is_prelude,
}
}
fn compute_struct_call_go_type(
&mut self,
name: &str,
ty: &Type,
is_prelude: bool,
is_enum: bool,
) -> String {
if name.contains('.') && !is_prelude {
let parts: Vec<&str> = name.split('.').collect();
let emits_qualified = (is_enum && parts.len() == 3) || (!is_enum && parts.len() == 2);
if emits_qualified && !self.facts.is_current_module(parts[0]) {
let type_args = if let Type::Nominal { params, .. } = ty {
self.format_type_args(params)
} else {
String::new()
};
let pkg = self.require_module_import(parts[0]);
return format!("{}.{}{}", pkg, go_name::snake_to_camel(parts[1]), type_args);
}
}
self.go_type_as_string(ty)
}
fn compute_enum_call_context(&mut self, name: &str, enum_id: &str) -> EnumCallContext {
let variant_name = unqualified_name(name).to_string();
let tag_constant = self.resolve_variant(name, enum_id);
let pointer_fields = if let Some(layout) = self.module.enum_layout(enum_id) {
if let Some(variant) = layout.get_variant(&variant_name) {
variant
.fields
.iter()
.filter(|f| f.go_type.starts_with('*'))
.map(|f| f.source_name.clone())
.collect()
} else {
HashSet::default()
}
} else {
HashSet::default()
};
EnumCallContext {
enum_id: enum_id.to_string(),
variant_name,
tag_constant,
pointer_fields,
}
}
fn add_enum_imports_if_needed(&mut self, name: &str, enum_id: &str) {
if let Some(enum_module) = self.facts.module_for_qualified_name(enum_id)
&& !self.facts.is_current_module(enum_module)
{
let enum_module = enum_module.to_string();
self.require_module_import(&enum_module);
}
let parts: Vec<&str> = name.split('.').collect();
if parts.len() == 3 {
let module = self
.module
.module_for_alias(parts[0])
.unwrap_or(parts[0])
.to_string();
self.require_module_import(&module);
}
}
fn resolve_struct_call_field_name(
&mut self,
field_name: &str,
ty: &Type,
ctx: &StructCallContext,
) -> String {
if let Some(ref enum_ctx) = ctx.enum_ctx {
self.enum_struct_field_name(&enum_ctx.enum_id, &enum_ctx.variant_name, field_name)
.unwrap_or_else(|| go_name::make_exported(field_name))
} else if ctx.is_prelude || self.field_is_public(ty, field_name) {
go_name::make_exported(field_name)
} else {
go_name::escape_keyword(field_name).into_owned()
}
}
pub(crate) fn emit_struct_literal(
&self,
ty: &str,
fields: &[(String, String)],
ctx: ExpressionContext<'_>,
) -> String {
let raw = if fields.is_empty() {
format!("{}{{}}", ty)
} else if fields.len() == 1 {
let (name, value) = &fields[0];
format!("{}{{ {}: {} }}", ty, name, value)
} else {
let field_strs: Vec<String> = fields
.iter()
.map(|(name, value)| format!("{}: {},", name, value))
.collect();
format!("{}{{\n{}\n}}", ty, field_strs.join("\n"))
};
if ctx.is_condition() && ty.contains('[') {
format!("({})", raw)
} else {
raw
}
}
fn emit_struct_update(
&mut self,
output: &mut String,
base: &Expression,
fields: &[(String, String)],
field_side_effects: &[bool],
) -> String {
if fields.is_empty() {
return self.emit_operand(output, base, ExpressionContext::value());
}
let fields: Vec<(String, String)> = fields
.iter()
.enumerate()
.map(|(i, (name, value))| {
if field_side_effects.get(i).copied().unwrap_or(false) {
let temp = self.hoist_tmp_value(output, "field", value);
(name.clone(), temp)
} else {
(name.clone(), value.clone())
}
})
.collect();
let base_string = self.emit_operand(output, base, ExpressionContext::value());
let tmp = self.hoist_tmp_value(output, "copy", &base_string);
for (name, value) in &fields {
write_line!(output, "{}.{} = {}", tmp, name, value);
}
tmp
}
}
fn forall_substitution(def_ty: &Type, params: &[Type]) -> syntax::types::SubstitutionMap {
if let Type::Forall { vars, .. } = def_ty
&& !vars.is_empty()
&& vars.len() == params.len()
{
generics_substitution(vars.iter().cloned(), params)
} else {
syntax::types::SubstitutionMap::default()
}
}
fn generics_substitution(
vars: impl Iterator<Item = ecow::EcoString>,
params: &[Type],
) -> syntax::types::SubstitutionMap {
let mut map = syntax::types::SubstitutionMap::default();
for (var, param) in vars.zip(params.iter()) {
map.insert(var, param.clone());
}
map
}
fn apply_substitution(ty: &Type, map: &syntax::types::SubstitutionMap) -> Type {
if map.is_empty() {
ty.clone()
} else {
syntax::types::substitute(ty, map)
}
}
fn unspecified_pairs<'a>(
fields: impl Iterator<Item = (&'a ecow::EcoString, &'a Type)>,
assigned: &HashSet<&str>,
map: &syntax::types::SubstitutionMap,
) -> Vec<(ecow::EcoString, Type)> {
fields
.filter(|(name, _)| !assigned.contains(name.as_str()))
.map(|(name, ty)| (name.clone(), apply_substitution(ty, map)))
.collect()
}