Telegram Integration for Flows.network
Quick Start
There is a echo bot, but plain text:
use tg_flows::{listen_to_update, Telegram, Update, UpdateKind};
#[no_mangle]
#[tokio::main(flavor = "current_thread")]
pub async fn run() {
let telegram_token = std::env::var("telegram_token").unwrap();
let tele = Telegram::new(telegram_token.clone());
listen_to_update(telegram_token, handler).await;
}
async fn handler(update: Update) {
if let UpdateKind::Message(msg) = update.kind {
let text = msg.text().unwrap_or("");
let chat_id = msg.chat.id;
let _sended_msg = tele.send_message(chat_id, text);
}
}
[Telegram::new()] is a Telegram constructor that represents a bot.
[listen_to_update()] is responsible for registering a listener for the bot
represented by the telegram_token. When a new Update coming, the callback
is called with received Update.