teloxide/examples/shared_state_bot/src/main.rs

// This bot answers how many messages it received in total on every message.

use std::sync::atomic::{AtomicU64, Ordering};

use lazy_static::lazy_static;
use teloxide::prelude2::*;

lazy_static! {
    static ref MESSAGES_TOTAL: AtomicU64 = AtomicU64::new(0);
}

#[tokio::main]
async fn main() {
    teloxide::enable_logging!();
    log::info!("Starting shared_state_bot...");

    let bot = Bot::from_env().auto_send();

    Dispatcher::new(bot)
        .messages_handler(|h| {
            h.branch(dptree::endpoint(|mes: Message, bot: AutoSend<Bot>| async move {
                let previous = MESSAGES_TOTAL.fetch_add(1, Ordering::Relaxed);
                bot.send_message(
                    mes.chat.id,
                    format!("I received {} messages in total.", previous),
                )
                .await?;
                respond(())
            }))
        })
        .dispatch()
        .await;
}