Struct MessageService 

pub struct MessageService { /* private fields */ }

Unified message and synchronization service

Implementations

impl MessageService

pub fn new(peer_id: String) -> Self

Create a new message service

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

Send a message to an entity

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

Receive and process an incoming message

pub async fn get_entity_messages( &self, entity_id: String, ) -> MessageServiceResult<SyncResponse>

Get all messages for an entity

pub async fn get_thread_messages( &self, entity_id: String, parent_message_id: String, ) -> MessageServiceResult<Vec<CRDTMessage>>

Get messages for a specific thread (all replies to a parent message)

pub async fn get_entity_sync_state( &self, entity_id: String, entity_type: EntityType, ) -> MessageServiceResult<EntitySyncState>

Get sync state for an entity (simplified implementation)

pub async fn send_direct_messages( &self, recipients: Vec<String>, content: MessageContent, ) -> MessageServiceResult<Vec<String>>

Send a direct message to specific recipients

pub async fn get_direct_messages( &self, other_peer_id: String, ) -> MessageServiceResult<SyncResponse>

Get direct messages between current user and another peer

pub async fn send_to_channel( &self, channel_id: String, content: MessageContent, ) -> MessageServiceResult<String>

Send message to channel (compatibility method)

pub async fn send_thread_reply( &self, entity_id: String, entity_type: EntityType, thread_id: String, content: MessageContent, ) -> MessageServiceResult<String>

Send thread reply (compatibility method)

pub async fn get_channel_messages( &self, channel_id: String, ) -> MessageServiceResult<Vec<CRDTMessage>>

Get channel messages (compatibility method)

pub fn sort_messages(&self, messages: &mut [CRDTMessage])

Sort messages causally (utility method)

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

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

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

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

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