zagens-runtime-orchestrator 0.8.3

Runtime thread/turn persist layer for Zagens sidecar (D16 E1-b)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

//! Sidecar hooks for the turn monitor loop (D16 E1-b phase 3).

use std::path::PathBuf;

use async_trait::async_trait;
use serde_json::Value;
use zagens_tools::{ToolError, ToolResult};

/// Host port for Zagens panel SSE, artifact refs, and sandbox elevation policy.
#[async_trait]
pub trait RuntimeThreadMonitorHost<P, R>: Send + Sync + Clone
where
    P: Send + Sync + Clone + 'static,
    R: Send + Sync + Clone + 'static,
{
    fn full_access_sandbox_policy(&self) -> P;

    fn artifact_refs_from_tool_output(
        &self,
        session_id: Option<&str>,
        content: &str,
        metadata: Option<&Value>,
    ) -> Vec<PathBuf>;

    async fn after_message_complete_panels(&self, thread_id: &str, turn_id: &str);

    async fn after_turn_complete_panels(&self, thread_id: &str, turn_id: &str);

    async fn after_tool_call_complete_panels(
        &self,
        thread_id: &str,
        turn_id: &str,
        tool_name: &str,
        result: &Result<ToolResult, ToolError>,
    );

    /// Observe a `long_horizon.*` status line as it streams (real-time harness
    /// observability). Lets the host cache nudge telemetry off the engine op
    /// loop so the task-graph panel stays live mid-turn. Default: no-op.
    async fn observe_harness_status(&self, _thread_id: &str, _turn_id: &str, _message: &str) {}
}