puniyu_runtime 0.8.4

puniyu 统一运行时 trait 库，提供运行时视图、消息发送能力与框架复合运行时
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
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62

//! # puniyu_runtime
//!
//! puniyu 的统一运行时抽象与运行时句柄定义。
//!
//! 该 crate 主要提供两类能力：
//! - 运行时 trait 抽象，用于描述适配器、Bot 与消息发送等通用能力
//! - 运行时句柄类型，用于管理框架内部的异步运行单元
//!
//! ## 提供内容
//!
//! - [`Runtime`]：运行时基础 trait，提供只读运行时访问视图
//! - [`AdapterProvider`]：访问适配器信息
//! - [`AdapterRuntime`]：适配器级运行时抽象
//! - [`SendMessage`]：发送消息能力 trait
//! - [`ServerRuntime`]：HTTP 服务运行句柄，封装服务停止与等待结束等生命周期能力
//!
//! ## 设计说明
//!
//! trait 抽象主要服务于上层业务与插件系统，便于以统一接口访问运行时能力；
//! 具体句柄类型则用于承载框架内部异步任务的生命周期管理。
mod server;
#[doc(inline)]
pub use server::ServerRuntime;
use std::any::Any;

use async_trait::async_trait;
use puniyu_adapter_types::{AdapterInfo, SendMsgType};
use puniyu_contact::ContactType;
use puniyu_error::Result;
use puniyu_message::Message;

pub trait Runtime: Any + Send + Sync {}

impl<T> Runtime for T where T: Any + Send + Sync {}

impl dyn Runtime {
	pub fn as_any(&self) -> &dyn Any {
		self
	}

	pub fn downcast_ref<T: Any>(&self) -> Option<&T> {
		self.as_any().downcast_ref::<T>()
	}
}

pub trait AdapterProvider: Send + Sync {
	fn adapter_info(&self) -> &AdapterInfo;
}

pub trait AdapterRuntime: Runtime + AdapterProvider + SendMessage {}

impl<T> AdapterRuntime for T where T: Runtime + AdapterProvider + SendMessage {}

#[async_trait]
pub trait SendMessage: Send + Sync {
	async fn send_message(
		&self,
		contact: &ContactType<'_>,
		message: &Message,
	) -> Result<SendMsgType>;
}