Struct Conversations 

pub struct Conversations {
    pub conversations: Arc<Collection>,
}

Storage wrapper for the conversations collection.

Fields

conversations: Arc<Collection>

Underlying AndaDB collection.

Implementations

impl Conversations

pub async fn connect(db: Arc<AndaDB>, name: String) -> Result<Self, BoxError>

Opens or creates the conversations collection and indexes.

pub async fn add_conversation( &self, conversation: ConversationRef<'_>, ) -> Result<u64, DBError>

Adds a conversation and flushes the collection.

pub async fn update_conversation( &self, id: u64, fields: BTreeMap<String, Fv>, ) -> Result<(), DBError>

Updates selected conversation fields and flushes the collection.

pub async fn get_conversation(&self, id: u64) -> Result<Conversation, DBError>

Retrieves a conversation by ID.

pub async fn delete_conversation(&self, id: u64) -> Result<bool, DBError>

Deletes a conversation by ID and returns whether it existed.

pub async fn batch_get_conversations( &self, user: &Principal, ids: Vec<u64>, ) -> Result<Vec<Conversation>, BoxError>

Retrieves the user’s conversations matching ids.

The underlying query limit is capped at 1000 IDs per call.

pub async fn list_conversations_by_user( &self, user: &Principal, cursor: Option<String>, limit: Option<usize>, ) -> Result<(Vec<Conversation>, Option<String>), BoxError>

Lists the user’s conversations, newest first, with cursor-based pagination.

pub async fn search_conversations( &self, user: &Principal, query: String, limit: Option<usize>, ) -> Result<Vec<Conversation>, BoxError>

Searches a user’s conversations with the BM25 conversation index.

pub async fn delete_expired_conversations( &self, timestamp: u64, ) -> Result<u64, BoxError>

Deletes all conversations created before timestamp (in milliseconds).

Trait Implementations

impl Clone for Conversations

fn clone(&self) -> Conversations

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Conversations

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

Formats the value using the given formatter.