crabtalk 0.0.17

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
47
48
49
50
51
52
53
54
55
56
57
58
59
60

//! `crabtalk daemon` — daemon lifecycle management.

use anyhow::Result;
use clap::{Args, Subcommand};

mod logs;
mod service;
mod start;

/// Manage the crabtalk daemon.
#[derive(Args, Debug)]
pub struct Daemon {
    /// Increase log verbosity (-v = info, -vv = debug, -vvv = trace).
    #[arg(short, long, action = clap::ArgAction::Count, global = true)]
    pub verbose: u8,
    #[command(subcommand)]
    pub command: DaemonCommand,
}

#[derive(Subcommand, Debug)]
pub enum DaemonCommand {
    /// Run the daemon in the foreground.
    Run,
    /// Trigger a hot-reload of the running daemon.
    Reload,
    /// View daemon logs (delegates to `tail`).
    ///
    /// Extra flags (e.g. `-f`, `-n 100`, `-t`) are passed through to `tail`.
    /// Defaults to `-n 50` if no flags are given.
    Logs {
        /// Arguments passed through to `tail` (e.g. `-f`, `-n 100`).
        #[arg(trailing_var_arg = true, allow_hyphen_values = true)]
        tail_args: Vec<String>,
    },
    /// Install and start crabtalk as a system service (launchd/systemd).
    Start {
        /// Re-install even if already installed.
        #[arg(short, long)]
        force: bool,
    },
    /// Stop and uninstall the crabtalk system service.
    Stop,
}

impl Daemon {
    pub async fn run(self) -> Result<()> {
        match self.command {
            DaemonCommand::Run => start::start().await,
            DaemonCommand::Reload => {
                let mut runner = crate::cmd::connect_default().await?;
                runner.reload().await?;
                println!("daemon reloaded");
                Ok(())
            }
            DaemonCommand::Logs { tail_args } => logs::logs(&tail_args),
            DaemonCommand::Start { force } => service::install(self.verbose.max(1), force),
            DaemonCommand::Stop => service::uninstall(),
        }
    }
}