Struct ChatHistoryService 

pub struct ChatHistoryService {
    repo: Arc<dyn ChatHistoryRepository>,
}

Service for managing chat history.

This is a thin orchestration layer over the ChatHistoryRepository port. It provides a clean API and handles any business logic that doesn’t belong in the repository layer.

Fields

repo: Arc<dyn ChatHistoryRepository>

Implementations

impl ChatHistoryService

pub fn new(repo: Arc<dyn ChatHistoryRepository>) -> Self

Create a new chat history service.

pub async fn create_conversation( &self, title: String, model_id: Option<i64>, system_prompt: Option<String>, ) -> Result<i64, ChatHistoryError>

Create a new conversation.

pub async fn create_conversation_with_settings( &self, conv: NewConversation, ) -> Result<i64, ChatHistoryError>

Create a new conversation with session settings for resume.

pub async fn list_conversations( &self, ) -> Result<Vec<Conversation>, ChatHistoryError>

List all conversations, ordered by most recently updated.

pub async fn get_conversation( &self, id: i64, ) -> Result<Option<Conversation>, ChatHistoryError>

Get a specific conversation by ID.

pub async fn update_conversation( &self, id: i64, new_title: Option<String>, system_prompt: Option<Option<String>>, ) -> Result<(), ChatHistoryError>

Update conversation metadata.

pub async fn delete_conversation(&self, id: i64) -> Result<(), ChatHistoryError>

Delete a conversation and all its messages.

pub async fn get_conversation_count(&self) -> Result<i64, ChatHistoryError>

Get conversation count.

pub async fn get_messages( &self, conversation_id: i64, ) -> Result<Vec<Message>, ChatHistoryError>

Get all messages for a conversation.

pub async fn save_message( &self, msg: NewMessage, ) -> Result<i64, ChatHistoryError>

Save a new message.

pub async fn update_message( &self, id: i64, content: String, metadata: Option<Value>, ) -> Result<(), ChatHistoryError>

Update a message’s content and optionally its metadata.

pub async fn delete_message_and_subsequent( &self, id: i64, ) -> Result<i64, ChatHistoryError>

Delete a message and all subsequent messages.

pub async fn get_message_count( &self, conversation_id: i64, ) -> Result<i64, ChatHistoryError>

Get message count for a conversation.