mirrors/loro
1
0
Fork 0
mirror of https://github.com/loro-dev/loro.git synced 2024-11-28 17:41:49 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

test: refine tests

Browse source
This commit is contained in:
Zixuan Chen 2022-10-22 11:04:30 +08:00
parent 5ac137c877
commit 9407f52a1d
3 changed files with 106 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

110
crates/loro-core/src/fuzz.rs
View file

@ -34,24 +34,24 @@ impl Tabled for Action {
match self {
Action::Ins { content, pos, site } => vec![
"ins".into(),
site.to_string().into(),
pos.to_string().into(),
content.len().to_string().into(),
content.into(),
site.to_string().into(),
],
Action::Del { pos, len, site } => vec![
"del".into(),
site.to_string().into(),
pos.to_string().into(),
len.to_string().into(),
"".into(),
site.to_string().into(),
],
Action::Sync { from, to } => vec![
"sync".into(),
"".into(),
"".into(),
"".into(),
format!("{} to {}", from, to).into(),
"".into(),
"".into(),
"".into(),
],
Action::SyncAll => vec![
"sync all".into(),
@ -66,10 +66,10 @@ impl Tabled for Action {
fn headers() -> Vec<std::borrow::Cow<'static, str>> {
vec![
"type".into(),
"site".into(),
"pos".into(),
"len".into(),
"content".into(),
"site".into(),
]
}
}
@ -307,7 +307,105 @@ mod test {
use super::Action::*;
use super::*;
#[test]
fn test_6() {
test_multi_sites(
2,
vec![
Ins {
content: "a".into(),
pos: 2718485539284123587,
site: 0,
},
Sync { from: 186, to: 187 },
Ins {
content: "b".into(),
pos: 2148733715,
site: 0,
},
],
);
}
#[test]
fn test_5() {
test_multi_sites(
2,
vec![
Ins {
content: "1".into(),
pos: 72066424675961795,
site: 195,
},
Ins {
content: "0".into(),
pos: 2718485543579090699,
site: 0,
},
Sync { from: 255, to: 122 },
Ins {
content: "abcd".into(),
pos: 14051512346867337995,
site: 16,
},
Ins {
content: "xy".into(),
pos: 13402753207529835459,
site: 255,
},
],
);
}
#[test]
fn test_k() {
test_multi_sites(
2,
vec![
Ins {
content: "123".into(),
pos: 9621242987464197630,
site: 133,
},
Sync { from: 255, to: 18 },
Ins {
content: "ab".into(),
pos: 33,
site: 0,
},
],
);
}
fn test_two_unknown() {
test_multi_sites(
2,
vec![
Ins {
content: "0".into(),
pos: 3665948784267561747,
site: 0,
},
Ins {
content: "1".into(),
pos: 847522254572686275,
site: 1,
},
Sync { from: 255, to: 122 },
Ins {
content: "2345".into(),
pos: 13402768428993809163,
site: 37,
},
Del {
pos: 1374463206306314938,
len: 799603422227,
site: 0,
},
],
)
}
#[test]
fn test_two_common_ancestors() {
test_multi_sites(
2,
vec![

2
crates/loro-core/src/id.rs
View file

@ -20,7 +20,7 @@ impl Debug for ID {
impl Display for ID {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
write!(f, "{}:{}", self.client_id, self.counter)
f.write_str(format!("c{}:{}", self.client_id, self.counter).as_str())
}
}

2
crates/loro-core/src/log_store.rs
View file

@ -254,7 +254,7 @@ impl LogStore {
let change = self.push_change(change).clone();
let mut container_manager = self.container.write().unwrap();
// Apply ops.
// NOTE: applying expects that log_store has store the Change, but has not updated its vv yet
// NOTE: applying expects that log_store has store the Change, and updated self vv
let mut set = FxHashSet::default();
for op in change.ops.iter() {
set.insert(&op.container);