Struct places::bookmark_sync::store::Merger

pub(crate) struct Merger<'a> {
    store: &'a BookmarksStore<'a>,
    remote_time: ServerTimestamp,
    local_time: Timestamp,
    external_transaction: bool,
    telem: Option<&'a mut Engine>,
    global_change_tracker: GlobalChangeCounterTracker,
}

Fields

store: &'a BookmarksStore<'a>

remote_time: ServerTimestamp

local_time: Timestamp

external_transaction: bool

telem: Option<&'a mut Engine>

global_change_tracker: GlobalChangeCounterTracker

Implementations

impl<'a> Merger<'a>

pub(crate) fn new(
    store: &'a BookmarksStore<'_>,
    remote_time: ServerTimestamp
) -> Self

pub(crate) fn with_telemetry(
    store: &'a BookmarksStore<'_>,
    remote_time: ServerTimestamp,
    telem: &'a mut Engine
) -> Self

pub(crate) fn set_external_transaction(&mut self, v: bool)

Prevent (or re-enable, in principal) using begin_transaction in apply().

The assumption is that if you call this, someone higher up the call_stack is managing the transaction at that point.

pub(crate) fn merge(&mut self) -> Result<()>

fn prepare(&self) -> Result<()>

Prepares synced bookmarks for merging.

fn local_row_to_item(&self, row: &Row<'_>) -> Result<(Item, Option<Content>)>

Creates a local tree item from a row in the localItems CTE.

fn remote_row_to_item(&self, row: &Row<'_>) -> Result<(Item, Option<Content>)>

Creates a remote tree item from a row in moz_bookmarks_synced.

Trait Implementations

impl<'a> Store for Merger<'a>

type Ok = ()

The type returned from a successful merge.

type Error = Error

The type returned in the event of a store error.

fn fetch_local_tree(&self) -> Result<Tree>

Builds a fully rooted, consistent tree from all local items and tombstones.

fn fetch_remote_tree(&self) -> Result<Tree>

Builds a fully rooted tree from all synced items and tombstones.

fn apply<'t>(&mut self, root: MergedRoot<'t>) -> Result<()>

Applies the merged root to the local store, and stages items for upload. On Desktop, this method inserts the merged tree into a temp table, updates Places, and inserts outgoing items into another temp table.

fn merge(&mut self) -> Result<Self::Ok, Self::Error>

Builds and applies a merged tree using the default merge driver.

fn merge_with_driver(
    &mut self,
    driver: &impl Driver,
    signal: &impl AbortSignal
) -> Result<Self::Ok, Self::Error>

Builds a complete merged tree from the local and remote trees, resolves conflicts, dedupes local items, and applies the merged tree using the given driver.