1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
|
use std::path::PathBuf;
use libmcp::{Generation, HostSessionKernelSnapshot};
use serde::{Deserialize, Serialize};
use serde_json::Value;
use crate::mcp::telemetry::ServerTelemetry;
pub(crate) const PROTOCOL_VERSION: &str = "2025-11-25";
pub(crate) const SERVER_NAME: &str = "phone_opus";
pub(crate) const HOST_STATE_ENV: &str = "PHONE_OPUS_MCP_HOST_STATE";
pub(crate) const FORCE_ROLLOUT_ENV: &str = "PHONE_OPUS_MCP_TEST_FORCE_ROLLOUT_KEY";
pub(crate) const WORKER_CRASH_ONCE_ENV: &str = "PHONE_OPUS_MCP_TEST_WORKER_CRASH_ONCE_KEY";
pub(crate) const CLAUDE_BIN_ENV: &str = "PHONE_OPUS_CLAUDE_BIN";
pub(crate) const CLAUDE_CONSULT_PREFIX: &str = r"You are being invoked in a read-only consultation mode by another model. You cannot edit files or make changes; your role is to inspect, reason, and advise.
Take your time. Think deeply, check assumptions, and prefer a careful, high-signal analysis over a fast, shallow response.
Your job is to produce a report for the calling model, not for an end user. Make it actionable. Itemize your findings and prioritize them by importance and urgency. Focus on concrete issues, risks, design flaws, behavioral regressions, missing validations, and better alternatives when relevant.
When useful, distinguish clearly between:
- confirmed findings
- plausible risks or hypotheses
- open questions that would change the recommendation
Prefer specific recommendations over vague commentary. If there are no meaningful problems, say so plainly.
The real prompt follows.";
pub(crate) const CLAUDE_EFFORT: &str = "max";
pub(crate) const CLAUDE_MODEL: &str = "claude-opus-4-6";
pub(crate) const CLAUDE_TOOLSET: &str = "Bash,Read,Grep,Glob,LS,WebFetch,WebSearch";
pub(crate) const EMPTY_MCP_CONFIG: &str = "{\"mcpServers\":{}}";
#[derive(Clone, Debug, Deserialize, Serialize)]
pub(crate) struct HostStateSeed {
pub(crate) session_kernel: HostSessionKernelSnapshot,
pub(crate) telemetry: ServerTelemetry,
pub(crate) next_request_id: u64,
pub(crate) worker_generation: Generation,
pub(crate) worker_spawned: bool,
pub(crate) force_rollout_consumed: bool,
pub(crate) worker_crash_once_consumed: bool,
}
#[derive(Clone, Copy, Debug, Deserialize, Eq, Ord, PartialEq, PartialOrd, Serialize)]
#[serde(transparent)]
pub(crate) struct HostRequestId(pub(crate) u64);
#[derive(Clone, Debug, Deserialize, Eq, PartialEq, Serialize)]
#[serde(tag = "kind", rename_all = "snake_case")]
pub(crate) enum WorkerRequest {
Execute {
id: HostRequestId,
operation: WorkerOperation,
},
}
#[derive(Clone, Debug, Deserialize, Eq, PartialEq, Serialize)]
#[serde(tag = "kind", rename_all = "snake_case")]
pub(crate) enum WorkerOperation {
CallTool { name: String, arguments: Value },
}
#[derive(Clone, Debug, Deserialize, Eq, PartialEq, Serialize)]
pub(crate) struct WorkerResponse {
pub(crate) id: HostRequestId,
pub(crate) outcome: WorkerOutcome,
}
#[derive(Clone, Debug, Deserialize, Eq, PartialEq, Serialize)]
#[serde(tag = "status", rename_all = "snake_case")]
pub(crate) enum WorkerOutcome {
Success {
result: Value,
},
Fault {
fault: crate::mcp::fault::FaultRecord,
},
}
#[derive(Clone, Debug, Deserialize, Eq, PartialEq, Serialize)]
pub(crate) struct BinaryFingerprint {
pub(crate) length_bytes: u64,
pub(crate) modified_unix_nanos: u128,
}
#[derive(Clone, Debug)]
pub(crate) struct WorkerSpawnConfig {
pub(crate) executable: PathBuf,
}
|