Struct ChatbotFrontend 

pub struct ChatbotFrontend {
    pub chat_id: String,
    pub session_id: String,
    pub platform_sender: Arc<dyn PlatformSender>,
    pub confirmer: Arc<Confirmer>,
    pub db: Arc<Mutex<Connection>>,
    pub buffer: Mutex<String>,
    pub last_msg_id: Mutex<Option<String>>,
    pub progress_hint_sent: Mutex<bool>,
    pub auto_approve: bool,
}

Per-session Frontend trait implementation for Bot platforms.

Each chat (group or private) gets its own ChatbotFrontend instance. TextDelta events are buffered and flushed once at TurnComplete with full Markdown sanitization to ensure clean output on platforms like QQ.

Fields

chat_id: String

The chat this frontend belongs to (group:{id} or private:{id}).

session_id: String

The session ID for database storage.

platform_sender: Arc<dyn PlatformSender>

Platform message sender (shared across all frontends).

confirmer: Arc<Confirmer>

Tool confirmation coordinator (shared).

db: Arc<Mutex<Connection>>

Database connection for persisting messages.

buffer: Mutex<String>

Buffer to accumulate text until TurnComplete.

last_msg_id: Mutex<Option<String>>

ID of the last message sent (for edit-based updates, e.g., replacing a progress hint with the actual response).

progress_hint_sent: Mutex<bool>

Whether a progress hint has already been sent this turn (rate limit).

auto_approve: bool

Auto-approve all tool calls.

Implementations

impl ChatbotFrontend

pub fn new( chat_id: String, session_id: String, platform_sender: Arc<dyn PlatformSender>, confirmer: Arc<Confirmer>, db: Arc<Mutex<Connection>>, auto_approve: bool, ) -> Self

Create a new ChatbotFrontend for chat_id.

pub async fn save_user_message(&self, content: &str)

Save a user message to the database (called from manager).

Trait Implementations

impl Frontend for ChatbotFrontend

fn on_event<'life0, 'async_trait>( &'life0 self, event: AgentEvent, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Agent pushes events to the frontend (text deltas, tool calls, errors, etc.).

fn request_tool_confirmation<'life0, 'life1, 'async_trait>( &'life0 self, info: &'life1 ToolCallInfo, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

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

Request user confirmation for a tool call. Blocks until user responds. Returns true if the user approved, false if rejected.

impl PlatformExt for ChatbotFrontend

fn upload_file<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, file_path: &'life1 str, media_type: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<UploadResult>> + Send + 'async_trait>>

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

Upload a local file to the platform. Returns the platform identifier.

fn send_media_message<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, file_url: &'life1 str, file_name: &'life2 str, media_type: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<SendResult>> + Send + 'async_trait>>

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

Send an already-uploaded media file to the chat.