Skip to content

Commit bb3eb4a

Browse files
committed
adds method to see if mcp config is disabled
1 parent 960a9e6 commit bb3eb4a

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
@@ -277,6 +277,13 @@ impl LoadedMcpServerConfig {
277277
source,
278278
}
279279
}
280+
281+
pub fn is_enabled(&self) -> bool {
282+
match &self.config {
283+
McpServerConfig::Local(local_mcp_server_config) => !local_mcp_server_config.disabled,
284+
McpServerConfig::Remote(remote_mcp_server_config) => !remote_mcp_server_config.disabled,
285+
}
286+
}
280287
}
281288

282289
#[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
@@ -1674,12 +1666,10 @@ impl Agent {
16741666
}
16751667

16761668
async fn handle_mcp_server_actor_events(&self, evt: McpServerActorEvent) {
1677-
tracing::info!(?evt, "received mcp actor event");
16781669
let converted_evt = AgentEvent::Mcp(evt);
16791670
if let Err(e) = self.agent_event_tx.send(converted_evt) {
16801671
error!(?e, "failed to emit agent event");
16811672
}
1682-
tracing::info!("event sent to agent loop");
16831673
}
16841674
}
16851675

0 commit comments

Comments
 (0)