yog 0.0.68

yog: the standalone server for litany loops — the world, the balls and the conversations, behind one wire
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

//! The §11 inspector family's decode arms (§8.5, REMOTE §9 step 2, bl-7067) —
//! the reads bl-6233 landed and bl-13f9 extended, split off [`super`] on the seam
//! `codec/query/inspector` already draws: these are the replies addressed at a
//! *conversation* rather than a workspace, and each one's rows are read by the
//! `wire` module that spells them, beside its own type.
//!
//! Nothing is read here but the envelope. The bodies belong to
//! `transcript::wire`, `steps_view::wire`, `files_view::wire`, `rail::wire`,
//! `inboxview::wire`, `workdiff::wire` and `science::wire` — the same modules
//! that write them,
//! for the same reason they write them: those rows' shape *is* each module's
//! vocabulary.

use serde_json::{Map, Value};

use super::super::Reply;
use crate::boundary::codec::fields::{opt_str_of, opt_val, str_of, strings_of, usize_of};

/// The §11 answers, plus the work diff that shares their shape. `None`
/// when the kind is not one of them.
pub(super) fn decode(kind: &str, o: &Map<String, Value>) -> Option<Result<Reply, String>> {
    Some(match kind {
        "transcript" => crate::transcript::wire::decode::transcript(o).map(Reply::Transcript),
        // One frame of the live tail (bl-73e7) — the fold read back by the
        // module that wrote it, so the lane needs no reader of its own.
        super::super::encode::FOLLOW => follow(o),
        "steps" => crate::steps_view::wire::decode::steps(o).map(Reply::Steps),
        "step" => crate::steps_view::wire::decode::detail(o).map(Reply::Step),
        "files" => files(o),
        "rail" => crate::rail::wire::rail_of(o).map(Reply::Rail),
        "governing" => governing(o),
        "inbox" => crate::inboxview::wire::entries_of(o).map(Reply::Inbox),
        "agent" => super::super::agent::view_of(o).map(Reply::Agent),
        "work-diff" => work_diff(o),
        "science" => crate::science::wire::rows_of(o).map(Reply::Science),
        _ => return None,
    })
}

/// One follow frame — spelled beside its own type, and read back there.
fn follow(o: &Map<String, Value>) -> Result<Reply, String> {
    super::super::follow_frame::frame_of(o).map(Reply::Follow)
}

fn files(o: &Map<String, Value>) -> Result<Reply, String> {
    Ok(Reply::Files {
        view: crate::files_view::wire::view_of(o)?,
        preview: opt_val(o, "preview", crate::files_view::wire::preview_of)?,
        working_dir: crate::files_view::wire::working_dir_of(o)?,
    })
}

/// The which-config-governs answer (bl-13f9; follow-the-tip, bl-e654).
/// `follows` names the lineage whose tip the conversation resolves — the
/// ordinary case — and its **absence is the held one**, which is why the
/// enum is rebuilt off that key alone: `diverged_lineages` is read only where
/// it can be anything but zero, so the two fields cannot decode to a state the
/// encoder could not have written.
fn governing(o: &Map<String, Value>) -> Result<Reply, String> {
    use crate::config_edit::branch::Governance;
    let governance = match opt_str_of(o, "follows")? {
        Some(branch) => Governance::Follows(branch),
        None => Governance::Held {
            diverged_lineages: usize_of(o, "diverged_lineages")?,
        },
    };
    Ok(Reply::Governing {
        config: crate::config_edit::branch::GoverningConfig {
            oid: str_of(o, "oid")?,
            short_oid: str_of(o, "short_oid")?,
            governance,
            files: strings_of(o, "files")?,
        },
        // Absent reads as null (REMOTE §3.2: a post-floor key an older engine
        // never wrote is the general path), and a present value is read
        // strictly by the module that spells it.
        workflow_mark: opt_val(o, "workflow_mark", super::super::workflow::mark_of)?,
    })
}

fn work_diff(o: &Map<String, Value>) -> Result<Reply, String> {
    Ok(Reply::WorkDiff {
        attempts: crate::workdiff::wire::attempts_of(o)?,
        patch: opt_val(o, "patch", crate::files_view::wire::preview_of)?,
    })
}