GameCult/Epiphany
Archived
Watch
9
0
Fork
You've already forked Epiphany
 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Delete static tool runtime smoke command

Browse source
This commit is contained in:
Meta Vens 2026-08-23 17:03:38 +02:00
commit 777dd1a507
1 changed files with 22 additions and 61 deletions
Download patch file Download diff file Expand all files Collapse all files

83
epiphany-tool-mcp-runtime/src/main.rs
View file

@ -15,17 +15,11 @@ use std::time::{SystemTime, UNIX_EPOCH};
#[tokio::main]
async fn main() -> Result<()> {
match Cli::parse(std::env::args().skip(1).collect())? {
Cli::Run(options) => println!("{}", serde_json::to_string_pretty(&run(options).await?)?),
Cli::Smoke => println!("{}", serde_json::to_string_pretty(&smoke())?),
}
let options = parse_cli(std::env::args().skip(1).collect())?;
println!("{}", serde_json::to_string_pretty(&run(options).await?)?);
Ok(())
}
enum Cli {
Run(RunOptions),
Smoke,
}
struct RunOptions {
store: PathBuf,
intent_id: String,
@ -34,29 +28,23 @@ struct RunOptions {
resident_store: Option<PathBuf>,
}
impl Cli {
fn parse(args: Vec<String>) -> Result<Self> {
let (command, rest) = args.split_first().ok_or_else(|| anyhow!(usage()))?;
match command.as_str() {
"smoke" if rest.is_empty() => Ok(Self::Smoke),
"smoke" => Err(anyhow!("smoke accepts no arguments")),
"run" => {
let flags = flags(rest)?;
reject_unknown(
&flags,
&["store", "intent-id", "mcp-config", "cwd", "resident-store"],
)?;
Ok(Self::Run(RunOptions {
store: PathBuf::from(required(&flags, "store")?),
intent_id: required(&flags, "intent-id")?.to_string(),
mcp_config: flags.get("mcp-config").map(PathBuf::from),
cwd: flags.get("cwd").map(PathBuf::from),
resident_store: flags.get("resident-store").map(PathBuf::from),
}))
}
_ => Err(anyhow!(usage())),
}
fn parse_cli(args: Vec<String>) -> Result<RunOptions> {
let (command, rest) = args.split_first().ok_or_else(|| anyhow!(usage()))?;
if command != "run" {
return Err(anyhow!(usage()));
}
let flags = flags(rest)?;
reject_unknown(
&flags,
&["store", "intent-id", "mcp-config", "cwd", "resident-store"],
)?;
Ok(RunOptions {
store: PathBuf::from(required(&flags, "store")?),
intent_id: required(&flags, "intent-id")?.to_string(),
mcp_config: flags.get("mcp-config").map(PathBuf::from),
cwd: flags.get("cwd").map(PathBuf::from),
resident_store: flags.get("resident-store").map(PathBuf::from),
})
}
async fn run(options: RunOptions) -> Result<RunSummary> {
@ -205,7 +193,7 @@ fn reject_unknown(flags: &BTreeMap<String, String>, allowed: &[&str]) -> Result<
}
}
fn usage() -> &'static str {
"usage: epiphany-tool-mcp-runtime run --store PATH --intent-id ID [--mcp-config PATH] [--cwd PATH] [--resident-store PATH] | smoke"
"usage: epiphany-tool-mcp-runtime run --store PATH --intent-id ID [--mcp-config PATH] [--cwd PATH] [--resident-store PATH]"
}
#[derive(Serialize)]
@ -218,22 +206,6 @@ struct RunSummary {
status: String,
schemas: BTreeMap<String, String>,
}
#[derive(Serialize)]
#[serde(rename_all = "camelCase")]
struct SmokeSummary {
adapter: String,
status: String,
native_namespace: String,
schemas: BTreeMap<String, String>,
}
fn smoke() -> SmokeSummary {
SmokeSummary {
adapter: EPIPHANY_TOOL_RUNTIME_ADAPTER_ID.into(),
status: "ok".into(),
native_namespace: "epiphany_source".into(),
schemas: schemas(),
}
}
fn schemas() -> BTreeMap<String, String> {
BTreeMap::from([
(
@ -267,7 +239,7 @@ mod tests {
#[test]
fn parses_production_cli_without_legacy_codex_flags() -> Result<()> {
let Cli::Run(options) = Cli::parse(vec![
let options = parse_cli(vec![
"run".into(),
"--store".into(),
"body.cc".into(),
@ -275,13 +247,10 @@ mod tests {
"i".into(),
"--mcp-config".into(),
"mcp.toml".into(),
])?
else {
panic!()
};
])?;
assert_eq!(options.intent_id, "i");
assert!(
Cli::parse(vec![
parse_cli(vec![
"run".into(),
"--store".into(),
"x".into(),
@ -295,14 +264,6 @@ mod tests {
Ok(())
}
#[test]
fn smoke_names_first_party_runtime() {
let value = serde_json::to_value(smoke()).unwrap();
assert_eq!(value["adapter"], EPIPHANY_TOOL_RUNTIME_ADAPTER_ID);
assert_eq!(value["nativeNamespace"], "epiphany_source");
assert!(!value.to_string().to_lowercase().contains("codex"));
}
#[tokio::test]
async fn native_source_run_persists_one_typed_receipt_without_mcp_config() -> Result<()> {
let temp = tempfile::tempdir()?;