atomwrite 0.1.37

Atomic file operations CLI for LLM agents — read, write, edit, search, replace with NDJSON output
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

// SPDX-License-Identifier: MIT OR Apache-2.0

//! v0.1.37 source guards for the retry and memory work (T3b).
//!
//! These pin design decisions that a behavioural test cannot see: which
//! primitive a module uses. Each assertion names the rule it protects.

const WATCH: &str = include_str!("../src/commands/watch.rs");
const LOCK: &str = include_str!("../src/lock.rs");
const PERSIST: &str = include_str!("../src/atomic/persist_retry.rs");
const SEARCH_STREAM: &str = include_str!("../src/commands/search_stream.inc.rs");
const CONCURRENCY: &str = include_str!("../src/concurrency.rs");

#[test]
fn watch_uses_a_bounded_channel() {
    assert!(
        WATCH.contains("sync_channel("),
        "watch must feed its event loop through a bounded channel"
    );
    assert!(
        !WATCH.contains("mpsc::channel") && !WATCH.contains(" channel()"),
        "an unbounded std channel lets a burst of events grow the queue without limit"
    );
}

#[test]
fn lock_and_persist_wait_through_the_retry_module() {
    assert!(
        LOCK.contains("crate::retry::"),
        "lock.rs must use src/retry.rs"
    );
    assert!(
        PERSIST.contains("crate::retry::"),
        "persist_retry.rs must use src/retry.rs"
    );
    for (name, src) in [("lock.rs", LOCK), ("persist_retry.rs", PERSIST)] {
        assert!(
            !src.contains("thread::sleep"),
            "{name} must not sleep on its own: a fixed sleep has no jitter, no deadline and no cancel"
        );
    }
}

#[test]
fn search_pipeline_is_bounded_in_bytes() {
    assert!(
        SEARCH_STREAM.contains("budget()"),
        "search events must go through the global byte budget"
    );
    assert!(
        !SEARCH_STREAM.contains("unbounded("),
        "the search pipeline must not use an unbounded channel"
    );
}

#[test]
fn rayon_pool_is_built_on_demand() {
    let lib = include_str!("../src/lib.rs");
    assert!(
        lib.contains("plan_global_pool"),
        "run() must plan the pool, not build it for every command"
    );
    assert!(
        !lib.contains("configure_global_pool("),
        "run() must not build the rayon pool unconditionally"
    );
    assert!(
        CONCURRENCY.contains("MAX_AUTO_THREADS"),
        "the automatic worker bound must keep its hard ceiling"
    );
}