reifydb_transaction/transaction/catalog/
role.rs

1// SPDX-License-Identifier: Apache-2.0
2// Copyright (c) 2025 ReifyDB
3
4use reifydb_core::interface::catalog::{
5	change::CatalogTrackRoleChangeOperations,
6	identity::{Role, RoleId},
7};
8use reifydb_type::Result;
9
10use crate::{
11	change::{
12		Change,
13		OperationType::{Create, Delete, Update},
14		TransactionalRoleChanges,
15	},
16	interceptor::role::{RolePostCreateContext, RolePostUpdateContext, RolePreDeleteContext, RolePreUpdateContext},
17	transaction::admin::AdminTransaction,
18};
19
20impl CatalogTrackRoleChangeOperations for AdminTransaction {
21	fn track_role_created(&mut self, role: Role) -> Result<()> {
22		self.interceptors.role_post_create.execute(RolePostCreateContext::new(&role))?;
23		let change = Change {
24			pre: None,
25			post: Some(role),
26			op: Create,
27		};
28		self.changes.add_role_change(change);
29		Ok(())
30	}
31
32	fn track_role_updated(&mut self, pre: Role, post: Role) -> Result<()> {
33		self.interceptors.role_pre_update.execute(RolePreUpdateContext::new(&pre))?;
34		self.interceptors.role_post_update.execute(RolePostUpdateContext::new(&pre, &post))?;
35		let change = Change {
36			pre: Some(pre),
37			post: Some(post),
38			op: Update,
39		};
40		self.changes.add_role_change(change);
41		Ok(())
42	}
43
44	fn track_role_deleted(&mut self, role: Role) -> Result<()> {
45		self.interceptors.role_pre_delete.execute(RolePreDeleteContext::new(&role))?;
46		let change = Change {
47			pre: Some(role),
48			post: None,
49			op: Delete,
50		};
51		self.changes.add_role_change(change);
52		Ok(())
53	}
54}
55
56impl TransactionalRoleChanges for AdminTransaction {
57	fn find_role(&self, id: RoleId) -> Option<&Role> {
58		for change in self.changes.role.iter().rev() {
59			if let Some(role) = &change.post {
60				if role.id == id {
61					return Some(role);
62				}
63			} else if let Some(role) = &change.pre
64				&& role.id == id && change.op == Delete
65			{
66				return None;
67			}
68		}
69		None
70	}
71
72	fn find_role_by_name(&self, name: &str) -> Option<&Role> {
73		self.changes.role.iter().rev().find_map(|change| change.post.as_ref().filter(|r| r.name == name))
74	}
75
76	fn is_role_deleted(&self, id: RoleId) -> bool {
77		self.changes
78			.role
79			.iter()
80			.rev()
81			.any(|change| change.op == Delete && change.pre.as_ref().map(|r| r.id) == Some(id))
82	}
83
84	fn is_role_deleted_by_name(&self, name: &str) -> bool {
85		self.changes.role.iter().rev().any(|change| {
86			change.op == Delete && change.pre.as_ref().map(|r| r.name == name).unwrap_or(false)
87		})
88	}
89}
reifydb_transaction/transaction/catalog/role.rs

reifydb_transaction/transaction/catalog/
role.rs
