Struct DatabaseManager

pub struct DatabaseManager { /* private fields */ }

Main database manager using sqlx for async operations

Implementations

impl DatabaseManager

pub async fn new(database_url: &str) -> Result<Self>

Create a new database manager with automatic migrations

pub async fn new_in_memory() -> Result<Self>

Create an in-memory database for testing

pub fn pool(&self) -> &SqlitePool

Get a reference to the connection pool

pub async fn begin_transaction(&self) -> Result<Transaction<'_, Sqlite>>

Start a new database transaction

impl DatabaseManager

pub async fn upsert_agent( &self, agent_id: &str, username: &str, contact_uri: Option<&str>, ) -> Result<()>

Register or update an agent

pub async fn update_agent_status( &self, agent_id: &str, status: AgentStatus, ) -> Result<()>

Update agent status

pub async fn get_available_agents(&self) -> Result<Vec<DbAgent>>

Get available agents

pub async fn reserve_agent(&self, agent_id: &str) -> Result<bool>

Reserve an agent atomically

pub async fn update_agent_call_count( &self, agent_id: &str, delta: i32, ) -> Result<()>

Update agent call count

pub async fn get_agent_stats(&self) -> Result<AgentStats>

Get agent statistics

impl DatabaseManager

pub async fn enqueue_call( &self, call_id: &str, session_id: &str, queue_id: &str, customer_info: Option<&str>, priority: i32, expires_at: DateTime<Utc>, ) -> Result<()>

Enqueue a call

pub async fn get_next_queued_call( &self, queue_id: &str, ) -> Result<Option<DbQueuedCall>>

Get next call in queue

pub async fn dequeue_call(&self, session_id: &str) -> Result<bool>

Remove call from queue

impl DatabaseManager

pub async fn add_active_call( &self, call_id: &str, agent_id: &str, session_id: &str, ) -> Result<()>

Add an active call

pub async fn remove_active_call(&self, session_id: &str) -> Result<bool>

Remove an active call

pub async fn assign_call_to_agent( &self, call_id: &str, session_id: &str, agent_id: &str, ) -> Result<()>

Assign call to agent atomically

pub async fn get_agent(&self, agent_id: &str) -> Result<Option<DbAgent>>

pub async fn list_agents(&self) -> Result<Vec<DbAgent>>

pub async fn mark_agent_offline(&self, agent_id: &str) -> Result<()>

pub async fn count_total_agents(&self) -> Result<i64>

pub async fn get_active_calls_count(&self) -> Result<i64>

pub async fn get_queue_depth(&self, queue_id: &str) -> Result<i64>

pub async fn remove_call_from_queue(&self, session_id: &str) -> Result<()>

pub async fn release_agent_reservation(&self, agent_id: &str) -> Result<()>

pub async fn dequeue_call_for_agent( &self, queue_id: &str, agent_id: &str, ) -> Result<Option<DbQueuedCall>>

pub async fn update_agent_call_count_with_retry( &self, agent_id: &str, delta: i32, ) -> Result<()>

pub async fn update_agent_status_with_retry( &self, agent_id: &str, status: AgentStatus, ) -> Result<()>

pub async fn atomic_assign_call_to_agent( &self, session_id: &str, agent_id: &str, _customer_sdp: String, ) -> Result<()>

pub async fn query(&self, sql: &str, _params: &[&str]) -> Result<()>

pub async fn execute(&self, sql: &str, params: &[String]) -> Result<()>

Trait Implementations

impl Clone for DatabaseManager

fn clone(&self) -> DatabaseManager

Returns a duplicate of the value.

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

Performs copy-assignment from source.