(
&self,
database: &Database,
conversation_id: String,
server_name: String,
init_failure_reason: Option<String>,
number_of_tools: usize,
all_too
| 392 | |
| 393 | #[allow(clippy::too_many_arguments)] |
| 394 | pub async fn send_mcp_server_init( |
| 395 | &self, |
| 396 | database: &Database, |
| 397 | conversation_id: String, |
| 398 | server_name: String, |
| 399 | init_failure_reason: Option<String>, |
| 400 | number_of_tools: usize, |
| 401 | all_tool_names: Option<String>, |
| 402 | loaded_tool_names: Option<String>, |
| 403 | all_tools_count: usize, |
| 404 | ) -> Result<(), TelemetryError> { |
| 405 | let mut telemetry_event = Event::new(crate::telemetry::EventType::McpServerInit { |
| 406 | conversation_id, |
| 407 | server_name, |
| 408 | init_failure_reason, |
| 409 | number_of_tools, |
| 410 | all_tool_names, |
| 411 | loaded_tool_names, |
| 412 | all_tools_count, |
| 413 | }); |
| 414 | set_event_metadata(database, &mut telemetry_event).await; |
| 415 | |
| 416 | Ok(self.tx.send(telemetry_event)?) |
| 417 | } |
| 418 | |
| 419 | pub async fn send_agent_config_init( |
| 420 | &self, |
no test coverage detected