diff --git a/libs/service/lib.rs b/libs/service/lib.rs index a803c52..8a108e9 100644 --- a/libs/service/lib.rs +++ b/libs/service/lib.rs @@ -1,8 +1,8 @@ use std::sync::Arc; use ::agent::chat::ChatService; -use ::agent::tool::ToolRegistry; use ::agent::task::service::TaskService; +use ::agent::tool::ToolRegistry; use async_openai::config::OpenAIConfig; use avatar::AppAvatar; use config::AppConfig; @@ -136,30 +136,30 @@ impl AppService { .unwrap_or_else(|| "redis://127.0.0.1:6379".to_string()); // Build ChatService if AI is configured; otherwise AI chat is disabled (graceful degradation) - let chat_service: Option> = match ( - config.ai_api_key(), - config.ai_basic_url(), - ) { - (Ok(api_key), Ok(base_url)) => { - slog::info!(logs, "AI chat enabled — connecting to {}", base_url); - let cfg = OpenAIConfig::new() - .with_api_key(&api_key) - .with_api_base(&base_url); - let client = async_openai::Client::with_config(cfg); - let mut registry = ToolRegistry::new(); - git_tools::register_all(&mut registry); - file_tools::register_all(&mut registry); - Some(Arc::new(ChatService::new(client).with_tool_registry(registry))) - } - (Err(e), _) => { - slog::warn!(logs, "AI chat disabled — {}", e); - None - } - (_, Err(e)) => { - slog::warn!(logs, "AI chat disabled — {}", e); - None - } - }; + let chat_service: Option> = + match (config.ai_api_key(), config.ai_basic_url()) { + (Ok(api_key), Ok(base_url)) => { + slog::info!(logs, "AI chat enabled — connecting to {}", base_url); + let cfg = OpenAIConfig::new() + .with_api_key(&api_key) + .with_api_base(&base_url); + let client = async_openai::Client::with_config(cfg); + let mut registry = ToolRegistry::new(); + git_tools::register_all(&mut registry); + file_tools::register_all(&mut registry); + Some(Arc::new( + ChatService::new(client).with_tool_registry(registry), + )) + } + (Err(e), _) => { + slog::warn!(logs, "AI chat disabled — {}", e); + None + } + (_, Err(e)) => { + slog::warn!(logs, "AI chat disabled — {}", e); + None + } + }; let room = RoomService::new( db.clone(), @@ -213,7 +213,8 @@ impl AppService { body: envelope.body, }; if let Err(e) = email.send(msg).await { - slog::error!(logs, "email send failed"; "to" => to, "error" => %e); + let err = format!("email send failed to:{} error: {}", to, e); + slog::error!(logs, "{}", err); } } Ok(()) @@ -228,9 +229,9 @@ impl AppService { pub mod agent; pub mod auth; pub mod error; +pub mod file_tools; pub mod git; pub mod git_tools; -pub mod file_tools; pub mod issue; pub mod project; pub mod pull_request;