89c63891fa
Replace all instances of the legacy product names "Kon" and "Corbie" with "Magnotia" across user-facing copy, code identifiers, package names, bundle ids, file paths, and documentation. Preserves the unrelated "konsole" (KDE terminal) reference and the parent CORBEL company name. - Renames 10 Rust crates (kon-* → magnotia-*) and the tauri binary - Updates package.json, tauri.conf.json (productName + identifier) - Renames CSS classes (kon-rh-* → magnotia-rh-*) and animations - Renames brand and roadmap docs - Regenerates Cargo.lock and package-lock.json Verified: svelte-check passes; pure-rust crates compile under new names.
54 lines
2.2 KiB
Rust
54 lines
2.2 KiB
Rust
//! Stdio entry point for magnotia-mcp. Reads newline-delimited JSON-RPC messages
|
|
//! from stdin, dispatches via `magnotia_mcp::handle_message`, writes responses to
|
|
//! stdout. Logs land on stderr so they don't collide with the JSON-RPC stream.
|
|
|
|
use tokio::io::{AsyncBufReadExt, AsyncWriteExt, BufReader};
|
|
|
|
#[tokio::main(flavor = "current_thread")]
|
|
async fn main() -> anyhow::Result<()> {
|
|
let db_path = magnotia_storage::database_path();
|
|
eprintln!(
|
|
"[magnotia-mcp] opening Magnotia database at {} (read-only)",
|
|
db_path.display()
|
|
);
|
|
// Open read-only at the connection level so the MCP server cannot write
|
|
// to the user's database, regardless of which tools the dispatcher
|
|
// exposes. Migrations are deliberately skipped — this binary never owns
|
|
// the schema; the main app is the single migration writer.
|
|
let pool = magnotia_storage::init_readonly(&db_path).await?;
|
|
eprintln!("[magnotia-mcp] ready, waiting for JSON-RPC on stdin");
|
|
|
|
let mut lines = BufReader::new(tokio::io::stdin()).lines();
|
|
let mut stdout = tokio::io::stdout();
|
|
|
|
while let Some(line) = lines.next_line().await? {
|
|
let trimmed = line.trim();
|
|
if trimmed.is_empty() {
|
|
continue;
|
|
}
|
|
|
|
let response = match serde_json::from_str::<serde_json::Value>(trimmed) {
|
|
Ok(raw) => match magnotia_mcp::handle_message(&pool, raw).await {
|
|
Some(response) => response,
|
|
None => continue, // notification — no reply
|
|
},
|
|
Err(err) => {
|
|
// Per JSON-RPC 2.0 §5.1: a Parse Error responds with
|
|
// code -32700 and id null. Previously this branch
|
|
// logged and continued, dropping the response —
|
|
// clients saw silence instead of a structured error
|
|
// (2026-04-22 review MAJOR).
|
|
eprintln!("[magnotia-mcp] parse error: {err}");
|
|
magnotia_mcp::parse_error_response(&err.to_string())
|
|
}
|
|
};
|
|
|
|
let payload = serde_json::to_string(&response)?;
|
|
stdout.write_all(payload.as_bytes()).await?;
|
|
stdout.write_all(b"\n").await?;
|
|
stdout.flush().await?;
|
|
}
|
|
|
|
Ok(())
|
|
}
|