ao-core 0.1.0

Core traits and types for the ao-rs agent orchestrator framework
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

//! Orchestrator session-strategy enums and helpers
//! (ported from `packages/core/src/orchestrator-session-strategy.ts`).
//!
//! Parity status: mixed.
//!
//! The two enums (`OrchestratorSessionStrategy`, `OpencodeIssueSessionStrategy`)
//! are re-exported from `ao_core` and used by production config
//! (`crates/ao-core/src/config.rs`). The helper
//! `decide_existing_session_action` is test-only — the runtime lifecycle has
//! its own strategy logic and does not call it. See
//! `docs/ts-core-parity-report.md` → "Parity-only modules".

use serde::{Deserialize, Serialize};

#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
#[serde(rename_all = "kebab-case")]
pub enum OrchestratorSessionStrategy {
    Reuse,
    Delete,
    Ignore,
    DeleteNew,
    IgnoreNew,
    KillPrevious,
}

#[derive(Debug, Clone, Copy, PartialEq, Eq, Serialize, Deserialize)]
#[serde(rename_all = "kebab-case")]
pub enum OpencodeIssueSessionStrategy {
    Reuse,
    Delete,
    Ignore,
}

#[derive(Debug, Clone, Copy, PartialEq, Eq)]
pub enum ExistingSessionAction {
    ReuseExisting,
    DeleteExistingAndReuseName,
    IgnoreExistingAndSpawnNew,
    Abort,
}

/// Minimal parity port of TS orchestrator-session-strategy behavior.
///
/// This is currently used only by parity tests; the ao-rs runtime has its own
/// session lifecycle implementation.
pub fn decide_existing_session_action(
    strategy: OrchestratorSessionStrategy,
    existing_found: bool,
) -> ExistingSessionAction {
    if !existing_found {
        return ExistingSessionAction::IgnoreExistingAndSpawnNew;
    }
    match strategy {
        OrchestratorSessionStrategy::Reuse => ExistingSessionAction::ReuseExisting,
        OrchestratorSessionStrategy::Delete => ExistingSessionAction::DeleteExistingAndReuseName,
        OrchestratorSessionStrategy::Ignore => ExistingSessionAction::Abort,
        OrchestratorSessionStrategy::DeleteNew => ExistingSessionAction::Abort,
        OrchestratorSessionStrategy::IgnoreNew => ExistingSessionAction::Abort,
        OrchestratorSessionStrategy::KillPrevious => {
            ExistingSessionAction::DeleteExistingAndReuseName
        }
    }
}