shenjack/socket-bot
1
0
Fork 0
mirror of http://shenjack.top:5100/shenjack/icalingua-python-bot.git synced 2025-04-19 14:39:54 +08:00
Code Issues Packages Projects Releases Wiki Activity

就喜欢花哨的

Browse Source
This commit is contained in:
shenjack-5600u 2025-04-08 00:18:19 +08:00
parent 1711270c9f
commit 3435b8c0fb
Signed by: shenjack
GPG Key ID: FDF9864E11C7E79F
3 changed files with 11 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
ica-rs/src/ica.rs
View File

@ -101,12 +101,12 @@ pub async fn start_ica(config: &IcaConfig, stop_reciver: StopGetter) -> ClientRe
} }
} }
// 等待停止信号 // 等待停止信号
event!(Level::INFO, "ica client waiting for stop signal"); event!(Level::INFO, "{}", "ica client waiting for stop signal".purple());
stop_reciver.await.ok(); stop_reciver.await.ok();
event!(Level::INFO, "socketio client stopping"); event!(Level::INFO, "{}", "socketio client stopping".yellow());
match socket.disconnect().await { match socket.disconnect().await {
Ok(_) => { Ok(_) => {
event!(Level::INFO, "socketio client stopped"); event!(Level::INFO, "{}", "socketio client stopped".green());
Ok(()) Ok(())
} }
Err(e) => { Err(e) => {
@ -114,7 +114,7 @@ pub async fn start_ica(config: &IcaConfig, stop_reciver: StopGetter) -> ClientRe
match e { match e {
rust_socketio::Error::IncompleteResponseFromEngineIo(inner_e) => { rust_socketio::Error::IncompleteResponseFromEngineIo(inner_e) => {
if inner_e.to_string().contains("AlreadyClosed") { if inner_e.to_string().contains("AlreadyClosed") {
event!(Level::INFO, "socketio client stopped"); event!(Level::INFO, "{}", "socketio client stopped".green());
Ok(()) Ok(())
} else { } else {
event!(Level::ERROR, "socketio 客户端出现了 Error: {:?}", inner_e); event!(Level::ERROR, "socketio 客户端出现了 Error: {:?}", inner_e);

11
ica-rs/src/main.rs
View File

@ -16,6 +16,7 @@ mod ica;
#[cfg(feature = "tailchat")] #[cfg(feature = "tailchat")]
mod tailchat; mod tailchat;
use colored::Colorize;
use config::BotConfig; use config::BotConfig;
use error::PyPluginError; use error::PyPluginError;
use tracing::{event, span, Level}; use tracing::{event, span, Level};
@ -167,7 +168,7 @@ fn main() -> anyhow::Result<()> {
} }
async fn inner_main() -> anyhow::Result<()> { async fn inner_main() -> anyhow::Result<()> {
let span = span!(Level::INFO, "Shenbot Main"); let span = span!(Level::INFO, "bot-main");
let _enter = span.enter(); let _enter = span.enter();
event!(Level::INFO, "shenbot-rs v{} starting", VERSION); event!(Level::INFO, "shenbot-rs v{} starting", VERSION);
@ -184,28 +185,28 @@ async fn inner_main() -> anyhow::Result<()> {
} }
// 准备一个用于停止 socket 的变量 // 准备一个用于停止 socket 的变量
event!(Level::INFO, "启动 ICA");
let (ica_send, ica_recv) = tokio::sync::oneshot::channel::<()>(); let (ica_send, ica_recv) = tokio::sync::oneshot::channel::<()>();
if bot_config.check_ica() { if bot_config.check_ica() {
event!(Level::INFO, "{}", "开始启动 ICA".green());
let config = bot_config.ica(); let config = bot_config.ica();
tokio::spawn(async move { tokio::spawn(async move {
ica::start_ica(&config, ica_recv).await.unwrap(); ica::start_ica(&config, ica_recv).await.unwrap();
}); });
} else { } else {
event!(Level::INFO, "未启用 ica"); event!(Level::INFO, "{}", "ica 未启用, 不管他".cyan());
} }
let (tailchat_send, tailchat_recv) = tokio::sync::oneshot::channel::<()>(); let (tailchat_send, tailchat_recv) = tokio::sync::oneshot::channel::<()>();
if bot_config.check_tailchat() { if bot_config.check_tailchat() {
event!(Level::INFO, "启动 Tailchat"); event!(Level::INFO, "{}", "开始启动 tailchat".green());
let config = bot_config.tailchat(); let config = bot_config.tailchat();
tokio::spawn(async move { tokio::spawn(async move {
tailchat::start_tailchat(config, tailchat_recv).await.unwrap(); tailchat::start_tailchat(config, tailchat_recv).await.unwrap();
}); });
} else { } else {
event!(Level::INFO, "未启用 Tailchat"); event!(Level::INFO, "{}", "tailchat 未启用, 不管他".bright_magenta());
} }
tokio::time::sleep(Duration::from_secs(1)).await; tokio::time::sleep(Duration::from_secs(1)).await;

1
news/0-9.md
View File

@ -5,6 +5,7 @@
- 修复了 Python 插件停不下来就真的停不下来的问题 - 修复了 Python 插件停不下来就真的停不下来的问题
- 让初始化的时候 插件启/禁状态显示更明显了 - 让初始化的时候 插件启/禁状态显示更明显了
- 有颜色啦! - 有颜色啦!
- 加了不少颜色
### ica 2.0.1 ### ica 2.0.1