3046cbab35Rather than returning an OpID for every mutation, we now return an `Option<ObjId>`. This is `Some` only when a `make*` operation was applied. This `ObjID` is an opaque type which can be used with any document.
52 lines
1.1 KiB
Rust
52 lines
1.1 KiB
Rust
use crate::types::OpId;
|
|
use fxhash::FxBuildHasher;
|
|
use std::cmp;
|
|
use std::collections::HashMap;
|
|
|
|
#[derive(Debug, Clone, PartialEq)]
|
|
pub(crate) struct Clock(HashMap<usize, u64, FxBuildHasher>);
|
|
|
|
impl Clock {
|
|
pub fn new() -> Self {
|
|
Clock(Default::default())
|
|
}
|
|
|
|
pub fn include(&mut self, key: usize, n: u64) {
|
|
self.0
|
|
.entry(key)
|
|
.and_modify(|m| *m = cmp::max(n, *m))
|
|
.or_insert(n);
|
|
}
|
|
|
|
pub fn covers(&self, id: &OpId) -> bool {
|
|
if let Some(val) = self.0.get(&id.1) {
|
|
val >= &id.0
|
|
} else {
|
|
false
|
|
}
|
|
}
|
|
}
|
|
|
|
#[cfg(test)]
|
|
mod tests {
|
|
use super::*;
|
|
|
|
#[test]
|
|
fn covers() {
|
|
let mut clock = Clock::new();
|
|
|
|
clock.include(1, 20);
|
|
clock.include(2, 10);
|
|
|
|
assert!(clock.covers(&OpId(10, 1)));
|
|
assert!(clock.covers(&OpId(20, 1)));
|
|
assert!(!clock.covers(&OpId(30, 1)));
|
|
|
|
assert!(clock.covers(&OpId(5, 2)));
|
|
assert!(clock.covers(&OpId(10, 2)));
|
|
assert!(!clock.covers(&OpId(15, 2)));
|
|
|
|
assert!(!clock.covers(&OpId(1, 3)));
|
|
assert!(!clock.covers(&OpId(100, 3)));
|
|
}
|
|
}
|