use reifydb_core::interface::catalog::{
change::CatalogTrackTestChangeOperations,
id::{NamespaceId, TestId},
test::Test,
};
use reifydb_type::Result;
use crate::{
change::{
Change,
OperationType::{Create, Delete},
TransactionalTestChanges,
},
transaction::admin::AdminTransaction,
};
impl CatalogTrackTestChangeOperations for AdminTransaction {
fn track_test_created(&mut self, test: Test) -> Result<()> {
let change = Change {
pre: None,
post: Some(test),
op: Create,
};
self.changes.add_test_change(change);
Ok(())
}
fn track_test_deleted(&mut self, test: Test) -> Result<()> {
let change = Change {
pre: Some(test),
post: None,
op: Delete,
};
self.changes.add_test_change(change);
Ok(())
}
}
impl TransactionalTestChanges for AdminTransaction {
fn find_test(&self, id: TestId) -> Option<&Test> {
for change in self.changes.test.iter().rev() {
if let Some(test) = &change.post {
if test.id == id {
return Some(test);
}
} else if let Some(test) = &change.pre
&& test.id == id && change.op == Delete
{
return None;
}
}
None
}
fn find_test_by_name(&self, namespace: NamespaceId, name: &str) -> Option<&Test> {
self.changes
.test
.iter()
.rev()
.find_map(|change| change.post.as_ref().filter(|t| t.namespace == namespace && t.name == name))
}
fn is_test_deleted(&self, id: TestId) -> bool {
self.changes
.test
.iter()
.rev()
.any(|change| change.op == Delete && change.pre.as_ref().map(|t| t.id) == Some(id))
}
fn is_test_deleted_by_name(&self, namespace: NamespaceId, name: &str) -> bool {
self.changes.test.iter().rev().any(|change| {
change.op == Delete
&& change
.pre
.as_ref()
.map(|t| t.namespace == namespace && t.name == name)
.unwrap_or(false)
})
}
}