Struct TelegramPlatform 

pub struct TelegramPlatform { /* private fields */ }

Implementations

impl TelegramPlatform

pub fn new(token: String) -> Self

Production constructor: official Telegram API base URL, 1 msg/s per-chat rate limit.

pub fn with_options( token: String, base_url: String, rate_limit_interval: Duration, ) -> Self

Test/advanced constructor: override the base URL (a local HTTP stub) and/or the rate-limit interval (kept tiny in tests so a rate-limit-blocks assertion doesn’t need a real second-plus sleep).

Trait Implementations

impl Platform for TelegramPlatform

fn name(&self) -> &str

Short identifier, e.g. "telegram". Matches InboundMessage::platform.

fn capabilities(&self) -> Capabilities

What this adapter supports.

fn start<'life0, 'async_trait>( &'life0 self, inbound: Sender<Inbound>, ) -> Pin<Box<dyn Future<Output = PlatformResult<()>> + Send + 'async_trait>>

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

Start receiving inbound events (messages and/or button presses), sending each onto inbound. Runs for the adapter’s lifetime (a long-poll loop, a WS connection, …); returns only on an unrecoverable error or stop().

fn reply<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 ReplyCtx, msg: OutboundMessage, ) -> Pin<Box<dyn Future<Output = PlatformResult<MessageRef>> + Send + 'async_trait>>

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

Send a message in reply to ctx.

fn edit<'life0, 'life1, 'async_trait>( &'life0 self, msg_ref: &'life1 MessageRef, new: OutboundMessage, ) -> Pin<Box<dyn Future<Output = PlatformResult<()>> + Send + 'async_trait>>

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

Edit a previously-sent message in place. Capability-gated on Capabilities::edit_message; adapters that don’t support it may return an error — callers must check the capability first.

fn answer_callback<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, callback_query_id: &'life1 str, text: Option<&'life2 str>, ) -> Pin<Box<dyn Future<Output = PlatformResult<()>> + Send + 'async_trait>>

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

Acknowledge a callback query (capability-gated on Capabilities::buttons — adapters without button support never receive one to acknowledge, so the default no-op is correct for them). Telegram requires exactly one ack per callback query, success or not; text, when Some, is shown as a brief toast (e.g. an “expired” notice for a stale/forged nonce).

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

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

Stop the adapter (best-effort; graceful shutdown).