agents-orchestrator/agent-orchestrator
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Wire play/stop buttons and DM send to agent lifecycle

Browse source 
- Play button in GroupAgentsPanel now starts agent session via emitAgentStart
- Stop button now stops running agent session via emitAgentStop
- Sending a DM to a stopped agent auto-wakes it (sets active + emitAgentStart)
- Fix autoPrompt in AgentPane to work for fresh sessions (not just done/error)
- Fix btmsg: admin (tier 0) bypasses stale heartbeat check so messages deliver

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
DexterFromLab 2026-03-12 12:33:08 +01:00
parent 42907f22a4
commit 2c710fa0db
6 changed files with 114 additions and 34 deletions
Download patch file Download diff file Expand all files Collapse all files

59
v2/src-tauri/src/btmsg.rs
View file

@ -215,38 +215,41 @@ pub fn send_message(from_agent: &str, to_agent: &str, content: &str) -> Result<S
}
// Check if recipient is stale (no heartbeat in 5 min) — route to dead letter queue
let now = std::time::SystemTime::now()
.duration_since(std::time::UNIX_EPOCH)
.unwrap_or_default()
.as_secs() as i64;
let cutoff = now - STALE_HEARTBEAT_SECS;
// Skip heartbeat check for admin (tier 0) — admin messages always go through
if sender_tier > 0 {
let now = std::time::SystemTime::now()
.duration_since(std::time::UNIX_EPOCH)
.unwrap_or_default()
.as_secs() as i64;
let cutoff = now - STALE_HEARTBEAT_SECS;
let recipient_stale: bool = db
.query_row(
"SELECT COALESCE(h.timestamp, 0) < ?1 FROM agents a \
LEFT JOIN heartbeats h ON a.id = h.agent_id \
WHERE a.id = ?2",
params![cutoff, to_agent],
|row| row.get(0),
)
.unwrap_or(false);
let recipient_stale: bool = db
.query_row(
"SELECT COALESCE(h.timestamp, 0) < ?1 FROM agents a \
LEFT JOIN heartbeats h ON a.id = h.agent_id \
WHERE a.id = ?2",
params![cutoff, to_agent],
|row| row.get(0),
)
.unwrap_or(false);
if recipient_stale {
// Queue to dead letter instead of delivering
let error_msg = format!("Recipient '{}' is stale (no heartbeat in {} seconds)", to_agent, STALE_HEARTBEAT_SECS);
db.execute(
"INSERT INTO dead_letter_queue (from_agent, to_agent, content, error) VALUES (?1, ?2, ?3, ?4)",
params![from_agent, to_agent, content, error_msg],
)
.map_err(|e| format!("Dead letter insert error: {e}"))?;
if recipient_stale {
// Queue to dead letter instead of delivering
let error_msg = format!("Recipient '{}' is stale (no heartbeat in {} seconds)", to_agent, STALE_HEARTBEAT_SECS);
db.execute(
"INSERT INTO dead_letter_queue (from_agent, to_agent, content, error) VALUES (?1, ?2, ?3, ?4)",
params![from_agent, to_agent, content, error_msg],
)
.map_err(|e| format!("Dead letter insert error: {e}"))?;
// Also log audit event
let _ = db.execute(
"INSERT INTO audit_log (agent_id, event_type, detail) VALUES (?1, 'dead_letter', ?2)",
params![from_agent, format!("Message to '{}' routed to dead letter queue: {}", to_agent, error_msg)],
);
// Also log audit event
let _ = db.execute(
"INSERT INTO audit_log (agent_id, event_type, detail) VALUES (?1, 'dead_letter', ?2)",
params![from_agent, format!("Message to '{}' routed to dead letter queue: {}", to_agent, error_msg)],
);
return Err(error_msg);
return Err(error_msg);
}
}
let msg_id = uuid::Uuid::new_v4().to_string();