runx-contracts 0.6.19

Shared Rust contract types for runx JSON and host protocol boundaries.
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

//! Decision contracts: choices, justifications, and closure dispositions.
use serde::{Deserialize, Serialize};

use crate::schema::{IsoDateTime, NonEmptyString, RunxSchema};
use crate::{Intent, Reference};

#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize, RunxSchema)]
#[serde(rename_all = "snake_case")]
pub enum DecisionChoice {
    Open,
    Continue,
    SpawnChild,
    Escalate,
    Defer,
    Close,
    Decline,
    Monitor,
}

#[derive(Clone, Debug, Default, PartialEq, Eq, Serialize, Deserialize, RunxSchema)]
#[serde(deny_unknown_fields)]
pub struct DecisionInputs {
    #[serde(default)]
    pub signal_refs: Vec<Reference>,
    pub target_ref: Option<Reference>,
    #[serde(default)]
    pub opportunity_refs: Vec<Reference>,
    pub selection_ref: Option<Reference>,
}

#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize, RunxSchema)]
#[serde(deny_unknown_fields)]
pub struct DecisionJustification {
    pub summary: NonEmptyString,
    #[serde(default)]
    pub evidence_refs: Vec<Reference>,
}

#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize, RunxSchema)]
#[serde(rename_all = "snake_case")]
pub enum ClosureDisposition {
    Closed,
    Deferred,
    Superseded,
    Declined,
    Blocked,
    Failed,
    Killed,
    TimedOut,
}

impl ClosureDisposition {
    /// Stable string label, identical to the serde `snake_case` representation.
    /// Single source of truth for the runtime's disposition strings.
    pub fn label(&self) -> &'static str {
        match self {
            ClosureDisposition::Closed => "closed",
            ClosureDisposition::Deferred => "deferred",
            ClosureDisposition::Superseded => "superseded",
            ClosureDisposition::Declined => "declined",
            ClosureDisposition::Blocked => "blocked",
            ClosureDisposition::Failed => "failed",
            ClosureDisposition::Killed => "killed",
            ClosureDisposition::TimedOut => "timed_out",
        }
    }
}

#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize, RunxSchema)]
#[serde(deny_unknown_fields)]
pub struct Closure {
    pub disposition: ClosureDisposition,
    pub reason_code: NonEmptyString,
    pub summary: NonEmptyString,
    pub closed_at: IsoDateTime,
}

#[derive(Clone, Debug, PartialEq, Eq, Serialize, Deserialize, RunxSchema)]
#[serde(deny_unknown_fields)]
#[runx_schema(id = "runx.decision.v1")]
pub struct Decision {
    pub decision_id: NonEmptyString,
    pub choice: DecisionChoice,
    pub inputs: DecisionInputs,
    pub proposed_intent: Intent,
    pub selected_act_id: Option<NonEmptyString>,
    pub selected_harness_ref: Option<Reference>,
    pub justification: DecisionJustification,
    pub closure: Option<Closure>,
    #[serde(default)]
    pub artifact_refs: Vec<Reference>,
}