malvin 0.2.4

Non-interactive research and coding agent
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

#![allow(dead_code, unused_imports)]

mod active;
mod config;
mod emit;
mod enrich;
mod sink;
mod sink_build;
mod tool_enrich;
mod types;

#[cfg(test)]
#[path = "tests_active.rs"]
mod tests_active;

#[cfg(test)]
mod test_fixtures;

#[cfg(test)]
pub(crate) mod tests;

#[cfg(test)]
#[path = "tests_plan.rs"]
mod tests_plan;

#[cfg(test)]
#[path = "tests_cursor_store.rs"]
mod tests_cursor_store;

pub(crate) use active::{
    SharedDeferSink, flush_pending_into as flush_pending_into_active_sink,
    register as register_active_sink, unregister as unregister_active_sink,
};
pub(crate) use sink::DeferredLogSink;
pub(crate) use sink_build::{
    build_acp_tee_entry, build_display_log_entry, build_raw_line_entry, build_tool_entry,
};
pub(crate) use tool_enrich::tool_drain_enrich_fields;
pub(crate) use types::{AcpTeeBuild, DeferredEntry, TeeSinkMeta, ToolSummaryBuild};

pub(crate) fn log_with_heartbeat(sink: &mut DeferredLogSink, entry: DeferredEntry) {
    if !active::defer_already_has_heartbeat(sink)
        && let Some((display, log)) =
            crate::output::heartbeat_rendered_if_due(std::time::Instant::now(), true)
        {
            crate::output::publish_heartbeat_live_terminal(&display);
            sink.push_entry(build_display_log_entry(display, log));
        }
    sink.push_entry(entry);
}

pub(crate) fn install_stdout_hooks() {
    static INSTALLED: std::sync::OnceLock<()> = std::sync::OnceLock::new();
    INSTALLED.get_or_init(|| {
        crate::output::register_defer_stdout_hooks(defer_tagged_stdout_hook, defer_heartbeat_hook);
    });
}

fn defer_tagged_stdout_hook(display: &str, log: &str) -> bool {
    active::try_log(build_display_log_entry(
        display.to_string(),
        log.to_string(),
    ))
}

fn defer_heartbeat_hook(display: &str, log: &str) -> bool {
    let show_live = !active::heartbeat_live_pending();
    if !active::try_push(build_display_log_entry(
        display.to_string(),
        log.to_string(),
    )) {
        return false;
    }
    if show_live && !active::defer_sink_mutex_held() {
        crate::output::publish_heartbeat_live_terminal(display);
    }
    true
}

#[cfg(test)]
#[path = "hook_tests.rs"]
mod hook_tests;

#[cfg(test)]
#[path = "deferred_log_kiss_cov_tests.rs"]
mod deferred_log_kiss_cov_tests;