reifydb_core/key/
identity.rs

1// SPDX-License-Identifier: Apache-2.0
2// Copyright (c) 2025 ReifyDB
3
4use reifydb_type::value::identity::IdentityId;
5
6use super::{EncodableKey, KeyKind};
7use crate::{
8	encoded::key::{EncodedKey, EncodedKeyRange},
9	util::encoding::keycode::{deserializer::KeyDeserializer, serializer::KeySerializer},
10};
11
12#[derive(Debug, Clone, PartialEq)]
13pub struct IdentityKey {
14	pub identity: IdentityId,
15}
16
17impl IdentityKey {
18	pub fn new(identity: IdentityId) -> Self {
19		Self {
20			identity,
21		}
22	}
23
24	pub fn encoded(identity: IdentityId) -> EncodedKey {
25		Self::new(identity).encode()
26	}
27
28	pub fn full_scan() -> EncodedKeyRange {
29		let mut start = KeySerializer::with_capacity(1);
30		start.extend_u8(Self::KIND as u8);
31		let mut end = KeySerializer::with_capacity(1);
32		end.extend_u8(Self::KIND as u8 - 1);
33		EncodedKeyRange::start_end(Some(start.to_encoded_key()), Some(end.to_encoded_key()))
34	}
35}
36
37impl EncodableKey for IdentityKey {
38	const KIND: KeyKind = KeyKind::Identity;
39
40	fn encode(&self) -> EncodedKey {
41		let mut serializer = KeySerializer::with_capacity(17);
42		serializer.extend_u8(Self::KIND as u8).extend_identity_id(&self.identity);
43		serializer.to_encoded_key()
44	}
45
46	fn decode(key: &EncodedKey) -> Option<Self> {
47		let mut de = KeyDeserializer::from_bytes(key.as_slice());
48		let kind: KeyKind = de.read_u8().ok()?.try_into().ok()?;
49		if kind != Self::KIND {
50			return None;
51		}
52		let identity = de.read_identity_id().ok()?;
53		Some(Self {
54			identity,
55		})
56	}
57}
reifydb_core/key/identity.rs

reifydb_core/key/
identity.rs
