15个版本 (8个重大更新)
0.11.0 | 2023年9月22日 |
---|---|
0.10.0 | 2023年7月31日 |
0.9.0 | 2023年3月6日 |
0.6.0 | 2022年12月28日 |
0.2.2 | 2021年12月31日 |
#1865 in 异步
在 zephyrus 中使用
90KB
1.5K SLoC
🎉🎉 我们正在更改名称!0.11.0将是使用名称 zephyrus
的最后一个版本,下一个版本(包括0.11.0)将在crates.io上以名称 vesper
提供 🎉🎉
Zephyrus 框架
Zephyrus
是一个用于twilight的命令框架
注意:该框架较新,可能存在一些问题,所有贡献都受到欢迎
此crate独立于twilight生态系统
Zephyrus
是一个使用斜杠命令的命令框架,主要提供可变参数解析。
解析使用 Parse
特性进行,因此用户可以为其自己的类型实现解析。
参数解析以命名的方式进行,这意味着在discord上显示的参数名称将解析为处理器函数中以相同方式命名的参数。
框架本身不会自行启动任何任务,因此您可能需要在调用 .process
方法之前,将其包装在 tokio::spawn
中并调用。
使用示例
use std::sync::Arc;
use futures_util::StreamExt;
use twilight_gateway::{stream::{self, ShardEventStream}, Config};
use twilight_http::Client;
use twilight_model::gateway::event::Event;
use twilight_model::gateway::Intents;
use twilight_model::http::interaction::{InteractionResponse, InteractionResponseData, InteractionResponseType};
use twilight_model::id::Id;
use twilight_model::id::marker::{ApplicationMarker, GuildMarker};
use zephyrus::prelude::*;
#[command]
#[description = "Says hello"]
async fn hello(ctx: &SlashContext<()>) -> DefaultCommandResult {
ctx.interaction_client.create_response(
ctx.interaction.id,
&ctx.interaction.token,
&InteractionResponse {
kind: InteractionResponseType::ChannelMessageWithSource,
data: Some(InteractionResponseData {
content: Some(String::from("Hello world")),
..Default::default()
})
}
).await?;
Ok(())
}
async fn handle_events(http_client: Arc<Client>, mut events: ShardEventStream, app_id: Id<ApplicationMarker>) {
let framework = Arc::new(Framework::builder(http_client, app_id, ())
.command(hello)
.build());
// Zephyrus can register commands in guilds or globally.
framework.register_guild_commands(Id::<GuildMarker>::new("<GUILD_ID>")).await.unwrap();
while let Some((_, event)) = events.next().await {
match event {
Event::InteractionCreate(i) => {
let clone = Arc::clone(&framework);
tokio::spawn(async move {
let inner = i.0;
clone.process(inner).await;
});
},
_ => (),
}
}
}
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
let token = std::env::var("DISCORD_TOKEN")?;
let app_id = Id::<ApplicationMarker>::new(std::env::var("APP_ID")?.parse()?);
let client = Arc::new(Client::new(token.clone()));
let config = Config::new(token, Intents::empty());
let mut shards = stream::create_recommended(
&client,
config,
|_, builder| builder.build()
).await.unwrap().collect::<Vec<_>>();
let mut shard_stream = ShardEventStream::new(shards.iter_mut());
handle_events(client, shard_stream, app_id).await;
Ok(())
}
使用指南
创建命令
每个命令都是一个 async
函数,总是将 &SlashContext<T>
作为第一个参数
框架支持 chat
、message
和 user
命令,让我们看看每个命令
聊天命令
#[command(chat)] // or #[command]
#[description = "This is the description of the command"]
async fn command(
ctx: &SlashContext</* Your type of context*/>, // The context must always be the first parameter.
#[description = "A description for the argument"] some_arg: String,
#[rename = "other_arg"] #[description = "other description"] other: Option<Id<UserMarker>>
) -> DefaultCommandResult
{
// Command body
Ok(())
}
用户命令
#[command(user)]
#[description = "This is the description of the command"]
async fn command(
ctx: &SlashContext</* Your type of context*/>, // The context must always be the first parameter.
) -> DefaultCommandResult
{
// Command body
Ok(())
}
消息命令
#[command(message)]
#[description = "This is the description of the command"]
async fn command(
ctx: &SlashContext</* Your type of context*/>, // The context must always be the first parameter.
) -> DefaultCommandResult
{
// Command body
Ok(())
}
如您所见,它们之间的唯一区别在于使用 #[command({chat, user, message})
以及只有 chat
命令可以接受参数。
command
宏默认为 chat
命令,因此如果没有使用 {chat, user, message}
任何指定,宏将将其视为 chat
命令,因此 #[command]
等同于 #[command(chat)]
。
如果非聊天命令在其处理程序中接受参数,框架将允许它,但不会将它们发送到 Discord。
框架还提供了一个 #[only_guilds]
属性,该属性将标记命令只能在公会中使用,以及一个 #[nsfw]
属性用于 nsfw 命令。
之前用作示例的相同命令可以以下方式标记为仅适用于公会/nsfw:
#[command]
#[nsfw] // This command is now marked as nsfw
#[description = "This is the description of the command"]
async fn command(
ctx: &SlashContext</* Your type of context*/>,
#[description = "A description for the argument"] some_arg: String,
#[rename = "other_arg"] #[description = "other description"] other: Option<Id<UserMarker>>
) -> DefaultCommandResult
{
// Command body
Ok(())
}
#[command(chat)]
#[only_guilds] // This command is now only marked as only available inside of guilds
#[description = "This is the description of the command"]
async fn command(
ctx: &SlashContext</* Your type of context*/>,
#[description = "A description for the argument"] some_arg: String,
#[rename = "other_arg"] #[description = "other description"] other: Option<Id<UserMarker>>
) -> DefaultCommandResult
{
// Command body
Ok(())
}
#[command(chat)]
#[only_guilds] // This command is now marked as nsfw and only available inside guilds
#[nsfw]
#[description = "This is the description of the command"]
async fn command(
ctx: &SlashContext</* Your type of context*/>, // The context must always be the first parameter.
#[description = "A description for the argument"] some_arg: String,
#[rename = "other_arg"] #[description = "other description"] other: Option<Id<UserMarker>>
) -> DefaultCommandResult
{
// Command body
Ok(())
}
使用本地化
框架允许在命令及其参数中使用本地化,为此我们有 #[localized_names]
和 #[localized_descriptions]
属性,这些属性接受逗号分隔的项目列表。让我们来看看它们:
区域设置必须有效,要查看它们,请参阅 Discord 区域设置参考
#[command]
#[localized_names("en-US" = "US name", "en-GB" = "GB name", "es-ES" = "Spanish name")]
#[localized_descriptions("en-US" = "US description", "en-GB" = "GB description", "es-ES" = "Spanish description")]
#[description = "My description"]
async fn my_localized_command(
ctx: &SlashContext</* Data type */>,
#[localized_names("en-US" = "US name", "en-GB" = "GB name", "es-ES" = "Spanish name")]
#[description = "Another description"]
#[localized_descriptions("en-US" = "US description", "en-GB" = "GB description", "es-ES" = "Spanish description")]
my_argument: String
) -> DefaultCommandResult
{
// Code here
Ok(())
}
命令函数
命令函数必须包含一个 description
属性,当用户尝试使用命令时,将在 Discord 中显示该属性。
#[command]
宏还允许通过将命令名称传递给属性来重命名命令,例如 #[command({chat, user, message}, name = "Command name here")]
。如果没有提供名称,命令将使用函数名称。
在创建chat
命令时使用短形式class="src-rs">#[command]
时,重命名可以直接传递,例如:#[command("Command name")]
,这相当于#[command(chat, name = "Command name")]
命令参数
命令参数与命令函数非常相似,它们也需要一个#[description]
属性,当用户填写命令参数时,这个属性将在discord中显示。
如示例所示,也可以使用#[rename]
属性,这将改变在discord中看到的参数名称。如果不使用该属性,则参数将具有与函数相同的名称。
参数还可以使用#[skip]
属性进行标记。标记为#[skip]
的参数不允许使用#[description]
或#[rename]
属性,并且在使用命令时不会被discord看到,但它们将被框架解析。这可以用于从交互中提取与命令输入无关的数据。让我们来看一个例子
pub struct ExtractSomething {
//...
}
#[async_trait]
impl Parse<T> for ExtractSomething
where T: Send + Sync
{
async fn parse(
http_client: &WrappedClient,
data: &T,
value: Option<&CommandOptionValue>, // <- will be empty since the option was not sent
resolved: Option<&mut CommandInteractionDataResolved>
) -> Result<Self, ParseError>
{
// implement parsing logic
}
fn kind() -> CommandOptionType {
// Since the struct will be marked as #[skip] this method won't be used.
unreachable!()
}
}
#[command]
#[description = "Something here"]
async fn my_command(
ctx: &SlashContext</* Data type */>,
#[skip] my_extractor: ExtractSomething // This won't be seen on discord, but will be parsed
) -> DefaultCommandResult
{
// Command logic here
Ok(())
}
重要:所有命令函数都必须以&SlashContext<T>
作为第一个参数
将选项设置为命令参数
选项是slash命令非常有用的功能,允许开发者设置一些用户必须从中选择的选项。
Zephyrus允许以简单的方式执行此操作,为此,框架提供了一个派生宏。这个宏的命名方式与Parse
trait相同,并且只能在枚举中用于定义选项。也可以使用#[parse(rename)]
属性来更改在discord中看到的选项名称。
#[derive(Parse)]
enum Choices {
First,
Second,
Third,
#[parse(rename = "Forth")]
Other
}
#[command]
#[description = "Some description"]
async fn choices(
ctx: &SlashContext<()>,
#[description = "Some description"] choice: Choices
) -> DefaultCommandResult
{
// Command body
Ok(())
}
自动完成命令
使用Zephyrus
可以轻松实现自动完成用户输入,只需使用框架提供的autocomplete
宏。
这里,看看这个例子。我们将使用一个这样的空命令作为基础:
#[command]
#[description = "Some description"]
async fn some_command(
ctx: &SlashCommand</* Some type */>,
#[autocomplete = "autocomplete_arg"] #[description = "Some description"] arg: String
) -> DefaultCommandResult
{
// Logic goes here
Ok(())
}
如您所注意到的,我们在参数 arg
上添加了一个 autocomplete
属性。该输入必须指向一个带有类似这样的 #[autocomplete]
属性的函数
#[autocomplete]
async fn autocomplete_arg(ctx: AutocompleteContext</* Some type */>) -> Option<InteractionResponseData> {
// Function body
}
自动完成函数必须有一个 AutocompleteContext<T>
作为唯一参数,它允许您访问框架存储的数据,同时允许您访问原始交互、框架的 HTTP 客户端以及用户输入(如果存在)。
权限
要指定运行命令所需权限,只需在声明命令时使用 #[required_permissions]
属性,或者在声明命令组时使用 .required_permissions
方法。
该属性接受一个逗号分隔的列表作为输入 twilight 的权限。让我们看看创建一个需要 MANAGE_CHANNELS
和 MANAGE_MESSAGES
权限的命令会是什么样子。
#[command]
#[description = "Super cool command"]
#[required_permissions(MANAGE_CHANNELS, MANAGE_MESSAGES)]
async fn super_cool_command(ctx: &SlashContext</* Your type */>) -> DefaultCommandResult {
// Body
Ok(())
}
命令组
Zephyrus
默认支持 SubCommands
和 SubCommandGroups
。
为了举例,假设我们创建了以下命令
#[command]
#[description = "Something"]
async fn something(ctx: &SlashContext</* Your type */>) -> DefaultCommandResult {
// Command block
Ok(())
}
有了这个,我们现在可以创建子命令和子命令组
创建子命令
要创建一个子命令,您需要创建一个组,然后可以添加所有子命令。
#[tokio::main]
async fn main() {
let framework = Framework::builder()
.group(|g| {
g.name("<GROUP_NAME>")
.description("<GROUP_DESCRIPTION>")
.add_command(something)
.add_command(..)
..
})
.build();
}
创建子命令组
子命令组与子命令非常相似,它们的创建方式几乎相同,但与直接使用 .add_command
不同,我们必须在注册组之前使用 .group
。
#[tokio::main]
async fn main() {
let framework = Framework::builder()
.group(|g| {
g.name("<GROUP_NAME>")
.description("<GROUP_DESCRIPTION>")
.group(|sub| { // With this we have created a subcommand group.
sub.name("<SUBGROUP_NAME>")
.description("<SUBGROUP_DESCRIPTION>")
.add_command(something)
.add_command(..)
..
})
})
.build();
}
钩子
有三种钩子可用,分别是 before
、after
和 error_handler
。
Before
在钩子触发之前,命令必须返回一个 bool
,表示是否应该执行该命令。
#[before]
async fn before_hook(ctx: &SlashContext</*Your type*/>, command_name: &str) -> bool {
// Do something
true // <- if we return true, the command will be executed normally.
}
After
在命令执行后触发 after 钩子,并提供命令的结果。
#[after]
async fn after_hook(ctx: &SlashContext</* Your type */>, command_name: &str, result: Option<DefaultCommandResult>) {
// Do something with the result.
}
特定错误处理
命令可以具有特定的错误处理器。当错误处理器被设置为命令时,如果命令(或其任何检查)失败,错误处理器将被调用,并且 after
钩子将接收 None
作为第三个参数。然而,如果命令执行完成而没有引发错误,after
钩子将接收命令的结果。
让我们看看一个简单的实现
#[error_handler]
async fn handle_ban_error(_ctx: &SlashContext</* Some type */>, error: DefaultError) {
println!("The ban command had an error");
// Handle the error
}
#[command]
#[description = "Tries to ban the bot itself, raising an error"]
#[error_handler(handle_ban_error)]
async fn ban_itself(ctx: &SlashContext</* Some type */>) -> DefaultCommandResult {
// A bot cannot ban itself, so this will result in an error.
ctx.http_client().ban(ctx.interaction.guild_id.unwrap(), Id::new(ctx.application_id.get()))
.await?;
Ok(())
}
由于命令总是会失败,因为机器人不能禁止自己,所以每次命令执行时都会调用错误处理器,如果设置了,则将 None
传递给 after
钩子。
检查
检查与 Before
钩子非常相似,但与它不同,它们不是全局的。相反,它们需要分配给每个命令。
让我们看看如何使用它
让我们创建一些检查,如下所示
#[check]
async fn only_guilds(ctx: &SlashContext</* Some type */>) -> Result<bool, DefaultError> {
// Only execute the command if we are inside a guild.
Ok(ctx.interaction.guild_id.is_some())
}
#[check]
async fn other_check(_ctx: &SlashContext</* Some type */>) -> Result<bool, DefaultError> {
// Some other check here.
Ok(true)
}
然后我们可以使用 check
属性将它们分配给我们的命令,该属性接受一个逗号分隔的检查列表
#[command]
#[description = "Some description"]
#[checks(only_guilds, other_check)]
async fn my_command(ctx: &SlashContext</* Some type */>) -> DefaultCommandResult {
// Do something
Ok(())
}
使用自定义返回类型
框架允许用户指定命令/检查执行返回的类型。框架定义如下
pub struct Framework<D, T = (), E = DefaultError>
其中 D
是框架中保存的数据类型,而 T
和 E
是命令的返回类型,以 Result<T, E>
的形式,然而,指定自定义类型是可选的,并且框架为那些不想自定义错误的人提供了 DefaultCommandResult
和 DefaultError
。
根据框架中指定的泛型,after
、error_handler
和 check
钩子参数的类型相应变化,因此它们的签名可以解释如下
钩子后
async fn(&SlashContext</* Some type */>, &str, Option<Result<T, E>>)
错误处理钩子
async fn(&SlashContext</* Some type */>, E)
命令检查
async fn(&SlashContext</* Some type */>) -> Result<bool, E>
注意,这些并不是真正的签名,因为这些函数返回 Box
包裹的 future。
模态框
从版本 0.8.0 开始,框架提供了一个 derive 宏,使模态框尽可能简单。让我们看一个例子
use zephyrus::prelude::*;
#[derive(Modal, Debug)]
#[modal(title = "Test modal")]
struct MyModal {
field: String,
#[modal(paragraph, label = "Paragraph")]
paragraph: String,
#[modal(placeholder = "This is an optional field")]
optional: Option<String>
}
#[command]
#[description = "My command description"]
async fn my_command(ctx: &SlashContext</* Some type */>) -> DefaultCommandResult {
let modal_waiter = ctx.create_modal::<MyModal>().await?;
let output = modal_waiter.await?;
println!("{output:?}");
Ok(())
}
在这里,`Modal` derive 宏派生了 modal 特性,这使我们能够创建它们,然后我们可以使用 #[modal(..)}
属性来修改它将如何显示给用户。要查看允许的属性完整列表,请查看 宏声明。
目前,只允许 String
和 Option<String>
字段。
批量命令覆盖
如果您想使用 Discord 的 批量覆盖全局应用命令 端点,也许与一个 命令锁文件 结合使用,您将想要使用 Framework#twilight_commands
。
注意 这需要
bulk
功能。
fn create_framework(
http_client: Arc<Client>,
app_id: Id<ApplicationMarker>
) -> Framework<()> {
Framework::builder(http_client, app_id, ())
.command(hello)
.build()
}
fn create_lockfile(framework: Framework<()>) -> Result<()> {
let commands = framework.twilight_commands();
let content = serde_json::to_string_pretty(&commands)?;
let path = concat!(env!("CARGO_MANIFEST_DIR"), "/commands.lock.json").to_string();
std::fs::write(path, content).unwrap();
Ok(())
}
依赖项
~0.6–1.1MB
~25K SLoC