14 个版本 (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日 |
#418 in 异步
135KB
2.5K SLoC
🎉🎉 我们正在更改名称!0.11.0 将是名为 zephyrus
的最后一个版本,下一个版本(包括 0.11.0)将在 crates.io 上以 vesper
的名称发布 🎉🎉
Zephyrus 框架
Zephyrus
是一个 slash-command 框架,旨在与 twilight 一起使用
注意:该框架是新的,可能存在一些问题,所有贡献都将受到欢迎
这个包与 twilight 生态系统独立
Zephyrus
是一个使用 slash commands 的命令框架,主要提供变量参数解析
解析使用 Parse
特性进行,这意味着 Discord 上显示的参数名称将按相同名称解析到处理函数中的参数
框架本身不会启动任何任务,因此你可能需要将其包装在 Arc
中,并在调用 tokio::spawn
方法之前调用 .process
方法
使用示例
使用指南
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 locales reference
#[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
命令时使用 #[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
特性相同,并且只能用于枚举中来定义选项。也可以通过使用 #[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]
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();
}
创建子命令组
子命令组与子命令非常相似,它们的创建方式几乎相同,但是在注册组之前,我们必须使用 .group
而不是直接使用 .add_command
。
#[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
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(())
}
由于命令总是会失败,因为机器人不能禁用自己,所以错误处理器将在每次命令执行时被调用,因此如果设置了,将向 after
钩子传递 None
。
检查
检查与 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
包裹的未来。
模态框
从版本 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(..)}
属性来修改它们如何显示给用户。要查看允许的属性列表,请参阅 宏声明。
目前,只允许 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(())
}
依赖项
~11–19MB
~269K SLoC