vantage_cmd/vista/
source.rs

1//! `CmdTableShell` — owns the typed `Table<Cmd, EmptyEntity>` and exposes
2//! it across the `TableShell` boundary.
3//!
4//! `Value = CborValue` end-to-end, so `list_vista_values` forwards the
5//! table's records unchanged. Relations are followed the built-in way:
6//! `get_ref` forwards to the wrapped table's [`Table::get_ref_from_row`],
7//! which reads the join value out of the parent row and pins the target
8//! table with a plain eq-condition — the same path csv / sqlite use.
9
10use async_trait::async_trait;
11use ciborium::Value as CborValue;
12use indexmap::IndexMap;
13use vantage_core::Result;
14use vantage_dataset::traits::ReadableValueSet;
15use vantage_table::table::Table;
16use vantage_types::{EmptyEntity, Record};
17use vantage_vista::{
18    Column as VistaColumn, Reference as VistaReference, TableShell, Vista, VistaCapabilities,
19    VistaMetadata,
20};
21
22use crate::cmd::Cmd;
23use crate::condition::CmdCondition;
24use crate::vista::factory::CmdVistaFactory;
25
26pub struct CmdTableShell {
27    table: Table<Cmd, EmptyEntity>,
28    capabilities: VistaCapabilities,
29    metadata: VistaMetadata,
30}
31
32impl CmdTableShell {
33    pub(crate) fn new(
34        table: Table<Cmd, EmptyEntity>,
35        capabilities: VistaCapabilities,
36        metadata: VistaMetadata,
37    ) -> Self {
38        Self {
39            table,
40            capabilities,
41            metadata,
42        }
43    }
44}
45
46#[async_trait]
47impl TableShell for CmdTableShell {
48    fn columns(&self) -> &IndexMap<String, VistaColumn> {
49        &self.metadata.columns
50    }
51
52    fn references(&self) -> &IndexMap<String, VistaReference> {
53        &self.metadata.references
54    }
55
56    fn id_column(&self) -> Option<&str> {
57        self.metadata.id_column.as_deref()
58    }
59
60    async fn list_vista_values(
61        &self,
62        _vista: &Vista,
63    ) -> Result<IndexMap<String, Record<CborValue>>> {
64        self.table.list_values().await
65    }
66
67    async fn get_vista_value(
68        &self,
69        _vista: &Vista,
70        id: &String,
71    ) -> Result<Option<Record<CborValue>>> {
72        let mut data = self.table.list_values().await?;
73        Ok(data.shift_remove(id))
74    }
75
76    async fn get_vista_some_value(
77        &self,
78        _vista: &Vista,
79    ) -> Result<Option<(String, Record<CborValue>)>> {
80        let data = self.table.list_values().await?;
81        Ok(data.into_iter().next())
82    }
83
84    async fn get_vista_count(&self, _vista: &Vista) -> Result<i64> {
85        Ok(self.table.list_values().await?.len() as i64)
86    }
87
88    fn add_eq_condition(&mut self, field: &str, value: &CborValue) -> Result<()> {
89        self.table
90            .add_condition(CmdCondition::eq(field, value.clone()));
91        Ok(())
92    }
93
94    fn get_ref(&self, relation: &str, row: &Record<CborValue>) -> Result<Vista> {
95        // `Cmd::Value` is `CborValue`, so the row passes through unchanged.
96        // The table's reference machinery reads the join value out of the
97        // parent row and pins the target with a plain eq-condition.
98        let target = self.table.get_ref_from_row::<EmptyEntity>(relation, row)?;
99        CmdVistaFactory::new(self.table.data_source().clone()).from_table(target)
100    }
101
102    fn get_ref_kinds(&self) -> Vec<(String, vantage_vista::ReferenceKind)> {
103        self.table.ref_kinds()
104    }
105
106    fn capabilities(&self) -> &VistaCapabilities {
107        &self.capabilities
108    }
109
110    fn driver_name(&self) -> &'static str {
111        "cmd"
112    }
113}
vantage_cmd/vista/source.rs

vantage_cmd/vista/
source.rs
