Struct MessageSyncService 

pub struct MessageSyncService { /* private fields */ }

Message synchronization service

Implementations

impl MessageSyncService

pub fn new(peer_id: String) -> Self

Create a new message sync service

pub async fn get_all_messages(&self, entity_id: &str) -> AppResult<SyncResponse>

Get all messages for an entity (contact, group, project, org, channel) This is the entry point for sync requests from other peers

pub async fn receive_message( &self, message: CRDTMessage, ) -> AppResult<ReceiveResult>

Handle incoming message - detect out-of-order and missing dependencies

pub async fn send_message( &self, entity_id: String, entity_type: EntityType, content: MessageContent, reply_to_id: Option<String>, ) -> AppResult<CRDTMessage>

Send a new message - assigns vector clock and Lamport timestamp

pub async fn request_sync( &self, entity_id: &str, from_peer_id: &str, ) -> AppResult<SyncRequest>

Request sync from a peer - send our vector clock and get missing messages

pub async fn handle_sync_response( &self, response: SyncResponse, ) -> AppResult<SyncResult>

Handle sync response - integrate received messages

pub async fn get_sync_state( &self, entity_id: &str, ) -> AppResult<EntitySyncState>

Get sync state for an entity

pub async fn get_messages(&self, entity_id: &str) -> AppResult<Vec<CRDTMessage>>

Get all messages in causal order for an entity

pub async fn needs_sync( &self, entity_id: &str, remote_clock: &VectorClock, ) -> bool

Check if we need to request a sync (missing messages)

pub async fn delete_message( &self, entity_id: &str, message_id: &str, ) -> AppResult<bool>

pub async fn edit_message( &self, entity_id: &str, message_id: &str, new_text: String, ) -> AppResult<u64>

pub async fn add_reaction( &self, entity_id: &str, message_id: &str, emoji: String, peer_id: String, ) -> AppResult<()>

pub async fn remove_reaction( &self, entity_id: &str, message_id: &str, emoji: String, peer_id: String, ) -> AppResult<()>

pub async fn get_reactions( &self, entity_id: &str, message_id: &str, ) -> AppResult<Vec<Reaction>>

Trait Implementations

impl Debug for MessageSyncService

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.