sprawling 0.0.12

A local multi-agent harness for persistent agent teams: long-running project work, agent communication, and experiments in coordination and social simulation.
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

// This Source Code Form is subject to the terms of the Mozilla Public
// License, v. 2.0. If a copy of the MPL was not distributed with this
// file, You can obtain one at https://mozilla.org/MPL/2.0/.
// Copyright (c) 2026 2youg1 and the sprawling contributors

//! The rounds of one run and the calls in each, folded the first time
//! the person opens the run (`crates/sprawling/spec/Main.lean` ยง8-117).

use std::collections::BTreeMap;

use kernel::{AxError, EventRecord, RunId};
use serde_json::json;
use wire::Turn;

use super::arrange::{Entry, NodeKey};
use super::follow::Row;

/// What each run the person has opened folded into.
pub(super) type Rounds = BTreeMap<RunId, Result<Vec<Turn>, AxError>>;

/// The turns of `run`, through the fold the rounds page uses.
///
/// # Errors
/// The first line of `run` that does not parse as a Ledger record.
pub(super) fn fold(run: RunId, rows: &[Row]) -> Result<Vec<Turn>, AxError> {
    let records = rows
        .iter()
        .filter(|row| row.run == run)
        .map(|row| EventRecord::parse_line(row.line.as_bytes()))
        .collect::<Result<Vec<_>, _>>()?;
    Ok(accounting::views::turns(&records))
}

/// The mark of a tree entry with no child entries: `+` on a run whose
/// rounds are not folded yet, since whether it has any is known only
/// once the person opens it; a blank on everything else.
pub(super) fn leaf_mark(rounds: &Rounds, key: &NodeKey) -> char {
    match key {
        NodeKey::Run(run) if !rounds.contains_key(run) => '+',
        NodeKey::City
        | NodeKey::Building(_)
        | NodeKey::Room(_)
        | NodeKey::Session(..)
        | NodeKey::Run(_)
        | NodeKey::Round(..)
        | NodeKey::Call(..) => ' ',
    }
}

/// Pushes the rounds of the run entry at `at`, each followed by its
/// calls; an unreadable run gets one entry naming the failure instead.
pub(super) fn append_below(
    entries: &mut Vec<Entry>,
    at: usize,
    folded: &Result<Vec<Turn>, AxError>,
) {
    let Some((NodeKey::Run(run), depth, seq)) = entries
        .get(at)
        .map(|entry| (entry.key.clone(), entry.depth.saturating_add(1), entry.seq))
    else {
        return;
    };
    let turns = match folded {
        Ok(turns) => turns,
        Err(failure) => {
            entries.push(Entry {
                key: NodeKey::Round(run, 0),
                depth,
                parent: Some(at),
                seq,
                label: format!("rounds unreadable: {failure}"),
                detail: serde_json::to_value(failure).unwrap_or_else(unserializable),
            });
            return;
        }
    };
    for turn in turns {
        let round_at = entries.len();
        entries.push(Entry {
            key: NodeKey::Round(run, turn.number),
            depth,
            parent: Some(at),
            seq: turn.opened,
            label: format!("round {} @{}", turn.number, turn.opened.value()),
            detail: serde_json::to_value(turn).unwrap_or_else(unserializable),
        });
        entries.extend(turn.calls.iter().map(|call| Entry {
            key: NodeKey::Call(run, call.at),
            depth: depth.saturating_add(1),
            parent: Some(round_at),
            seq: call.at,
            label: call.subject.as_ref().map_or_else(
                || call.tool.clone(),
                |subject| format!("{} {subject}", call.tool),
            ),
            detail: serde_json::to_value(call).unwrap_or_else(unserializable),
        }));
    }
}

fn unserializable(failure: serde_json::Error) -> serde_json::Value {
    json!({ "error": failure.to_string() })
}