reifydb_transaction/transaction/catalog/
identity.rs

1// SPDX-License-Identifier: Apache-2.0
2// Copyright (c) 2025 ReifyDB
3
4use reifydb_core::interface::catalog::{change::CatalogTrackIdentityChangeOperations, identity::Identity};
5use reifydb_type::{Result, value::identity::IdentityId};
6
7use crate::{
8	change::{
9		Change,
10		OperationType::{Create, Delete, Update},
11		TransactionalIdentityChanges,
12	},
13	interceptor::identity::{
14		IdentityPostCreateContext, IdentityPostUpdateContext, IdentityPreDeleteContext,
15		IdentityPreUpdateContext,
16	},
17	transaction::admin::AdminTransaction,
18};
19
20impl CatalogTrackIdentityChangeOperations for AdminTransaction {
21	fn track_identity_created(&mut self, identity: Identity) -> Result<()> {
22		self.interceptors.identity_post_create.execute(IdentityPostCreateContext::new(&identity))?;
23		let change = Change {
24			pre: None,
25			post: Some(identity),
26			op: Create,
27		};
28		self.changes.add_identity_change(change);
29		Ok(())
30	}
31
32	fn track_identity_updated(&mut self, pre: Identity, post: Identity) -> Result<()> {
33		self.interceptors.identity_pre_update.execute(IdentityPreUpdateContext::new(&pre))?;
34		self.interceptors.identity_post_update.execute(IdentityPostUpdateContext::new(&pre, &post))?;
35		let change = Change {
36			pre: Some(pre),
37			post: Some(post),
38			op: Update,
39		};
40		self.changes.add_identity_change(change);
41		Ok(())
42	}
43
44	fn track_identity_deleted(&mut self, identity: Identity) -> Result<()> {
45		self.interceptors.identity_pre_delete.execute(IdentityPreDeleteContext::new(&identity))?;
46		let change = Change {
47			pre: Some(identity),
48			post: None,
49			op: Delete,
50		};
51		self.changes.add_identity_change(change);
52		Ok(())
53	}
54}
55
56impl TransactionalIdentityChanges for AdminTransaction {
57	fn find_identity(&self, id: IdentityId) -> Option<&Identity> {
58		for change in self.changes.identity.iter().rev() {
59			if let Some(identity) = &change.post {
60				if identity.id == id {
61					return Some(identity);
62				}
63			} else if let Some(identity) = &change.pre
64				&& identity.id == id && change.op == Delete
65			{
66				return None;
67			}
68		}
69		None
70	}
71
72	fn find_identity_by_name(&self, name: &str) -> Option<&Identity> {
73		self.changes.identity.iter().rev().find_map(|change| change.post.as_ref().filter(|u| u.name == name))
74	}
75
76	fn is_identity_deleted(&self, id: IdentityId) -> bool {
77		self.changes
78			.identity
79			.iter()
80			.rev()
81			.any(|change| change.op == Delete && change.pre.as_ref().map(|u| u.id) == Some(id))
82	}
83
84	fn is_identity_deleted_by_name(&self, name: &str) -> bool {
85		self.changes.identity.iter().rev().any(|change| {
86			change.op == Delete && change.pre.as_ref().map(|u| u.name == name).unwrap_or(false)
87		})
88	}
89}
reifydb_transaction/transaction/catalog/identity.rs

reifydb_transaction/transaction/catalog/
identity.rs
