let mut stream = self.api.stream();
while let Some(update) = stream.next().await {
let update = update?;
if let UpdateKind::Message(message) = update.kind {
if self.admins.contains(&message.from.id.into()) {
self.api
.send(
message
.text_reply(format!(
"Hello admin, [{}](tg://user?id={})",
message.from.first_name, message.from.id,
))
.parse_mode(ParseMode::Markdown),
)
.await?;
tokio::spawn(async {
self.admin_handler.handle(message).await;
// TODO: add logging error
});
}
}
}
Ok(())
}
Потому что использовать нужно teloxide 😊
Обсуждают сегодня