diff options
Diffstat (limited to 'crates/phone-opus/src/mcp/host')
| -rw-r--r-- | crates/phone-opus/src/mcp/host/runtime.rs | 26 |
1 files changed, 1 insertions, 25 deletions
diff --git a/crates/phone-opus/src/mcp/host/runtime.rs b/crates/phone-opus/src/mcp/host/runtime.rs index df54844..9855191 100644 --- a/crates/phone-opus/src/mcp/host/runtime.rs +++ b/crates/phone-opus/src/mcp/host/runtime.rs @@ -25,9 +25,6 @@ use crate::mcp::protocol::{ FORCE_ROLLOUT_ENV, HOST_STATE_ENV, HostRequestId, HostStateSeed, PROTOCOL_VERSION, SERVER_NAME, WORKER_CRASH_ONCE_ENV, WorkerOperation, WorkerSpawnConfig, }; -use crate::mcp::service::{ - consult_job_tool_output, consult_jobs_tool_output, consult_wait_tool_output, -}; use crate::mcp::telemetry::ServerTelemetry; pub(crate) fn run_host() -> Result<(), Box<dyn std::error::Error>> { @@ -363,30 +360,9 @@ impl HostRuntime { fn handle_host_tool(&mut self, name: &str, arguments: Value) -> Result<Value, FaultRecord> { let operation = format!("tools/call:{name}"); let generation = self.worker.generation(); - let (presentation, arguments) = + let (presentation, _arguments) = split_presentation(arguments, &operation, generation, FaultStage::Host)?; match name { - "consult_job" => tool_success( - consult_job_tool_output(arguments, generation, FaultStage::Host, &operation)?, - presentation, - generation, - FaultStage::Host, - &operation, - ), - "consult_wait" => tool_success( - consult_wait_tool_output(arguments, generation, FaultStage::Host, &operation)?, - presentation, - generation, - FaultStage::Host, - &operation, - ), - "consult_jobs" => tool_success( - consult_jobs_tool_output(arguments, generation, FaultStage::Host, &operation)?, - presentation, - generation, - FaultStage::Host, - &operation, - ), "health_snapshot" => { let rollout = if self.binary.rollout_pending().map_err(|error| { FaultRecord::rollout(generation, &operation, error.to_string()) |