This commit is contained in:
shenjack 2024-08-02 21:34:28 +08:00
parent 4753df8ded
commit 4479002b8d
Signed by: shenjack
GPG Key ID: 7B1134A979775551
3 changed files with 13 additions and 5 deletions

View File

@ -76,8 +76,9 @@ impl BotConfig {
pub fn new_from_path(config_file_path: String) -> Self { pub fn new_from_path(config_file_path: String) -> Self {
// try read config from file // try read config from file
let config = fs::read_to_string(&config_file_path).expect("Failed to read config file"); let config = fs::read_to_string(&config_file_path).expect("Failed to read config file");
let ret: Self = from_str(&config) let ret: Self = from_str(&config).unwrap_or_else(|e| {
.unwrap_or_else(|_| panic!("Failed to parse config file {}", &config_file_path)); panic!("Failed to parse config file {}\ne:{:?}", &config_file_path, e)
});
ret ret
} }
pub fn new_from_cli() -> Self { pub fn new_from_cli() -> Self {

View File

@ -52,6 +52,7 @@ pub async fn start_ica(config: &IcaConfig, stop_reciver: StopGetter) -> ClientRe
*room, *room,
None, None,
); );
// 这可是 qq, 要保命
tokio::time::sleep(std::time::Duration::from_secs(1)).await; tokio::time::sleep(std::time::Duration::from_secs(1)).await;
event!(Level::INFO, "发送启动消息到房间: {}", room); event!(Level::INFO, "发送启动消息到房间: {}", room);

View File

@ -96,13 +96,19 @@ pub async fn start_tailchat(
event!(Level::INFO, "{}", "tailchat 已经加入房间".green()); event!(Level::INFO, "{}", "tailchat 已经加入房间".green());
if config.notice_start { if config.notice_start {
for (group, room) in config.notice_room { event!(Level::INFO, "正在发送启动消息");
for (group, con) in config.notice_room {
event!(Level::INFO, "发送启动消息到: {}|{}", con, group);
let startup_msg = let startup_msg =
crate::data_struct::tailchat::messages::SendingMessage::new_without_meta( crate::data_struct::tailchat::messages::SendingMessage::new_without_meta(
"ica-rs 启动成功".to_string(), "ica-rs 启动成功".to_string(),
group.clone(), con.clone(),
Some(room.clone()), Some(group.clone()),
); );
// 反正是 tailchat, 不需要等, 直接发
if let Err(e) = socket.emit("chat.message.sendMessage", startup_msg.as_value()).await {
event!(Level::ERROR, "发送启动消息失败: {}", e);
}
} }
} }