Struct miraie::bot::Bot

pub struct Bot { /* fields omitted */ }

Bot 用来保存一个 bot 中的状态，如消息队列、跟连接的沟通、数据库连接等。

Implementations

impl Bot

pub async fn new(
    addr: SocketAddr,
    verify_key: impl Into<String>,
    qq: QQ
) -> Result<(Self, Connection)>

建立一个 bot，会在这里建立跟服务器的 websocket 连接。

参数

• addr: mirai 服务器的地址，需要开启 websocket 的 adapter
• verify_key: 鉴权 key
• qq：机器人的 qq 号

Example

let (bot, conn) = Bot::new(
    "127.0.0.1:8080".parse().unwrap(),
    "verify_key",
    QQ(12345)
).await?;

async fn handler(msg: Message) {}

bot.handler(handler);
conn.run().await?;

pub async fn request<Request>(
    &self,
    request: Request
) -> Result<Request::Response> where
    Request: Api + 'static, 

对 mirai bot 发送一个请求，默认超时 10s，如果需要调整超时，使用 Self::request_timeout。

pub async fn request_timeout<Request>(
    &self,
    request: Request,
    timeout: Duration
) -> Result<Request::Response> where
    Request: Api + 'static, 

对 mirai bot 发送一个请求，带有自定义超时

pub fn messages(&self) -> impl Stream<Item = Message>

获取一个全部消息的 stream

pub fn group_messages(&self) -> impl Stream<Item = GroupMessage>

获取一个全部群聊消息的 stream

pub fn friend_messages(&self) -> impl Stream<Item = FriendMessage>

获取一个私聊消息的 stream

pub fn events(&self) -> impl Stream<Item = Event>

获取一个事件的 stream

Trait Implementations

impl App for Bot

type Message = Message

fn event_bus(&self) -> Sender<Self::Message>

fn handler<F, I, Fut>(self, f: F) -> Self where
    F: Func<I, Fut>,
    I: FromRequest<Self> + Send + 'static,
    Fut: Future + Send,
    Fut::Output: Return + Send, 

impl Clone for Bot

fn clone(&self) -> Bot

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.