Struct CacheSyncService 

pub struct CacheSyncService { /* private fields */ }

Service that syncs the cache with on-chain events

Provides both polling-based and manual event processing for cache invalidation.

Example

use blueprint_tangle_extra::cache::{CacheSyncService, shared_cache};

let cache = shared_cache();
let sync_service = CacheSyncService::new(client, cache.clone());

// Option 1: Poll for events periodically
loop {
    let events_processed = sync_service.poll_and_sync(last_block).await?;
    tokio::time::sleep(Duration::from_secs(12)).await;
}

// Option 2: Process events from your own subscription
sync_service.process_logs(&logs);

Implementations

impl CacheSyncService

pub fn new(client: Arc<TangleClient>, cache: SharedServiceConfigCache) -> Self

Create a new cache sync service

pub fn with_services(self, services: Vec<u64>) -> Self

Only watch specific services

pub fn from_block(self, block: u64) -> Self

Set the starting block for polling

pub async fn poll_and_sync(&self) -> Result<usize, CacheError>

Poll for new events and sync the cache

Returns the number of events processed.

pub fn process_logs(&self, logs: &[Log]) -> usize

Process a batch of logs and invalidate cache as needed

Returns the number of events processed.

pub fn parse_log(&self, log: &Log) -> Option<CacheInvalidationEvent>

Parse a log into a cache invalidation event

pub fn process_event(&self, event: CacheInvalidationEvent)

Process a single event manually (useful for testing or custom event sources)

pub fn last_block(&self) -> u64

Get the last processed block number