synwire-agent

The agent runtime for Synwire. Concrete implementations of all synwire-core agent traits: Runner, execution strategies, backends, middleware, MCP transports, and session management.

What this crate provides

• Runner — drives the agent turn loop: AgentNode + ExecutionStrategy + middleware + backend + session
• DirectStrategy — unconstrained execution; model decides everything
• FsmStrategy / FsmStrategyBuilder — finite state machine with guards, priorities, and named transitions
• 10 BackendProtocol implementations — StateBackend, FilesystemBackend, GitBackend, HttpBackend, LocalShellBackend, ProcessBackend, ArchiveBackend, StoreBackend, PipelineExecutor, CompositeBackend
• 9 Middleware types — ToolInjection, SystemPrompt, RateLimit, AuditLog, Summarisation, ConversationHistory, Caching, Timeout, CircuitBreaker
• MCP transports — StdioMcpTransport, HttpMcpTransport, InProcessMcpTransport, McpLifecycleManager
• InMemorySessionManager — in-process session storage
• Approval gates — ThresholdGate, RiskLevel, ApprovalDecision
• Signals — Signal, SignalKind, Action, SignalRoute, ComposedRouter
• Permissions — PermissionMode, PermissionRule, PermissionBehavior

Quick start

[dependencies]
synwire-agent = "0.1"
synwire-core = "0.1"
tokio = { version = "1", features = ["full"] }

Run an agent with the direct strategy:

use synwire_agent::runner::Runner;
use synwire_agent::strategies::DirectStrategy;
use synwire_agent::backends::StateBackend;

// Assume `my_agent` implements `AgentNode`
// let runner = Runner::builder()
//     .agent(my_agent)
//     .strategy(DirectStrategy::new())
//     .backend(StateBackend::new())
//     .build()?;
//
// let mut events = runner.run("Hello, agent!".to_string(), Default::default()).await?;
// while let Some(event) = events.next().await {
//     println!("{:?}", event?);
// }

FSM strategy with two states and a guard:

use synwire_agent::strategies::{FsmStrategyBuilder, ClosureGuard};

// let strategy = FsmStrategyBuilder::new()
//     .add_state("idle")
//     .add_state("working")
//     .set_initial_state("idle")
//     .add_transition("idle", "working", ClosureGuard::new(|directive| {
//         matches!(directive, Directive::RunInstruction { .. })
//     }))
//     .add_transition("working", "idle", ClosureGuard::always())
//     .build()?;

Middleware stack:

use synwire_agent::middleware::{SystemPromptMiddleware, AuditLogMiddleware};

// let runner = Runner::builder()
//     .middleware(SystemPromptMiddleware::new("You are a helpful assistant."))
//     .middleware(AuditLogMiddleware::new(std::io::stderr()))
//     .build()?;

Backend selection

Documentation

• Your First Agent
• Agent Runtime Explanation
• When to use StateGraph vs FsmStrategy
• Full API docs
• Synwire documentation