reifydb-catalog 0.4.13

Database catalog and metadata management for ReifyDB
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

// SPDX-License-Identifier: Apache-2.0
// Copyright (c) 2025 ReifyDB

use reifydb_core::{
	common::CommitVersion,
	interface::catalog::identity::{Role, RoleId},
};

use crate::materialized::{MaterializedCatalog, MultiVersionRole};

impl MaterializedCatalog {
	/// Find a role by ID at a specific version
	pub fn find_role_at(&self, id: RoleId, version: CommitVersion) -> Option<Role> {
		self.roles.get(&id).and_then(|entry| {
			let multi = entry.value();
			multi.get(version)
		})
	}

	/// Find a role by name at a specific version
	pub fn find_role_by_name_at(&self, name: &str, version: CommitVersion) -> Option<Role> {
		self.roles_by_name.get(name).and_then(|entry| {
			let role_id = *entry.value();
			self.find_role_at(role_id, version)
		})
	}

	/// Find a role by ID (returns latest version)
	pub fn find_role(&self, id: RoleId) -> Option<Role> {
		self.roles.get(&id).and_then(|entry| {
			let multi = entry.value();
			multi.get_latest()
		})
	}

	pub fn set_role(&self, id: RoleId, version: CommitVersion, role: Option<Role>) {
		if let Some(entry) = self.roles.get(&id)
			&& let Some(pre) = entry.value().get_latest()
		{
			self.roles_by_name.remove(&pre.name);
		}

		let multi = self.roles.get_or_insert_with(id, MultiVersionRole::new);
		if let Some(new) = role {
			self.roles_by_name.insert(new.name.clone(), id);
			multi.value().insert(version, new);
		} else {
			multi.value().remove(version);
		}
	}
}