Struct RuntimeAgentNodeHandler 

pub struct RuntimeAgentNodeHandler { /* private fields */ }

Production AgentNodeHandler wrapping the agentic-worker runtime.

Holds a shared AgentRuntime and translates a DwAgent flow node’s JSON payload into an AgentInput, invoking one Plan-Act-Observe step per call. Construction (Task 4.3b) lives in the runner binary; the engine only ever sees this through the AgentNodeHandler trait object.

Implementations

impl RuntimeAgentNodeHandler

pub fn new( runtime: Arc<AgentRuntime>, audit_sink: Option<AuditSink>, project_id: Option<String>, ) -> RuntimeAgentNodeHandler

Wrap a shared AgentRuntime in a flow-node handler. audit_sink is Some only when a NATS audit client was configured; execute then drives the step via AgentRuntime::step_with_observer with an AgentAuditObserver so tool calls/results are published to audit.<tenant>.agent.<event>. When None, execute uses AgentRuntime::step directly (no observer, no behaviour change).

project_id is the deployed unit’s bundle_id (None on the legacy tenant-only path); it becomes the project_id billing dimension of every step this handler runs.

Trait Implementations

impl AgentNodeHandler for RuntimeAgentNodeHandler

fn execute<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, tenant_id: &'life1 str, env_id: &'life2 str, agent_id: &'life3 str, session_id: &'life4 str, flow_input: &'life5 Value, ) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait, RuntimeAgentNodeHandler: 'async_trait,

Execute one agentic step. flow_input is the upstream node’s JSON payload (expects at least {"user_text": "..."}); returns the node output JSON ({"reply", "trail", "terminated_by"}).