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

//! **Founding the model, and the one signal it sends the worker** (DESIGN §7.2).
//!
//! Split off [`super`] at §12's budget on the seam that root's own doc draws:
//! the root declares what a frame owns, and this is how one is brought into
//! being and how it reaches the derivation thread. Both members are the same
//! subject read from its two ends — [`AppModel::boot`] builds the [`Deriver`]
//! and hands the caller the pair, and [`AppModel::mark_dirty`] is the frame's
//! *only* outbound signal to it — so the root stays declaration-light and
//! carries no coverable `impl` header (the llvm-cov phantom this module tree is
//! arranged around).

use super::{AppModel, Deriver, Roots, Snapshot};
use crate::projects::runner::BlRunner;
use crate::state::{DirtySet, latest_snapshot, new_snapshot_cell};
use crate::ui_state::{Clock, UiState};
use crate::watch::Mark;
use std::path::PathBuf;
use std::sync::Arc;

impl AppModel {
    /// Build the model **and** the worker's [`Deriver`], taking the first
    /// derivation synchronously so the engine answers real content from its
    /// first gesture rather than an empty snapshot.
    ///
    /// Returned as a pair rather than spawned here: the thread is the caller's
    /// ([`Engine::boot`](crate::engine::Engine::boot) hands it a wake hook; a
    /// test drives `step()` by hand), and a model that spawned its own thread
    /// could not be exercised deterministically. This is the same shape the
    /// watch bridge always had.
    pub fn boot(
        roots: Roots,
        clock: Arc<dyn Clock>,
        balls: Box<dyn BlRunner>,
        user: Option<String>,
    ) -> (Self, Deriver) {
        let ui = UiState::open(roots.ui_json());
        let dirty = DirtySet::default();
        let cell = new_snapshot_cell(Arc::new(Snapshot::empty(clock.unix())));
        let mut deriver = Deriver::new(
            roots.clone(),
            Arc::clone(&clock),
            balls,
            dirty.clone(),
            Arc::clone(&cell),
        );
        deriver.boot();
        let snap = latest_snapshot(&cell);
        let model = Self {
            snap,
            roots,
            ui,
            cell,
            clock,
            dirty,
            identity_user: user,
        };
        (model, deriver)
    }

    /// Tell the worker a root changed (§7.2). The model's *only* outbound
    /// signal: a dispatched verb names the root it touched and the worker's
    /// ordinary routing does the rest, so there is no second path in.
    pub(crate) fn mark_dirty<I: IntoIterator<Item = PathBuf>>(&self, roots: I) {
        self.dirty
            .mark_all(roots.into_iter().map(|r| (r, Mark::Watch)));
    }
}