use crate::adapter::go::{field_name, go_type_name, go_value_type, module_prefix};
use crate::default_common::{discriminator_default_value, resolve_alias, selected_case};
use crate::emit::go::type_tag;
use crate::encode::EncodeError;
use crate::fixed_literal::{fixed_text, zero_decimal};
use zerodds_ast::{
Ast, ConstExpr, Literal as AstLiteral, MemberNode, PrimitiveKind, TypeKind, TypeNode,
};
use zerodds_ast_core::Id;
use zerodds_lang_cst::common::{Doc, Ident, Literal};
use zerodds_lang_cst::go;
const MAX_ALIAS_DEPTH: usize = 64;
#[must_use]
pub fn defaulter_name(ast: &Ast, id: Id<TypeNode>) -> String {
let name = match ast.type_(id).map(|node| node.kind.clone()) {
Ok(TypeKind::Primitive(kind)) => {
format!("zd_def_p_{}", kind.as_str().replace(' ', "_"))
}
_ => format!("zd_def_{}", type_tag(ast, id, 0)),
};
crate::emit::go::exported_name(&name)
}
fn defaulter_prefix() -> String {
crate::emit::go::exported_name("zd_def_")
}
#[must_use]
pub fn defaulter_from_decoder(decoder: &str) -> String {
let prefix = crate::emit::go::exported_name("zd_dec_");
let name = match decoder.strip_prefix(&prefix) {
Some(rest) => format!("zd_def_{rest}"),
None => format!("zd_def_{decoder}"),
};
crate::emit::go::exported_name(&name)
}
pub fn member_default(
ast: &Ast,
node: &MemberNode,
type_: Id<TypeNode>,
place: go::Expr,
) -> Result<Vec<go::Stmt>, EncodeError> {
let mut value = member_value(ast, node, type_)?;
if node.facets.is_optional() {
let member_type = match go_value_type(ast, type_) {
Ok(member_type) => member_type,
Err(_) => {
return Err(EncodeError::NoWriter {
member: node.name.clone(),
kind: "optional member whose type has no Go form",
});
}
};
value = go::Expr::call(
go::Expr::selector(go::Expr::name("zdwire"), "Ptr"),
vec![go::Expr::Convert {
type_: Box::new(member_type),
value: Box::new(value),
}],
);
}
Ok(vec![go::Stmt::Assign { place, value }])
}
pub fn go_defaulters_called_by(
ast: &Ast,
decls: &[go::Decl],
) -> Result<Vec<go::Decl>, EncodeError> {
let index: Vec<(String, Id<TypeNode>)> = ast
.types()
.map(|(id, _)| (defaulter_name(ast, id), id))
.collect();
let mut called: Vec<String> = Vec::new();
for decl in decls {
calls_in_decl(decl, &mut called);
}
let mut wanted: Vec<Id<TypeNode>> = Vec::new();
let mut have: Vec<String> = Vec::new();
for _ in 0..=index.len() {
let mut grew = false;
for name in &called {
if have.contains(name) {
continue;
}
have.push(name.clone());
if let Some(id) = index.iter().find(|(n, _)| n == name).map(|(_, id)| *id) {
wanted.push(id);
grew = true;
}
}
let produced = go_defaulters_over(ast, &wanted)?;
if !grew {
return Ok(produced);
}
for decl in &produced {
calls_in_decl(decl, &mut called);
}
}
go_defaulters_over(ast, &wanted)
}
pub fn go_defaulters_over(ast: &Ast, types: &[Id<TypeNode>]) -> Result<Vec<go::Decl>, EncodeError> {
let mut out = Vec::new();
let mut emitted: Vec<String> = Vec::new();
for id in types.iter().copied() {
let name = defaulter_name(ast, id);
if emitted.contains(&name) {
continue;
}
let value = match value_of(ast, id, &name)? {
Some(value) => value,
None => continue,
};
let returns = match go_value_type(ast, resolve_alias(ast, id)) {
Ok(returns) => returns,
Err(_) => {
return Err(EncodeError::NoWriter {
member: name,
kind: "type with no Go form to return",
});
}
};
emitted.push(name.clone());
out.push(go::Decl::Func(go::FuncDecl {
doc: Doc::line(
"Table 9 of DDS-XTypes 1.3: what this type is where the stream did not \
carry it.",
),
name: Ident::new(&name),
params: Vec::new(),
results: vec![returns],
body: vec![go::Stmt::Return(Some(value))],
}));
}
Ok(out)
}
#[allow(clippy::too_many_lines)]
fn value_of(ast: &Ast, id: Id<TypeNode>, own_name: &str) -> Result<Option<go::Expr>, EncodeError> {
let id = resolve_alias(ast, id);
let node = match ast.type_(id) {
Ok(node) => node,
Err(_) => {
return Err(EncodeError::NoWriter {
member: own_name.to_string(),
kind: "a type the model does not hold",
});
}
};
let refuse = |kind: &'static str| EncodeError::NoWriter {
member: own_name.to_string(),
kind,
};
let value = match &node.kind {
TypeKind::Primitive(kind) => primitive_default(*kind),
TypeKind::String { .. } => text(""),
TypeKind::Fixed { scale, .. } => text(&zero_decimal(*scale)),
TypeKind::Alias { .. } => {
return Err(refuse("typedef with an unresolved target"));
}
TypeKind::Enumeration { .. } => {
let enumerator = match crate::emit::default_enumerator_name(ast, id) {
Some(enumerator) => enumerator,
None => {
return Err(refuse(
"enumeration with no enumerator to take as its default",
));
}
};
enumerator_expr(ast, id, &enumerator)
}
TypeKind::Bitmask { .. } => go::Expr::Convert {
type_: Box::new(go::Type::named(&go_type_name(ast, id))),
value: Box::new(go::Expr::int(0)),
},
TypeKind::Bitset { .. } => {
let mut elems = Vec::new();
for field in &ast.all_bitfields_of(id) {
let field_node = match ast.bitfield(*field) {
Ok(field_node) => field_node,
Err(_) => continue,
};
if let Some(name) = field_node.name.as_ref() {
elems.push(go::CompositeElem {
key: Some(Ident::new(&field_name(name))),
value: go::Expr::int(0),
});
}
}
composite(ast, id, elems)
}
TypeKind::Sequence { .. } | TypeKind::Map { .. } => {
let type_ = match go_value_type(ast, id) {
Ok(type_) => type_,
Err(_) => return Err(refuse("collection with no Go form")),
};
go::Expr::Composite {
type_: Some(Box::new(type_)),
elems: Vec::new(),
}
}
TypeKind::Array { element, dims } => {
let element = match element.resolved() {
Some(element) => element,
None => return Err(refuse("array with an unresolved element")),
};
let mut lengths = Vec::new();
for dim in dims {
let length = match ast.eval_integral(*dim) {
Ok(length) => length,
Err(_) => return Err(refuse("array whose length does not evaluate")),
};
let length = match usize::try_from(length) {
Ok(length) => length,
Err(_) => return Err(refuse("array of a length this column cannot spell")),
};
lengths.push(length);
}
let type_ = match go_value_type(ast, id) {
Ok(type_) => type_,
Err(_) => return Err(refuse("array with no Go form")),
};
let mut out = go::Expr::call(go::Expr::name(&defaulter_name(ast, element)), Vec::new());
let mut level = lengths.len();
for length in lengths.into_iter().rev() {
level -= 1;
let elems = core::iter::repeat_with(|| go::CompositeElem {
key: None,
value: out.clone(),
})
.take(length)
.collect();
out = go::Expr::Composite {
type_: if level == 0 {
Some(Box::new(type_.clone()))
} else {
None
},
elems,
};
}
out
}
TypeKind::Structure { .. } | TypeKind::Valuetype { .. } => {
let mut elems = Vec::new();
if let Some(base) = crate::adapter::c::struct_base(ast, id) {
elems.push(go::CompositeElem {
key: Some(Ident::new(&field_name("parent"))),
value: go::Expr::call(go::Expr::name(&defaulter_name(ast, base)), Vec::new()),
});
}
for member_id in ast.members_of(id) {
let member_node = match ast.member(*member_id) {
Ok(member_node) => member_node,
Err(_) => continue,
};
if member_node.facets.is_optional() {
continue;
}
let member_type = match member_node.type_.resolved() {
Some(member_type) => member_type,
None => {
return Err(EncodeError::NoWriter {
member: member_node.name.clone(),
kind: "member with an unresolved type",
});
}
};
elems.push(go::CompositeElem {
key: Some(Ident::new(&field_name(&member_node.name))),
value: member_value(ast, member_node, member_type)?,
});
}
composite(ast, id, elems)
}
TypeKind::Union { discriminator, .. } => {
let discriminator = match discriminator.resolved() {
Some(discriminator) => discriminator,
None => return Err(refuse("union with an unresolved discriminator")),
};
let selector = discriminator_default_value(ast, discriminator);
let mut elems = vec![go::CompositeElem {
key: Some(Ident::new("D")),
value: discriminant_literal(ast, discriminator, selector.unwrap_or(0)),
}];
if let Some((member_type, field)) = selected_by_default(ast, id, selector)? {
elems.push(go::CompositeElem {
key: Some(Ident::new(&field)),
value: go::Expr::call(
go::Expr::name(&defaulter_name(ast, member_type)),
Vec::new(),
),
});
}
composite(ast, id, elems)
}
TypeKind::Native | TypeKind::ObjectRef { .. } | TypeKind::AnnotationType { .. } => {
return Ok(None);
}
TypeKind::ValueBox { .. } => {
return Err(refuse(
"boxed value, whose presence flag has no settled wire form",
));
}
TypeKind::Any => {
return Err(refuse(
"`any`, which DDS-XTypes has no encoding for; only CORBA CDR writes one, \
as a TypeCode ahead of the value",
));
}
TypeKind::ValueBase => {
return Err(refuse(
"`ValueBase`, which DDS-XTypes has no encoding for; only CORBA CDR writes \
one, as a chunked value with its repository id",
));
}
};
Ok(Some(value))
}
fn member_value(
ast: &Ast,
node: &MemberNode,
type_: Id<TypeNode>,
) -> Result<go::Expr, EncodeError> {
match node.facets.xtypes.as_ref().and_then(|x| x.default_value) {
Some(expr) => explicit(ast, expr, type_, &node.name),
None => Ok(go::Expr::call(
go::Expr::name(&defaulter_name(ast, type_)),
Vec::new(),
)),
}
}
fn primitive_default(kind: PrimitiveKind) -> go::Expr {
match kind {
PrimitiveKind::Boolean => go::Expr::Literal(Literal::Bool(false)),
PrimitiveKind::Float32 | PrimitiveKind::Float64 => {
go::Expr::Literal(Literal::Float("0.0".to_string()))
}
PrimitiveKind::Float128 => text("0.0"),
PrimitiveKind::Char
| PrimitiveKind::WChar
| PrimitiveKind::Octet
| PrimitiveKind::Int8
| PrimitiveKind::UInt8
| PrimitiveKind::Int16
| PrimitiveKind::UInt16
| PrimitiveKind::Int32
| PrimitiveKind::UInt32
| PrimitiveKind::Int64
| PrimitiveKind::UInt64 => go::Expr::int(0),
}
}
fn composite(ast: &Ast, id: Id<TypeNode>, elems: Vec<go::CompositeElem>) -> go::Expr {
go::Expr::Composite {
type_: Some(Box::new(go::Type::named(&go_type_name(ast, id)))),
elems,
}
}
fn enumerator_expr(ast: &Ast, id: Id<TypeNode>, enumerator: &str) -> go::Expr {
go::Expr::name(&format!(
"{}{}",
module_prefix(ast, id),
field_name(enumerator)
))
}
fn selected_by_default(
ast: &Ast,
id: Id<TypeNode>,
selector: Option<i128>,
) -> Result<Option<(Id<TypeNode>, String)>, EncodeError> {
let selector = match selector {
Some(selector) => selector,
None => return Ok(None),
};
Ok(selected_case(ast, id, selector)?
.map(|(member, member_type)| (member_type, field_name(&member.name))))
}
fn discriminant_literal(ast: &Ast, discriminator: Id<TypeNode>, value: i128) -> go::Expr {
let resolved = resolve_alias(ast, discriminator);
if matches!(
ast.type_(resolved).map(|node| node.kind.clone()),
Ok(TypeKind::Enumeration { .. })
) {
if let Some(enumerator) = crate::emit::default_enumerator_name(ast, resolved) {
return enumerator_expr(ast, resolved, &enumerator);
}
}
match resolved_primitive(ast, resolved) {
Some(PrimitiveKind::Boolean) => go::Expr::Literal(Literal::Bool(value != 0)),
_ => go::Expr::int(value),
}
}
fn resolved_primitive(ast: &Ast, id: Id<TypeNode>) -> Option<PrimitiveKind> {
let mut current = id;
for _ in 0..MAX_ALIAS_DEPTH {
match ast.type_(current).map(|node| node.kind.clone()) {
Ok(TypeKind::Primitive(kind)) => return Some(kind),
Ok(TypeKind::Alias { aliased }) => current = aliased.resolved()?,
_ => return None,
}
}
None
}
#[allow(clippy::too_many_lines)]
fn explicit(
ast: &Ast,
expr: Id<zerodds_ast::ConstExprNode>,
type_: Id<TypeNode>,
member_name: &str,
) -> Result<go::Expr, EncodeError> {
let refuse = |kind: &'static str| EncodeError::NoWriter {
member: member_name.to_string(),
kind,
};
let node = match ast.expr(expr) {
Ok(node) => node,
Err(_) => return Err(refuse("a `@default` this frontend cannot follow")),
};
let resolved = resolve_alias(ast, type_);
let kind = ast.type_(resolved).map(|node| node.kind.clone());
let is_float128 = matches!(kind, Ok(TypeKind::Primitive(PrimitiveKind::Float128)));
match &node.expr {
ConstExpr::Literal(AstLiteral::Boolean(flag)) => {
Ok(go::Expr::Literal(Literal::Bool(*flag)))
}
ConstExpr::Literal(AstLiteral::Char(ch)) => Ok(go::Expr::int(i128::from(u32::from(*ch)))),
ConstExpr::Literal(AstLiteral::WChar(code)) => Ok(go::Expr::int(i128::from(*code))),
ConstExpr::Literal(AstLiteral::String(value)) => Ok(text(value)),
ConstExpr::Literal(AstLiteral::WString(codes)) => {
let mut out = String::new();
for code in codes {
let ch = match char::from_u32(*code) {
Some(ch) => ch,
None => {
return Err(refuse("a `@default` wide string that is not code points"));
}
};
out.push(ch);
}
Ok(text(&out))
}
ConstExpr::Literal(AstLiteral::Float { mantissa, exponent }) => {
let exponent = match exponent.as_ref() {
Some(exponent) => format!("e{exponent}"),
None => String::new(),
};
let written = format!("{mantissa}{exponent}");
if is_float128 {
return Ok(text(&written));
}
Ok(go::Expr::Literal(Literal::Float(written)))
}
ConstExpr::Literal(AstLiteral::Fixed { digits, scale }) => {
Ok(text(&fixed_text(digits, *scale)))
}
ConstExpr::Literal(AstLiteral::Enumerator(reference)) => {
let target = match reference.resolved() {
Some(target) => target,
None => return Err(refuse("a `@default` enumerator that is unresolved")),
};
let enumerator = match ast.enumerator(target) {
Ok(enumerator) => enumerator,
Err(_) => {
return Err(refuse(
"a `@default` enumerator this frontend cannot follow",
));
}
};
Ok(enumerator_expr(ast, resolved, &enumerator.name))
}
_ => {
let value = match ast.eval_integral(expr) {
Ok(value) => value,
Err(_) => return Err(refuse("a `@default` this frontend cannot evaluate")),
};
Ok(match kind {
Ok(TypeKind::Primitive(PrimitiveKind::Boolean)) => {
go::Expr::Literal(Literal::Bool(value != 0))
}
Ok(TypeKind::Primitive(PrimitiveKind::Char)) => {
if !(0..=0xFF).contains(&value) {
return Err(refuse("a `@default` character outside one octet"));
}
go::Expr::int(value)
}
Ok(TypeKind::Primitive(PrimitiveKind::WChar)) => {
if !(0..=0xFFFF).contains(&value) {
return Err(refuse(
"a `@default` character outside the range of a UTF-16 code unit",
));
}
go::Expr::int(value)
}
Ok(TypeKind::Primitive(PrimitiveKind::Float128)) => text(&value.to_string()),
_ => go::Expr::int(value),
})
}
}
}
fn calls_in_decl(decl: &go::Decl, out: &mut Vec<String>) {
match decl {
go::Decl::Func(func) => calls_in_body(&func.body, out),
go::Decl::Const(constant) => calls_in_expr(&constant.value, out),
go::Decl::Type(_)
| go::Decl::Interface(_)
| go::Decl::Comment(_)
| go::Decl::Verbatim(_) => {}
}
}
fn calls_in_body(body: &[go::Stmt], out: &mut Vec<String>) {
for statement in body {
calls_in_stmt(statement, out);
}
}
fn calls_in_stmt(statement: &go::Stmt, out: &mut Vec<String>) {
match statement {
go::Stmt::Var { value, .. } => {
if let Some(value) = value {
calls_in_expr(value, out);
}
}
go::Stmt::Assign { place, value } => {
calls_in_expr(place, out);
calls_in_expr(value, out);
}
go::Stmt::Expr(value) => calls_in_expr(value, out),
go::Stmt::Return(value) => {
if let Some(value) = value {
calls_in_expr(value, out);
}
}
go::Stmt::If {
condition,
then,
otherwise,
} => {
calls_in_expr(condition, out);
calls_in_body(then, out);
if let Some(otherwise) = otherwise {
calls_in_body(otherwise, out);
}
}
go::Stmt::For {
init, bound, body, ..
} => {
calls_in_expr(init, out);
calls_in_expr(bound, out);
calls_in_body(body, out);
}
go::Stmt::While { condition, body } => {
calls_in_expr(condition, out);
calls_in_body(body, out);
}
go::Stmt::Break | go::Stmt::Comment(_) => {}
}
}
fn calls_in_expr(expr: &go::Expr, out: &mut Vec<String>) {
match expr {
go::Expr::Call { func, args } => {
if let go::Expr::Name(name) = func.as_ref() {
let name = name.as_str();
if name.starts_with(&defaulter_prefix()) && !out.iter().any(|seen| seen == name) {
out.push(name.to_string());
}
}
calls_in_expr(func, out);
for arg in args {
calls_in_expr(arg, out);
}
}
go::Expr::Binary { lhs, rhs, .. } => {
calls_in_expr(lhs, out);
calls_in_expr(rhs, out);
}
go::Expr::Convert { value, .. }
| go::Expr::Paren(value)
| go::Expr::Unary { value, .. } => calls_in_expr(value, out),
go::Expr::Selector { value, .. } => calls_in_expr(value, out),
go::Expr::Index { value, index } => {
calls_in_expr(value, out);
calls_in_expr(index, out);
}
go::Expr::SliceTo { value, high } => {
calls_in_expr(value, out);
calls_in_expr(high, out);
}
go::Expr::Composite { elems, .. } => {
for elem in elems {
calls_in_expr(&elem.value, out);
}
}
go::Expr::Make { length, .. } => calls_in_expr(length, out),
go::Expr::Literal(_) | go::Expr::Name(_) => {}
}
}
fn text(value: &str) -> go::Expr {
go::Expr::Literal(Literal::Str(value.to_string()))
}