agent-block 0.20.0

Lua-first Agent Runtime built on AgentMesh
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
139
140
141
142
143

mod common;

use predicates::prelude::*;
use tempfile::tempdir;

#[test]
fn task_phase1_fixture() {
    let tmp = tempdir().expect("tempdir");
    common::agent_block_cmd()
        .env("AGENT_BLOCK_HOME", tmp.path())
        .args(["-s", &common::fixture("task_phase1.lua")])
        .assert()
        .success()
        .stdout(
            predicate::str::contains("h1.id_type=string")
                .and(predicate::str::contains("v1=42"))
                .and(predicate::str::contains("slept_ok=true"))
                .and(predicate::str::contains("v2=a"))
                .and(predicate::str::contains("v3=b"))
                .and(predicate::str::contains("concurrent_ok=true"))
                .and(predicate::str::contains("h4.name=worker"))
                .and(predicate::str::contains("h5.elapsed_positive=true"))
                .and(predicate::str::contains("yield_ok=true"))
                .and(predicate::str::contains("sql_from_task=from_task"))
                .and(predicate::str::contains("abort_ok=true"))
                .and(predicate::str::contains("done")),
        );
}

#[test]
fn task_phase2_fixture() {
    let tmp = tempdir().expect("tempdir");
    common::agent_block_cmd()
        .env("AGENT_BLOCK_HOME", tmp.path())
        .args(["-s", &common::fixture("task_phase2.lua")])
        .assert()
        .success()
        .stdout(
            predicate::str::contains("scope_elapsed_ok=true")
                .and(predicate::str::contains("scope_children_done=true"))
                .and(predicate::str::contains("scope_name=worker_group"))
                .and(predicate::str::contains("cooperative_cancel_ok=true"))
                .and(predicate::str::contains("timeout_raises=true"))
                .and(predicate::str::contains("timeout_success_val=ok"))
                .and(predicate::str::contains("token_initial=false"))
                .and(predicate::str::contains("token_after_cancel=true"))
                .and(predicate::str::contains("token_check_raises=true"))
                .and(predicate::str::contains("scope_error_propagated=true"))
                .and(predicate::str::contains("sibling_cancelled_ok=true"))
                .and(predicate::str::contains("scope_spawn_join=7"))
                .and(predicate::str::contains("done")),
        );
}

#[test]
fn task_phase3_fixture() {
    let tmp = tempdir().expect("tempdir");
    common::agent_block_cmd()
        .env("AGENT_BLOCK_HOME", tmp.path())
        .args(["-s", &common::fixture("task_phase3.lua")])
        .assert()
        .success()
        .stdout(
            predicate::str::contains("outside_current_nil=true")
                .and(predicate::str::contains("current_id_type=string"))
                .and(predicate::str::contains("current_name=introspect"))
                .and(predicate::str::contains("current_cancelled=false"))
                .and(predicate::str::contains("coro_val=coro_done"))
                .and(predicate::str::contains("coro_sleep_ok=true"))
                .and(predicate::str::contains("coro_yield_val=99"))
                .and(predicate::str::contains("coro_concurrent_ok=true"))
                .and(predicate::str::contains("unknown_driver_rejected=true"))
                .and(predicate::str::contains("coro_current_name=coro_named"))
                .and(predicate::str::contains("done")),
        );
}

#[test]
fn task_phase4_fixture() {
    let tmp = tempdir().expect("tempdir");
    common::agent_block_cmd()
        .env("AGENT_BLOCK_HOME", tmp.path())
        .args(["-s", &common::fixture("task_phase4.lua")])
        .assert()
        .success()
        .stdout(
            predicate::str::contains("timeout_abort_raises=true")
                .and(predicate::str::contains("timeout_abort_bounded=true"))
                .and(predicate::str::contains("a_grandchild_ran=true"))
                .and(predicate::str::contains("b_inner_child_ran=true"))
                .and(predicate::str::contains("unknown_opts_rejected=true"))
                .and(predicate::str::contains("sleep_rejects_inf=true"))
                .and(predicate::str::contains("coro_cancel_bounded=true"))
                .and(predicate::str::contains(
                    "opts_name_non_string_rejected=true",
                ))
                .and(predicate::str::contains(
                    "opts_driver_non_string_rejected=true",
                ))
                .and(predicate::str::contains(
                    "opts_non_string_key_rejected=true",
                ))
                .and(predicate::str::contains("driver_async_fn_alias_ok=true"))
                .and(predicate::str::contains("driver_async_alias_ok=true"))
                .and(predicate::str::contains("grace_zero_raises=true"))
                .and(predicate::str::contains("grace_zero_bounded=true"))
                .and(predicate::str::contains("cleanup_ran=true"))
                .and(predicate::str::contains(
                    "timeout_unknown_opts_rejected=true",
                ))
                .and(predicate::str::contains("grace_non_number_rejected=true"))
                .and(predicate::str::contains("sleep_ms_out_of_range=true"))
                .and(predicate::str::contains("done")),
        );
}

#[test]
fn task_phase5_fixture() {
    let tmp = tempdir().expect("tempdir");
    common::agent_block_cmd()
        .env("AGENT_BLOCK_HOME", tmp.path())
        .args(["-s", &common::fixture("task_phase5.lua")])
        .assert()
        .success()
        .stdout(
            predicate::str::contains("sql_cancel_raises=true")
                .and(predicate::str::contains("sql_cancel_bounded=true"))
                .and(predicate::str::contains("sql_cancel_raises_b=true"))
                .and(predicate::str::contains("sql_cancel_err_match=true"))
                .and(predicate::str::contains("sql_cancel_no_hybrid=true"))
                .and(predicate::str::contains("kv_cancel_raises=true"))
                .and(predicate::str::contains("kv_cancel_bounded=true"))
                .and(predicate::str::contains("kv_cancel_raises_b=true"))
                .and(predicate::str::contains("kv_cancel_err_match=true"))
                .and(predicate::str::contains("kv_cancel_no_hybrid=true"))
                .and(predicate::str::contains("kv_plain_ok=true"))
                .and(predicate::str::contains("sql_plain_ok=true"))
                .and(predicate::str::contains("fan_all_joined=true"))
                .and(predicate::str::contains("fan_values_ok=true"))
                .and(predicate::str::contains("fan_bounded=true"))
                .and(predicate::str::contains("done")),
        );
}