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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

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

use reifydb_core::{
	common::CommitVersion,
	interface::catalog::authentication::{Authentication, AuthenticationId},
};
use reifydb_type::value::identity::IdentityId;

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

impl MaterializedCatalog {
	/// Find an authentication by id at a specific version
	pub fn find_authentication_at(&self, id: AuthenticationId, version: CommitVersion) -> Option<Authentication> {
		self.authentications.get(&id).and_then(|entry| {
			let multi = entry.value();
			multi.get(version)
		})
	}

	/// Find an authentication by (identity, method) at a specific version
	pub fn find_authentication_by_identity_and_method_at(
		&self,
		identity: IdentityId,
		method: &str,
		version: CommitVersion,
	) -> Option<Authentication> {
		self.authentications_by_identity_method.get(&(identity, method.to_string())).and_then(|entry| {
			let auth_id = *entry.value();
			self.find_authentication_at(auth_id, version)
		})
	}

	/// Find an authentication by id (returns latest version)
	pub fn find_authentication(&self, id: AuthenticationId) -> Option<Authentication> {
		self.authentications.get(&id).and_then(|entry| {
			let multi = entry.value();
			multi.get_latest()
		})
	}

	/// List authentications filtered by method at a specific version
	pub fn list_authentications_by_method_at(&self, method: &str, version: CommitVersion) -> Vec<Authentication> {
		self.authentications
			.iter()
			.filter_map(|entry| entry.value().get(version))
			.filter(|a| a.method == method)
			.collect()
	}

	pub fn set_authentication(&self, id: AuthenticationId, version: CommitVersion, auth: Option<Authentication>) {
		if let Some(entry) = self.authentications.get(&id)
			&& let Some(pre) = entry.value().get_latest()
		{
			self.authentications_by_identity_method.remove(&(pre.identity, pre.method.clone()));
		}

		let multi = self.authentications.get_or_insert_with(id, MultiVersionAuthentication::new);
		if let Some(new) = auth {
			self.authentications_by_identity_method.insert((new.identity, new.method.clone()), id);
			multi.value().insert(version, new);
		} else {
			multi.value().remove(version);
		}
	}
}