sprawling-kernel 0.0.11

Every decision of a sprawling city - addresses, events, gates, plans and errors - with nothing that touches a disk.
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

// 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 golden bytes: each typed payload encodes to the exact string the
//! hand-written writer before it put on the ledger, and reads back as
//! itself, so a replay over an older history re-hashes identically.

use super::*;
use crate::event::Payload;

fn golden<T>(record: &T, bytes: &str)
where
    T: Serialize + serde::de::DeserializeOwned + PartialEq + std::fmt::Debug,
{
    let payload = Payload::of(record).unwrap();
    assert_eq!(serde_json::to_string(&payload).unwrap(), bytes);
    let parsed: Payload = serde_json::from_str(bytes).unwrap();
    assert_eq!(&parsed.read::<T>().unwrap(), record);
}

fn lab() -> Address {
    Address::parse("lab").unwrap()
}

#[test]
fn genesis_lines_keep_their_bytes() {
    golden(&CityInitialized {}, "{}");
    golden(
        &BuildingCreated {
            addr: lab(),
            template: "minimal".to_owned(),
            adopted: false,
        },
        r#"{"addr":"lab","template":"minimal"}"#,
    );
    golden(
        &BuildingCreated {
            addr: lab(),
            template: "minimal".to_owned(),
            adopted: true,
        },
        r#"{"addr":"lab","adopted":true,"template":"minimal"}"#,
    );
    golden(
        &BuildingConfigured {
            addr: lab(),
            sandbox: true,
            mcp: false,
            desktop: false,
            context: true,
        },
        r#"{"addr":"lab","context":true,"desktop":false,"mcp":false,"sandbox":true}"#,
    );
}

#[test]
fn run_control_lines_keep_their_bytes() {
    golden(&CancelReceived {}, "{}");
    let must_read = Locator::parse(&format!("cas:b3-{}", "ab".repeat(32))).unwrap();
    golden(
        &HandoffWritten {
            must_read: vec![must_read.clone()],
            overview: "o".to_owned(),
            progress: "p".to_owned(),
            context: "c".to_owned(),
            next_step: "n".to_owned(),
        },
        &format!(
            r#"{{"context":"c","must_read":["{must_read}"],"next_step":"n","overview":"o","progress":"p"}}"#
        ),
    );
    golden(
        &WatchdogFired {
            action: FiredAction::BackOff {
                until_ms: 5000,
                code: "E_PROVIDER".to_owned(),
                subject: "503".to_owned(),
            },
            corrections: 0,
            provider_failures: 1,
        },
        r#"{"action":"back_off","code":"E_PROVIDER","corrections":0,"provider_failures":1,"subject":"503","until_ms":5000}"#,
    );
    golden(
        &WatchdogFired {
            action: FiredAction::Switch {
                to: crate::ServerLabel::parse("b").unwrap(),
                code: "E_PROVIDER".to_owned(),
                subject: "401 Unauthorized".to_owned(),
            },
            corrections: 0,
            provider_failures: 1,
        },
        r#"{"action":"switch","code":"E_PROVIDER","corrections":0,"provider_failures":1,"subject":"401 Unauthorized","to":"b"}"#,
    );
    golden(
        &WatchdogFired {
            action: FiredAction::Freeze {
                reason: "stall".to_owned(),
            },
            corrections: 2,
            provider_failures: 0,
        },
        r#"{"action":"freeze","corrections":2,"provider_failures":0,"reason":"stall"}"#,
    );
}