use anyhow::{Context, Result};
pub async fn run() -> Result<()> {
let store = perspt_store::SessionStore::new().context("Failed to open session store")?;
println!("📊 SRBN Agent Status");
println!("{}", "═".repeat(70));
let sessions = store.list_recent_sessions(1)?;
if sessions.is_empty() {
println!("No agent sessions found.");
println!();
println!("Start a new session with:");
println!(" perspt agent \"<task description>\"");
return Ok(());
}
let session = &sessions[0];
println!(
"📁 Session: {}",
&session.session_id[..16.min(session.session_id.len())]
);
let status_display = match session.status.as_str() {
"COMPLETED" => "✅ Completed",
"RUNNING" => "🔄 Running",
"PAUSED" => "⏸️ Paused",
"FAILED" => "❌ Failed",
"active" => "🔄 Active",
_ => &session.status,
};
println!("📌 Status: {}", status_display);
println!("📂 Directory: {}", session.working_dir);
println!("📝 Task: {}", session.task);
if let Some(toolchain) = &session.detected_toolchain {
println!("🔧 Toolchain: {}", toolchain);
}
let node_states = store.get_node_states(&session.session_id)?;
let latest_states = store
.get_latest_node_states(&session.session_id)
.unwrap_or_default();
let display_states = if latest_states.is_empty() {
&node_states
} else {
&latest_states
};
if !display_states.is_empty() {
let completed = display_states
.iter()
.filter(|n| n.state == "Completed" || n.state == "COMPLETED" || n.state == "STABLE")
.count();
let running = display_states
.iter()
.filter(|n| {
n.state == "RUNNING"
|| n.state == "Coding"
|| n.state == "Verifying"
|| n.state == "Planning"
})
.count();
let failed = display_states
.iter()
.filter(|n| n.state == "FAILED" || n.state == "Failed")
.count();
let queued = display_states
.iter()
.filter(|n| n.state == "Queued" || n.state == "QUEUED" || n.state == "TaskQueued")
.count();
let retrying = display_states
.iter()
.filter(|n| n.state == "Retrying" || n.state == "RETRYING" || n.state == "Retry")
.count();
let escalated = display_states
.iter()
.filter(|n| n.state == "Escalated" || n.state == "ESCALATED")
.count();
println!();
println!("📊 Node Lifecycle:");
println!(" Total: {}", display_states.len());
println!(" ✅ Completed: {}", completed);
if queued > 0 {
println!(" ◇ Queued: {}", queued);
}
if running > 0 {
println!(" 🔄 Running: {}", running);
}
if retrying > 0 {
println!(" ↻ Retrying: {}", retrying);
}
if failed > 0 {
println!(" ❌ Failed: {}", failed);
}
if escalated > 0 {
println!(" ⚠️ Escalated: {}", escalated);
}
let interface_count = display_states
.iter()
.filter(|n| n.node_class.as_deref() == Some("Interface"))
.count();
let impl_count = display_states
.iter()
.filter(|n| n.node_class.as_deref() == Some("Implementation"))
.count();
let integ_count = display_states
.iter()
.filter(|n| n.node_class.as_deref() == Some("Integration"))
.count();
if interface_count > 0 || impl_count > 0 || integ_count > 0 {
println!();
println!("🏗️ Node Classes:");
if interface_count > 0 {
println!(" 🔌 Interface: {}", interface_count);
}
if impl_count > 0 {
println!(" ⚙️ Implementation: {}", impl_count);
}
if integ_count > 0 {
println!(" 🔗 Integration: {}", integ_count);
}
}
if let Some(latest) = display_states.last() {
println!(" ⚡ Energy: V(x) = {:.3}", latest.v_total);
if let Ok(energy_history) =
store.get_energy_history(&session.session_id, &latest.node_id)
{
if let Some(last_energy) = energy_history.last() {
println!(
" Components: syn={:.2} str={:.2} log={:.2} boot={:.2} sheaf={:.2}",
last_energy.v_syn,
last_energy.v_str,
last_energy.v_log,
last_energy.v_boot,
last_energy.v_sheaf
);
}
}
let total_retries: i32 = display_states.iter().map(|n| n.attempt_count.max(0)).sum();
if total_retries > 0 {
println!(" ↻ Retries: {} total across all nodes", total_retries);
}
}
let mut ver_ok = 0;
let mut ver_degraded = 0;
for ns in display_states {
if let Ok(Some(vr)) = store.get_verification_result(&session.session_id, &ns.node_id) {
if vr.degraded {
ver_degraded += 1;
} else {
ver_ok += 1;
}
}
}
if ver_ok > 0 || ver_degraded > 0 {
println!();
println!("🔍 Verification:");
println!(" ✅ Passed: {}", ver_ok);
if ver_degraded > 0 {
println!(" ⚠️ Degraded: {}", ver_degraded);
}
}
}
let escalations = store.get_escalation_reports(&session.session_id)?;
if !escalations.is_empty() {
println!();
println!("⚠️ Escalations ({}):", escalations.len());
for esc in escalations.iter().take(3) {
println!(" {} → {} ({})", esc.node_id, esc.category, esc.action);
}
if escalations.len() > 3 {
println!(" ... and {} more", escalations.len() - 3);
}
}
let llm_requests = store.get_llm_requests(&session.session_id)?;
if !llm_requests.is_empty() {
let total_tokens: i32 = llm_requests
.iter()
.map(|r| r.tokens_in + r.tokens_out)
.sum();
println!();
println!("🤖 LLM Usage:");
println!(" Requests: {}", llm_requests.len());
println!(" Tokens: {}", total_tokens);
}
let branches = store.get_provisional_branches(&session.session_id)?;
if !branches.is_empty() {
let active = branches.iter().filter(|b| b.state == "active").count();
let sealed = branches.iter().filter(|b| b.state == "sealed").count();
let merged = branches.iter().filter(|b| b.state == "merged").count();
let flushed = branches.iter().filter(|b| b.state == "flushed").count();
println!();
println!("🌿 Provisional Branches:");
println!(" Total: {}", branches.len());
if active > 0 {
println!(" 🔄 Active: {}", active);
}
if sealed > 0 {
println!(" 🔒 Sealed: {}", sealed);
}
if merged > 0 {
println!(" ✅ Merged: {}", merged);
}
if flushed > 0 {
println!(" ❌ Flushed: {}", flushed);
}
}
let flushes = store.get_branch_flushes(&session.session_id)?;
if !flushes.is_empty() {
println!();
println!("🗑️ Recent Flush Decisions:");
for flush in flushes.iter().take(3) {
println!(
" Parent: {} Reason: {}",
flush.parent_node_id, flush.reason
);
}
}
let reviews = store.get_all_review_outcomes(&session.session_id)?;
if !reviews.is_empty() {
let approved = reviews
.iter()
.filter(|r| r.outcome.starts_with("approved") || r.outcome == "auto_approved")
.count();
let rejected = reviews
.iter()
.filter(|r| r.outcome == "rejected" || r.outcome == "aborted")
.count();
let corrected = reviews
.iter()
.filter(|r| r.outcome == "correction_requested")
.count();
let degraded_reviews = reviews.iter().filter(|r| r.degraded == Some(true)).count();
println!();
println!("📋 Review Audit:");
println!(" Total: {}", reviews.len());
println!(" ✅ Approved: {}", approved);
if rejected > 0 {
println!(" ❌ Rejected: {}", rejected);
}
if corrected > 0 {
println!(" 🔄 Corrected: {}", corrected);
}
if degraded_reviews > 0 {
println!(" ⚠️ Degraded: {}", degraded_reviews);
}
}
println!();
println!("{}", "─".repeat(70));
println!("Commands:");
println!(" perspt resume --last Resume this session");
println!(" perspt logs --last View LLM request history");
println!(" perspt logs List all sessions");
Ok(())
}