ralph-workflow 0.7.18

PROMPT-driven multi-agent orchestrator for git repos
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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109

//! Pure domain logic for XSD retry input source selection.
//!
//! Determines the strategy for obtaining last output content for XSD retry prompts
//! without performing I/O. Boundary layer receives the decided strategy and executes it.

use std::path::{Path, PathBuf};

/// Strategy for obtaining XSD retry last-output content.
#[derive(Debug, Clone, PartialEq, Eq)]
pub(crate) enum XsdRetryInputSource {
    /// Read from primary issues.xml file.
    Primary { path: PathBuf },
    /// Primary missing; read from archived .processed file.
    ArchivedFallback { path: PathBuf },
    /// Both files missing; use empty string as fallback.
    EmptyFallback,
}

/// Determine XSD retry input source based on file availability flags.
///
/// # Domain Policy
/// This function encodes the retry input fallback policy:
/// 1. Try primary issues.xml first
/// 2. If missing, try archived .processed file
/// 3. If both missing, use empty string
///
/// This is a pure decision function - boundary layer executes the I/O.
pub(crate) fn decide_xsd_retry_input_source(
    primary_exists: bool,
    archived_exists: bool,
    primary_path: &Path,
    archived_path: &Path,
) -> XsdRetryInputSource {
    if primary_exists {
        XsdRetryInputSource::Primary {
            path: primary_path.to_path_buf(),
        }
    } else if archived_exists {
        XsdRetryInputSource::ArchivedFallback {
            path: archived_path.to_path_buf(),
        }
    } else {
        XsdRetryInputSource::EmptyFallback
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn prefers_primary_when_both_exist() {
        let source = decide_xsd_retry_input_source(
            true,
            true,
            Path::new(".agent/tmp/issues.xml"),
            Path::new(".agent/tmp/issues.xml.processed"),
        );
        assert_eq!(
            source,
            XsdRetryInputSource::Primary {
                path: PathBuf::from(".agent/tmp/issues.xml")
            }
        );
    }

    #[test]
    fn uses_archived_when_primary_missing() {
        let source = decide_xsd_retry_input_source(
            false,
            true,
            Path::new(".agent/tmp/issues.xml"),
            Path::new(".agent/tmp/issues.xml.processed"),
        );
        assert_eq!(
            source,
            XsdRetryInputSource::ArchivedFallback {
                path: PathBuf::from(".agent/tmp/issues.xml.processed")
            }
        );
    }

    #[test]
    fn uses_empty_fallback_when_both_missing() {
        let source = decide_xsd_retry_input_source(
            false,
            false,
            Path::new(".agent/tmp/issues.xml"),
            Path::new(".agent/tmp/issues.xml.processed"),
        );
        assert_eq!(source, XsdRetryInputSource::EmptyFallback);
    }

    #[test]
    fn ignores_archived_when_primary_exists() {
        let source = decide_xsd_retry_input_source(
            true,
            false, // archived doesn't exist but shouldn't matter
            Path::new(".agent/tmp/issues.xml"),
            Path::new(".agent/tmp/issues.xml.processed"),
        );
        assert_eq!(
            source,
            XsdRetryInputSource::Primary {
                path: PathBuf::from(".agent/tmp/issues.xml")
            }
        );
    }
}