use crate::value::Value;
use derive_more::Display;
use serde::{Deserialize, Serialize};
use std::collections::HashMap;
use uuid::Uuid;
use crate::gen_bb_uuid;
#[derive(Debug, Clone, Display, Serialize, Deserialize, PartialEq)]
#[display("KV({:?})", fields)]
pub struct KeyValue {
pub id: Uuid,
pub fields: HashMap<String, KeyValueField>,
}
impl Default for KeyValue {
fn default() -> Self {
Self::new()
}
}
impl KeyValue {
pub fn new() -> Self {
KeyValue::new_with_id(gen_bb_uuid())
}
pub fn new_with_id(id: Uuid) -> Self {
Self {
id,
fields: HashMap::new(),
}
}
pub fn set_field(&mut self, field: KeyValueField) {
self.fields.insert(field.name.clone(), field);
}
pub fn set_field_value(&mut self, key: &str, value: Value) {
let key_str = key.to_string();
if let Some(existing_field) = self.fields.get_mut(&key_str) {
existing_field.value = Some(Box::new(value));
} else {
let field = KeyValueField::new(key_str.clone(), value);
self.fields.insert(key_str, field);
}
}
pub fn get_fields(&self) -> &HashMap<String, KeyValueField> {
&self.fields
}
pub fn get_field_keys(&self) -> Vec<String> {
self.fields.keys().cloned().collect()
}
pub fn get_field(&self, key: &str) -> Option<&KeyValueField> {
self.fields.get(key)
}
pub fn as_value(self) -> Value {
Value::KeyValue(self)
}
}
#[derive(Debug, Clone, Display, Serialize, Deserialize, PartialEq)]
#[display("{} ({}): {:?}", name, id, value)]
pub struct KeyValueField {
pub id: Uuid,
pub name: String,
pub value: Option<Box<Value>>,
}
#[derive(Debug, Clone, Serialize, Deserialize, PartialEq, Default)]
pub struct KeyValueItems(pub Vec<KeyValueField>);
impl std::ops::Deref for KeyValueItems {
type Target = [KeyValueField];
fn deref(&self) -> &Self::Target {
&self.0
}
}
impl IntoIterator for KeyValueItems {
type Item = KeyValueField;
type IntoIter = std::vec::IntoIter<KeyValueField>;
fn into_iter(self) -> Self::IntoIter {
self.0.into_iter()
}
}
impl From<Vec<KeyValueField>> for KeyValueItems {
fn from(v: Vec<KeyValueField>) -> Self {
let mut kvis = KeyValueItems::new();
for f in v.into_iter() {
kvis.set(f);
}
kvis
}
}
impl<'a> From<&'a [KeyValueField]> for KeyValueItems {
fn from(slice: &'a [KeyValueField]) -> Self {
let mut kvis = KeyValueItems::new();
for f in slice.iter().cloned() {
kvis.set(f);
}
kvis
}
}
impl From<KeyValueItems> for Vec<KeyValueField> {
fn from(kvs: KeyValueItems) -> Self {
kvs.0
}
}
impl KeyValueItems {
pub fn new() -> Self {
Self(Vec::new())
}
pub fn set(&mut self, field: KeyValueField) -> Option<KeyValueField> {
if let Some(idx) = self.0.iter().position(|f| f.name == field.name) {
let mut old = field; std::mem::swap(&mut self.0[idx], &mut old);
Some(old)
} else {
self.0.push(field);
None
}
}
pub fn is_empty(&self) -> bool {
self.0.is_empty()
}
pub fn len(&self) -> usize {
self.0.len()
}
pub fn into_inner(self) -> Vec<KeyValueField> {
self.0
}
pub fn iter(&self) -> std::slice::Iter<'_, KeyValueField> {
self.0.iter()
}
pub fn get(&self, name: &str) -> Option<&KeyValueField> {
self.0.iter().find(|f| f.name == name)
}
pub fn from_hash<K>(pairs: impl IntoIterator<Item = (K, KeyValueField)>) -> KeyValueItems
where
K: Into<String>,
{
use std::collections::HashMap; let mut map: HashMap<String, KeyValueField> = HashMap::new();
for (k, v) in pairs.into_iter() {
map.insert(k.into(), v); }
KeyValueItems(map.into_values().collect())
}
}
impl AsRef<[KeyValueField]> for KeyValueItems {
fn as_ref(&self) -> &[KeyValueField] {
&self.0
}
}
impl KeyValueField {
pub fn new<S: Into<String>>(name: S, value: Value) -> Self {
Self::new_with_option(name, Some(value))
}
pub fn new_with_option<S: Into<String>>(name: S, value: Option<Value>) -> Self {
Self::new_with_id_and_option(name, gen_bb_uuid(), value)
}
pub fn new_with_id<S: Into<String>>(name: S, id: Uuid, value: Value) -> Self {
Self {
name: name.into(),
id,
value: Some(Box::new(value)),
}
}
pub fn new_with_id_and_option<S: Into<String>>(name: S, id: Uuid, value: Option<Value>) -> Self {
Self {
name: name.into(),
id,
value: value.map(Box::new),
}
}
pub fn new_nested_kv<S: Into<String>, F: AsRef<[KeyValueField]>>(kv_name: S, fields: &F) -> Self {
Self::new_nested_kv_with_kv_id(kv_name, gen_bb_uuid(), fields)
}
pub fn new_nested_kv_with_kv_id<S: Into<String>, F: AsRef<[KeyValueField]>>(
kv_name: S,
kv_id: Uuid,
fields: &F,
) -> Self {
Self::new_nested_kv_with_both_ids(kv_name, gen_bb_uuid(), kv_id, fields)
}
pub fn new_nested_kv_with_both_ids<S: Into<String>, F: AsRef<[KeyValueField]>>(
kv_name: S,
field_id: Uuid,
kv_id: Uuid,
fields: &F,
) -> Self {
let kv: KeyValue = (kv_id, fields.as_ref()).into();
KeyValueField::new_with_id(kv_name, field_id, kv.into())
}
}
impl From<KeyValue> for Value {
fn from(kv: KeyValue) -> Self {
kv.as_value()
}
}
impl From<Vec<KeyValueField>> for KeyValue {
fn from(fields: Vec<KeyValueField>) -> Self {
let id = gen_bb_uuid();
(id, fields).into()
}
}
impl From<&[KeyValueField]> for KeyValue {
fn from(fields: &[KeyValueField]) -> Self {
let id = gen_bb_uuid();
(id, fields).into()
}
}
impl<const N: usize> From<[KeyValueField; N]> for KeyValue {
fn from(arr: [KeyValueField; N]) -> Self {
let id = gen_bb_uuid();
(id, arr.into_iter().collect::<Vec<_>>()).into()
}
}
impl From<KeyValueItems> for KeyValue {
fn from(set: KeyValueItems) -> Self {
let id = gen_bb_uuid();
(id, set.0).into()
}
}
impl From<(Uuid, Vec<KeyValueField>)> for KeyValue {
fn from((id, fields): (Uuid, Vec<KeyValueField>)) -> Self {
let mut map = HashMap::with_capacity(fields.len());
for f in fields.into_iter() {
map.insert(f.name.clone(), f); }
KeyValue { id, fields: map }
}
}
impl From<(Uuid, &[KeyValueField])> for KeyValue {
fn from((id, fields): (Uuid, &[KeyValueField])) -> Self {
let mut map = HashMap::with_capacity(fields.len());
for f in fields.iter().cloned() {
map.insert(f.name.clone(), f);
}
KeyValue { id, fields: map }
}
}
impl From<(Uuid, KeyValueItems)> for KeyValue {
fn from((id, set): (Uuid, KeyValueItems)) -> Self {
(id, set.0).into()
}
}
impl From<(Uuid, HashMap<String, KeyValueField>)> for KeyValue {
fn from((id, map): (Uuid, HashMap<String, KeyValueField>)) -> Self {
KeyValue { id, fields: map }
}
}
impl<const N: usize> From<(Uuid, [KeyValueField; N])> for KeyValue {
fn from((id, arr): (Uuid, [KeyValueField; N])) -> Self {
(id, arr.into_iter().collect::<Vec<_>>()).into()
}
}
impl From<HashMap<String, KeyValueField>> for KeyValue {
fn from(map: HashMap<String, KeyValueField>) -> Self {
let id = gen_bb_uuid();
(id, map).into()
}
}
#[cfg(test)]
mod tests {
use super::*;
use crate::value::Value;
#[test]
fn test_keyvalue_new() {
let uuid = gen_bb_uuid();
let kv = KeyValue::new_with_id(uuid);
assert_eq!(kv.id, uuid);
assert!(kv.fields.is_empty());
}
#[test]
fn test_keyvalue_set_field_value_new() {
let mut kv = KeyValue::new();
let health_value = Value::I32(100);
kv.set_field_value("health", health_value.clone());
assert_eq!(kv.fields.len(), 1);
assert!(kv.fields.contains_key("health"));
let field = kv.get_field("health").unwrap();
match field.value.as_deref() {
Some(Value::I32(value)) => assert_eq!(*value, 100),
_ => panic!("Expected I32 value"),
}
}
#[test]
fn test_keyvalue_set_field_value_update_existing() {
let mut kv = KeyValue::new();
kv.set_field_value("health", Value::I32(100));
kv.set_field_value("health", Value::I32(50));
assert_eq!(kv.fields.len(), 1);
let field = kv.get_field("health").unwrap();
match field.value.as_deref() {
Some(Value::I32(value)) => assert_eq!(*value, 50),
_ => panic!("Expected I32 value"),
}
}
#[test]
fn test_keyvalue_set_field() {
let mut kv = KeyValue::new();
let field = KeyValueField::new("health_id", Value::I32(100));
kv.set_field(field.clone());
assert_eq!(kv.fields.len(), 1);
assert!(kv.fields.contains_key("health_id"));
assert_eq!(kv.get_field("health_id"), Some(&field));
}
#[test]
fn test_keyvalue_get_field_keys() {
let mut kv = KeyValue::new();
kv.set_field_value("health", Value::I32(100));
kv.set_field_value("mana", Value::I32(50));
kv.set_field_value("level", Value::I32(5));
let keys = kv.get_field_keys();
assert_eq!(keys.len(), 3);
assert!(keys.contains(&"health".to_string()));
assert!(keys.contains(&"mana".to_string()));
assert!(keys.contains(&"level".to_string()));
}
#[test]
fn test_keyvalue_get_field_nonexistent() {
let kv = KeyValue::new();
assert_eq!(kv.get_field("nonexistent"), None);
}
#[test]
fn test_keyvalue_field_new() {
let field = KeyValueField::new("test_id", Value::String("test_value".to_string()));
assert_eq!(field.name, "test_id");
match field.value.as_deref() {
Some(Value::String(value)) => assert_eq!(value, "test_value"),
_ => panic!("Expected String value"),
}
}
#[test]
fn test_keyvalue_field_simple_nested_keyvalue() {
let id = gen_bb_uuid();
let inner_kv = KeyValue::new_with_id(id);
let field = KeyValueField::new("test_id", inner_kv.as_value());
assert_eq!(field.name, "test_id");
match field.value.as_deref() {
Some(Value::KeyValue(kv)) => assert_eq!(kv.id, id),
_ => panic!("Expected KeyValue variant"),
}
}
#[test]
fn test_simple_make_kv_from_fields() {
let fields = vec![
KeyValueField::new("health", Value::I32(100)),
KeyValueField::new("mana", Value::I32(50)),
];
let id = gen_bb_uuid();
let kv: KeyValue = KeyValue::from((id, fields));
assert_eq!(kv.id, id);
assert_eq!(kv.fields.len(), 2);
assert!(kv.fields.contains_key("health"));
assert!(kv.fields.contains_key("mana"));
match kv.fields.get("health").unwrap().value.as_deref() {
Some(Value::I32(value)) => assert_eq!(*value, 100),
_ => panic!("Expected I32 value"),
}
match kv.fields.get("mana").unwrap().value.as_deref() {
Some(Value::I32(value)) => assert_eq!(*value, 50),
_ => panic!("Expected I32 value"),
}
}
#[test]
fn test_keyvalue_nested_structure_without_ids() {
let player: KeyValue = {
let fields = [
KeyValueField::new("health", Value::I32(100)),
KeyValueField::new_nested_kv(
"stats",
&KeyValueItems::from(vec![
KeyValueField::new("strength", Value::I32(50)),
KeyValueField::new("agility", Value::I32(75)),
]),
),
KeyValueField::new_nested_kv(
"position",
&KeyValueItems::from(vec![
KeyValueField::new("x", Value::F32(10.0)),
KeyValueField::new("y", Value::F32(20.0)),
]),
),
];
KeyValue::from(fields)
};
assert_eq!(player.fields.len(), 3);
let health_field = player.get_field("health").expect("health field");
match health_field.value.as_deref() {
Some(Value::I32(100)) => {}
other => panic!("Expected I32(100) got {:?}", other),
}
let stats_field = player.get_field("stats").expect("stats field");
match stats_field.value.as_deref() {
Some(Value::KeyValue(stats_kv)) => {
assert_eq!(stats_kv.fields.len(), 2);
match stats_kv.get_field("strength").unwrap().value.as_deref() {
Some(Value::I32(50)) => {}
other => panic!("Expected strength=50 got {:?}", other),
}
match stats_kv.get_field("agility").unwrap().value.as_deref() {
Some(Value::I32(75)) => {}
other => panic!("Expected agility=75 got {:?}", other),
}
}
other => panic!("Expected KeyValue for stats got {:?}", other),
}
let position_field = player.get_field("position").expect("position field");
match position_field.value.as_deref() {
Some(Value::KeyValue(pos_kv)) => {
assert_eq!(pos_kv.fields.len(), 2);
match pos_kv.get_field("x").unwrap().value.as_deref() {
Some(Value::F32(f)) if (*f - 10.0).abs() < f32::EPSILON => {}
other => panic!("Expected x=10.0 got {:?}", other),
}
match pos_kv.get_field("y").unwrap().value.as_deref() {
Some(Value::F32(f)) if (*f - 20.0).abs() < f32::EPSILON => {}
other => panic!("Expected y=20.0 got {:?}", other),
}
}
other => panic!("Expected KeyValue for position got {:?}", other),
}
}
#[test]
fn test_make_kv_from_fields_duplicate_names_last_wins() {
let fields = vec![
KeyValueField::new("health", Value::I32(100)),
KeyValueField::new("health", Value::I32(150)), ];
let kv: KeyValue = KeyValue::from(fields);
assert_eq!(kv.fields.len(), 1); let health_field = kv.get_field("health").unwrap();
match health_field.value.as_deref() {
Some(Value::I32(150)) => {}
other => panic!("Expected 150 got {:?}", other),
}
}
#[test]
fn test_keyvalue_nested_structure_with_ids() {
let outer_id = gen_bb_uuid();
let health_id = gen_bb_uuid();
let inner_field_id = gen_bb_uuid();
let inner_kv_id = gen_bb_uuid();
let strength_id = gen_bb_uuid();
let agility_id = gen_bb_uuid();
let stats_set = KeyValueItems::from(vec![
KeyValueField::new_with_id("strength", strength_id, Value::I32(50)),
KeyValueField::new_with_id("agility", agility_id, Value::I32(75)),
]);
let player = KeyValue::from((
outer_id,
vec![
KeyValueField::new_with_id("health", health_id, Value::I32(100)),
KeyValueField::new_nested_kv_with_both_ids(
"stats",
inner_field_id,
inner_kv_id,
&stats_set,
),
],
));
assert_eq!(player.id, outer_id);
assert_eq!(player.fields.len(), 2);
let health_field = player.get_field("health").unwrap();
assert_eq!(health_field.id, health_id);
match health_field.value.as_ref().unwrap().as_ref() {
Value::I32(100) => {}
_ => panic!("Expected I32(100)"),
}
let stats_field = player.get_field("stats").unwrap();
assert_eq!(stats_field.id, inner_field_id);
match stats_field.value.as_deref() {
Some(Value::KeyValue(stats_kv)) => {
assert_eq!(stats_kv.id, inner_kv_id);
assert_eq!(stats_kv.fields.len(), 2);
let strength_field = stats_kv.get_field("strength").unwrap();
assert_eq!(strength_field.id, strength_id);
match strength_field.value.as_deref() {
Some(Value::I32(50)) => {}
other => panic!("Expected I32(50) got {:?}", other),
}
let agility_field = stats_kv.get_field("agility").unwrap();
assert_eq!(agility_field.id, agility_id);
match agility_field.value.as_deref() {
Some(Value::I32(75)) => {}
other => panic!("Expected I32(75) got {:?}", other),
}
}
other => panic!("Expected KeyValue for stats got {:?}", other),
}
}
#[test]
fn test_keyvalue_display() {
let mut kv = KeyValue::new();
kv.set_field_value("key1", Value::String("value1".to_string()));
kv.set_field_value("key2", Value::I32(42));
let display_str = format!("{}", kv);
assert!(display_str.contains("KV("));
assert!(display_str.contains("key1"));
assert!(display_str.contains("key2"));
}
#[test]
fn test_keyvalue_field_display() {
let field = KeyValueField::new("test_field", Value::String("test_value".to_string()));
let display_str = format!("{}", field);
assert!(display_str.contains("test_field"));
assert!(display_str.contains("test_value"));
}
#[test]
fn test_keyvalue_clone_and_equality() {
let mut original = KeyValue::new();
original.set_field_value("health", Value::I32(100));
original.set_field_value("level", Value::I32(5));
let cloned = original.clone();
assert_eq!(original, cloned);
assert_eq!(original.id, cloned.id);
assert_eq!(original.fields.len(), cloned.fields.len());
let mut modified = cloned;
modified.set_field_value("health", Value::I32(200));
assert_ne!(original, modified);
}
#[test]
fn test_keyvalue_serialization() {
use json5;
let id = gen_bb_uuid();
let mut kv = KeyValue::new_with_id(id);
kv.set_field_value("health", Value::I32(100));
kv.set_field_value("name", Value::String("Hero".to_string()));
let json = json5::to_string(&kv).expect("Serialization should succeed");
assert!(json.contains(&id.to_string()));
assert!(json.contains("health"));
assert!(json.contains("name"));
let deserialized: KeyValue = json5::from_str(&json).expect("Deserialization should succeed");
assert_eq!(kv, deserialized);
}
#[test]
fn test_keyvalue_empty_operations() {
let kv = KeyValue::new();
assert!(kv.get_field_keys().is_empty());
assert!(kv.get_fields().is_empty());
assert_eq!(kv.get_field("any_key"), None);
}
#[test]
fn test_valueblock_with_different_value_types() {
let test_cases = vec![
("bool", Value::Boolean(true)),
("u8", Value::U8(255)),
("u16", Value::U16(65535)),
("u32", Value::U32(4294967295)),
("u64", Value::U64(18446744073709551615)),
("i8", Value::I8(-128)),
("i16", Value::I16(-32768)),
("i32", Value::I32(-2147483648)),
("i64", Value::I64(-9223372036854775808)),
("f32", Value::F32(std::f32::consts::PI)),
("f64", Value::F64(std::f64::consts::E)),
("string", Value::String("test string".to_string())),
("unit", Value::Unit),
];
for (name, value) in test_cases {
let mut kv = KeyValue::new();
kv.set_field_value(name, value.clone());
let retrieved_field = kv.get_field(name).unwrap();
assert_eq!(
retrieved_field.value.as_deref(),
Some(&value),
"Failed for type: {}",
name
);
}
}
#[test]
fn test_keyvalue_field_map_from_hash() {
use std::collections::HashMap;
let mut map: HashMap<String, KeyValueField> = HashMap::new();
map.insert("a".into(), KeyValueField::new("a", Value::I32(1)));
map.insert("b".into(), KeyValueField::new("b", Value::I32(2)));
map.insert("a".into(), KeyValueField::new("a", Value::I32(10)));
let auto_kv: KeyValue = map.clone().into();
assert_eq!(auto_kv.fields.len(), 2);
match auto_kv.get_field("a").unwrap().value.as_deref() {
Some(Value::I32(10)) => {}
other => panic!("expected 10 got {:?}", other),
}
match auto_kv.get_field("b").unwrap().value.as_deref() {
Some(Value::I32(2)) => {}
other => panic!("expected 2 got {:?}", other),
}
let explicit_id = gen_bb_uuid();
let kv_with_id: KeyValue = (explicit_id, map).into();
assert_eq!(kv_with_id.id, explicit_id);
assert_eq!(kv_with_id.fields.len(), 2);
assert!(kv_with_id.get_field("a").is_some());
assert!(kv_with_id.get_field("b").is_some());
}
#[test]
fn test_keyvalueset_from_vec_deduplicates_last_wins() {
let set = KeyValueItems::from(vec![
KeyValueField::new("health", Value::I32(100)),
KeyValueField::new("mana", Value::I32(50)),
KeyValueField::new("health", Value::I32(150)), ]);
assert_eq!(set.len(), 2);
let health = set.get("health").unwrap();
match health.value.as_deref() {
Some(Value::I32(150)) => {}
other => panic!("expected 150 got {:?}", other),
}
}
#[test]
fn test_keyvalueitems_set_replaces() {
let mut kvis = KeyValueItems::new();
let inserted = kvis.set(KeyValueField::new("speed", Value::I32(10)));
assert!(inserted.is_none());
let inserted2 = kvis.set(KeyValueField::new("speed", Value::I32(20))); assert!(inserted2.is_some());
assert_eq!(kvis.len(), 1);
match kvis.get("speed").unwrap().value.as_deref() {
Some(Value::I32(20)) => {}
other => panic!("expected 20 got {:?}", other),
}
}
#[test]
fn test_keyvalueitems_set_returns_old() {
let mut kvis = KeyValueItems::new();
assert!(kvis.set(KeyValueField::new("x", Value::I32(1))).is_none());
let old = kvis
.set(KeyValueField::new("x", Value::I32(2)))
.expect("old value");
match old.value.as_deref() {
Some(Value::I32(1)) => {}
other => panic!("expected old=1 got {:?}", other),
}
match kvis.get("x").unwrap().value.as_deref() {
Some(Value::I32(2)) => {}
other => panic!("expected new=2 got {:?}", other),
}
}
}