artifactize-core 0.12.0

The library behind artifactize: Artifacts, evals, reviews, the monitor and review models, and the shared operations every interface calls.
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
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127

//! Parse MCP arguments once at the transport boundary.
use crate::{project::selection::Selection, runs::ResultCursor, types::*};
use serde::Deserialize;

/// Bound model-driven array envelopes, without changing core selection expansion.
pub(super) const SCOPE_IDS: usize = 64;
pub(super) struct Scope(pub Selection);
impl<'de> Deserialize<'de> for Scope {
    fn deserialize<D: serde::Deserializer<'de>>(deserializer: D) -> Result<Self, D::Error> {
        let selection = Selection::deserialize(deserializer)?;
        let count = match &selection {
            Selection::Artifacts { artifact_ids } => Some(artifact_ids.len()),
            Selection::Evals { eval_ids } => Some(eval_ids.len()),
            _ => None,
        };
        if count.is_some_and(|count| count == 0 || count > SCOPE_IDS) {
            return Err(serde::de::Error::custom(
                "scope arrays must contain 1–64 IDs",
            ));
        }
        Ok(Self(selection))
    }
}

#[derive(Deserialize)]
#[serde(deny_unknown_fields)]
pub(super) struct Start {
    pub scope: Scope,
    pub request_key: Option<RequestKey>,
    pub jobs: Option<u32>,
    #[serde(default)]
    pub speculate: bool,
    #[serde(default)]
    pub defer_human: bool,
}
#[derive(Deserialize)]
#[serde(deny_unknown_fields)]
pub(super) struct Run {
    pub run: RunId,
}
#[derive(Deserialize)]
#[serde(deny_unknown_fields)]
pub(super) struct Wait {
    pub run: RunId,
    pub seconds: Option<u64>,
}
#[derive(Deserialize)]
#[serde(deny_unknown_fields)]
pub(super) struct ResultInput {
    pub run: RunId,
    pub cursor: Option<ResultCursor>,
}
// Cursors are consumed by the shared transport projection, not core operations.
#[derive(Deserialize)]
#[serde(deny_unknown_fields)]
pub(super) struct Empty {}
#[derive(Deserialize)]
#[serde(deny_unknown_fields)]
pub(super) struct Status {
    #[serde(default = "all")]
    pub scope: Scope,
}
fn all() -> Scope {
    Scope(Selection::All)
}
#[derive(Deserialize)]
#[serde(deny_unknown_fields)]
pub(super) struct Runs {
    pub limit: Option<u32>,
    pub offset: Option<u32>,
}
#[derive(Deserialize)]
#[serde(deny_unknown_fields)]
pub(super) struct RunDetails {
    pub run: RunId,
}
#[derive(Deserialize)]
#[serde(deny_unknown_fields)]
pub(super) struct Requests {
    pub run: Option<RunId>,
}
#[derive(Deserialize)]
#[serde(deny_unknown_fields)]
pub(super) struct Request {
    pub id: RequestId,
}
#[derive(Deserialize)]
#[serde(deny_unknown_fields)]
pub(super) struct Session {
    pub reference: String,
    #[serde(default)]
    pub summary: bool,
}
#[derive(Deserialize)]
#[serde(deny_unknown_fields)]
pub(super) struct Tools {
    pub eval: Option<EvalId>,
    pub artifact: Option<ArtifactName>,
    pub tool: Option<crate::config::ToolName>,
    pub audience: Option<Audience>,
}
#[derive(Deserialize)]
#[serde(rename_all = "lowercase")]
pub(super) enum Audience {
    Agent,
    Human,
}
impl From<Audience> for crate::diagnostics::Audience {
    fn from(value: Audience) -> Self {
        match value {
            Audience::Agent => Self::Agent,
            Audience::Human => Self::Human,
        }
    }
}
#[derive(Deserialize)]
#[serde(deny_unknown_fields)]
pub(super) struct Models {
    pub provider: crate::config::Backend,
}
#[derive(Deserialize)]
#[serde(deny_unknown_fields)]
pub(super) struct Cache {
    pub key: ReuseKey,
    #[serde(default)]
    pub history: bool,
}