yog 0.0.66

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
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
128
129
130
131
132
133
134
135
136
137
138

//! **What one tick does when it takes work**: the §8.1 start flow through the
//! ordinary doors, and what the trail says about a birth that lands, one the
//! substrate refuses, and one whose fire never launches at all (bl-ab13).
//!
//! Split from [`super`] at §12's cap on the seam that module's own doc draws —
//! the loop makes two moves, so its effect tests are cut in two: giving a claim
//! back is there, taking work is here.

use super::*;

/// The spawn: the ordinary §8.1 start flow, through the ordinary doors, leaving
/// the loop's own row naming the ball it took and the conversation it minted.
#[test]
fn a_landed_spawn_starts_a_drone_and_leaves_one_row() {
    let root = tempdir().expect("tempdir");
    let project = root.path().join("proj");
    let ws = root.path().join("ws");
    std::fs::create_dir_all(&project).expect("mkdir");
    let mut ctx = ctx(root.path(), armed_world(&ws, &project, false, None));
    // `bl claim` prints the worktree it minted (§3.2), and the start flow
    // cross-checks it — so the fake prints exactly the one balls' delivery
    // layout puts under this state root.
    let worktree = ctx
        .deps
        .world
        .balls_state_root_for(&project)
        .join("plugins/bl-delivery")
        .join(project.strip_prefix("/").expect("absolute"))
        .join("bl-1");
    std::fs::create_dir_all(&worktree).expect("mkdir");
    ctx.deps.bl = fake(
        root.path(),
        "bl",
        &format!(
            "#!/bin/sh\ncase \"$1\" in\n  claim) printf '%s\\n' '{}' ;;\nesac\nexit 0\n",
            worktree.display()
        ),
    );
    ctx.deps.litany = fake(
        root.path(),
        "litany",
        &format!(
            "#!/bin/sh\ncase \"$1\" in\n{}esac\nexit 0\n",
            crate::test_support::authoring_new_arm()
        ),
    );
    let acted = ctx.pass();
    let trail0 = std::fs::read_to_string(root.path().join("ops.jsonl")).unwrap_or_default();
    assert!(acted, "a ready ball under the cap is taken: {trail0}");
    let trail = std::fs::read_to_string(root.path().join("ops.jsonl")).expect("trail");
    assert!(trail.contains("yog-fleet"), "{trail}");
    assert!(trail.contains("spawn"), "{trail}");
    assert!(trail.contains("bl-1"), "{trail}");
}

/// **A birth is atomic against its own claim** (bl-ab13). Every piped step of
/// the §8.1 flow lands, the `bl claim` with them — and then the detached fire
/// cannot launch at all. The ball comes straight back rather than being held
/// forever by a workspace with no conversation on it, and there is still no
/// loop row, because the birth did not land.
///
/// The fire fails because the driver's working directory is the workspace and
/// it is gone by then — here removed under the flow by the `bl claim` that runs
/// between the birth and the fire, which is the shape a `/delete` racing a
/// start already has. A launch into a directory that is not there is exactly
/// the class the loop could not previously survive.
///
/// It used to be arranged by a `litany new` that made nothing and exited zero.
/// bl-1af5 closed that off: a birth is one act or none, so an ensure whose
/// `litany new` left no workspace now fails outright instead of reporting a
/// create it did not perform — which is the same defect one rung earlier, and
/// the claim would never have been taken.
#[test]
fn a_birth_whose_fire_never_launches_gives_its_own_claim_back() {
    let root = tempdir().expect("tempdir");
    let project = root.path().join("proj");
    let ws = root.path().join("ws");
    std::fs::create_dir_all(&project).expect("mkdir");
    let mut ctx = ctx(root.path(), armed_world(&ws, &project, false, None));
    let worktree = ctx
        .deps
        .world
        .balls_state_root_for(&project)
        .join("plugins/bl-delivery")
        .join(project.strip_prefix("/").expect("absolute"))
        .join("bl-1");
    std::fs::create_dir_all(&worktree).expect("mkdir");
    let seen = root.path().join("bl.args");
    ctx.deps.bl = fake(
        root.path(),
        "bl",
        &format!(
            "#!/bin/sh\nprintf '%s\\n' \"$*\" >>'{}'\ncase \"$1\" in\n  \
             claim) rm -rf '{}'; printf '%s\\n' '{}' ;;\nesac\nexit 0\n",
            seen.display(),
            ws.display(),
            worktree.display()
        ),
    );
    ctx.deps.litany = fake(
        root.path(),
        "litany",
        &format!(
            "#!/bin/sh\ncase \"$1\" in\n{}esac\nexit 0\n",
            crate::test_support::authoring_new_arm()
        ),
    );
    assert!(!ctx.pass(), "the fire never launched, so no birth landed");
    let args = std::fs::read_to_string(&seen).expect("bl was called");
    assert!(
        args.contains("claim bl-1") && args.contains("unclaim bl-1"),
        "the claim landed and was given straight back: {args}"
    );
    let trail = std::fs::read_to_string(root.path().join("ops.jsonl")).unwrap_or_default();
    assert!(
        !trail.contains("yog-fleet"),
        "a birth that did not converge is not a spawn row: {trail}"
    );
}

/// A spawn the start flow refuses leaves no loop row, for the same reason a
/// refused reap does.
#[test]
fn a_refused_spawn_writes_no_loop_row() {
    let root = tempdir().expect("tempdir");
    let project = root.path().join("proj");
    let ws = root.path().join("ws");
    std::fs::create_dir_all(&project).expect("mkdir");
    let mut ctx = ctx(root.path(), armed_world(&ws, &project, false, None));
    ctx.deps.bl = fake(
        root.path(),
        "bl",
        "#!/bin/sh\nprintf 'no\\n' 1>&2\nexit 3\n",
    );
    assert!(!ctx.pass());
    let trail = std::fs::read_to_string(root.path().join("ops.jsonl")).unwrap_or_default();
    assert!(!trail.contains("yog-fleet"), "{trail}");
}