Struct TelegramChannel 

pub struct TelegramChannel { /* private fields */ }

Implementations

impl TelegramChannel

pub fn new(bot_token: String, chat_id: i64) -> Self

pub fn with_memory(self, memory: Arc<dyn MemoryBackend>) -> Self

pub fn with_ingress_filter(self, ingress: TelegramIngressFilter) -> Self

pub async fn send_message(&self, text: &str) -> Result<i64>

Send a message and return its message_id (of the last chunk if split)

pub async fn edit_message(&self, message_id: i64, text: &str) -> Result<()>

Edit an existing message

pub async fn delete_message(&self, message_id: i64) -> Result<()>

Delete a message

pub async fn send_typing(&self, _chat_id: &str) -> Result<()>

Send typing indicator

Trait Implementations

impl Channel for TelegramChannel

fn name(&self) -> &str

Channel name (e.g., “telegram”, “discord”, “cli”)

fn start<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<Receiver<IncomingMessage>>> + Send + 'async_trait>>

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

Start receiving messages. Returns a receiver for incoming messages.

fn send<'life0, 'async_trait>( &'life0 self, message: OutgoingMessage, ) -> Pin<Box<dyn Future<Output = Result<Option<String>>> + Send + 'async_trait>>

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

Send a message through this channel. Returns an optional message ID for tracking/editing.

fn send_typing<'life0, 'life1, 'async_trait>( &'life0 self, chat_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Send a typing indicator (or equivalent) to the user.

fn edit<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _chat_id: &'life1 str, message_id: &'life2 str, new_text: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Edit a previously sent message if the channel supports it.

fn stop<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Stop the channel gracefully.

fn supports_draft_updates(&self) -> bool

Whether this channel supports live draft updates (send → update → finalize).

fn send_draft<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _chat_id: &'life1 str, _text: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<Option<String>>> + Send + 'async_trait>>

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

Send an initial draft placeholder (e.g. “⏳”). Returns message ID for edits.

fn update_draft_progress<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _chat_id: &'life1 str, _message_id: &'life2 str, _text: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Edit the draft with a live progress update (tool start/end). Rate-limited by impl.

fn finalize_draft<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, _chat_id: &'life1 str, _message_id: &'life2 str, _text: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Finalize the draft with the full formatted response, replacing any progress text.

impl Clone for TelegramChannel

fn clone(&self) -> TelegramChannel

Returns a duplicate of the value.

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

Performs copy-assignment from source.