kovi 0.13.0

A Milky & OneBot V11 bot plugin framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

use crate::ApiReturn;
use crate::bot::SendApi;
use crate::event::MessageEventTrait;
use crate::types::ArcTypeDeMsgEventFn;
use futures_util::Stream;
use serde_json::Value;
use std::pin::Pin;
use std::sync::Arc;

pub enum DriverEvent {
    /// Drive 的退出事件
    Exit,
    /// 正常的运行时事件
    Normal(Value),
}

pub type AnyError = Box<dyn std::error::Error + Send + Sync>;

pub type ApiHandlerResult =
    Pin<Box<dyn Future<Output = Result<Result<ApiReturn, ApiReturn>, AnyError>> + Send>>;

#[async_trait::async_trait]
pub trait Driver: Send + Sync {
    async fn event_channel(
        &self,
    ) -> Result<Pin<Box<dyn Stream<Item = Result<DriverEvent, AnyError>> + Send>>, AnyError>;

    fn api_handler(&self, value: SendApi) -> ApiHandlerResult;

    fn message_event_register(&self) -> MessageEventRegister;
}

pub struct MessageEventRegister {
    pub(crate) type_de: ArcTypeDeMsgEventFn,
}
impl MessageEventRegister {
    pub fn register<T: MessageEventTrait + Send + Sync>() -> Self {
        MessageEventRegister {
            type_de: Arc::new(|value, bot_info, sender| {
                Some(Arc::new(T::de(value, bot_info, sender)?))
            }),
        }
    }
}