Struct MessageHistory 

pub struct MessageHistory { /* private fields */ }

Message history storage and retrieval

Implementations

impl MessageHistory

pub fn new(connection: Arc<Mutex<Connection>>) -> Self

pub fn store_incoming_message( &self, rdx_fingerprint: &str, timestamp: u64, plaintext: &[u8], was_prekey_message: bool, session_established: bool, ) -> Result<i64, MessageHistoryError>

Store an incoming message

pub fn store_outgoing_message( &self, rdx_fingerprint: &str, timestamp: u64, plaintext: &[u8], ) -> Result<i64, MessageHistoryError>

Store an outgoing message

pub fn update_delivery_status( &self, message_id: i64, status: DeliveryStatus, ) -> Result<(), MessageHistoryError>

Update message delivery status

pub fn get_message( &self, message_id: i64, ) -> Result<StoredMessage, MessageHistoryError>

Retrieve message by ID

pub fn get_conversation_messages( &self, rdx_fingerprint: &str, limit: u32, offset: u32, ) -> Result<Vec<StoredMessage>, MessageHistoryError>

Get messages for a conversation (paginated, newest first)

pub fn get_conversations( &self, include_archived: bool, ) -> Result<Vec<Conversation>, MessageHistoryError>

Get all conversations ordered by recent activity

pub fn get_unread_count( &self, rdx_fingerprint: &str, ) -> Result<u32, MessageHistoryError>

Get unread message count for a conversation

pub fn mark_conversation_read( &self, rdx_fingerprint: &str, ) -> Result<(), MessageHistoryError>

Mark conversation as read

pub fn delete_message(&self, message_id: i64) -> Result<(), MessageHistoryError>

Delete message

pub fn delete_conversation( &self, rdx_fingerprint: &str, ) -> Result<(), MessageHistoryError>

Delete entire conversation