reifydb-catalog 0.4.8

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

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

use reifydb_core::interface::catalog::config::Config;
use reifydb_transaction::transaction::admin::AdminTransaction;
use reifydb_type::value::{Value, r#type::Type};

use crate::{CatalogStore, Result, catalog::Catalog, error::CatalogError};

impl Catalog {
	pub fn set_config(&self, txn: &mut AdminTransaction, key: &str, value: Value) -> Result<()> {
		if self.materialized.system_config().get(key).is_none() {
			return Err(CatalogError::ConfigKeyNotFound(key.to_string()).into());
		}
		if matches!(value, Value::None { .. }) {
			return Err(CatalogError::ConfigValueInvalid(key.to_string()).into());
		}
		let expected = self
			.materialized
			.system_config()
			.get_default(key)
			.expect("key exists, default must be present")
			.get_type();
		let actual = value.get_type();
		if !types_compatible(&expected, &actual) {
			return Err(CatalogError::ConfigTypeMismatch {
				key: key.to_string(),
				expected,
				actual,
			}
			.into());
		}
		CatalogStore::set_config(txn, key, &value)?;
		txn.changes.add_config_change(key.to_string(), value);
		Ok(())
	}

	pub fn list_configs(&self) -> Vec<Config> {
		self.materialized.list_configs()
	}
}

fn types_compatible(expected: &Type, actual: &Type) -> bool {
	if expected == actual {
		return true;
	}
	is_numeric(expected) && is_numeric(actual)
}

fn is_numeric(ty: &Type) -> bool {
	matches!(
		ty,
		Type::Int1
			| Type::Int2 | Type::Int4
			| Type::Int8 | Type::Int16
			| Type::Uint1 | Type::Uint2
			| Type::Uint4 | Type::Uint8
			| Type::Uint16 | Type::Float4
			| Type::Float8 | Type::Int
			| Type::Uint | Type::Decimal
	)
}