use std::env;

use telbot_hyper::{types::update::GetUpdates, Api};

#[tokio::main]
async fn main() {
    let api = Api::new(env::var("BOT_TOKEN").unwrap());

    let mut offset = 0;
    loop {
        let get_updates = GetUpdates::new().with_offset(offset as i32).with_timeout(1);

        let updates = api.send_json(&get_updates).await.unwrap();
        for update in updates {
            if let Some(message) = update.kind.message() {
                if let Some(text) = message.kind.text() {
                    let request = message.reply_text(text);
                    let api = api.clone();
                    tokio::spawn(async move {
                        api.send_json(&request).await.unwrap();
                    });
                }
            }
            offset = offset.max(update.update_id + 1);
        }
    }
}