use anyhow::Context;
use clap::Parser;
use pathfinder_common::config::PathfinderConfig;
use pathfinder_common::types::WorkspaceRoot;
use rmcp::ServiceExt;
use std::path::PathBuf;
use tracing_subscriber::EnvFilter;
mod server;
use server::PathfinderServer;
#[derive(Parser, Debug)]
#[command(name = "pathfinder", version, about)]
struct Cli {
#[arg(value_name = "WORKSPACE_PATH")]
workspace_path: PathBuf,
#[arg(long, default_value_t = false)]
lsp_trace: bool,
}
#[tokio::main]
async fn main() -> anyhow::Result<()> {
let cli = Cli::parse();
let mut filter = EnvFilter::try_from_default_env().unwrap_or_else(|_| EnvFilter::new("info"));
if cli.lsp_trace {
if let Ok(dir) = "pathfinder_lsp::client::transport=debug".parse() {
filter = filter.add_directive(dir);
}
}
tracing_subscriber::fmt()
.json()
.with_env_filter(filter)
.with_writer(std::io::stderr)
.with_target(false)
.init();
tracing::info!(
workspace = %cli.workspace_path.display(),
version = env!("CARGO_PKG_VERSION"),
"Pathfinder starting"
);
let workspace_root = WorkspaceRoot::new(&cli.workspace_path)
.with_context(|| format!("Invalid workspace path: {}", cli.workspace_path.display()))?;
let config = PathfinderConfig::load(workspace_root.path())
.await
.with_context(|| "Failed to load configuration")?;
let server = PathfinderServer::new(workspace_root, config).await;
tracing::info!("Starting MCP stdio transport");
let service = server
.serve(rmcp::transport::io::stdio())
.await
.context("Failed to start MCP server")?;
service.waiting().await?;
tracing::info!("Pathfinder shutting down");
Ok(())
}