Struct AppStateProcessor 

pub struct AppStateProcessor {
    pub backend: Arc<dyn Backend>,
    pub runtime: Arc<dyn Runtime>,
    /* private fields */
}

Fields

backend: Arc<dyn Backend>

runtime: Arc<dyn Runtime>

Implementations

impl AppStateProcessor

pub fn new( backend: Arc<dyn Backend>, runtime: Arc<dyn Runtime>, ) -> AppStateProcessor

pub async fn get_app_state_key( &self, key_id: &[u8], ) -> Result<Arc<ExpandedAppStateKeys>, AppStateSyncError>

pub async fn clear_key_cache(&self)

Clear the in-memory key cache (e.g. on reconnect). Keys will be re-fetched from the database backend on next access.

pub async fn decode_patch_list<FDownload>( &self, stanza_root: &Node, download: FDownload, validate_macs: bool, ) -> Result<(Vec<Mutation>, HashState, PatchList), Error>

where FDownload: Fn(&ExternalBlobReference) -> Result<Vec<u8>, Error> + Send + Sync,

pub async fn decode_multi_patch_list<FDownload>( &self, stanza_root: &Node, download: &FDownload, validate_macs: bool, ) -> Result<Vec<(Vec<Mutation>, HashState, PatchList)>, Error>

where FDownload: Fn(&ExternalBlobReference) -> Result<Vec<u8>, Error> + Send + Sync,

Decode a multi-collection IQ response into per-collection results. Each collection is parsed and processed independently.

pub async fn process_patch_list( &self, pl: PatchList, validate_macs: bool, ) -> Result<(Vec<Mutation>, HashState, PatchList), Error>

pub async fn build_patch( &self, collection_name: &str, mutations: Vec<(SyncdMutation, Vec<u8>)>, ) -> Result<(Vec<u8>, u64), Error>

Build and encode a SyncdPatch for sending mutations to the server.

Takes a list of pre-encoded mutations (from encode_record) and produces the protobuf-encoded patch bytes ready for inclusion in an IQ stanza.

Returns

A tuple of (patch_bytes, updated_hash_state). Encode mutations into a SyncdPatch protobuf blob.

Returns (patch_bytes, base_version) where base_version is the collection version before the patch (for the IQ version attribute). Does NOT persist state — the caller must only persist after the server acknowledges the patch.

pub async fn get_missing_key_ids( &self, pl: &PatchList, ) -> Result<Vec<Vec<u8>>, Error>

pub async fn sync_collection<D, FDownload>( &self, driver: &D, name: WAPatchName, validate_macs: bool, download: FDownload, ) -> Result<Vec<Mutation>, Error>

where D: AppStateSyncDriver + Sync, FDownload: Fn(&ExternalBlobReference) -> Result<Vec<u8>, Error> + Send + Sync,

Trait Implementations

impl Clone for AppStateProcessor

fn clone(&self) -> AppStateProcessor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.