rpi-cli 0.21.1

Terminal coding-agent CLI (the `rpi` binary) built on the rpi-* library crates
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

//! Resource authority is initialized for the NEW native identity, independently
//! of the historical fork cut. Never copy a source retry ledger as authority.
use super::*;
#[cfg(test)]
mod tests;

/// Startup preflight is advisory: authorize against the exact source snapshot
/// supplied by the metadata-first fork, before any destination is published.
pub(crate) fn initial_values_for_selection(
    source: &rpi_harness::session::SessionValues,
    selected: Option<&ResolvedSelection>,
) -> rpi_harness::error::SessionResult<Vec<(String, Value)>> {
    validate_session_binding(source, selected)
        .map_err(rpi_harness::error::SessionError::invalid_payload)?;
    initial_values(source)
}

pub(crate) fn initial_values(
    source: &rpi_harness::session::SessionValues,
) -> rpi_harness::error::SessionResult<Vec<(String, Value)>> {
    use rpi_harness::error::SessionError;
    let Some(binding) = source.get(SESSION_KEY) else {
        return Ok(Vec::new());
    };
    validate_persisted_binding(binding).map_err(SessionError::invalid_payload)?;
    let initial =
        json!({"revision":1,"declaration":binding["declaration"],"inventory":binding["inventory"]});
    if serde_json::to_vec(&initial)
        .map_err(|e| SessionError::invalid_payload(e.to_string()))?
        .len()
        > MAX_STATE_BYTES
    {
        return Err(SessionError::invalid_payload(
            "fork resource binding exceeds 256 KiB",
        ));
    }
    Ok(vec![(SESSION_KEY.into(), initial)])
}