beachcomber 0.4.0

A centralized daemon that caches shell state (git, battery, hostname, etc.) so every consumer reads from one fast cache instead of independently forking shells
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

use beachcomber::config::Config;
use beachcomber::daemon;
use tempfile::TempDir;
use tokio::net::UnixStream;

#[tokio::test]
async fn daemon_shuts_down_on_cancel() {
    let tmp = TempDir::new().unwrap();
    let sock = tmp.path().join("sock");
    let config = Config::default();

    let token = tokio_util::sync::CancellationToken::new();
    let handle = daemon::start_in_process_with_cancel(sock.clone(), config, token.clone());

    tokio::time::sleep(std::time::Duration::from_millis(200)).await;
    assert!(
        UnixStream::connect(&sock).await.is_ok(),
        "Daemon should be running"
    );

    token.cancel();

    let result = tokio::time::timeout(std::time::Duration::from_secs(2), handle).await;
    assert!(result.is_ok(), "Daemon should shut down within timeout");
}