sparrow-cli 0.8.2

A local-first Rust agent cockpit — route, run, replay, rewind
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

// src/cmd_handlers/handle_daemon_cmd.rs
use super::prelude::*;
pub async fn handle_daemon(
    config: &sparrow::config::Config,
    memory: Arc<dyn Memory>,
    scheduler: Arc<MemoryScheduler>,
    recorder: Arc<FsRecorder>,
    skills: Arc<dyn SkillLibrary>,
) -> anyhow::Result<()> {
    use sparrow::engine::Engine;
    use sparrow::router::BasicRouter;

    let providers = build_provider_brains(config, &memory, true);
    let router = Arc::new(BasicRouter::new(config, providers));
    let engine = Arc::new(
        Engine::new(router, config.clone())
            .with_memory(memory.clone())
            .with_skills(skills),
    );
    let event_bus = EventBus::new(256);
    let runtime = SparrowRuntime::new(
        engine,
        scheduler,
        recorder,
        event_bus,
        memory,
        config.clone(),
    );
    runtime.start().await?;
    println!("Sparrow daemon running. API on 127.0.0.1:9337. Ctrl+C to stop.");

    // Background update check — non-blocking, emits UpdateAvailable event
    // to all connected surfaces (WebView, TUI, gateway).
    {
        let bus = runtime.event_bus().clone();
        tokio::spawn(async move {
            tokio::time::sleep(std::time::Duration::from_secs(5)).await;
            if let Some(info) = sparrow::update::check_update() {
                bus.publish(sparrow::event::Event::UpdateAvailable {
                    current: info.current,
                    latest: info.latest,
                    download_url: info.download_url,
                    crate_url: info.crate_url,
                    release_url: info.release_url,
                    install_cmd: info.install_cmd,
                });
            }
        });
    }

    tokio::signal::ctrl_c().await?;
    runtime.stop().await?;
    Ok(())
}