Struct MessageHistory 

pub struct MessageHistory {
    tree: Tree,
    encryption: Option<StorageEncryption>,
}

A MessageStore implementation using sled for storage.

Fields

tree: Tree

encryption: Option<StorageEncryption>

Implementations

impl MessageHistory

pub fn new(db: Db, encryption: Option<StorageEncryption>) -> Result<Self>

Creates a new MessageHistory store.

Arguments

• db - The sled::Db instance to use for storage.
• encryption - Optional StorageEncryption for encrypting message data.

Errors

Returns an error if the underlying sled tree cannot be opened.

fn get_conversation_id(p1: &PeerId, p2: &PeerId) -> Vec<u8>

Creates a canonical, ordered conversation ID from two PeerIds.

This ensures that the conversation ID is always the same regardless of the order of the PeerIds.

fn make_composite_key( conversation_id: &[u8], timestamp: i64, nonce: u64, ) -> Vec<u8>

Creates a composite key for storing a message, based on conversation ID, timestamp, and nonce.

fn serialize_message(&self, msg: &Message) -> Result<Vec<u8>>

Serializes a Message and encrypts it if encryption is enabled.

fn deserialize_message(&self, data: &[u8]) -> Result<Message>

Decrypts and deserializes a Message.

Trait Implementations

impl MessageStore for MessageHistory

fn store_message<'life0, 'async_trait>( &'life0 self, msg: Message, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Stores a message in the history.

fn get_message_by_id<'life0, 'life1, 'async_trait>( &'life0 self, msg_id: &'life1 Uuid, ) -> Pin<Box<dyn Future<Output = Result<Option<Message>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieves a message by its ID.

fn get_history<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, own_id: &'life1 PeerId, peer: &'life2 PeerId, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Retrieves the message history for a conversation.

fn get_recent_messages<'life0, 'life1, 'async_trait>( &'life0 self, own_id: &'life1 PeerId, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Retrieves a limited number of the most recent messages from all conversations.

fn get_messages_before<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, own_id: &'life1 PeerId, peer: &'life2 PeerId, before_id: &'life3 Uuid, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Retrieves messages before a specific message in a conversation.

fn get_messages_after<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, own_id: &'life1 PeerId, peer: &'life2 PeerId, after_id: &'life3 Uuid, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Retrieves messages after a specific message in a conversation.

fn update_delivery_status<'life0, 'life1, 'async_trait>( &'life0 self, msg_id: &'life1 Uuid, status: DeliveryStatus, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Updates the delivery status of a message.