use crate::sql::part::Next; use crate::sql::part::Part; use crate::sql::value::Value; impl Value { pub fn put(&mut self, path: &[Part], val: Value) { match path.first() { // Get the current path part Some(p) => match self { // Current path part is an object Value::Object(v) => match p { Part::Thing(t) => match v.get_mut(t.to_raw().as_str()) { Some(v) if v.is_some() => v.put(path.next(), val), _ => { let mut obj = Value::base(); obj.put(path.next(), val); v.insert(t.to_raw(), obj); } }, Part::Graph(g) => match v.get_mut(g.to_raw().as_str()) { Some(v) if v.is_some() => v.put(path.next(), val), _ => { let mut obj = Value::base(); obj.put(path.next(), val); v.insert(g.to_raw(), obj); } }, Part::Field(f) => match v.get_mut(f.to_raw().as_str()) { Some(v) if v.is_some() => v.put(path.next(), val), _ => { let mut obj = Value::base(); obj.put(path.next(), val); v.insert(f.to_raw(), obj); } }, _ => (), }, // Current path part is an array Value::Array(v) => match p { Part::All => { let path = path.next(); v.iter_mut().for_each(|v| v.put(path, val.clone())); } Part::First => { if let Some(v) = v.first_mut() { v.put(path.next(), val) } } Part::Last => { if let Some(v) = v.last_mut() { v.put(path.next(), val) } } Part::Index(i) => { if let Some(v) = v.get_mut(i.to_usize()) { v.put(path.next(), val) } } _ => { v.iter_mut().for_each(|v| v.put(path, val.clone())); } }, // Current path part is empty Value::Null => { *self = Value::base(); self.put(path, val) } // Current path part is empty Value::None => { *self = Value::base(); self.put(path, val) } // Ignore everything else _ => (), }, // No more parts so put the value None => { *self = val; } } } } #[cfg(test)] mod tests { use super::*; use crate::sql::idiom::Idiom; use crate::sql::test::Parse; #[tokio::test] async fn put_none() { let idi = Idiom::default(); let mut val = Value::parse("{ test: { other: null, something: 123 } }"); let res = Value::parse("999"); val.put(&idi, Value::from(999)); assert_eq!(res, val); } #[tokio::test] async fn put_empty() { let idi = Idiom::parse("test"); let mut val = Value::None; let res = Value::parse("{ test: 999 }"); val.put(&idi, Value::from(999)); assert_eq!(res, val); } #[tokio::test] async fn put_blank() { let idi = Idiom::parse("test.something"); let mut val = Value::None; let res = Value::parse("{ test: { something: 999 } }"); val.put(&idi, Value::from(999)); assert_eq!(res, val); } #[tokio::test] async fn put_reput() { let idi = Idiom::parse("test"); let mut val = Value::parse("{ test: { other: null, something: 123 } }"); let res = Value::parse("{ test: 999 }"); val.put(&idi, Value::from(999)); assert_eq!(res, val); } #[tokio::test] async fn put_basic() { let idi = Idiom::parse("test.something"); let mut val = Value::parse("{ test: { other: null, something: 123 } }"); let res = Value::parse("{ test: { other: null, something: 999 } }"); val.put(&idi, Value::from(999)); assert_eq!(res, val); } #[tokio::test] async fn put_allow() { let idi = Idiom::parse("test.something.allow"); let mut val = Value::parse("{ test: { other: null } }"); let res = Value::parse("{ test: { other: null, something: { allow: 999 } } }"); val.put(&idi, Value::from(999)); assert_eq!(res, val); } #[tokio::test] async fn put_wrong() { let idi = Idiom::parse("test.something.wrong"); let mut val = Value::parse("{ test: { other: null, something: 123 } }"); let res = Value::parse("{ test: { other: null, something: 123 } }"); val.put(&idi, Value::from(999)); assert_eq!(res, val); } #[tokio::test] async fn put_other() { let idi = Idiom::parse("test.other.something"); let mut val = Value::parse("{ test: { other: null, something: 123 } }"); let res = Value::parse("{ test: { other: { something: 999 }, something: 123 } }"); val.put(&idi, Value::from(999)); assert_eq!(res, val); } #[tokio::test] async fn put_array() { let idi = Idiom::parse("test.something[1]"); let mut val = Value::parse("{ test: { something: [123, 456, 789] } }"); let res = Value::parse("{ test: { something: [123, 999, 789] } }"); val.put(&idi, Value::from(999)); assert_eq!(res, val); } #[tokio::test] async fn put_array_field() { let idi = Idiom::parse("test.something[1].age"); let mut val = Value::parse("{ test: { something: [{ age: 34 }, { age: 36 }] } }"); let res = Value::parse("{ test: { something: [{ age: 34 }, { age: 21 }] } }"); val.put(&idi, Value::from(21)); assert_eq!(res, val); } #[tokio::test] async fn put_array_fields() { let idi = Idiom::parse("test.something[*].age"); let mut val = Value::parse("{ test: { something: [{ age: 34 }, { age: 36 }] } }"); let res = Value::parse("{ test: { something: [{ age: 21 }, { age: 21 }] } }"); val.put(&idi, Value::from(21)); assert_eq!(res, val); } #[tokio::test] async fn put_array_fields_flat() { let idi = Idiom::parse("test.something.age"); let mut val = Value::parse("{ test: { something: [{ age: 34 }, { age: 36 }] } }"); let res = Value::parse("{ test: { something: [{ age: 21 }, { age: 21 }] } }"); val.put(&idi, Value::from(21)); assert_eq!(res, val); } }