Struct SyncEngine 

pub struct SyncEngine { /* private fields */ }

Sync engine for managing real-time synchronization

Implementations

impl SyncEngine

pub fn new(event_bus: Arc<EventBus>) -> Self

Create a new sync engine

pub fn with_db(event_bus: Arc<EventBus>, db: Pool<Sqlite>) -> Self

Create a new sync engine with database support for state snapshots

pub fn with_integration( event_bus: Arc<EventBus>, db: Pool<Sqlite>, core_bridge: Arc<CoreBridge>, workspace_service: Arc<WorkspaceService>, ) -> Self

Create a new sync engine with full integration

pub fn subscribe( &self, workspace_id: Uuid, client_id: Uuid, ) -> Result<Receiver<ChangeEvent>>

Subscribe a client to a workspace

Errors

Returns an error if subscription fails.

pub fn unsubscribe(&self, workspace_id: Uuid, client_id: Uuid) -> Result<()>

Unsubscribe a client from a workspace

Errors

Returns an error if unsubscription fails.

pub fn publish_change(&self, event: ChangeEvent) -> Result<()>

Publish a change event

Errors

Returns an error if publishing fails.

pub fn get_state(&self, workspace_id: Uuid) -> Option<SyncState>

Get current state for a workspace

pub fn update_state(&self, workspace_id: Uuid, new_state: Value) -> Result<()>

Update state for a workspace

Errors

Returns an error if the state update fails.

pub async fn get_full_workspace_state( &self, workspace_id: Uuid, ) -> Result<Option<Value>>

Get full workspace state for a workspace

Uses CoreBridge to get the complete workspace state including all mocks.

Errors

Returns an error if the workspace cannot be retrieved.

pub async fn load_state_snapshot( &self, workspace_id: Uuid, version: Option<i64>, ) -> Result<Option<SyncState>>

Load state snapshot from database

Errors

Returns an error if the database is not available or the query fails.

pub async fn record_state_change( &self, workspace_id: Uuid, change_type: &str, change_data: Value, version: i64, user_id: Uuid, ) -> Result<()>

Record a state change for incremental sync

Errors

Returns an error if the database is not available or the insert fails.

pub async fn get_state_changes_since( &self, workspace_id: Uuid, since_version: i64, ) -> Result<Vec<Value>>

Get state changes since a specific version

Errors

Returns an error if the database is not available or the query fails.

pub fn get_connections(&self, workspace_id: Uuid) -> Vec<Uuid>

Get connected clients for a workspace

pub fn connection_count(&self) -> usize

Get total number of connections

pub fn has_connections(&self, workspace_id: Uuid) -> bool

Check if a workspace has any active connections

pub fn cleanup_inactive(&self)

Clean up inactive workspaces (no connections)