crabtalk 0.0.16

Run autonomous agents with built-in LLM inference
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

//! Crabtalk CLI binary entry point.

use anyhow::Result;
use clap::Parser;
use crabtalk::Cli;

#[tokio::main]
async fn main() -> Result<()> {
    rustls::crypto::ring::default_provider()
        .install_default()
        .expect("failed to install rustls crypto provider");

    let cli = Cli::parse();

    let level = match cli.log_filter() {
        Some(f) => {
            // Set RUST_LOG so spawned child services inherit the same level.
            // SAFETY: called in main before spawning any threads.
            unsafe { std::env::set_var("RUST_LOG", f) };
            parse_level(f)
        }
        None => std::env::var("RUST_LOG")
            .ok()
            .map(|v| parse_level(&v))
            .unwrap_or(tracing::Level::WARN),
    };
    tracing_subscriber::fmt()
        .with_max_level(level)
        .without_time()
        .with_target(false)
        .init();

    cli.run().await
}

/// Extract the most specific level from a filter string like "crabtalk=debug".
fn parse_level(s: &str) -> tracing::Level {
    let level_str = s.rsplit('=').next().unwrap_or(s);
    match level_str.to_lowercase().as_str() {
        "trace" => tracing::Level::TRACE,
        "debug" => tracing::Level::DEBUG,
        "info" => tracing::Level::INFO,
        "error" => tracing::Level::ERROR,
        _ => tracing::Level::WARN,
    }
}