reifydb-core 0.6.0

Core database interfaces and data structures 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

// SPDX-License-Identifier: AGPL-3.0-or-later
// Copyright (c) 2026 ReifyDB

use reifydb_runtime::hash::Hash64;
use reifydb_value::value::value_type::ValueType;

use super::RowShape;

pub fn widen_type(a: ValueType, b: ValueType) -> ValueType {
	match (a, b) {
		(ValueType::Option(_), t) | (t, ValueType::Option(_)) => t,
		(ref a, ref b) if a == b => a.clone(),
		(a, b) => unimplemented!("type widening not yet supported: {:?} vs {:?}", a, b),
	}
}

#[allow(unused_variables)]
pub fn consolidate_shapes(fingerprints: &[Hash64], lookup: impl Fn(Hash64) -> Option<RowShape>) -> RowShape {
	unimplemented!("shape consolidation not yet supported")
}

#[cfg(test)]
mod tests {
	use super::*;

	#[test]
	fn test_widen_type_same() {
		assert_eq!(widen_type(ValueType::Int4, ValueType::Int4), ValueType::Int4);
	}

	#[test]
	fn test_widen_type_undefined() {
		assert_eq!(
			widen_type(ValueType::Option(Box::new(ValueType::Boolean)), ValueType::Int4),
			ValueType::Int4
		);
		assert_eq!(
			widen_type(ValueType::Int4, ValueType::Option(Box::new(ValueType::Boolean))),
			ValueType::Int4
		);
	}

	#[test]
	#[should_panic(expected = "type widening not yet supported")]
	fn test_widen_type_different_panics() {
		widen_type(ValueType::Int4, ValueType::Utf8);
	}
}