Andras Schmelczer
8b8f1d91d9
* WIP * Add debug * Dedupe inserts * Add deterministic ordering * Fix whitespaces * Update insta * Add integration test script * Rename * Add test * Working for non-deletes * omg it mostly works for deletes * Isdeleted fix * remove created dates * update api * Take document id * No max attempt * works * Use string uuids * . * working!!!! (hopefully) * Improve bundling * Add module * lint * . * lint * Fix CI * use toolchain * clean up * Add useSlowFileEvents * Delete fuzz * Fix CI * use docker * fix script * clean up * Clean up * change node version * Build docker image on every commit * fix ci * 1 db per vault * Add scritps folder * Bump versions * Lint * . * Fix tests for real * Style * . * try * Consistent ordering * Fix tests * hmm * . * Clean up diff * Fixes * . * Fix version bump * . * . * .
91 lines
2.6 KiB
Rust
91 lines
2.6 KiB
Rust
use core::fmt::Debug;
|
|
|
|
use crate::operation_transformation::Operation;
|
|
|
|
#[derive(Clone)]
|
|
pub struct MergeContext<T>
|
|
where
|
|
T: PartialEq + Clone + std::fmt::Debug,
|
|
{
|
|
last_operation: Option<Operation<T>>,
|
|
pub shift: i64,
|
|
}
|
|
|
|
impl<T> Default for MergeContext<T>
|
|
where
|
|
T: PartialEq + Clone + std::fmt::Debug,
|
|
{
|
|
fn default() -> Self {
|
|
MergeContext {
|
|
last_operation: None,
|
|
shift: 0,
|
|
}
|
|
}
|
|
}
|
|
|
|
impl<T> Debug for MergeContext<T>
|
|
where
|
|
T: PartialEq + Clone + std::fmt::Debug,
|
|
{
|
|
fn fmt(&self, f: &mut core::fmt::Formatter<'_>) -> core::fmt::Result {
|
|
f.debug_struct("MergeContext")
|
|
.field("last_operation", &self.last_operation)
|
|
.field("shift", &self.shift)
|
|
.finish()
|
|
}
|
|
}
|
|
|
|
impl<T> MergeContext<T>
|
|
where
|
|
T: PartialEq + Clone + std::fmt::Debug,
|
|
{
|
|
pub fn last_operation(&self) -> Option<&Operation<T>> { self.last_operation.as_ref() }
|
|
|
|
/// Replace the last delete operation (if there was one) with a new one
|
|
/// while applying it to the shift.
|
|
pub fn consume_and_replace_last_operation(&mut self, operation: Option<Operation<T>>) {
|
|
if let Some(Operation::Delete {
|
|
deleted_character_count,
|
|
..
|
|
}) = self.last_operation.take()
|
|
{
|
|
self.shift -= deleted_character_count as i64;
|
|
}
|
|
|
|
self.last_operation = operation;
|
|
}
|
|
|
|
pub fn replace_last_operation(&mut self, operation: Option<Operation<T>>) {
|
|
self.last_operation = operation;
|
|
}
|
|
|
|
/// Remove the last operation (if there was one) in case it is behind the
|
|
/// threshold operation. This changes the shift in case the last operation
|
|
/// was a delete.
|
|
pub fn consume_last_operation_if_it_is_too_behind(
|
|
&mut self,
|
|
threshold_operation: &Operation<T>,
|
|
) {
|
|
if let Some(last_operation) = self.last_operation.as_ref() {
|
|
if let Operation::Delete {
|
|
deleted_character_count,
|
|
..
|
|
} = last_operation
|
|
{
|
|
if threshold_operation.start_index() as i64 + self.shift
|
|
> last_operation.end_index() as i64
|
|
{
|
|
self.shift -= *deleted_character_count as i64;
|
|
self.last_operation = None;
|
|
}
|
|
} else if let Operation::Insert { .. } = last_operation {
|
|
if threshold_operation.start_index() as i64 + self.shift
|
|
- last_operation.len() as i64
|
|
> last_operation.end_index() as i64
|
|
{
|
|
self.last_operation = None;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|