symphony-core 0.1.0

Domain model and shared types for Symphony orchestration engine
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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67

//! Session and run attempt types (Spec Sections 4.1.5, 4.1.6, 4.1.7).

use chrono::{DateTime, Utc};
use serde::{Deserialize, Serialize};

/// One execution attempt for one issue.
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct RunAttempt {
    pub issue_id: String,
    pub issue_identifier: String,
    /// `None` for first run, `Some(n)` for retries/continuation.
    pub attempt: Option<u32>,
    pub workspace_path: String,
    pub started_at: DateTime<Utc>,
    pub status: RunAttemptStatus,
    pub error: Option<String>,
}

/// Run attempt lifecycle phases (Spec Section 7.2).
#[derive(Debug, Clone, PartialEq, Eq, Serialize, Deserialize)]
#[serde(rename_all = "snake_case")]
pub enum RunAttemptStatus {
    PreparingWorkspace,
    BuildingPrompt,
    LaunchingAgentProcess,
    InitializingSession,
    StreamingTurn,
    Finishing,
    Succeeded,
    Failed,
    TimedOut,
    Stalled,
    CanceledByReconciliation,
}

/// State tracked while a coding-agent subprocess is running (Spec Section 4.1.6).
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct LiveSession {
    /// `<thread_id>-<turn_id>`
    pub session_id: String,
    pub thread_id: String,
    pub turn_id: String,
    pub codex_app_server_pid: Option<String>,
    pub last_codex_event: Option<String>,
    pub last_codex_timestamp: Option<DateTime<Utc>>,
    pub last_codex_message: Option<String>,
    pub codex_input_tokens: u64,
    pub codex_output_tokens: u64,
    pub codex_total_tokens: u64,
    pub last_reported_input_tokens: u64,
    pub last_reported_output_tokens: u64,
    pub last_reported_total_tokens: u64,
    pub turn_count: u32,
}

/// Scheduled retry state for an issue (Spec Section 4.1.7).
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct RetryEntry {
    pub issue_id: String,
    /// Best-effort human ID for status surfaces/logs.
    pub identifier: String,
    /// 1-based for retry queue.
    pub attempt: u32,
    /// Monotonic clock timestamp in ms.
    pub due_at_ms: u64,
    pub error: Option<String>,
}