use std::sync::{Arc, OnceLock};
use derive_where::derive_where;
use topcoat::{context::Cx, view::*};
use super::{Column, ColumnBase, ColumnWidth};
use crate::{
Lens,
form::FormValues,
schema::{EmbeddedForm, FieldResolver, Schema},
};
#[derive_where(Clone, Debug)]
pub struct EmbeddedColumn<M, T> {
lens: Lens<M, T>,
base: ColumnBase,
schema: Arc<OnceLock<Schema>>,
}
impl<M, T> EmbeddedColumn<M, T>
where
M: toasty::schema::Model,
T: EmbeddedForm,
{
pub fn new(lens: Lens<M, T>) -> Self {
Self {
base: ColumnBase::new(lens.path(), ColumnWidth::Wide),
lens,
schema: Arc::default(),
}
}
base_builders!();
fn spelled(&self, row: &M) -> Option<(&Schema, FormValues)> {
let schema = self.schema.get()?;
let mut values = FormValues::new();
self.lens
.read(row)
.write_node(schema.embedded_root(), &mut values);
Some((schema, values))
}
}
impl<M, T> Column<M> for EmbeddedColumn<M, T>
where
M: toasty::schema::Model + Send + Sync + 'static,
T: EmbeddedForm + Send + Sync + 'static,
{
base_column_methods!();
fn text(&self, _cx: &Cx, row: &M) -> String {
let Some((schema, values)) = self.spelled(row) else {
return String::new();
};
schema
.embedded_root()
.shown(&schema.fields, &values)
.into_iter()
.filter_map(|index| {
let field = &schema.fields[index];
let value = values.text(field.name()).unwrap_or_default();
let read = field.read(value)?;
Some(format!("{}: {read}", field.label_str()))
})
.collect::<Vec<_>>()
.join(", ")
}
fn entry<'a>(&self, cx: &'a Cx, row: &M) -> BoxView<'a> {
match self.spelled(row) {
Some((schema, values)) => schema.embedded_root().display(cx, &schema.fields, &values),
None => ().boxed(),
}
}
fn misdeclared(&self) -> Option<crate::DeclarationErrorKind> {
if let Some(error) = self.base.binding.misdeclared() {
return Some(error);
}
match self.schema.get() {
Some(schema) => schema.declaration_errors().into_iter().next(),
None => Some(crate::DeclarationErrorKind::Unbound {
item: std::any::type_name::<T>(),
}),
}
}
fn bind(&self, resolver: &FieldResolver) {
self.base.binding.bind(resolver);
self.schema
.get_or_init(|| T::build_schema(resolver, self.lens.path().clone()));
}
}