OpenSource/teloxide
OpenSource/teloxide
1
0
Fork 0
mirror of https://github.com/teloxide/teloxide.git synced 2024-12-22 22:46:39 +01:00
Code Issues Projects Releases Packages Wiki Activity

Use teloxide::handler! for command handling too

Browse source
This commit is contained in:
Hirrolot 2022-04-25 01:23:05 +06:00
parent fd31cba6d7
commit c3d5ed9fb7
1 changed files with 28 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

47
examples/purchase.rs
View file

@ -42,6 +42,8 @@ enum Command {
Help, Help,
#[command(description = "start the purchase procedure.")] #[command(description = "start the purchase procedure.")]
Start, Start,
#[command(description = "cancel the purchase procedure.")]
Cancel,
} }
#[tokio::main] #[tokio::main]
@ -57,9 +59,14 @@ async fn main() {
.branch( .branch(
Update::filter_message() Update::filter_message()
.branch( .branch(
teloxide::handler![State::Start] dptree::entry()
.filter_command::<Command>() .filter_command::<Command>()
.endpoint(handle_command), .branch(
teloxide::handler![State::Start]
.branch(teloxide::handler![Command::Help].endpoint(help))
.branch(teloxide::handler![Command::Start].endpoint(start)),
)
.branch(teloxide::handler![Command::Cancel].endpoint(cancel)),
) )
.branch(teloxide::handler![State::ReceiveFullName].endpoint(receive_full_name)) .branch(teloxide::handler![State::ReceiveFullName].endpoint(receive_full_name))
.branch(dptree::endpoint(invalid_state)), .branch(dptree::endpoint(invalid_state)),
@ -78,22 +85,26 @@ async fn main() {
.await; .await;
} }
async fn handle_command( async fn start(bot: AutoSend<Bot>, msg: Message, dialogue: MyDialogue) -> HandlerResult {
bot: AutoSend<Bot>,
msg: Message,
cmd: Command,
dialogue: MyDialogue,
) -> HandlerResult {
match cmd {
Command::Help => {
bot.send_message(msg.chat.id, Command::descriptions().to_string()).await?;
}
Command::Start => {
bot.send_message(msg.chat.id, "Let's start! What's your full name?").await?; bot.send_message(msg.chat.id, "Let's start! What's your full name?").await?;
dialogue.update(State::ReceiveFullName).await?; dialogue.update(State::ReceiveFullName).await?;
} Ok(())
} }
async fn help(bot: AutoSend<Bot>, msg: Message) -> HandlerResult {
bot.send_message(msg.chat.id, Command::descriptions().to_string()).await?;
Ok(())
}
async fn cancel(bot: AutoSend<Bot>, msg: Message, dialogue: MyDialogue) -> HandlerResult {
bot.send_message(msg.chat.id, "Cancelling the dialogue.").await?;
dialogue.exit().await?;
Ok(())
}
async fn invalid_state(bot: AutoSend<Bot>, msg: Message) -> HandlerResult {
bot.send_message(msg.chat.id, "Unable to handle the message. Type /help to see the usage.")
.await?;
Ok(()) Ok(())
} }
@ -138,9 +149,3 @@ async fn receive_product_selection(
Ok(()) Ok(())
} }
async fn invalid_state(bot: AutoSend<Bot>, msg: Message) -> HandlerResult {
bot.send_message(msg.chat.id, "Unable to handle the message. Type /help to see the usage.")
.await?;
Ok(())
}