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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
use serde_json::Value;
use std::collections::BTreeMap;
use std::collections::HashMap;
use crate::error::Result;
use crate::hashmap::DiffHashMap;
use crate::traits::Diff;
pub type DiffObject = DiffHashMap<String, Value>;
type ObjectSrc = BTreeMap<String, Value>;
type ObjectDst = HashMap<String, Value>;
impl Diff for ObjectSrc {
type Type = DiffObject;
fn diff(&self, other: &Self) -> Result<Self::Type> {
let a: ObjectDst = self.clone().into_iter().collect();
let b: ObjectDst = other.clone().into_iter().collect();
a.diff(&b)
}
fn merge(&self, diff: Self::Type) -> Result<Self> {
let this: ObjectDst = self.clone().into_iter().collect();
let this: ObjectDst = this.merge(diff)?;
Ok(this.into_iter().collect())
}
fn from_diff(diff: Self::Type) -> Result<Self> {
Ok(ObjectDst::from_diff(diff)?.into_iter().collect())
}
fn into_diff(self) -> Result<Self::Type> {
self.into_iter().collect::<ObjectDst>().into_diff()
}
}
#[cfg(test)]
mod tests {
use super::*;
use crate::hashmap::InnerValue;
use serde_json::json;
#[test]
fn test_diff_empty() {
let a: ObjectSrc = ObjectSrc::default();
let b: ObjectSrc = ObjectSrc::default();
let diff: DiffObject = Diff::diff(&a, &b).unwrap();
assert!(diff.0.is_none());
let merge: ObjectSrc = a.merge(diff.clone()).unwrap();
assert_eq!(merge, a);
let serialized: String = serde_json::to_string(&diff).unwrap();
let deserialized: DiffObject = serde_json::from_str(&serialized).unwrap();
assert_eq!(diff, deserialized)
}
#[test]
fn test_diff() {
let mut a: ObjectSrc = ObjectSrc::new();
a.insert("foo".into(), 12.into());
a.insert("bar".into(), 34.into());
a.insert("baz".into(), 56.into());
a.insert("qux".into(), 78.into());
let mut b: ObjectSrc = ObjectSrc::new();
b.insert("foo".into(), 56.into());
b.insert("thud".into(), 9.into());
b.insert("bar".into(), 34.into());
b.insert("qux".into(), 78.into());
let diff: DiffObject = Diff::diff(&a, &b).unwrap();
let expected: DiffObject = DiffHashMap(Some(vec![
InnerValue::Change {
key: "foo".into(),
value: json!(56).into_diff().unwrap(),
},
InnerValue::Add {
key: "thud".into(),
value: json!(9).into_diff().unwrap(),
},
InnerValue::Remove { key: "baz".into() },
]));
assert_eq!(expected, diff);
let merge: ObjectSrc = a.merge(diff.clone()).unwrap();
assert_eq!(merge, b);
let serialized: String = serde_json::to_string(&diff).unwrap();
let deserialized: DiffObject = serde_json::from_str(&serialized).unwrap();
assert_eq!(diff, deserialized)
}
}