reifydb-testing 0.4.11

Testing utilities and helpers 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

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

// This file includes and modifies code from the toydb project (https://github.com/erikgrinaker/toydb),
// originally licensed under the Apache License, Version 2.0.
// Original copyright:
//   Copyright (c) 2024 Erik Grinaker
//
// The original Apache License can be found at:
//   http://www.apache.org/licenses/LICENSE-2.0

pub mod wait;

use std::{error::Error, ops::Bound};

use reifydb_core::util::encoding::binary::decode_binary;
use reifydb_type::util::cowvec::CowVec;

type KeyRange = (Bound<CowVec<u8>>, Bound<CowVec<u8>>);

/// Parses an binary key range, using Rust range syntax.
pub fn parse_key_range(s: &str) -> Result<KeyRange, Box<dyn Error>> {
	let mut bound = (Bound::<CowVec<u8>>::Unbounded, Bound::<CowVec<u8>>::Unbounded);

	if let Some(dot_pos) = s.find("..") {
		let start_part = &s[..dot_pos];
		let end_part = &s[dot_pos + 2..];

		// Parse start bound
		if !start_part.is_empty() {
			bound.0 = Bound::Included(decode_binary(start_part));
		}

		// Parse end bound - check for inclusive marker "="
		if let Some(end_str) = end_part.strip_prefix('=') {
			if !end_str.is_empty() {
				bound.1 = Bound::Included(decode_binary(end_str));
			}
		} else if !end_part.is_empty() {
			bound.1 = Bound::Excluded(decode_binary(end_part));
		}

		Ok(bound)
	} else {
		Err(format!("invalid range {s}").into())
	}
}