vantage_table/references/
one.rs1use std::fmt::Display;
6use std::{any::Any, marker::PhantomData, sync::Arc};
7
8use vantage_core::Result;
9use vantage_types::Entity;
10
11use crate::{
12 any::AnyTable,
13 references::Reference,
14 table::Table,
15 traits::{column_like::ColumnLike, table_source::TableSource},
16};
17
18pub struct HasOne<T: TableSource, SourceE: Entity<T::Value>, TargetE: Entity<T::Value>> {
19 foreign_key: String,
21 build_target: Arc<dyn Fn(T) -> Table<T, TargetE> + Send + Sync>,
23 _phantom: PhantomData<SourceE>,
24}
25
26impl<T: TableSource, SourceE: Entity<T::Value>, TargetE: Entity<T::Value>>
27 HasOne<T, SourceE, TargetE>
28{
29 pub fn new(
30 foreign_key: impl Into<String>,
31 build_target: impl Fn(T) -> Table<T, TargetE> + Send + Sync + 'static,
32 ) -> Self {
33 Self {
34 foreign_key: foreign_key.into(),
35 build_target: Arc::new(build_target),
36 _phantom: PhantomData,
37 }
38 }
39}
40
41impl<T: TableSource, SourceE: Entity<T::Value>, TargetE: Entity<T::Value>> Clone
42 for HasOne<T, SourceE, TargetE>
43{
44 fn clone(&self) -> Self {
45 Self {
46 foreign_key: self.foreign_key.clone(),
47 build_target: self.build_target.clone(),
48 _phantom: PhantomData,
49 }
50 }
51}
52
53impl<T: TableSource, SourceE: Entity<T::Value>, TargetE: Entity<T::Value>> std::fmt::Debug
54 for HasOne<T, SourceE, TargetE>
55{
56 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
57 f.debug_struct("HasOne")
58 .field("foreign_key", &self.foreign_key)
59 .finish()
60 }
61}
62
63impl<
64 T: TableSource + 'static,
65 SourceE: Entity<T::Value> + 'static,
66 TargetE: Entity<T::Value> + 'static,
67> Reference for HasOne<T, SourceE, TargetE>
68where
69 T::Value: Into<serde_json::Value> + From<serde_json::Value>,
70 T::Id: Display + From<String>,
71{
72 fn columns(&self, _source_id: &str, target_id: &str) -> (String, String) {
73 (self.foreign_key.clone(), target_id.to_string())
74 }
75
76 fn build_target(&self, data_source: &dyn Any) -> Box<dyn Any> {
77 let ds = data_source
78 .downcast_ref::<T>()
79 .expect("data source type mismatch in HasOne::build_target");
80 Box::new((self.build_target)(ds.clone()))
81 }
82
83 fn resolve_as_any(&self, source_table: &dyn Any) -> Result<AnyTable> {
84 let source = source_table
85 .downcast_ref::<Table<T, SourceE>>()
86 .ok_or_else(|| {
87 vantage_core::error!("Source table type mismatch in HasOne::resolve_as_any")
88 })?;
89
90 let source_id = source
91 .id_field()
92 .map(|c| c.name().to_string())
93 .unwrap_or_else(|| "id".to_string());
94
95 let mut target = (self.build_target)(source.data_source().clone());
96
97 let target_id = target
98 .id_field()
99 .map(|c| c.name().to_string())
100 .unwrap_or_else(|| "id".to_string());
101
102 let (src_col, tgt_col) = self.columns(&source_id, &target_id);
103 let condition = source
104 .data_source()
105 .related_in_condition(&tgt_col, source, &src_col);
106 target.add_condition(condition);
107
108 Ok(AnyTable::from_table(target))
109 }
110
111 fn target_type_name(&self) -> &'static str {
112 std::any::type_name::<Table<T, TargetE>>()
113 }
114}