maxoxide 2.0.0

Async Rust library for the Max messenger Bot API
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

//! Echo bot — mirrors every received message back to the sender.
//!
//! Run:
//!   MAX_BOT_TOKEN=your_token cargo run --example echo_bot

use maxoxide::types::Update;
use maxoxide::{Bot, Context, Dispatcher};

#[tokio::main]
async fn main() {
    tracing_subscriber::fmt::init();

    let bot = Bot::from_env();
    let mut dp = Dispatcher::new(bot);

    // /start command
    dp.on_command("/start", |ctx: Context| async move {
        if let Update::MessageCreated { message, .. } = &ctx.update {
            ctx.bot
                .send_markdown_to_chat(
                    message.chat_id(),
                    "Привет! Я эхо-бот. Напиши что-нибудь, и я отвечу тем же 🤖",
                )
                .await?;
        }
        Ok(())
    });

    // Mirror every other message
    dp.on_message(|ctx: Context| async move {
        if let Update::MessageCreated { message, .. } = &ctx.update {
            let text = message.text().unwrap_or("(без текста)").to_string();
            ctx.bot.send_text_to_chat(message.chat_id(), text).await?;
        }
        Ok(())
    });

    dp.start_polling().await;
}