Struct BotLifecycleService 

pub struct BotLifecycleService<B, C>
where
    B: BotRepository,
    C: ConfigRepository,
{ /* private fields */ }

Implementations

impl<B, C> BotLifecycleService<B, C>

where B: BotRepository, C: ConfigRepository,

pub fn new(bot_repo: Arc<B>, config_repo: Arc<C>) -> Self

pub async fn get_bot(&self, bot_id: Uuid) -> Result<Bot, LifecycleError>

pub async fn get_bot_with_token( &self, bot_id: Uuid, token: &str, ) -> Result<Bot, LifecycleError>

pub async fn list_account_bots( &self, account_id: Uuid, limit: i64, offset: i64, ) -> Result<Vec<Bot>, LifecycleError>

PERF-002: List bots with pagination support

• limit: Maximum number of bots to return
• offset: Number of bots to skip

pub async fn create_bot_config( &self, bot_id: Uuid, config: StoredBotConfig, ) -> Result<StoredBotConfig, LifecycleError>

pub async fn acknowledge_config( &self, bot_id: Uuid, config_id: Uuid, ) -> Result<(), LifecycleError>

pub async fn get_desired_config( &self, bot_id: Uuid, ) -> Result<Option<StoredBotConfig>, LifecycleError>

pub async fn record_heartbeat(&self, bot_id: Uuid) -> Result<(), LifecycleError>

pub async fn check_stale_bots( &self, heartbeat_timeout: Duration, ) -> Result<Vec<Bot>, LifecycleError>

Check for bots with stale heartbeats and mark them as Error (HIGH-001)