Cargo.toml

@@ -5,6 +5,6 @@ members = [
 resolver = "2"
 
 [patch.crates-io]
-rust_socketio = { git = "https://github.com/shenjackyuanjie/rust-socketio.git", branch = "main" }
+# rust_socketio = { git = "https://github.com/shenjackyuanjie/rust-socketio.git", branch = "message_pack" }
 # rust_socketio = { path = "../../rust-socketio/socketio" }
 # pyo3 = { git = "https://github.com/PyO3/pyo3.git", branch = "main" }

ica-rs/Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "ica-rs"
-version = "0.9.0"
-edition = "2024"
+version = "0.8.1"
+edition = "2021"
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
@@ -36,13 +36,13 @@ serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 chrono = "0.4"
 toml = "0.8"
-toml_edit = "0.22"
+toml_edit = "0.22.20"
 colored = "3.0"
 
 # runtime
-tokio = { version = "1.43", features = ["rt-multi-thread", "time", "signal", "macros"] }
-futures-util = "0.3"
-pyo3 = { version = "0.24", features = ["experimental-async"] }
+tokio = { version = "1.43", features = ["full"] }
+futures-util = "0.3.30"
+pyo3 = { version = "0.23", features = ["experimental-async", "py-clone"] }
 anyhow = { version = "1.0", features = ["backtrace"] }
 # async 这玩意以后在搞
 # pyo3-async = "0.3.2"

ica-rs/src/config.rs

@@ -102,7 +102,7 @@ impl BotConfig {
     pub fn new_from_cli() -> Self {
         // let config_file_path = env::args().nth(1).expect("No config path given");
         // -c <config_file_path>
-        let mut config_file_path = "./config.toml".to_string();
+        let mut config_file_path = String::new();
         let mut args = env::args();
         while let Some(arg) = args.next() {
             if arg == "-c" {

ica-rs/src/data_struct/ica.rs

@@ -13,9 +13,7 @@ pub type MessageId = String;
 
 #[allow(unused)]
 pub trait RoomIdTrait {
-    /// 判断是否是群聊
     fn is_room(&self) -> bool;
-    /// 判断是否是私聊
     fn is_chat(&self) -> bool { !self.is_room() }
     fn as_room_id(&self) -> RoomId;
     fn as_chat_id(&self) -> RoomId;

ica-rs/src/data_struct/ica/all_rooms.rs

@@ -1,8 +1,8 @@
-use crate::data_struct::ica::messages::{At, LastMessage, SendMessage};
-use crate::data_struct::ica::{RoomId, UserId};
+use crate::data_struct::ica::messages::{At, LastMessage};
+use crate::data_struct::ica::RoomId;
 
 use serde::{Deserialize, Serialize};
-use serde_json::{Number, Value as JsonValue};
+use serde_json::Value as JsonValue;
 
 /// export default interface Room {
 ///     roomId: number
@@ -39,14 +39,14 @@ pub struct Room {
 
 impl Room {
     pub fn new_from_json(raw_json: &JsonValue) -> Self {
-        let mut parse_json = raw_json.clone();
+        let parse_json = raw_json.clone();
         // 手动 patch 一下 roomId
         // ica issue: https://github.com/Icalingua-plus-plus/Icalingua-plus-plus/issues/793
-        if parse_json.get("roomId").is_none_or(|id| id.is_null()) {
-            use tracing::warn;
-            warn!("Room::new_from_json roomId is None, patching it to -1, raw: {:?}", raw_json);
-            parse_json["roomId"] = JsonValue::Number(Number::from(-1));
-        }
+        // if parse_json.get("roomId").is_none_or(|id| id.is_null()) {
+        //     use tracing::warn;
+        //     warn!("Room::new_from_json roomId is None, patching it to -1, raw: {:#?}", raw_json);
+        //     parse_json["roomId"] = JsonValue::Number(Number::from(-1));
+        // }
         // 现在 fix 了
 
         let inner = match serde_json::from_value::<InnerRoom>(parse_json) {
@@ -69,9 +69,6 @@ impl Room {
             // download_path: inner.download_path,
         }
     }
-    pub fn new_message_to(&self, content: String) -> SendMessage {
-        SendMessage::new(content, self.room_id, None)
-    }
 }
 
 fn room_id_default() -> RoomId { -1 }
@@ -101,37 +98,3 @@ struct InnerRoom {
     // #[serde(rename = "downloadPath")]
     // pub download_path: Option<String>,
 }
-
-/// ```json
-/// {
-///  "comment": "问题：从哪里了解到的本群\n答案：aaa",
-///  "flag": "e4cd5a892ba34bed063196a0cc47a8",
-///  "group_id": xxxxx,
-///  "group_name": "Nuitka 和 Python 打包",
-///  "nickname": "jashcken",
-///  "post_type": "request",
-///  "request_type": "group",
-///  "self_id": 45620725,
-///  "sub_type": "add",
-///  "time": 1743372872,
-///  "tips": "",
-///  "user_id": 3838663305
-/// }
-/// ```
-#[derive(Debug, Clone, Deserialize, Serialize)]
-pub struct JoinRequestRoom {
-    /// 问题+答案
-    pub comment: String,
-    pub group_id: RoomId,
-    pub group_name: String,
-    pub user_id: UserId,
-    pub nickname: String,
-
-    // 剩下的应该没用了……吧?
-    pub request_type: String,
-    pub post_type: String,
-    pub sub_type: String,
-    pub time: i64,
-    pub tips: String,
-    pub flag: String,
-}

ica-rs/src/data_struct/ica/messages.rs

@@ -3,7 +3,7 @@ use crate::data_struct::ica::{MessageId, RoomId, UserId};
 
 use chrono::DateTime;
 use serde::{Deserialize, Serialize};
-use serde_json::{Value as JsonValue, json};
+use serde_json::{json, Value as JsonValue};
 use tracing::warn;
 
 pub mod msg_trait;
@@ -331,7 +331,7 @@ impl SendMessage {
     /// file_type: 图片类型(MIME) (image/png; image/jpeg)
     pub fn set_img(&mut self, file: &Vec<u8>, file_type: &str, as_sticker: bool) {
         self.sticker = as_sticker;
-        use base64::{Engine as _, engine::general_purpose};
+        use base64::{engine::general_purpose, Engine as _};
         let base64_data = general_purpose::STANDARD.encode(file);
         self.file_data = Some(format!("data:{};base64,{}", file_type, base64_data));
     }

ica-rs/src/data_struct/ica/messages/msg_trait.rs

@@ -4,9 +4,9 @@ use chrono::DateTime;
 use serde::{Deserialize, Serialize};
 use serde_json::Value as JsonValue;
 
-use crate::MainStatus;
 use crate::data_struct::ica::messages::{At, Message, NewMessage};
 use crate::data_struct::ica::{MessageId, UserId};
+use crate::MainStatus;
 
 impl Serialize for At {
     fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>
@@ -88,26 +88,7 @@ impl<'de> Deserialize<'de> for Message {
 
 impl Display for Message {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
-        if !self.content.is_empty() && !self.content.trim().is_empty() {
-            write!(f, "{}|{}|{}|{}", self.msg_id(), self.sender_id, self.sender_name, self.content)
-        } else if !self.files.is_empty() {
-            write!(
-                f,
-                "{}|{}|{}|{:?}",
-                self.msg_id(),
-                self.sender_id,
-                self.sender_name,
-                self.files[0].name
-            )
-        } else {
-            write!(
-                f,
-                "{}|{}|{}|empty content & empty files",
-                self.msg_id(),
-                self.sender_id,
-                self.sender_name
-            )
-        }
+        write!(f, "{}|{}|{}|{}", self.msg_id(), self.sender_id, self.sender_name, self.content)
     }
 }
 
@@ -133,32 +114,14 @@ impl MessageTrait for NewMessage {
 
 impl Display for NewMessage {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
-        if !self.msg.content.trim().is_empty() {
-            write!(
-                f,
-                "{}|{}|{}|{}|{}",
-                self.msg.msg_id,
-                self.room_id,
-                self.msg.sender_id,
-                self.msg.sender_name,
-                self.msg.content
-            )
-        } else if !self.msg.files.is_empty() {
-            write!(
-                f,
-                "{}|{}|{}|{}|{:?}",
-                self.msg.msg_id,
-                self.room_id,
-                self.msg.sender_id,
-                self.msg.sender_name,
-                self.msg.files[0]
-            )
-        } else {
-            write!(
-                f,
-                "{}|{}|{}|{}|empty content & empty files",
-                self.msg.msg_id, self.room_id, self.msg.sender_id, self.msg.sender_name
-            )
-        }
+        write!(
+            f,
+            "{}|{}|{}|{}|{}",
+            self.msg_id(),
+            self.room_id,
+            self.msg.sender_id,
+            self.msg.sender_name,
+            self.msg.content
+        )
     }
 }

ica-rs/src/data_struct/tailchat/messages.rs

@@ -1,7 +1,7 @@
 use std::fmt::Display;
 
 use serde::{Deserialize, Serialize};
-use serde_json::{Value as JsonValue, json};
+use serde_json::{json, Value as JsonValue};
 
 use crate::data_struct::tailchat::{ConverseId, GroupId, MessageId, UserId};
 

ica-rs/src/error.rs

@@ -33,8 +33,6 @@ pub enum PyPluginError {
     /// 插件内函数调用错误
     /// pyerr, func_name, module_name
     FuncCallError(pyo3::PyErr, String, String),
-    /// 插件停不下来!
-    PluginNotStopped,
 }
 
 impl From<rust_socketio::Error> for IcaError {
@@ -83,9 +81,6 @@ impl std::fmt::Display for PyPluginError {
             PyPluginError::FuncCallError(py_err, name, module) => {
                 write!(f, "插件内函数调用错误: {:#?}|{} in {}", py_err, name, module)
             }
-            PyPluginError::PluginNotStopped => {
-                write!(f, "插件未停止")
-            }
         }
     }
 }
@@ -116,7 +111,6 @@ impl std::error::Error for PyPluginError {
             PyPluginError::CouldNotGetFunc(e, _, _) => Some(e),
             PyPluginError::FuncNotCallable(_, _) => None,
             PyPluginError::FuncCallError(e, _, _) => Some(e),
-            PyPluginError::PluginNotStopped => None,
         }
     }
 }

ica-rs/src/ica.rs

@@ -1,46 +1,45 @@
 pub mod client;
 pub mod events;
 
-// use std::sync::OnceLock;
+use std::sync::OnceLock;
 
-use colored::Colorize;
 use rust_socketio::asynchronous::{Client, ClientBuilder};
-use rust_socketio::{Event, Payload, TransportType};
 use rust_socketio::{async_any_callback, async_callback};
-use tracing::{Level, event, span};
+use rust_socketio::{Event, Payload, TransportType};
+use tracing::{event, span, Level};
 
 use crate::config::IcaConfig;
 use crate::error::{ClientResult, IcaError};
-use crate::{StopGetter, version_str};
+use crate::{version_str, StopGetter};
 
 /// icalingua 客户端的兼容版本号
-pub const ICA_PROTOCOL_VERSION: &str = "2.12.28";
+pub const ICA_PROTOCOL_VERSION: &str = "2.12.26";
 
-// mod status {
-//     use crate::data_struct::ica::all_rooms::Room;
-//     pub use crate::data_struct::ica::online_data::OnlineData;
+mod status {
+    use crate::data_struct::ica::all_rooms::Room;
+    pub use crate::data_struct::ica::online_data::OnlineData;
 
-//     #[derive(Debug, Clone)]
-//     pub struct MainStatus {
-//         /// 是否启用 ica
-//         pub enable: bool,
-//         /// qq 是否登录
-//         pub qq_login: bool,
-//         /// 当前已加载的消息数量
-//         pub current_loaded_messages_count: u64,
-//         /// 房间数据
-//         pub rooms: Vec<Room>,
-//         /// 在线数据 (Icalingua 信息)
-//         pub online_status: OnlineData,
-//     }
+    #[derive(Debug, Clone)]
+    pub struct MainStatus {
+        /// 是否启用 ica
+        pub enable: bool,
+        /// qq 是否登录
+        pub qq_login: bool,
+        /// 当前已加载的消息数量
+        pub current_loaded_messages_count: u64,
+        /// 房间数据
+        pub rooms: Vec<Room>,
+        /// 在线数据 (Icalingua 信息)
+        pub online_status: OnlineData,
+    }
 
-//     impl MainStatus {
-//         pub fn update_rooms(&mut self, room: Vec<Room>) { self.rooms = room; }
-//         pub fn update_online_status(&mut self, status: OnlineData) { self.online_status = status; }
-//     }
-// }
+    impl MainStatus {
+        pub fn update_rooms(&mut self, room: Vec<Room>) { self.rooms = room; }
+        pub fn update_online_status(&mut self, status: OnlineData) { self.online_status = status; }
+    }
+}
 
-// static ICA_STATUS: OnceLock<status::MainStatus> = OnceLock::new();
+static ICA_STATUS: OnceLock<status::MainStatus> = OnceLock::new();
 
 pub async fn start_ica(config: &IcaConfig, stop_reciver: StopGetter) -> ClientResult<(), IcaError> {
     let span = span!(Level::INFO, "Icalingua Client");
@@ -48,7 +47,6 @@ pub async fn start_ica(config: &IcaConfig, stop_reciver: StopGetter) -> ClientRe
 
     event!(Level::INFO, "ica-async-rs v{} initing", crate::ICA_VERSION);
 
-    let start_connect_time = std::time::Instant::now();
     let socket = match ClientBuilder::new(config.host.clone())
         .transport_type(TransportType::Websocket)
         .on_any(async_any_callback!(events::any_event))
@@ -63,16 +61,11 @@ pub async fn start_ica(config: &IcaConfig, stop_reciver: StopGetter) -> ClientRe
         .on("setMessages", async_callback!(events::set_messages))
         .on("addMessage", async_callback!(events::add_message))
         .on("deleteMessage", async_callback!(events::delete_message))
-        .on("handleRequest", async_callback!(events::join_request))
         .connect()
         .await
     {
         Ok(client) => {
-            event!(
-                Level::INFO,
-                "{}",
-                format!("socketio connected time: {:?}", start_connect_time.elapsed()).on_cyan()
-            );
+            event!(Level::INFO, "socketio connected");
             client
         }
         Err(e) => {
@@ -101,12 +94,11 @@ pub async fn start_ica(config: &IcaConfig, stop_reciver: StopGetter) -> ClientRe
         }
     }
     // 等待停止信号
-    event!(Level::INFO, "{}", "ica client waiting for stop signal".purple());
     stop_reciver.await.ok();
-    event!(Level::INFO, "{}", "socketio client stopping".yellow());
+    event!(Level::INFO, "socketio client stopping");
     match socket.disconnect().await {
         Ok(_) => {
-            event!(Level::INFO, "{}", "socketio client stopped".green());
+            event!(Level::INFO, "socketio client stopped");
             Ok(())
         }
         Err(e) => {
@@ -114,7 +106,7 @@ pub async fn start_ica(config: &IcaConfig, stop_reciver: StopGetter) -> ClientRe
             match e {
                 rust_socketio::Error::IncompleteResponseFromEngineIo(inner_e) => {
                     if inner_e.to_string().contains("AlreadyClosed") {
-                        event!(Level::INFO, "{}", "socketio client stopped".green());
+                        event!(Level::INFO, "socketio client stopped");
                         Ok(())
                     } else {
                         event!(Level::ERROR, "socketio 客户端出现了 Error: {:?}", inner_e);

ica-rs/src/ica/client.rs

@@ -1,25 +1,25 @@
-use crate::MainStatus;
 use crate::data_struct::ica::messages::{DeleteMessage, SendMessage};
 use crate::data_struct::ica::{RoomId, RoomIdTrait, UserId};
 use crate::error::{ClientResult, IcaError};
+use crate::MainStatus;
 
 use colored::Colorize;
 use ed25519_dalek::{Signature, Signer, SigningKey};
-use rust_socketio::Payload;
 use rust_socketio::asynchronous::Client;
-use serde_json::{Value, json};
-use tracing::{Level, event, span};
+use rust_socketio::Payload;
+use serde_json::{json, Value};
+use tracing::{debug, event, span, warn, Level};
 
 /// "安全" 的 发送一条消息
 pub async fn send_message(client: &Client, message: &SendMessage) -> bool {
     let value = message.as_value();
     match client.emit("sendMessage", value).await {
         Ok(_) => {
-            event!(Level::INFO, "send_message {}", format!("{:#?}", message).cyan());
+            debug!("send_message {}", format!("{:#?}", message).cyan());
             true
         }
         Err(e) => {
-            event!(Level::WARN, "send_message faild:{}", format!("{:#?}", e).red());
+            warn!("send_message faild:{}", format!("{:#?}", e).red());
             false
         }
     }
@@ -30,11 +30,11 @@ pub async fn delete_message(client: &Client, message: &DeleteMessage) -> bool {
     let value = message.as_value();
     match client.emit("deleteMessage", value).await {
         Ok(_) => {
-            event!(Level::DEBUG, "delete_message {}", format!("{:#?}", message).yellow());
+            debug!("delete_message {}", format!("{:#?}", message).yellow());
             true
         }
         Err(e) => {
-            event!(Level::WARN, "delete_message faild:{}", format!("{:#?}", e).red());
+            warn!("delete_message faild:{}", format!("{:#?}", e).red());
             false
         }
     }
@@ -71,8 +71,7 @@ async fn inner_sign(payload: Payload, client: &Client) -> ClientResult<(), IcaEr
         .as_str()
         .unwrap_or("unknow");
     if server_protocol_version != crate::ica::ICA_PROTOCOL_VERSION {
-        event!(
-            Level::WARN,
+        warn!(
             "服务器版本与兼容版本不一致\n服务器协议版本:{:?}\n兼容版本:{}",
             version.get("protocolVersion"),
             crate::ica::ICA_PROTOCOL_VERSION

ica-rs/src/ica/events.rs

@@ -2,14 +2,14 @@ use colored::Colorize;
 use rust_socketio::asynchronous::Client;
 use rust_socketio::{Event, Payload};
 use serde_json::json;
-use tracing::{Level, event, info, span, warn};
+use tracing::{event, info, span, warn, Level};
 
-use crate::data_struct::ica::RoomId;
-use crate::data_struct::ica::all_rooms::{JoinRequestRoom, Room};
+use crate::data_struct::ica::all_rooms::Room;
 use crate::data_struct::ica::messages::{Message, MessageTrait, NewMessage};
 use crate::data_struct::ica::online_data::OnlineData;
+use crate::data_struct::ica::RoomId;
 use crate::ica::client::send_message;
-use crate::{MainStatus, VERSION, client_id, help_msg, py, version_str};
+use crate::{client_id, help_msg, py, version_str, MainStatus, VERSION};
 
 /// 获取在线数据
 pub async fn get_online_data(payload: Payload, _client: Client) {
@@ -175,31 +175,10 @@ pub async fn failed_message(payload: Payload, _client: Client) {
     }
 }
 
-/// 处理加群申请
-///
-/// add: 2.0.1
-pub async fn join_request(payload: Payload, _client: Client) {
-    if let Payload::Text(values) = payload {
-        if let Some(value) = values.first() {
-            match serde_json::from_value::<JoinRequestRoom>(value.clone()) {
-                Ok(join_room) => {
-                    event!(Level::INFO, "{}", format!("收到加群申请 {:?}", join_room).on_blue());
-                }
-                Err(e) => {
-                    event!(
-                        Level::WARN,
-                        "呼叫 shenjack! JoinRequestRoom 的 serde 没写好! {}\nraw: {:#?}",
-                        e,
-                        value
-                    )
-                }
-            }
-        }
-    }
+pub async fn fetch_history(client: Client, room: RoomId) {
+    let mut request_body = json!(room);
 }
 
-pub async fn fetch_history(client: Client, room: RoomId) { let mut request_body = json!(room); }
-
 pub async fn fetch_messages(client: &Client, room: RoomId) {
     let mut request_body = json!(room);
     match client.emit("fetchMessages", request_body).await {
@@ -223,11 +202,11 @@ pub async fn any_event(event: Event, payload: Payload, _client: Client) {
         "deleteMessage",
         "setAllRooms",
         "setMessages",
-        "handleRequest", // 处理验证消息 (加入请求之类的)
         // 也许以后会用到
         "messageSuccess",
         "messageFailed",
         "setAllChatGroups",
+        "handleRequest", // 处理验证消息 (加入请求之类的)
         // 忽略的
         "notify",
         "setShutUp",    // 禁言

ica-rs/src/main.rs

@@ -9,17 +9,14 @@ mod data_struct;
 mod error;
 mod py;
 mod status;
-mod wasms;
 
 #[cfg(feature = "ica")]
 mod ica;
 #[cfg(feature = "tailchat")]
 mod tailchat;
 
-use colored::Colorize;
 use config::BotConfig;
-use error::PyPluginError;
-use tracing::{Level, event, span};
+use tracing::{event, span, Level};
 
 pub static mut MAIN_STATUS: status::BotStatus = status::BotStatus {
     config: None,
@@ -32,8 +29,8 @@ pub type MainStatus = status::BotStatus;
 pub type StopGetter = tokio::sync::oneshot::Receiver<()>;
 
 pub const VERSION: &str = env!("CARGO_PKG_VERSION");
-pub const ICA_VERSION: &str = "2.0.1";
-pub const TAILCHAT_VERSION: &str = "2.0.0";
+pub const ICA_VERSION: &str = "1.6.5";
+pub const TAILCHAT_VERSION: &str = "1.2.5";
 
 const HELP_MSG: &str = r#"/bot-rs
     展示 rust 侧信息
@@ -82,7 +79,7 @@ pub fn version_str() -> String {
 
 /// 是否为稳定版本
 /// 会在 release 的时候设置为 true
-pub const STABLE: bool = false;
+pub const STABLE: bool = true;
 
 #[macro_export]
 macro_rules! async_callback_with_state {
@@ -104,32 +101,25 @@ macro_rules! async_any_callback_with_state {
     }};
 }
 
-const CLI_HELP_MSG: &str = r#"{VERSION}
-    -d
-        debug 模式
-    -t
-        trace 模式
-    -h
-        显示帮助信息
-    -env <env>
-        指定虚拟环境路径
-    -c <config_file_path>
-        指定配置文件路径
-"#;
-
 fn main() -> anyhow::Result<()> {
     let start_up_time = SystemTime::now();
     STARTUP_TIME.set(start_up_time).expect("WTF, why did you panic?");
 
+    tokio::runtime::Builder::new_multi_thread()
+        .enable_all()
+        .thread_name("shenbot-rs")
+        .worker_threads(4)
+        .build()
+        .unwrap()
+        .block_on(inner_main())
+}
+
+async fn inner_main() -> anyhow::Result<()> {
     // -d -> debug
     // none -> info
-    let args = std::env::args();
-    let args = args.collect::<Vec<String>>();
-    if args.contains(&"-h".to_string()) {
-        println!("{}", CLI_HELP_MSG.replace("{VERSION}", version_str().as_str()));
-        return Ok(());
-    }
     let level = {
+        let args = std::env::args();
+        let args = args.collect::<Vec<String>>();
         if args.contains(&"-d".to_string()) {
             Level::DEBUG
         } else if args.contains(&"-t".to_string()) {
@@ -140,35 +130,7 @@ fn main() -> anyhow::Result<()> {
     };
 
     tracing_subscriber::fmt().with_max_level(level).init();
-
-    let rt = tokio::runtime::Builder::new_multi_thread()
-        .enable_all()
-        .thread_name("shenbot-rs")
-        .worker_threads(10)
-        .build()
-        .unwrap();
-
-    let result = rt.block_on(inner_main());
-
-    event!(Level::INFO, "shenbot-rs v{} exiting", VERSION);
-
-    match result {
-        Ok(_) => {}
-        Err(e) => {
-            if let Some(PyPluginError::PluginNotStopped) = e.downcast_ref::<PyPluginError>() {
-                event!(Level::WARN, "Python 插件停不下来, 3s 后终止 tokio rt");
-                rt.shutdown_timeout(Duration::from_secs(3));
-            } else {
-                event!(Level::ERROR, "shenbot-rs v{} exiting with error: {}", VERSION, e);
-            }
-        }
-    }
-
-    Ok(())
-}
-
-async fn inner_main() -> anyhow::Result<()> {
-    let span = span!(Level::INFO, "bot-main");
+    let span = span!(Level::INFO, "Shenbot Main");
     let _enter = span.enter();
 
     event!(Level::INFO, "shenbot-rs v{} starting", VERSION);
@@ -185,43 +147,43 @@ async fn inner_main() -> anyhow::Result<()> {
     }
 
     // 准备一个用于停止 socket 的变量
+    event!(Level::INFO, "启动 ICA");
     let (ica_send, ica_recv) = tokio::sync::oneshot::channel::<()>();
 
     if bot_config.check_ica() {
-        event!(Level::INFO, "{}", "开始启动 ICA".green());
+        event!(Level::INFO, "启动 ica");
         let config = bot_config.ica();
         tokio::spawn(async move {
             ica::start_ica(&config, ica_recv).await.unwrap();
         });
     } else {
-        event!(Level::INFO, "{}", "ica 未启用, 不管他".cyan());
+        event!(Level::INFO, "未启用 ica");
     }
 
     let (tailchat_send, tailchat_recv) = tokio::sync::oneshot::channel::<()>();
 
     if bot_config.check_tailchat() {
-        event!(Level::INFO, "{}", "开始启动 tailchat".green());
+        event!(Level::INFO, "启动 Tailchat");
         let config = bot_config.tailchat();
         tokio::spawn(async move {
             tailchat::start_tailchat(config, tailchat_recv).await.unwrap();
         });
     } else {
-        event!(Level::INFO, "{}", "tailchat 未启用, 不管他".bright_magenta());
+        event!(Level::INFO, "未启用 Tailchat");
     }
 
-    tokio::time::sleep(Duration::from_secs(1)).await;
+    tokio::time::sleep(Duration::from_secs(2)).await;
     // 等待一个输入
-    event!(Level::INFO, "Press ctrl+c to exit, second ctrl+c to force exit");
-    tokio::signal::ctrl_c().await.ok();
+    event!(Level::INFO, "Press any key to exit");
+    let mut input = String::new();
+    std::io::stdin().read_line(&mut input).unwrap();
 
     ica_send.send(()).ok();
     tailchat_send.send(()).ok();
 
     event!(Level::INFO, "Disconnected");
 
-    py::post_py().await?;
-
-    event!(Level::INFO, "Shenbot-rs exiting");
+    py::post_py()?;
 
     Ok(())
 }
@@ -233,8 +195,8 @@ async fn test_macro() {
     use std::sync::Arc;
     use tokio::sync::RwLock;
 
-    use rust_socketio::Payload;
     use rust_socketio::asynchronous::{Client, ClientBuilder};
+    use rust_socketio::Payload;
 
     /// 一个简单的例子
     #[derive(Clone)]

ica-rs/src/py/call.rs

@@ -1,84 +1,13 @@
 use std::path::PathBuf;
-use std::sync::LazyLock;
 
 use pyo3::prelude::*;
 use rust_socketio::asynchronous::Client;
-use tokio::sync::Mutex;
-use tracing::{Level, event, info, warn};
+use tracing::{event, info, warn, Level};
 
-use crate::MainStatus;
 use crate::data_struct::{ica, tailchat};
 use crate::error::PyPluginError;
-use crate::py::consts::events_func;
-use crate::py::{PyPlugin, PyStatus, class};
-
-pub struct PyTasks {
-    pub ica_new_message: Vec<tokio::task::JoinHandle<()>>,
-    pub ica_delete_message: Vec<tokio::task::JoinHandle<()>>,
-    pub tailchat_new_message: Vec<tokio::task::JoinHandle<()>>,
-}
-
-impl PyTasks {
-    pub fn push_ica_new_message(&mut self, handle: tokio::task::JoinHandle<()>) {
-        self.ica_new_message.push(handle);
-        self.ica_new_message.retain(|handle| !handle.is_finished());
-    }
-
-    pub fn push_ica_delete_message(&mut self, handle: tokio::task::JoinHandle<()>) {
-        self.ica_delete_message.push(handle);
-        self.ica_delete_message.retain(|handle| !handle.is_finished());
-    }
-
-    pub fn push_tailchat_new_message(&mut self, handle: tokio::task::JoinHandle<()>) {
-        self.tailchat_new_message.push(handle);
-        self.tailchat_new_message.retain(|handle| !handle.is_finished());
-    }
-
-    pub async fn join_all(&mut self) {
-        for handle in self.ica_new_message.drain(..) {
-            let _ = handle.await;
-        }
-        for handle in self.ica_delete_message.drain(..) {
-            let _ = handle.await;
-        }
-        for handle in self.tailchat_new_message.drain(..) {
-            let _ = handle.await;
-        }
-    }
-
-    pub fn len_check(&mut self) -> usize {
-        self.ica_delete_message.retain(|handle| !handle.is_finished());
-        self.ica_new_message.retain(|handle| !handle.is_finished());
-        self.tailchat_new_message.retain(|handle| !handle.is_finished());
-        self.ica_new_message.len() + self.ica_delete_message.len() + self.tailchat_new_message.len()
-    }
-
-    pub fn len(&self) -> usize {
-        self.ica_new_message.len() + self.ica_delete_message.len() + self.tailchat_new_message.len()
-    }
-
-    pub fn is_empty(&self) -> bool { self.len() == 0 }
-
-    pub fn cancel_all(&mut self) {
-        for handle in self.ica_new_message.drain(..) {
-            handle.abort();
-        }
-        for handle in self.ica_delete_message.drain(..) {
-            handle.abort();
-        }
-        for handle in self.tailchat_new_message.drain(..) {
-            handle.abort();
-        }
-    }
-}
-
-pub static PY_TASKS: LazyLock<Mutex<PyTasks>> = LazyLock::new(|| {
-    Mutex::new(PyTasks {
-        ica_new_message: Vec::new(),
-        ica_delete_message: Vec::new(),
-        tailchat_new_message: Vec::new(),
-    })
-});
+use crate::py::{class, PyPlugin, PyStatus};
+use crate::MainStatus;
 
 pub fn get_func<'py>(
     py_module: &Bound<'py, PyAny>,
@@ -175,6 +104,11 @@ pub fn verify_and_reload_plugins() {
     }
 }
 
+pub const ICA_NEW_MESSAGE_FUNC: &str = "on_ica_message";
+pub const ICA_DELETE_MESSAGE_FUNC: &str = "on_ica_delete_message";
+
+pub const TAILCHAT_NEW_MESSAGE_FUNC: &str = "on_tailchat_message";
+
 macro_rules! call_py_func {
     ($args:expr, $plugin:expr, $plugin_path:expr, $func_name:expr, $client:expr) => {
         tokio::spawn(async move {
@@ -220,8 +154,8 @@ pub async fn ica_new_message_py(message: &ica::messages::NewMessage, client: &Cl
         let msg = class::ica::NewMessagePy::new(message);
         let client = class::ica::IcaClientPy::new(client);
         let args = (msg, client);
-        let task = call_py_func!(args, plugin, path, events_func::ICA_NEW_MESSAGE, client);
-        PY_TASKS.lock().await.push_ica_new_message(task);
+        // 甚至实际上压根不需要await这个spawn, 直接让他自己跑就好了(离谱)
+        call_py_func!(args, plugin, path, ICA_NEW_MESSAGE_FUNC, client);
     }
 }
 
@@ -233,8 +167,7 @@ pub async fn ica_delete_message_py(msg_id: ica::MessageId, client: &Client) {
         let msg_id = msg_id.clone();
         let client = class::ica::IcaClientPy::new(client);
         let args = (msg_id.clone(), client);
-        let task = call_py_func!(args, plugin, path, events_func::ICA_DELETE_MESSAGE, client);
-        PY_TASKS.lock().await.push_ica_delete_message(task);
+        call_py_func!(args, plugin, path, ICA_DELETE_MESSAGE_FUNC, client);
     }
 }
 
@@ -249,7 +182,6 @@ pub async fn tailchat_new_message_py(
         let msg = class::tailchat::TailchatReceiveMessagePy::from_recive_message(message);
         let client = class::tailchat::TailchatClientPy::new(client);
         let args = (msg, client);
-        let task = call_py_func!(args, plugin, path, events_func::TAILCHAT_NEW_MESSAGE, client);
-        PY_TASKS.lock().await.push_tailchat_new_message(task);
+        call_py_func!(args, plugin, path, TAILCHAT_NEW_MESSAGE_FUNC, client);
     }
 }

ica-rs/src/py/class.rs

@@ -1,17 +1,27 @@
-pub mod commander;
-pub mod config;
 pub mod ica;
-pub mod schdule;
 pub mod tailchat;
 
 use pyo3::{
-    Bound, IntoPyObject, PyAny, PyRef, PyResult, pyclass, pymethods, pymodule,
-    types::{PyBool, PyModule, PyModuleMethods, PyString},
+    pyclass, pymethods,
+    types::{PyBool, PyString},
+    Bound, IntoPyObject, PyAny, PyRef,
 };
 use toml::Value as TomlValue;
-use tracing::{Level, event};
 
-// #[derive(Clone)]
+#[derive(Clone)]
+#[pyclass]
+#[pyo3(name = "ConfigRequest")]
+pub struct ConfigRequestPy {
+    pub path: String,
+}
+
+#[pymethods]
+impl ConfigRequestPy {
+    #[new]
+    pub fn py_new(path: String) -> Self { Self { path } }
+}
+
+#[derive(Clone)]
 #[pyclass]
 #[pyo3(name = "ConfigData")]
 pub struct ConfigDataPy {
@@ -51,35 +61,3 @@ impl ConfigDataPy {
 impl ConfigDataPy {
     pub fn new(data: TomlValue) -> Self { Self { data } }
 }
-
-/// Rust 侧向 Python 侧提供的 api
-#[pymodule]
-#[pyo3(name = "shenbot_api")]
-fn rs_api_module(m: &Bound<'_, PyModule>) -> PyResult<()> {
-    m.add("__version__", crate::VERSION)?;
-    m.add("_version_", crate::VERSION)?;
-    m.add("_ica_version_", crate::ICA_VERSION)?;
-    m.add("_tailchat_version_", crate::TAILCHAT_VERSION)?;
-    m.add_class::<ConfigDataPy>()?;
-    m.add_class::<config::ConfigStoragePy>()?;
-    m.add_class::<schdule::SchedulerPy>()?;
-    Ok(())
-}
-
-/// 在 python 初始化之前注册所有需要的类
-///
-/// WARNING: 这个函数需要在 Python 初始化之前调用，否则会导致报错
-///
-/// (pyo3 提供的宏会检查一遍, 不过我这里就直接用原始形式了)
-pub fn regist_class() {
-    event!(Level::INFO, "向 Python 注册 Rust 侧模块/函数");
-    unsafe {
-        // 单纯没用 macro 而已
-        pyo3::ffi::PyImport_AppendInittab(
-            rs_api_module::__PYO3_NAME.as_ptr(),
-            Some(rs_api_module::__pyo3_init),
-        );
-    }
-
-    event!(Level::INFO, "注册完成");
-}

ica-rs/src/py/class/commander.rs

@@ -1 +0,0 @@
-

ica-rs/src/py/class/config.rs

@@ -1,343 +0,0 @@
-use std::collections::HashMap;
-
-use pyo3::{
-    Bound, PyAny, PyResult, pyclass, pymethods,
-    types::{
-        PyAnyMethods, PyBool, PyBoolMethods, PyDict, PyDictMethods, PyFloat, PyInt, PyList,
-        PyListMethods, PyString, PyStringMethods, PyTypeMethods,
-    },
-};
-use tracing::{Level, event};
-
-#[derive(Debug, Clone)]
-pub enum ConfigItem {
-    None,
-    String(String),
-    Int(i64),
-    Float(f64),
-    Bool(bool),
-    Array(Vec<ConfigItemPy>),
-    Table(HashMap<String, ConfigItemPy>),
-}
-
-#[derive(Clone, Debug)]
-#[pyclass]
-#[pyo3(name = "ConfigItem")]
-pub struct ConfigItemPy {
-    pub item: ConfigItem,
-    pub default_value: ConfigItem,
-}
-
-impl ConfigItemPy {
-    pub fn new(item: ConfigItem, default_value: ConfigItem) -> Self {
-        Self {
-            item,
-            default_value,
-        }
-    }
-
-    pub fn new_uninit(default_value: ConfigItem) -> Self {
-        Self {
-            item: ConfigItem::None,
-            default_value,
-        }
-    }
-}
-
-#[derive(Clone)]
-#[pyclass]
-#[pyo3(name = "ConfigStorage")]
-pub struct ConfigStoragePy {
-    pub keys: HashMap<String, ConfigItemPy>,
-}
-
-/// Storage 里允许的最大层级深度
-///
-/// 我也不知道为啥就突然有这玩意了(
-pub const MAX_CFG_DEPTH: usize = 10;
-
-fn parse_py_string(obj: &Bound<'_, PyAny>) -> PyResult<String> {
-    let py_str = obj.downcast::<PyString>()?;
-    let value = py_str.to_str()?;
-    Ok(value.to_string())
-}
-
-fn parse_py_bool(obj: &Bound<'_, PyAny>) -> PyResult<bool> {
-    let py_bool = obj.downcast::<PyBool>()?;
-    Ok(py_bool.is_true())
-}
-
-fn parse_py_int(obj: &Bound<'_, PyAny>) -> PyResult<i64> {
-    let py_int = obj.downcast::<PyInt>()?;
-    py_int.extract::<i64>()
-}
-
-fn parse_py_float(obj: &Bound<'_, PyAny>) -> PyResult<f64> {
-    let py_float = obj.downcast::<PyFloat>()?;
-    py_float.extract::<f64>()
-}
-
-impl ConfigStoragePy {
-    /// 递归 list 解析配置
-    ///
-    /// 用个 Result 来标记递归过深
-    fn parse_py_list(
-        args: &Bound<'_, PyList>,
-        list: &mut Vec<ConfigItemPy>,
-        current_deepth: usize,
-    ) -> Result<(), usize> {
-        if current_deepth > MAX_CFG_DEPTH {
-            return Err(current_deepth);
-        } else {
-            for value in args.iter() {
-                // 匹配 item
-                let value_type = value.get_type();
-                if value_type.is_instance_of::<PyDict>() {
-                    let py_dict = value.downcast::<PyDict>().unwrap();
-                    let mut new_map = HashMap::new();
-                    match Self::parse_py_dict(py_dict, &mut new_map, current_deepth + 1) {
-                        Ok(_) => {
-                            list.push(ConfigItemPy::new_uninit(ConfigItem::Table(new_map)));
-                        }
-                        Err(e) => {
-                            event!(
-                                Level::WARN,
-                                "value(dict) 解析时出现错误: {}\nraw: {}",
-                                e,
-                                value
-                            );
-                        }
-                    }
-                } else if value_type.is_instance_of::<PyList>() {
-                    let py_list = value.downcast::<PyList>().unwrap();
-                    let mut new_list = Vec::new();
-                    match Self::parse_py_list(py_list, &mut new_list, current_deepth + 1) {
-                        Ok(_) => {
-                            list.push(ConfigItemPy::new_uninit(ConfigItem::Array(new_list)));
-                        }
-                        Err(e) => {
-                            event!(
-                                Level::WARN,
-                                "value(list) 解析时出现错误: {}\nraw: {}",
-                                e,
-                                value
-                            );
-                        }
-                    }
-                } else if value_type.is_instance_of::<PyString>() {
-                    match parse_py_string(&value) {
-                        Ok(value) => {
-                            list.push(ConfigItemPy::new_uninit(ConfigItem::String(value)));
-                        }
-                        Err(e) => {
-                            event!(
-                                Level::WARN,
-                                "value(string) 解析时出现错误: {}\nraw: {}",
-                                e,
-                                value
-                            );
-                        }
-                    }
-                } else if value_type.is_instance_of::<PyBool>() {
-                    match parse_py_bool(&value) {
-                        Ok(value) => {
-                            list.push(ConfigItemPy::new_uninit(ConfigItem::Bool(value)));
-                        }
-                        Err(e) => {
-                            event!(
-                                Level::WARN,
-                                "value(bool) 解析时出现错误: {}\nraw: {}",
-                                e,
-                                value
-                            );
-                        }
-                    }
-                } else if value_type.is_instance_of::<PyInt>() {
-                    match parse_py_int(&value) {
-                        Ok(value) => {
-                            list.push(ConfigItemPy::new_uninit(ConfigItem::Int(value)));
-                        }
-                        Err(e) => {
-                            event!(Level::WARN, "value(int) 解析时出现错误: {}\nraw: {}", e, value);
-                        }
-                    }
-                } else if value_type.is_instance_of::<PyFloat>() {
-                    match parse_py_float(&value) {
-                        Ok(value) => {
-                            list.push(ConfigItemPy::new_uninit(ConfigItem::Float(value)));
-                        }
-                        Err(e) => {
-                            event!(
-                                Level::WARN,
-                                "value(float) 解析时出现错误: {}\nraw: {}",
-                                e,
-                                value
-                            );
-                        }
-                    }
-                } else {
-                    // 先丢个 warning 出去
-                    match value_type.name() {
-                        Ok(type_name) => {
-                            event!(
-                                Level::WARN,
-                                "value 为不支持的 {} 类型\nraw: {}",
-                                type_name,
-                                value
-                            )
-                        }
-                        Err(e) => {
-                            event!(
-                                Level::WARN,
-                                "value 为不支持的类型 (获取类型名失败: {})\nraw: {}",
-                                e,
-                                value
-                            )
-                        }
-                    }
-                }
-            }
-        }
-        Ok(())
-    }
-
-    /// 递归 dict 解析配置
-    ///
-    /// 用个 Result 来标记递归过深
-    fn parse_py_dict(
-        kwargs: &Bound<'_, PyDict>,
-        map: &mut HashMap<String, ConfigItemPy>,
-        current_deepth: usize,
-    ) -> Result<(), usize> {
-        if current_deepth > MAX_CFG_DEPTH {
-            Err(current_deepth)
-        } else {
-            for (key, value) in kwargs.iter() {
-                if let Ok(name) = key.downcast::<PyString>() {
-                    let name = name.to_string();
-                    // 匹配 item
-                    let value_type = value.get_type();
-                    if value_type.is_instance_of::<PyDict>() {
-                        let py_dict = value.downcast::<PyDict>().unwrap();
-                        let mut new_map = HashMap::new();
-                        match Self::parse_py_dict(py_dict, &mut new_map, current_deepth + 1) {
-                            Ok(_) => {
-                                map.insert(
-                                    name.clone(),
-                                    ConfigItemPy::new_uninit(ConfigItem::Table(new_map)),
-                                );
-                            }
-                            Err(e) => {
-                                event!(Level::WARN, "value(dict) {} 解析时出现错误: {}", name, e);
-                            }
-                        }
-                    } else if value_type.is_instance_of::<PyList>() {
-                        let py_list = value.downcast::<PyList>().unwrap();
-                        let mut new_list = Vec::new();
-                        match Self::parse_py_list(py_list, &mut new_list, current_deepth + 1) {
-                            Ok(_) => {
-                                map.insert(
-                                    name.clone(),
-                                    ConfigItemPy::new_uninit(ConfigItem::Array(new_list)),
-                                );
-                            }
-                            Err(e) => {
-                                event!(Level::WARN, "value(list) {} 解析时出现错误: {}", name, e);
-                            }
-                        }
-                    } else if value_type.is_instance_of::<PyString>() {
-                        match parse_py_string(&value) {
-                            Ok(value) => {
-                                map.insert(
-                                    name.clone(),
-                                    ConfigItemPy::new_uninit(ConfigItem::String(value)),
-                                );
-                            }
-                            Err(e) => {
-                                event!(Level::WARN, "value(string) {} 解析时出现错误: {}", name, e);
-                            }
-                        }
-                    } else if value_type.is_instance_of::<PyBool>() {
-                        match parse_py_bool(&value) {
-                            Ok(value) => {
-                                map.insert(
-                                    name.clone(),
-                                    ConfigItemPy::new_uninit(ConfigItem::Bool(value)),
-                                );
-                            }
-                            Err(e) => {
-                                event!(Level::WARN, "value(bool) {} 解析时出现错误: {}", name, e);
-                            }
-                        }
-                    } else if value_type.is_instance_of::<PyInt>() {
-                        match parse_py_int(&value) {
-                            Ok(value) => {
-                                map.insert(
-                                    name.clone(),
-                                    ConfigItemPy::new_uninit(ConfigItem::Int(value)),
-                                );
-                            }
-                            Err(e) => {
-                                event!(Level::WARN, "value(int) {} 解析时出现错误: {}", name, e);
-                            }
-                        }
-                    } else if value_type.is_instance_of::<PyFloat>() {
-                        match parse_py_float(&value) {
-                            Ok(value) => {
-                                map.insert(
-                                    name.clone(),
-                                    ConfigItemPy::new_uninit(ConfigItem::Float(value)),
-                                );
-                            }
-                            Err(e) => {
-                                event!(Level::WARN, "value(float) {} 解析时出现错误: {}", name, e);
-                            }
-                        }
-                    } else {
-                        // 先丢个 warning 出去
-                        match value_type.name() {
-                            Ok(type_name) => {
-                                event!(Level::WARN, "value {} 为不支持的 {} 类型", name, type_name)
-                            }
-                            Err(e) => event!(
-                                Level::WARN,
-                                "value {} 为不支持的类型 (获取类型名失败: {})",
-                                name,
-                                e
-                            ),
-                        }
-                        continue;
-                    }
-                }
-            }
-            Ok(())
-        }
-    }
-}
-
-#[pymethods]
-impl ConfigStoragePy {
-    #[new]
-    #[pyo3(signature = (**kwargs))]
-    pub fn new(kwargs: Option<&Bound<'_, PyDict>>) -> PyResult<Self> {
-        match kwargs {
-            Some(kwargs) => {
-                let mut keys = HashMap::new();
-                // 解析 kwargs
-                Self::parse_py_dict(kwargs, &mut keys, 0).map_err(|e| {
-                    event!(Level::ERROR, "配置解析过深: {}", e);
-                    pyo3::exceptions::PyValueError::new_err(format!("配置解析过深: {}", e))
-                })?;
-                // 解析完成
-                Ok(Self { keys })
-            }
-            None => Ok(Self {
-                keys: HashMap::new(),
-            }),
-        }
-    }
-
-    #[getter]
-    /// 获取最大允许的层级深度
-    pub fn get_max_allowed_depth(&self) -> usize { MAX_CFG_DEPTH }
-}

ica-rs/src/py/class/ica.rs

@@ -3,15 +3,15 @@ use std::time::SystemTime;
 use pyo3::{pyclass, pymethods};
 use rust_socketio::asynchronous::Client;
 use tokio::runtime::Runtime;
-use tracing::{Level, event};
+use tracing::{event, Level};
 
-use crate::MainStatus;
 use crate::data_struct::ica::messages::{
     DeleteMessage, MessageTrait, NewMessage, ReplyMessage, SendMessage,
 };
 use crate::data_struct::ica::{MessageId, RoomId, RoomIdTrait, UserId};
 use crate::ica::client::{delete_message, send_message, send_poke, send_room_sign_in};
 use crate::py::PyStatus;
+use crate::MainStatus;
 
 #[pyclass]
 #[pyo3(name = "IcaStatus")]
@@ -63,27 +63,6 @@ impl IcaStatusPy {
     pub fn get_load(&self) -> String {
         MainStatus::global_ica_status().online_status.icalingua_info.load.clone()
     }
-    #[getter]
-    /// 获取当前用户加入的所有房间
-    ///
-    /// 添加自 2.0.1
-    pub fn get_rooms(&self) -> Vec<IcaRoomPy> {
-        MainStatus::global_ica_status().rooms.iter().map(|r| r.into()).collect()
-    }
-    #[getter]
-    /// 获取所有管理员
-    ///
-    /// 添加自 2.0.1
-    pub fn get_admins(&self) -> Vec<UserId> { MainStatus::global_config().ica().admin_list.clone() }
-    #[getter]
-    /// 获取所有被屏蔽的人
-    ///
-    /// (好像没啥用就是了, 反正被过滤的不会给到插件)
-    ///
-    /// 添加自 2.0.1
-    pub fn get_filtered(&self) -> Vec<UserId> {
-        MainStatus::global_config().ica().filter_list.clone()
-    }
 }
 
 impl Default for IcaStatusPy {
@@ -94,47 +73,6 @@ impl IcaStatusPy {
     pub fn new() -> Self { Self {} }
 }
 
-#[derive(Clone)]
-#[pyclass]
-#[pyo3(name = "IcaRoom")]
-/// Room api
-///
-/// 添加自 2.0.1
-pub struct IcaRoomPy {
-    pub inner: crate::data_struct::ica::all_rooms::Room,
-}
-
-impl From<crate::data_struct::ica::all_rooms::Room> for IcaRoomPy {
-    fn from(inner: crate::data_struct::ica::all_rooms::Room) -> Self { Self { inner } }
-}
-
-impl From<&crate::data_struct::ica::all_rooms::Room> for IcaRoomPy {
-    fn from(inner: &crate::data_struct::ica::all_rooms::Room) -> Self {
-        Self {
-            inner: inner.clone(),
-        }
-    }
-}
-
-#[pymethods]
-impl IcaRoomPy {
-    #[getter]
-    pub fn get_room_id(&self) -> i64 { self.inner.room_id }
-    #[getter]
-    pub fn get_room_name(&self) -> String { self.inner.room_name.clone() }
-    #[getter]
-    pub fn get_unread_count(&self) -> u64 { self.inner.unread_count }
-    #[getter]
-    pub fn get_priority(&self) -> u8 { self.inner.priority }
-    #[getter]
-    pub fn get_utime(&self) -> i64 { self.inner.utime }
-    pub fn is_group(&self) -> bool { self.inner.room_id.is_room() }
-    pub fn is_chat(&self) -> bool { self.inner.room_id.is_chat() }
-    pub fn new_message_to(&self, content: String) -> SendMessagePy {
-        SendMessagePy::new(self.inner.new_message_to(content))
-    }
-}
-
 #[derive(Clone)]
 #[pyclass]
 #[pyo3(name = "NewMessage")]
@@ -208,10 +146,6 @@ impl SendMessagePy {
     pub fn get_content(&self) -> String { self.msg.content.clone() }
     #[setter]
     pub fn set_content(&mut self, content: String) { self.msg.content = content; }
-    #[getter]
-    pub fn get_room_id(&self) -> RoomId { self.msg.room_id }
-    #[setter]
-    pub fn set_room_id(&mut self, room_id: RoomId) { self.msg.room_id = room_id; }
     /// 设置消息图片
     pub fn set_img(&mut self, file: Vec<u8>, file_type: String, as_sticker: bool) {
         self.msg.set_img(&file, &file_type, as_sticker);
@@ -317,14 +251,6 @@ impl IcaClientPy {
     #[getter]
     pub fn get_startup_time(&self) -> SystemTime { crate::start_up_time() }
 
-    #[getter]
-    pub fn get_py_tasks_count(&self) -> usize {
-        tokio::task::block_in_place(|| {
-            let rt = Runtime::new().unwrap();
-            rt.block_on(async { crate::py::call::PY_TASKS.lock().await.len_check() })
-        })
-    }
-
     /// 重新加载插件状态
     /// 返回是否成功
     pub fn reload_plugin_status(&self) -> bool { PyStatus::get_mut().config.reload_from_default() }

ica-rs/src/py/class/schdule.rs

@@ -1,59 +0,0 @@
-use std::time::Duration;
-
-use pyo3::{Bound, Py, PyTraverseError, PyVisit, Python, pyclass, pymethods, types::PyFunction};
-use tracing::{Level, event};
-
-#[derive(Debug)]
-#[pyclass]
-#[pyo3(name = "Scheduler")]
-/// 用于计划任务的类
-///
-/// 给 Python 侧使用
-///
-/// add: 0.9.0
-pub struct SchedulerPy {
-    /// 回调函数
-    ///
-    /// 你最好不要把他清理掉
-    pub callback: Py<PyFunction>,
-    /// 预计等待时间
-    pub schdule_time: Duration,
-}
-
-#[pymethods]
-impl SchedulerPy {
-    fn __traverse__(&self, visit: PyVisit<'_>) -> Result<(), PyTraverseError> {
-        visit.call(&self.callback)?;
-        Ok(())
-    }
-
-    #[new]
-    pub fn new(func: Bound<'_, PyFunction>, schdule_time: Duration) -> Self {
-        Self {
-            callback: func.unbind(),
-            schdule_time,
-        }
-    }
-
-    /// 开始
-    pub fn start(&self, py: Python<'_>) {
-        let wait = self.schdule_time;
-        let cb = self.callback.clone_ref(py);
-        tokio::spawn(async move {
-            let second = Duration::from_secs(1);
-            if wait > second {
-                let big_sleep = wait.checked_sub(second).unwrap();
-                tokio::time::sleep(big_sleep).await;
-                tokio::time::sleep(second).await;
-            } else {
-                tokio::time::sleep(wait).await;
-            }
-            Python::with_gil(|py| {
-                event!(Level::INFO, "正在调用计划 {:?}", wait);
-                if let Err(e) = cb.call0(py) {
-                    event!(Level::WARN, "调用时出现错误 {}", e);
-                }
-            });
-        });
-    }
-}

ica-rs/src/py/class/tailchat.rs

@@ -3,7 +3,6 @@ use std::time::SystemTime;
 use pyo3::prelude::*;
 
 use rust_socketio::asynchronous::Client;
-use tokio::runtime::Runtime;
 use tracing::{debug, info, warn};
 
 use crate::data_struct::tailchat::messages::{ReceiveMessage, SendingFile, SendingMessage};
@@ -74,15 +73,6 @@ impl TailchatClientPy {
     pub fn get_tailchat_version(&self) -> String { crate::TAILCHAT_VERSION.to_string() }
     #[getter]
     pub fn get_startup_time(&self) -> SystemTime { crate::start_up_time() }
-
-    #[getter]
-    pub fn get_py_tasks_count(&self) -> usize {
-        tokio::task::block_in_place(|| {
-            let rt = Runtime::new().unwrap();
-            rt.block_on(async { crate::py::call::PY_TASKS.lock().await.len_check() })
-        })
-    }
-
     /// 重新加载插件状态
     /// 返回是否成功
     pub fn reload_plugin_status(&self) -> bool { PyStatus::get_mut().config.reload_from_default() }

ica-rs/src/py/config.rs

@@ -1,11 +1,13 @@
-use std::{path::Path, str::FromStr};
+use std::{
+    path::{Path, PathBuf},
+    str::FromStr,
+};
 
-use colored::Colorize;
-use toml_edit::{DocumentMut, Key, Table, TomlError, Value, value};
-use tracing::{Level, event};
+use toml_edit::{value, DocumentMut, Key, Table, TomlError, Value};
+use tracing::{event, Level};
 
-use crate::MainStatus;
 use crate::py::PyStatus;
+use crate::MainStatus;
 
 /// ```toml
 /// # 这个文件是由 shenbot 自动生成的, 请 **谨慎** 修改
@@ -28,7 +30,6 @@ pub const DEFAULT_CONFIG: &str = r#"
 [plugins]
 "#;
 
-#[allow(unused)]
 impl PluginConfigFile {
     pub fn from_str(data: &str) -> Result<Self, TomlError> {
         let mut data = DocumentMut::from_str(data)?;
@@ -45,7 +46,7 @@ impl PluginConfigFile {
     pub fn default_init() -> anyhow::Result<Self> {
         let config_path = MainStatus::global_config().py().config_path.clone();
         let path = Path::new(&config_path);
-        Self::from_config_path(path)
+        Self::from_config_path(&path)
     }
 
     pub fn reload_from_default(&mut self) -> bool {
@@ -136,35 +137,18 @@ impl PluginConfigFile {
         }
         event!(Level::INFO, "同步插件状态");
         let plugins = PyStatus::get_mut();
-
-        fn fmt_bool(b: bool) -> String {
-            if b {
-                "启用".green().to_string()
-            } else {
-                "禁用".red().to_string()
-            }
-        }
-
         plugins.files.iter_mut().for_each(|(path, status)| {
             let plugin_id = status.get_id();
             let config_status = self.get_status(&plugin_id);
-            if config_status != status.enabled {
-                event!(
-                    Level::INFO,
-                    "插件状态: {} {} -> {}",
-                    status.get_id(),
-                    fmt_bool(status.enabled),
-                    fmt_bool(config_status)
-                );
-                status.enabled = config_status;
-            } else {
-                event!(
-                    Level::INFO,
-                    "插件状态: {} {} (没变)",
-                    status.get_id(),
-                    fmt_bool(status.enabled)
-                );
-            }
+            event!(
+                Level::INFO,
+                "插件状态: {}({:?}) {} -> {}",
+                status.get_id(),
+                path,
+                status.enabled,
+                config_status
+            );
+            status.enabled = config_status;
         });
         true
     }
@@ -181,7 +165,7 @@ impl PluginConfigFile {
     pub fn write_to_default(&self) -> Result<(), std::io::Error> {
         let config_path = MainStatus::global_config().py().config_path.clone();
         let config_path = Path::new(&config_path);
-        self.write_to_file(config_path)
+        self.write_to_file(&config_path)
     }
 
     pub fn write_to_file(&self, path: &Path) -> Result<(), std::io::Error> {

ica-rs/src/py/consts.rs

@@ -1,21 +0,0 @@
-pub mod events_func {
-
-    /// icalingua 的 加群请求
-    ///
-    /// added: 2.0.1
-    pub const ICA_JOIN_REQUEST: &str = "on_ica_join_request";
-    /// icalingua 的 新消息
-    pub const ICA_NEW_MESSAGE: &str = "on_ica_message";
-    /// icalingua 的 消息撤回
-    pub const ICA_DELETE_MESSAGE: &str = "on_ica_delete_message";
-
-    /// tailchat 的 新消息
-    pub const TAILCHAT_NEW_MESSAGE: &str = "on_tailchat_message";
-}
-
-pub mod config_func {
-    /// 请求配置用的函数
-    pub const REQUIRE_CONFIG: &str = "require_config";
-    /// 接受配置用的函数
-    pub const ON_CONFIG: &str = "on_config";
-}

ica-rs/src/py/mod.rs

@@ -1,7 +1,6 @@
 pub mod call;
 pub mod class;
 pub mod config;
-pub mod consts;
 
 use std::ffi::CString;
 use std::fmt::Display;
@@ -11,20 +10,13 @@ use std::time::SystemTime;
 use std::{collections::HashMap, path::PathBuf};
 
 use colored::Colorize;
-use pyo3::{
-    Bound, Py, PyErr, PyResult, Python,
-    exceptions::PyTypeError,
-    intern,
-    types::{PyAnyMethods, PyModule, PyTracebackMethods, PyTuple},
-};
-use tracing::{Level, event, span, warn};
+use pyo3::prelude::*;
+use pyo3::types::PyTuple;
+use tracing::{event, span, warn, Level};
 
 use crate::MainStatus;
-use crate::error::PyPluginError;
 
-use consts::config_func;
-
-#[derive(Debug)]
+#[derive(Debug, Clone)]
 pub struct PyStatus {
     pub files: PyPlugins,
     pub config: config::PluginConfigFile,
@@ -36,7 +28,6 @@ pub type RawPyPlugin = (PathBuf, Option<SystemTime>, String);
 #[allow(non_upper_case_globals)]
 static mut PyPluginStatus: OnceLock<PyStatus> = OnceLock::new();
 
-#[allow(static_mut_refs)]
 impl PyStatus {
     pub fn init() {
         let config =
@@ -121,24 +112,15 @@ pub fn get_py_err_traceback(py_err: &PyErr) -> String {
     .to_string()
 }
 
-#[derive(Debug)]
+#[derive(Debug, Clone)]
 pub struct PyPlugin {
     pub file_path: PathBuf,
-    pub modify_time: Option<SystemTime>,
-    pub py_module: Py<PyModule>,
+    pub changed_time: Option<SystemTime>,
+    pub py_module: Py<PyAny>,
     pub enabled: bool,
 }
 
 impl PyPlugin {
-    pub fn new(path: PathBuf, modify_time: Option<SystemTime>, module: Py<PyModule>) -> Self {
-        PyPlugin {
-            file_path: path.clone(),
-            modify_time,
-            py_module: module,
-            enabled: false,
-        }
-    }
-
     /// 从文件创建一个新的
     pub fn new_from_path(path: &PathBuf) -> Option<Self> {
         let raw_file = load_py_file(path);
@@ -169,7 +151,7 @@ impl PyPlugin {
             Ok(raw_file) => match Self::try_from(raw_file) {
                 Ok(plugin) => {
                     self.py_module = plugin.py_module;
-                    self.modify_time = plugin.modify_time;
+                    self.changed_time = plugin.changed_time;
                     self.enabled = PyStatus::get().config.get_status(&self.get_id());
                     event!(Level::INFO, "更新 Python 插件文件 {:?} 完成", self.file_path);
                     true
@@ -196,7 +178,7 @@ impl PyPlugin {
         match get_change_time(&self.file_path) {
             None => false,
             Some(time) => {
-                if let Some(changed_time) = self.modify_time {
+                if let Some(changed_time) = self.changed_time {
                     time.eq(&changed_time)
                 } else {
                     true
@@ -216,147 +198,11 @@ impl Display for PyPlugin {
 
 pub const CONFIG_DATA_NAME: &str = "CONFIG_DATA";
 
-fn set_str_cfg_default_plugin(
-    module: &Bound<'_, PyModule>,
-    default: String,
-    path: String,
-) -> PyResult<()> {
-    let base_path = MainStatus::global_config().py().config_path;
-
-    let mut base_path: PathBuf = PathBuf::from(base_path);
-
-    if !base_path.exists() {
-        event!(Level::WARN, "python 插件路径不存在, 创建: {:?}", base_path);
-        std::fs::create_dir_all(&base_path)?;
-    }
-    base_path.push(&path);
-
-    let config_str: String = if base_path.exists() {
-        event!(Level::INFO, "加载 {:?} 的配置文件 {:?} 中", path, base_path);
-        match std::fs::read_to_string(&base_path) {
-            Ok(v) => v,
-            Err(e) => {
-                event!(Level::WARN, "配置文件 {:?} 读取失败 {}, 创建默认配置", base_path, e);
-                // 写入默认配置
-                std::fs::write(&base_path, &default)?;
-                default
-            }
-        }
-    } else {
-        event!(Level::WARN, "配置文件 {:?} 不存在, 创建默认配置", base_path);
-        // 写入默认配置
-        std::fs::write(base_path, &default)?;
-        default
-    };
-
-    if let Err(e) = module.setattr(intern!(module.py(), CONFIG_DATA_NAME), &config_str) {
-        event!(Level::WARN, "Python 插件 {:?} 的配置文件信息设置失败:{:?}", path, e);
-        return Err(PyTypeError::new_err(format!(
-            "Python 插件 {:?} 的配置文件信息设置失败:{:?}",
-            path, e
-        )));
-    }
-
-    // 给到 on config
-    if let Ok(attr) = module.getattr(intern!(module.py(), config_func::ON_CONFIG)) {
-        if !attr.is_callable() {
-            event!(
-                Level::WARN,
-                "Python 插件 {:?} 的 {} 函数不是 Callable",
-                path,
-                config_func::ON_CONFIG
-            );
-            return Ok(());
-        }
-        let args = (config_str.as_bytes(),);
-        if let Err(e) = attr.call1(args) {
-            event!(
-                Level::WARN,
-                "Python 插件 {:?} 的 {} 函数返回了一个报错 {}",
-                path,
-                config_func::ON_CONFIG,
-                e
-            );
-        }
-    }
-
-    Ok(())
-}
-
-fn set_bytes_cfg_default_plugin(
-    module: &Bound<'_, PyModule>,
-    default: Vec<u8>,
-    path: String,
-) -> PyResult<()> {
-    let base_path = MainStatus::global_config().py().config_path;
-
-    let mut base_path: PathBuf = PathBuf::from(base_path);
-
-    if !base_path.exists() {
-        event!(Level::WARN, "python 插件路径不存在, 创建: {:?}", base_path);
-        std::fs::create_dir_all(&base_path)?;
-    }
-    base_path.push(&path);
-
-    let config_vec: Vec<u8> = if base_path.exists() {
-        event!(Level::INFO, "加载 {:?} 的配置文件 {:?} 中", path, base_path);
-        match std::fs::read(&base_path) {
-            Ok(v) => v,
-            Err(e) => {
-                event!(Level::WARN, "配置文件 {:?} 读取失败 {}, 创建默认配置", base_path, e);
-                // 写入默认配置
-                std::fs::write(&base_path, &default)?;
-                default
-            }
-        }
-    } else {
-        event!(Level::WARN, "配置文件 {:?} 不存在, 创建默认配置", base_path);
-        // 写入默认配置
-        std::fs::write(base_path, &default)?;
-        default
-    };
-
-    match module.setattr(intern!(module.py(), CONFIG_DATA_NAME), &config_vec) {
-        Ok(()) => (),
-        Err(e) => {
-            warn!("Python 插件 {:?} 的配置文件信息设置失败:{:?}", path, e);
-            return Err(PyTypeError::new_err(format!(
-                "Python 插件 {:?} 的配置文件信息设置失败:{:?}",
-                path, e
-            )));
-        }
-    }
-
-    // 给到 on config
-    if let Ok(attr) = module.getattr(intern!(module.py(), config_func::ON_CONFIG)) {
-        if !attr.is_callable() {
-            event!(
-                Level::WARN,
-                "Python 插件 {:?} 的 {} 函数不是 Callable",
-                path,
-                config_func::ON_CONFIG
-            );
-            return Ok(());
-        }
-        let args = (&config_vec,);
-        if let Err(e) = attr.call1(args) {
-            event!(
-                Level::WARN,
-                "Python 插件 {:?} 的 {} 函数返回了一个报错 {}",
-                path,
-                config_func::ON_CONFIG,
-                e
-            );
-        }
-    }
-    Ok(())
-}
-
 impl TryFrom<RawPyPlugin> for PyPlugin {
     type Error = PyErr;
     fn try_from(value: RawPyPlugin) -> Result<Self, Self::Error> {
-        let (path, modify_time, content) = value;
-        let py_module: Py<PyModule> = match py_module_from_code(&content, &path) {
+        let (path, changed_time, content) = value;
+        let py_module = match py_module_from_code(&content, &path) {
             Ok(module) => module,
             Err(e) => {
                 warn!("加载 Python 插件: {:?} 失败", e);
@@ -365,37 +211,119 @@ impl TryFrom<RawPyPlugin> for PyPlugin {
         };
         Python::with_gil(|py| {
             let module = py_module.bind(py);
-            if let Ok(config_func) = call::get_func(module, config_func::REQUIRE_CONFIG) {
+            if let Ok(config_func) = call::get_func(module, "on_config") {
                 match config_func.call0() {
                     Ok(config) => {
                         if config.is_instance_of::<PyTuple>() {
-                            // let (config, default) = config.extract::<(String, Vec<u8>)>().unwrap();
-                            // let (config, default) = config.extract::<(String, String)>().unwrap();
-                            if let Ok((config, default)) = config.extract::<(String, String)>() {
-                                set_str_cfg_default_plugin(module, default, config)?;
-                            } else if let Ok((config, default)) =
-                                config.extract::<(String, Vec<u8>)>()
-                            {
-                                set_bytes_cfg_default_plugin(module, default, config)?;
-                            } else {
-                                warn!(
-                                    "加载 Python 插件 {:?} 的配置文件信息时失败:返回的不是 [str, bytes | str]",
-                                    path
-                                );
-                                return Err(PyTypeError::new_err(
-                                    "返回的不是 [str, bytes | str]".to_string(),
-                                ));
+                            let (config, default) = config.extract::<(String, String)>().unwrap();
+                            let base_path = MainStatus::global_config().py().config_path;
+
+                            let mut base_path: PathBuf = PathBuf::from(base_path);
+
+                            if !base_path.exists() {
+                                event!(Level::WARN, "python 插件路径不存在, 创建: {:?}", base_path);
+                                std::fs::create_dir_all(&base_path)?;
+                            }
+                            base_path.push(&config);
+
+                            let config_value = if base_path.exists() {
+                                event!(
+                                    Level::INFO,
+                                    "加载 {:?} 的配置文件 {:?} 中",
+                                    path,
+                                    base_path
+                                );
+                                let content = std::fs::read_to_string(&base_path)?;
+                                toml::from_str(&content)
+                            } else {
+                                event!(
+                                    Level::WARN,
+                                    "配置文件 {:?} 不存在, 创建默认配置",
+                                    base_path
+                                );
+                                // 写入默认配置
+                                std::fs::write(base_path, &default)?;
+                                toml::from_str(&default)
+                            };
+                            match config_value {
+                                Ok(config) => {
+                                    let py_config =
+                                        Bound::new(py, class::ConfigDataPy::new(config));
+                                    if let Err(e) = py_config {
+                                        event!(Level::WARN, "添加配置文件信息失败: {:?}", e);
+                                        return Err(e);
+                                    }
+                                    let py_config = py_config.unwrap();
+                                    // 先判定一下原来有没有
+                                    if let Ok(true) = module.hasattr(CONFIG_DATA_NAME) {
+                                        // get 过来, 后面直接覆盖, 这里用于发个警告
+                                        match module.getattr(CONFIG_DATA_NAME) {
+                                            Ok(old_config) => {
+                                                // 先判断是不是 None, 直接忽略掉 None
+                                                // 毕竟有可能有占位
+                                                if !old_config.is_none() {
+                                                    warn!(
+                                                        "Python 插件 {:?} 的配置文件信息已经存在\n原始内容: {}",
+                                                        path, old_config
+                                                    );
+                                                }
+                                            }
+                                            Err(e) => {
+                                                warn!(
+                                                    "Python 插件 {:?} 的配置文件信息已经存在, 但获取失败:{:?}",
+                                                    path, e
+                                                );
+                                            }
+                                        }
+                                    }
+                                    match module.setattr(CONFIG_DATA_NAME, py_config) {
+                                        Ok(()) => Ok(PyPlugin {
+                                            file_path: path,
+                                            changed_time,
+                                            py_module: module.into_py(py),
+                                            enabled: true,
+                                        }),
+                                        Err(e) => {
+                                            warn!(
+                                                "Python 插件 {:?} 的配置文件信息设置失败:{:?}",
+                                                path, e
+                                            );
+                                            Err(PyErr::new::<pyo3::exceptions::PyTypeError, _>(
+                                                format!(
+                                                    "Python 插件 {:?} 的配置文件信息设置失败:{:?}",
+                                                    path, e
+                                                ),
+                                            ))
+                                        }
+                                    }
+                                }
+                                Err(e) => {
+                                    warn!(
+                                        "加载 Python 插件 {:?} 的配置文件信息时失败:{:?}",
+                                        path, e
+                                    );
+                                    Err(PyErr::new::<pyo3::exceptions::PyTypeError, _>(format!(
+                                        "加载 Python 插件 {:?} 的配置文件信息时失败:{:?}",
+                                        path, e
+                                    )))
+                                }
                             }
-                            Ok(PyPlugin::new(path, modify_time, module.clone().unbind()))
                         } else if config.is_none() {
                             // 没有配置文件
-                            Ok(PyPlugin::new(path, modify_time, module.clone().unbind()))
+                            Ok(PyPlugin {
+                                file_path: path,
+                                changed_time,
+                                py_module: module.into_py(py),
+                                enabled: true,
+                            })
                         } else {
                             warn!(
                                 "加载 Python 插件 {:?} 的配置文件信息时失败:返回的不是 [str, str]",
                                 path
                             );
-                            Err(PyTypeError::new_err("返回的不是 [str, str]".to_string()))
+                            Err(PyErr::new::<pyo3::exceptions::PyTypeError, _>(
+                                "返回的不是 [str, str]".to_string(),
+                            ))
                         }
                     }
                     Err(e) => {
@@ -404,14 +332,19 @@ impl TryFrom<RawPyPlugin> for PyPlugin {
                     }
                 }
             } else {
-                Ok(PyPlugin::new(path, modify_time, module.clone().unbind()))
+                Ok(PyPlugin {
+                    file_path: path,
+                    changed_time,
+                    py_module: module.into_py(py),
+                    enabled: true,
+                })
             }
         })
     }
 }
 
 /// 插件路径转换为 id
-pub fn plugin_path_as_id(path: &Path) -> String {
+pub fn plugin_path_as_id(path: &PathBuf) -> String {
     path.file_name()
         .unwrap_or_default()
         .to_str()
@@ -457,9 +390,9 @@ pub fn load_py_plugins(path: &PathBuf) {
 
 pub fn get_change_time(path: &Path) -> Option<SystemTime> { path.metadata().ok()?.modified().ok() }
 
-pub fn py_module_from_code(content: &str, path: &Path) -> PyResult<Py<PyModule>> {
-    Python::with_gil(|py| -> PyResult<Py<PyModule>> {
-        let module = PyModule::from_code(
+pub fn py_module_from_code(content: &str, path: &Path) -> PyResult<Py<PyAny>> {
+    Python::with_gil(|py| -> PyResult<Py<PyAny>> {
+        let module: PyResult<Py<PyAny>> = PyModule::from_code(
             py,
             CString::new(content).unwrap().as_c_str(),
             CString::new(path.to_string_lossy().as_bytes()).unwrap().as_c_str(),
@@ -467,8 +400,9 @@ pub fn py_module_from_code(content: &str, path: &Path) -> PyResult<Py<PyModule>>
                 .unwrap()
                 .as_c_str(),
             // !!!! 请注意, 一定要给他一个名字, cpython 会自动把后面的重名模块覆盖掉前面的
-        )?;
-        Ok(module.unbind())
+        )
+        .map(|module| module.into());
+        module
     })
 }
 
@@ -480,89 +414,16 @@ pub fn load_py_file(path: &PathBuf) -> std::io::Result<RawPyPlugin> {
     Ok((path.clone(), changed_time, content))
 }
 
-fn init_py_with_env_path(path: &str) {
-    unsafe {
-        #[cfg(target_os = "windows")]
-        use std::ffi::OsStr;
-        #[cfg(target_os = "windows")]
-        use std::os::windows::ffi::OsStrExt;
-
-        let mut config = std::mem::zeroed::<pyo3::ffi::PyConfig>();
-        let config_ptr = &mut config as *mut pyo3::ffi::PyConfig;
-        // 初始化配置
-        // pyo3::ffi::PyConfig_InitIsolatedConfig(config_ptr);
-        pyo3::ffi::PyConfig_InitPythonConfig(config_ptr);
-
-        #[cfg(target_os = "linux")]
-        let wide_path = path.as_bytes().iter().map(|i| *i as i32).collect::<Vec<i32>>();
-        #[cfg(target_os = "windows")]
-        let wide_path = OsStr::new(path).encode_wide().chain(Some(0)).collect::<Vec<u16>>();
-
-        // 设置 prefix 和 exec_prefix
-        pyo3::ffi::PyConfig_SetString(config_ptr, &mut config.prefix as *mut _, wide_path.as_ptr());
-        pyo3::ffi::PyConfig_SetString(
-            config_ptr,
-            &mut config.exec_prefix as *mut _,
-            wide_path.as_ptr(),
-        );
-
-        // 使用 Py_InitializeFromConfig 初始化 python
-        let status = pyo3::ffi::Py_InitializeFromConfig(&config as *const _);
-        pyo3::ffi::PyEval_SaveThread();
-        // 清理配置
-        pyo3::ffi::PyConfig_Clear(config_ptr);
-        match status._type {
-            pyo3::ffi::_PyStatus_TYPE::_PyStatus_TYPE_OK => {
-                event!(Level::INFO, "根据配置初始化 python 完成");
-            }
-            pyo3::ffi::_PyStatus_TYPE::_PyStatus_TYPE_EXIT => {
-                event!(Level::ERROR, "不对啊, 怎么刚刚初始化 Python 就 EXIT 了");
-            }
-            pyo3::ffi::_PyStatus_TYPE::_PyStatus_TYPE_ERROR => {
-                event!(Level::ERROR, "初始化 python 时发生错误: ERROR");
-                pyo3::ffi::Py_ExitStatusException(status);
-            }
-        }
-    }
-}
-
 /// Python 侧初始化
 pub fn init_py() {
     // 从 全局配置中获取 python 插件路径
-    let span = span!(Level::INFO, "py init");
+    let span = span!(Level::INFO, "初始化 python 及其插件.ing");
     let _enter = span.enter();
 
-    event!(Level::INFO, "开始初始化 python");
-
-    // 注册东西
-    class::regist_class();
-
     let plugin_path = MainStatus::global_config().py().plugin_path;
 
-    let cli_args = std::env::args().collect::<Vec<String>>();
-
-    if cli_args.contains(&"-env".to_string()) {
-        let env_path = cli_args.iter().find(|&arg| arg != "-env").expect("未找到 -env 参数的值");
-        event!(Level::INFO, "找到 -env 参数: {} 正在初始化", env_path);
-        // 判断一下是否有 VIRTUAL_ENV 环境变量
-        if let Ok(virtual_env) = std::env::var("VIRTUAL_ENV") {
-            event!(Level::WARN, "找到 VIRTUAL_ENV 环境变量: {} 将会被 -env 参数覆盖", virtual_env);
-        }
-        init_py_with_env_path(env_path);
-    } else {
-        // 根据 VIRTUAL_ENV 环境变量 进行一些处理
-        match std::env::var("VIRTUAL_ENV") {
-            Ok(virtual_env) => {
-                event!(Level::INFO, "找到 VIRTUAL_ENV 环境变量: {} 正在初始化", virtual_env);
-                init_py_with_env_path(&virtual_env);
-            }
-            Err(_) => {
-                event!(Level::INFO, "未找到 VIRTUAL_ENV 环境变量, 正常初始化");
-                pyo3::prepare_freethreaded_python();
-                event!(Level::INFO, "prepare_freethreaded_python 完成");
-            }
-        }
-    }
+    event!(Level::INFO, "正在初始化 python");
+    pyo3::prepare_freethreaded_python();
 
     PyStatus::init();
     let plugin_path = PathBuf::from(plugin_path);
@@ -572,30 +433,9 @@ pub fn init_py() {
     event!(Level::INFO, "python 初始化完成")
 }
 
-pub async fn post_py() -> anyhow::Result<()> {
+pub fn post_py() -> anyhow::Result<()> {
     let status = PyStatus::get_mut();
     status.config.sync_status_to_config();
     status.config.write_to_default()?;
-
-    stop_tasks().await?;
     Ok(())
 }
-
-async fn stop_tasks() -> Result<(), PyPluginError> {
-    if call::PY_TASKS.lock().await.is_empty() {
-        return Ok(());
-    }
-    let waiter = tokio::spawn(async {
-        call::PY_TASKS.lock().await.join_all().await;
-    });
-    tokio::select! {
-        _ = waiter => {
-            event!(Level::INFO, "Python 任务完成");
-            Ok(())
-        }
-        _ = tokio::signal::ctrl_c() => {
-            event!(Level::WARN, "正在强制结束 Python 任务");
-            Err(PyPluginError::PluginNotStopped)
-        }
-    }
-}

ica-rs/src/status.rs

@@ -1,5 +1,5 @@
-use crate::MAIN_STATUS;
 use crate::config::BotConfig;
+use crate::MAIN_STATUS;
 
 #[derive(Debug, Clone)]
 pub struct BotStatus {

ica-rs/src/tailchat.rs

@@ -9,13 +9,13 @@ use reqwest::ClientBuilder as reqwest_ClientBuilder;
 use rust_socketio::async_callback;
 use rust_socketio::asynchronous::{Client, ClientBuilder};
 use rust_socketio::{Event, Payload, TransportType};
-use serde_json::{Value, json};
-use tracing::{Level, event, span};
+use serde_json::{json, Value};
+use tracing::{event, span, Level};
 
 use crate::config::TailchatConfig;
 use crate::data_struct::tailchat::status::{BotStatus, LoginData};
 use crate::error::{ClientResult, TailchatError};
-use crate::{StopGetter, async_any_callback_with_state, async_callback_with_state, version_str};
+use crate::{async_any_callback_with_state, async_callback_with_state, version_str, StopGetter};
 
 pub async fn start_tailchat(
     config: TailchatConfig,

ica-rs/src/tailchat/client.rs

@@ -4,8 +4,8 @@ use crate::data_struct::tailchat::messages::SendingMessage;
 use colored::Colorize;
 use reqwest::multipart;
 use rust_socketio::asynchronous::Client;
-use serde_json::{Value, json};
-use tracing::{Level, event, span};
+use serde_json::{json, Value};
+use tracing::{event, span, Level};
 
 pub async fn send_message(client: &Client, message: &SendingMessage) -> bool {
     let span = span!(Level::INFO, "tailchat send message");

ica-rs/src/tailchat/events.rs

@@ -3,14 +3,14 @@ use std::sync::Arc;
 use colored::Colorize;
 use rust_socketio::asynchronous::Client;
 use rust_socketio::{Event, Payload};
-use tracing::{Level, event, info};
+use tracing::{event, info, Level};
 
 use crate::data_struct::tailchat::messages::ReceiveMessage;
 use crate::data_struct::tailchat::status::{BotStatus, UpdateDMConverse};
-use crate::py::PyStatus;
 use crate::py::call::tailchat_new_message_py;
+use crate::py::PyStatus;
 use crate::tailchat::client::{emit_join_room, send_message};
-use crate::{MainStatus, VERSION, client_id, help_msg, version_str};
+use crate::{client_id, help_msg, version_str, MainStatus, VERSION};
 
 /// 所有
 pub async fn any_event(event: Event, payload: Payload, _client: Client, _status: Arc<BotStatus>) {

ica-rs/src/wasms.rs

@@ -1 +0,0 @@
-

news.md

@@ -1,5 +1,342 @@
 # 更新日志
 
-## [0.9](./news/0-9.md)
+## 0.8.1
 
-## [0.2 ~ 0.8](./news/old.md)
+- 修复了 Python 插件状态写入的时候写入路径错误的问题
+- `ica-typing` 加入了 `from __future__ import annotations`
+  - 这样就可以随便用 typing 了
+  - 把 NewType 都扬了
+
+### ica 1.6.6
+
+- 修复了 `send_poke` api 的问题
+  - 现在可以正常使用了
+
+## 0.8.0
+
+- ica 兼容版本号更新到 ~~`2.12.24`~~ `2.12.26`
+- 从 `py::PyStatus` 开始进行一个 `static mut` -> `static mut OnceLock` 的改造
+  - 用于看着更舒服(逃)
+- 部分重构了一下 读取插件启用状态 的配置文件的代码
+- 现在 `/bot-help` 会直接输出实际的 client id, 而不是给你一个默认的 `<client-id>`
+
+### ica 1.6.5
+
+- 添加了 `send_room_sign_in` api
+  - 用于发送群签到信息
+  - socketio event: `sendGroupSign`
+- 添加了 `send_poke` api
+  - 用于发送戳一戳
+  - 可以指定群的某个人
+  - 或者指定好友
+  - 目前还是有点问题
+  - socketio event: `sendGroupPoke`
+- 添加了 `reload_plugin_status` api
+  - 用于重新加载插件状态
+- 添加了 `reload_plugin(plugin_name: str)` api
+  - 用于重新加载指定插件
+- 添加了 `set_plugin_status(plugin_name: str, status: bool)` api
+  - 用于设置插件的启用状态
+- 添加了 `get_plugin_status(plugin_name: str) -> bool` api
+  - 用于获取插件的启用状态
+- 添加了 `sync_status_to_config` api
+  - 用于将内存中的插件状态同步到配置文件中
+
+### tailchat 1.2.5
+
+- 添加了 `reload_plugin_status` api
+  - 用于重新加载插件状态
+- 添加了 `reload_plugin(plugin_name: str)` api
+  - 用于重新加载指定插件
+- 添加了 `set_plugin_status(plugin_name: str, status: bool)` api
+  - 用于设置插件的启用状态
+- 添加了 `get_plugin_status(plugin_name: str) -> bool` api
+  - 用于获取插件的启用状态
+- 添加了 `sync_status_to_config` api
+  - 用于将内存中的插件状态同步到配置文件中
+
+## 0.7.4
+
+- ica 兼容版本号更新到 `2.12.23`
+- 通过一个手动 json patch 修复了因为 icalingua 的奇怪类型问题导致的 bug
+- [icalingua issue](https://github.com/Icalingua-plus-plus/Icalingua-plus-plus/issues/793)
+
+## 0.7.3
+
+- 也许修复了删除插件不会立即生效的问题
+- ica 兼容版本号更新到 `2.12.21`
+添加了一些新的 api
+
+### ica 1.6.4
+
+- 给 `SendMessagePy`
+  - 添加了 `remove_reply` 方法
+  - 用于取消回复状态
+- 删除了 `Room` 的 `auto_download` 和 `download_path` 字段
+  - 因为这两个字段也没啥用
+
+### tailcaht 1.2.4
+
+- 给 `TailchatClientPy`
+  - 添加了 `new_message` 方法
+  - 用于创建新的消息
+- 给 `TailchatSendingMessagePy`
+  - 添加了 `clear_meta` 功能
+  - 用于清除 `meta` 字段
+  - 可以用来取消回复状态
+
+## 0.7.2
+
+- 修复了一些 ica 和 tailchat 表现不一致的问题(捂脸)
+
+## 0.7.1
+
+- 两个 api 版本号分别升级到 `1.6.3(ica)` 和 `1.2.3(tailchat)`
+- 加入了 `client_id`
+  - 用的 startup time hash 一遍取后六位
+  - 以及也有 python 侧的 `client_id` api
+- 修复了上个版本其实没有写 python 侧 `version_str` api 的问题
+
+## 0.7.0
+
+> 我决定叫他 0.7.0
+> 因为修改太多了.png
+
+- 加入了 禁用/启用 插件功能
+- 现在会在插件加载时警告你的插件原来定义了 `CONFIG_DATA` 这一项
+- `IcaNewMessage` 添加了新的 api
+  - `get_sender_name` 获取发送人昵称
+- `ica` 兼容版本号 `2.12.11` -> `2.12.12`
+- 加入了 `STABLE` 信息, 用于标记稳定版本
+- 不少配置文件项加上了默认值
+- 添加了 `version_str() -> String` 用于方便的获取版本信息
+  - 同样在 `py` 侧也有 `version_str` 方法
+- 加入了 `/help` 命令
+  - 用于获取帮助信息
+- 加入了 `/bot-ls`
+  - 用于展示所有插件的信息
+- 加入了 `/bot-enable` 和 `/bot-disable`
+  - 用于启用/禁用插件
+
+## 0.6.10
+
+- 加了点东西 (?)
+
+## 0.6.9
+
+我决定立即发布 0.6.9
+
+- 添加了 `Client.startup_time() -> datetime` 方法
+  - 用于获取 bot 启动时间
+  - 这样就可以经常吹我 bot 跑了多久了 ( ˘•ω•˘ )
+  - 顺手加上了 `/bot-uptime` 命令
+    - 可以获取 bot 运行时间
+    - 谢谢 GitHub Copilot 的帮助
+
+## 0.6.8
+
+- 修复了一堆拼写错误
+- 太难绷了
+  - `TailchatReciveMessagePy` -> `TailchatReceiveMessagePy`
+  - `ReciveMessage` -> `ReceiveMessage`
+- `ReceiveMessage::meta`
+  - 从 `JsonValue` 改成 `Option<JsonValue>`
+  - 用来解决发图片的时候没有 `meta` 字段的问题
+- 去除了自带的两个 macro
+  - `wrap_callback` 和 `wrap_any_callback`
+  - 因为现在他俩已经进到 `rust_socketio` 里啦
+- 添加了新的 macro
+- 支持了 `TailchatReceiveMessagePy` 的 `is_from_self` 方法
+  - 用于判断是否是自己发的消息
+
+## 0.6.7
+
+游学回来啦
+
+- 处理了一些 tailchat 的特殊情况
+  - 比如 message 里面的 `GroupId` 实际上是可选的, 在私聊中没有这一项
+  - 忽略了所有的 `__v` (用于数据库记录信息的, bot不需要管)
+    - 作者原话 `不用管。数据库记录版本`
+  - 修复了如果没法解析新的信息, 会 panic 的问题
+- `ica_typing.py`
+  - 补充了 `TailchatSendingMessage` 的 `group_id` 和 `converse_id` 字段
+  - 把 `group_id` 的设置和返回都改成了 `Optional[GroupId]`
+- tailchat 的 API 也差点意思就是了(逃)
+- 处理了 icalingua 的 `renewMessage` 事件 (其实就是直接忽略掉了)
+
+## 0.6.6
+
+游学之前最后一次更新
+其实也就五天
+
+正式支持了 tailchat 端
+好耶！
+
+[!note]
+
+```text
+notice_room = []
+notice_start = true
+
+admin_list = []
+filter_list = []
+```
+
+的功能暂时不支持
+
+## 0.6.5
+
+怎么就突然 0.6.5 了
+我也不造啊
+
+- 反正支持了 tailchat 的信息接受
+- 但是需要你在对面服务端打开 `DISABLE_MESSAGEPACK` 环境变量
+- 能用就行
+
+- 现在 `update_online_data` 不会再以 INFO 级别显示了
+- `update_all_room` 同上
+
+## 0.6.2
+
+- 添加 API
+  - `NewMessage.set_img` 用于设置消息的图片
+  - `IcaSendMessage.set_img` 用于设置消息的图片 (python)
+
+## 0.6.1
+
+还是没写完 tailchat 支持
+因为 rust_socketio 还是没写好 serdelizer 的支持
+
+- 正在添加发送图片的 api
+
+## 0.6.0-dev
+
+- 去除了 matrix 的支持
+  - 淦哦
+  - 去除了相应代码和依赖
+  - 去除了 Python 侧代码
+  - 向 tailchat (typescript 低头)
+
+- 修复了没法编译的问题（
+
+## 0.5.3
+
+修复了 Icalingua 断开时 如果 socketio 已经断开会导致程序 返回 Error 的问题
+以及还有一些别的修复就是了
+
+- Python 端修改
+  - `on_message` -> `on_ica_message`
+  - `on_delete_message` -> `on_ica_delete_message`
+  - 添加 `on_matrix_message`
+
+## 0.5.1/2
+
+重构了一整波, 还没改 `ica-typing.py` 的代码
+但至少能用了
+
+- Ica 版本号 `1.4.0`
+- Matrix 版本号 `0.1.0`
+
+## 0.5.0
+
+准备接入 `Matrix`
+
+去掉 `pyo3-async` 的依赖
+
+## 0.4.12
+
+把 0.4.11 的遗留问题修完了
+
+## 0.4.11
+
+这几天就是在刷版本号的感觉
+
+- 添加
+  - `DeleteMessage` 用于删除消息
+  - `NewMessage.as_delete` 用于将消息转换为删除消息
+  - `client::delete_message` 用于删除消息
+  - `client::fetch_history` 用于获取历史消息 TODO
+  - `py::class::DeleteMessagePy` 用于删除消息 的 Python 侧 API
+  - `py::class::IcaClientPy.delete_message` 用于删除消息 的 Python 侧 API
+  - `IcalinguaStatus.current_loaded_messages_count`
+    - 用于以后加载信息计数
+- 修改
+  - `py::class::IcaStatusPy`
+    - 大部分方法从手动 `unsafe` + `Option`
+    - 改成直接调用 `IcalinguaStatus` 的方法
+  - `IcalinguaStatus`
+    - 所有方法均改成 直接对着 `IcalinguaStatus` 的方法调用
+    - 补全没有的方法
+
+## 0.4.10
+
+好家伙, 我感觉都快能叫 0.5 了
+修改了一些内部数据结构, 使得插件更加稳定
+
+添加了 `rustfmt.toml` 用于格式化代码
+**注意**: 请在提交代码前使用 `cargo +nightly fmt` 格式化代码
+
+修复了 `Message` 解析 `replyMessage` 字段是 如果是 null 则会解析失败的问题
+
+## 0.4.9
+
+修复了 Python 插件运行错误会导致整个程序崩溃的问题
+
+## 0.4.8
+
+添加了 `filter_list` 用于过滤特定人的消息
+
+## 0.4.7
+
+修复了重载时如果代码有问题会直接 panic 的问题
+
+## 0.4.6
+
+现在更适合部署了
+
+## 0.4.5
+
+添加 `is_reply` api 到 `NewMessagePy`
+
+## 0.4.4
+
+现在正式支持 Python 插件了
+`/bmcl` 也迁移到了 Python 插件版本
+
+## 0.4.3
+
+噫! 好! 我成了!
+
+## 0.4.2
+
+现在是 async 版本啦!
+
+## 0.4.1
+
+现在能发送登录信息啦
+
+## 0.4.0
+
+使用 Rust 从头实现一遍
+\能登录啦/
+
+## 0.3.3
+
+适配 Rust 端的配置文件修改
+
+## 0.3.1/2
+
+改进 `/bmcl` 的细节
+
+## 0.3.0
+
+合并了 dongdigua 的代码, 把消息处理部分分离
+现在代码更阳间了（喜
+
+## 0.2.3
+
+添加了 `/bmcl` 请求 bmclapi 状态
+
+## 0.2.2
+
+重构了一波整体代码

news/0-9.md

@@ -1,38 +0,0 @@
-# 0.9 更新日志
-
-## 0.9.0
-
-- 修复了 Python 插件停不下来就真的停不下来的问题
-- 让初始化的时候 插件启/禁状态显示更明显了
-  - 有颜色啦!
-- 加了不少颜色
-
-### ica 2.0.1
-
-> 添加了 `Room` 相关的 api
-
-- `IcaStatus` 添加了 `rooms(self) -> list[IcaRoom]` 方法
-  - 用于获取当前所有的房间
-
-- 添加了 `IcaRoom` 类
-  - 用于表示一个房间
-  - `room_id -> int` 群号 (i64)
-
-  - `def is_group(self) -> bool` 是否为群聊
-  - `def is_chat(self) -> bool` 是否为私聊
-
-  - `room_name -> int` 群名 (String)
-  - `unread_count -> int` 未读消息数 (u64)
-  - `priority -> int` 优先级 (u8)
-  - `utime -> int` 最后活跃时间 (unix sec * 1000)
-
-  - `def new_message_to(self, content: str) -> IcaSendMessage`
-    - 用于创建一条指向这个房间的消息
-
-> 添加了 Ica 侧的相关配置获取
-
-- `IcaStatus` 添加了 `admins(self) -> list[UserId]` 方法
-  - 用于获取当前所有的管理员
-
-- `IcaStatus` 添加了 `blocked(self) -> list[UserId]` 方法
-  - 用于获取当前所有的被屏蔽的人

news/olds.md

@@ -1,383 +0,0 @@
-# 更新日志 (0.2 ~ 0.8)
-
-## 0.8.2
-
-- ica 兼容版本号更新到 `2.12.28`
-- 现在支持通过读取环境变量里的 `VIRTUAL_ENV` 来获取虚拟环境路径
-  - 用于在虚拟环境中运行插件
-- 添加了 `-h` 参数
-  - 用于展示帮助信息
-- 添加了 `-env` 参数
-  - 用于指定 python 插件的虚拟环境路径
-  - 会覆盖环境变量中的 `VIRTUAL_ENV`
-- 现在加入了默认的配置文件路径 `./config.toml`
-- 现在会记录所有的 python 运行中 task 了
-  - 也会在退出的时候等待所有的 task 结束
-  - 二次 ctrl-c 会立即退出
-- 改进了一下 ica 的新消息显示
-- 添加了 ica 链接用时的显示
-
-### ica&tailchat 2.0.0
-
-- BREAKING CHANGE
-  - 现在 `CONFIG_DATA` 为一个 `str | bytes`
-  - 用于存储插件的配置信息
-  - 需要自行解析
-  - 现在 `on_config` 函数签名为 `on_config = Callable[[bytes], None]`
-    - 用于接收配置信息
-  - 现在使用 `require_config = Callable[[None], str, bytes | str]` 函数来请求配置信息
-    - 用于请求配置信息
-    - `str` 为配置文件名
-    - `bytes | str` 为配置文件默认内容
-      - 以 `bytes` 形式或者 `str` 形式均可
-
-### ica 1.6.7
-
-- 为 `IcaClinet` 添加了 `py_tasks_count -> int` 属性
-  - 用于获取当前运行中的 python task 数量
-
-### tailchat 1.2.6
-
-- 为 `TailchatClient` 添加了 `py_tasks_count -> int` 属性
-  - 用于获取当前运行中的 python task 数量
-
-## 0.8.1
-
-- 修复了 Python 插件状态写入的时候写入路径错误的问题
-- `ica-typing` 加入了 `from __future__ import annotations`
-  - 这样就可以随便用 typing 了
-  - 把 NewType 都扬了
-
-### ica 1.6.6
-
-- 修复了 `send_poke` api 的问题
-  - 现在可以正常使用了
-
-## 0.8.0
-
-- ica 兼容版本号更新到 ~~`2.12.24`~~ `2.12.26`
-- 从 `py::PyStatus` 开始进行一个 `static mut` -> `static mut OnceLock` 的改造
-  - 用于看着更舒服(逃)
-- 部分重构了一下 读取插件启用状态 的配置文件的代码
-- 现在 `/bot-help` 会直接输出实际的 client id, 而不是给你一个默认的 `<client-id>`
-
-### ica 1.6.5
-
-- 添加了 `send_room_sign_in` api
-  - 用于发送群签到信息
-  - socketio event: `sendGroupSign`
-- 添加了 `send_poke` api
-  - 用于发送戳一戳
-  - 可以指定群的某个人
-  - 或者指定好友
-  - 目前还是有点问题
-  - socketio event: `sendGroupPoke`
-- 添加了 `reload_plugin_status` api
-  - 用于重新加载插件状态
-- 添加了 `reload_plugin(plugin_name: str)` api
-  - 用于重新加载指定插件
-- 添加了 `set_plugin_status(plugin_name: str, status: bool)` api
-  - 用于设置插件的启用状态
-- 添加了 `get_plugin_status(plugin_name: str) -> bool` api
-  - 用于获取插件的启用状态
-- 添加了 `sync_status_to_config` api
-  - 用于将内存中的插件状态同步到配置文件中
-
-### tailchat 1.2.5
-
-- 添加了 `reload_plugin_status` api
-  - 用于重新加载插件状态
-- 添加了 `reload_plugin(plugin_name: str)` api
-  - 用于重新加载指定插件
-- 添加了 `set_plugin_status(plugin_name: str, status: bool)` api
-  - 用于设置插件的启用状态
-- 添加了 `get_plugin_status(plugin_name: str) -> bool` api
-  - 用于获取插件的启用状态
-- 添加了 `sync_status_to_config` api
-  - 用于将内存中的插件状态同步到配置文件中
-
-## 0.7.4
-
-- ica 兼容版本号更新到 `2.12.23`
-- 通过一个手动 json patch 修复了因为 icalingua 的奇怪类型问题导致的 bug
-- [icalingua issue](https://github.com/Icalingua-plus-plus/Icalingua-plus-plus/issues/793)
-
-## 0.7.3
-
-- 也许修复了删除插件不会立即生效的问题
-- ica 兼容版本号更新到 `2.12.21`
-添加了一些新的 api
-
-### ica 1.6.4
-
-- 给 `SendMessagePy`
-  - 添加了 `remove_reply` 方法
-  - 用于取消回复状态
-- 删除了 `Room` 的 `auto_download` 和 `download_path` 字段
-  - 因为这两个字段也没啥用
-
-### tailcaht 1.2.4
-
-- 给 `TailchatClientPy`
-  - 添加了 `new_message` 方法
-  - 用于创建新的消息
-- 给 `TailchatSendingMessagePy`
-  - 添加了 `clear_meta` 功能
-  - 用于清除 `meta` 字段
-  - 可以用来取消回复状态
-
-## 0.7.2
-
-- 修复了一些 ica 和 tailchat 表现不一致的问题(捂脸)
-
-## 0.7.1
-
-- 两个 api 版本号分别升级到 `1.6.3(ica)` 和 `1.2.3(tailchat)`
-- 加入了 `client_id`
-  - 用的 startup time hash 一遍取后六位
-  - 以及也有 python 侧的 `client_id` api
-- 修复了上个版本其实没有写 python 侧 `version_str` api 的问题
-
-## 0.7.0
-
-> 我决定叫他 0.7.0
-> 因为修改太多了.png
-
-- 加入了 禁用/启用 插件功能
-- 现在会在插件加载时警告你的插件原来定义了 `CONFIG_DATA` 这一项
-- `IcaNewMessage` 添加了新的 api
-  - `get_sender_name` 获取发送人昵称
-- `ica` 兼容版本号 `2.12.11` -> `2.12.12`
-- 加入了 `STABLE` 信息, 用于标记稳定版本
-- 不少配置文件项加上了默认值
-- 添加了 `version_str() -> String` 用于方便的获取版本信息
-  - 同样在 `py` 侧也有 `version_str` 方法
-- 加入了 `/help` 命令
-  - 用于获取帮助信息
-- 加入了 `/bot-ls`
-  - 用于展示所有插件的信息
-- 加入了 `/bot-enable` 和 `/bot-disable`
-  - 用于启用/禁用插件
-
-## 0.6.10
-
-- 加了点东西 (?)
-
-## 0.6.9
-
-我决定立即发布 0.6.9
-
-- 添加了 `Client.startup_time() -> datetime` 方法
-  - 用于获取 bot 启动时间
-  - 这样就可以经常吹我 bot 跑了多久了 ( ˘•ω•˘ )
-  - 顺手加上了 `/bot-uptime` 命令
-    - 可以获取 bot 运行时间
-    - 谢谢 GitHub Copilot 的帮助
-
-## 0.6.8
-
-- 修复了一堆拼写错误
-- 太难绷了
-  - `TailchatReciveMessagePy` -> `TailchatReceiveMessagePy`
-  - `ReciveMessage` -> `ReceiveMessage`
-- `ReceiveMessage::meta`
-  - 从 `JsonValue` 改成 `Option<JsonValue>`
-  - 用来解决发图片的时候没有 `meta` 字段的问题
-- 去除了自带的两个 macro
-  - `wrap_callback` 和 `wrap_any_callback`
-  - 因为现在他俩已经进到 `rust_socketio` 里啦
-- 添加了新的 macro
-- 支持了 `TailchatReceiveMessagePy` 的 `is_from_self` 方法
-  - 用于判断是否是自己发的消息
-
-## 0.6.7
-
-游学回来啦
-
-- 处理了一些 tailchat 的特殊情况
-  - 比如 message 里面的 `GroupId` 实际上是可选的, 在私聊中没有这一项
-  - 忽略了所有的 `__v` (用于数据库记录信息的, bot不需要管)
-    - 作者原话 `不用管。数据库记录版本`
-  - 修复了如果没法解析新的信息, 会 panic 的问题
-- `ica_typing.py`
-  - 补充了 `TailchatSendingMessage` 的 `group_id` 和 `converse_id` 字段
-  - 把 `group_id` 的设置和返回都改成了 `Optional[GroupId]`
-- tailchat 的 API 也差点意思就是了(逃)
-- 处理了 icalingua 的 `renewMessage` 事件 (其实就是直接忽略掉了)
-
-## 0.6.6
-
-游学之前最后一次更新
-其实也就五天
-
-正式支持了 tailchat 端
-好耶！
-
-[!note]
-
-```text
-notice_room = []
-notice_start = true
-
-admin_list = []
-filter_list = []
-```
-
-的功能暂时不支持
-
-## 0.6.5
-
-怎么就突然 0.6.5 了
-我也不造啊
-
-- 反正支持了 tailchat 的信息接受
-- 但是需要你在对面服务端打开 `DISABLE_MESSAGEPACK` 环境变量
-- 能用就行
-
-- 现在 `update_online_data` 不会再以 INFO 级别显示了
-- `update_all_room` 同上
-
-## 0.6.2
-
-- 添加 API
-  - `NewMessage.set_img` 用于设置消息的图片
-  - `IcaSendMessage.set_img` 用于设置消息的图片 (python)
-
-## 0.6.1
-
-还是没写完 tailchat 支持
-因为 rust_socketio 还是没写好 serdelizer 的支持
-
-- 正在添加发送图片的 api
-
-## 0.6.0-dev
-
-- 去除了 matrix 的支持
-  - 淦哦
-  - 去除了相应代码和依赖
-  - 去除了 Python 侧代码
-  - 向 tailchat (typescript 低头)
-
-- 修复了没法编译的问题（
-
-## 0.5.3
-
-修复了 Icalingua 断开时 如果 socketio 已经断开会导致程序 返回 Error 的问题
-以及还有一些别的修复就是了
-
-- Python 端修改
-  - `on_message` -> `on_ica_message`
-  - `on_delete_message` -> `on_ica_delete_message`
-  - 添加 `on_matrix_message`
-
-## 0.5.1/2
-
-重构了一整波, 还没改 `ica-typing.py` 的代码
-但至少能用了
-
-- Ica 版本号 `1.4.0`
-- Matrix 版本号 `0.1.0`
-
-## 0.5.0
-
-准备接入 `Matrix`
-
-去掉 `pyo3-async` 的依赖
-
-## 0.4.12
-
-把 0.4.11 的遗留问题修完了
-
-## 0.4.11
-
-这几天就是在刷版本号的感觉
-
-- 添加
-  - `DeleteMessage` 用于删除消息
-  - `NewMessage.as_delete` 用于将消息转换为删除消息
-  - `client::delete_message` 用于删除消息
-  - `client::fetch_history` 用于获取历史消息 TODO
-  - `py::class::DeleteMessagePy` 用于删除消息 的 Python 侧 API
-  - `py::class::IcaClientPy.delete_message` 用于删除消息 的 Python 侧 API
-  - `IcalinguaStatus.current_loaded_messages_count`
-    - 用于以后加载信息计数
-- 修改
-  - `py::class::IcaStatusPy`
-    - 大部分方法从手动 `unsafe` + `Option`
-    - 改成直接调用 `IcalinguaStatus` 的方法
-  - `IcalinguaStatus`
-    - 所有方法均改成 直接对着 `IcalinguaStatus` 的方法调用
-    - 补全没有的方法
-
-## 0.4.10
-
-好家伙, 我感觉都快能叫 0.5 了
-修改了一些内部数据结构, 使得插件更加稳定
-
-添加了 `rustfmt.toml` 用于格式化代码
-**注意**: 请在提交代码前使用 `cargo +nightly fmt` 格式化代码
-
-修复了 `Message` 解析 `replyMessage` 字段是 如果是 null 则会解析失败的问题
-
-## 0.4.9
-
-修复了 Python 插件运行错误会导致整个程序崩溃的问题
-
-## 0.4.8
-
-添加了 `filter_list` 用于过滤特定人的消息
-
-## 0.4.7
-
-修复了重载时如果代码有问题会直接 panic 的问题
-
-## 0.4.6
-
-现在更适合部署了
-
-## 0.4.5
-
-添加 `is_reply` api 到 `NewMessagePy`
-
-## 0.4.4
-
-现在正式支持 Python 插件了
-`/bmcl` 也迁移到了 Python 插件版本
-
-## 0.4.3
-
-噫! 好! 我成了!
-
-## 0.4.2
-
-现在是 async 版本啦!
-
-## 0.4.1
-
-现在能发送登录信息啦
-
-## 0.4.0
-
-使用 Rust 从头实现一遍
-\能登录啦/
-
-## 0.3.3
-
-适配 Rust 端的配置文件修改
-
-## 0.3.1/2
-
-改进 `/bmcl` 的细节
-
-## 0.3.0
-
-合并了 dongdigua 的代码, 把消息处理部分分离
-现在代码更阳间了（喜
-
-## 0.2.3
-
-添加了 `/bmcl` 请求 bmclapi 状态
-
-## 0.2.2
-
-重构了一波整体代码

readme.md

@@ -1,8 +1,9 @@
 # icalingua bot
 
-这是一个基于 icalingua-bridge 的 bot
+这是一个基于 icalingua docker 版的 bot
 
-[插件市场(确信)](https://github.com/shenjackyuanjie/shenbot-plugins)
+> 出于某个企鹅, 和保护 作者 和 原项目 ( ica ) 的原因 \
+> 功能请自行理解
 
 ## 通用环境准备
 
@@ -14,14 +15,12 @@
 choco install python
 # 或者
 scoop install python
-# 又或者
-uv venv
 ```
 
 - 启动 icalingua 后端
 
 ```bash
-# 用你自己的方法启动你的 icalingua-bridge
+# 用你自己的方法启动你的 icalingua 后端
 # 例如
 docker start icalingua
 docker-compose up -d