Skip to content

Commit f8afffe

Browse files
committed
adds method to see if mcp config is disabled
1 parent dc1079e commit f8afffe

File tree

2 files changed

+8
-11
lines changed

2 files changed

+8
-11
lines changed

crates/agent/src/agent/agent_config/mod.rs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -275,6 +275,13 @@ impl LoadedMcpServerConfig {
275275
source,
276276
}
277277
}
278+
279+
pub fn is_enabled(&self) -> bool {
280+
match &self.config {
281+
McpServerConfig::Local(local_mcp_server_config) => !local_mcp_server_config.disabled,
282+
McpServerConfig::Remote(remote_mcp_server_config) => !remote_mcp_server_config.disabled,
283+
}
284+
}
278285
}
279286

280287
#[derive(Debug, Clone)]

crates/agent/src/agent/mod.rs

Lines changed: 1 addition & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -350,15 +350,7 @@ impl Agent {
350350
.cached_mcp_configs
351351
.configs
352352
.iter()
353-
.filter(|config| match &config.config {
354-
agent_config::definitions::McpServerConfig::Local(local_mcp_server_config) => {
355-
!local_mcp_server_config.disabled
356-
},
357-
agent_config::definitions::McpServerConfig::Remote(remote_mcp_server_config) => {
358-
!remote_mcp_server_config.disabled
359-
},
360-
})
361-
.collect::<Vec<_>>()
353+
.filter(|config| config.is_enabled())
362354
{
363355
if let Err(e) = self
364356
.mcp_manager_handle
@@ -1670,12 +1662,10 @@ impl Agent {
16701662
}
16711663

16721664
async fn handle_mcp_server_actor_events(&self, evt: McpServerActorEvent) {
1673-
tracing::info!(?evt, "received mcp actor event");
16741665
let converted_evt = AgentEvent::Mcp(evt);
16751666
if let Err(e) = self.agent_event_tx.send(converted_evt) {
16761667
error!(?e, "failed to emit agent event");
16771668
}
1678-
tracing::info!("event sent to agent loop");
16791669
}
16801670
}
16811671

0 commit comments

Comments
 (0)