use reifydb_core::interface::catalog::{
change::CatalogTrackTableChangeOperations,
id::{NamespaceId, TableId},
table::Table,
};
use reifydb_type::Result;
use crate::{
change::{
Change,
OperationType::{Create, Delete, Update},
TransactionalTableChanges,
},
transaction::admin::AdminTransaction,
};
impl CatalogTrackTableChangeOperations for AdminTransaction {
fn track_table_created(&mut self, table: Table) -> Result<()> {
let change = Change {
pre: None,
post: Some(table),
op: Create,
};
self.changes.add_table_change(change);
Ok(())
}
fn track_table_updated(&mut self, pre: Table, post: Table) -> Result<()> {
let change = Change {
pre: Some(pre),
post: Some(post),
op: Update,
};
self.changes.add_table_change(change);
Ok(())
}
fn track_table_deleted(&mut self, table: Table) -> Result<()> {
let change = Change {
pre: Some(table),
post: None,
op: Delete,
};
self.changes.add_table_change(change);
Ok(())
}
}
impl TransactionalTableChanges for AdminTransaction {
fn find_table(&self, id: TableId) -> Option<&Table> {
for change in self.changes.table.iter().rev() {
if let Some(table) = &change.post {
if table.id == id {
return Some(table);
}
} else if let Some(table) = &change.pre
&& table.id == id && change.op == Delete
{
return None;
}
}
None
}
fn find_table_by_name(&self, namespace: NamespaceId, name: &str) -> Option<&Table> {
self.changes
.table
.iter()
.rev()
.find_map(|change| change.post.as_ref().filter(|t| t.namespace == namespace && t.name == name))
}
fn is_table_deleted(&self, id: TableId) -> bool {
self.changes
.table
.iter()
.rev()
.any(|change| change.op == Delete && change.pre.as_ref().map(|t| t.id) == Some(id))
}
fn is_table_deleted_by_name(&self, namespace: NamespaceId, name: &str) -> bool {
self.changes.table.iter().rev().any(|change| {
change.op == Delete
&& change
.pre
.as_ref()
.map(|t| t.namespace == namespace && t.name == name)
.unwrap_or(false)
})
}
}