appctl 0.3.0

One command. Any app. Full AI control. The universal AI CLI for any web app, database, or service.
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

use anyhow::Result;
use tokio::sync::mpsc;
use uuid::Uuid;

use crate::{
    ai::run_agent,
    config::{AppConfig, ConfigPaths},
    executor::ExecutionContext,
    safety::SafetyMode,
    sync::{load_schema, load_tools},
};

#[derive(Debug, Clone)]
pub struct RunOptions {
    pub prompt: String,
    pub provider: Option<String>,
    pub model: Option<String>,
    pub read_only: bool,
    pub dry_run: bool,
    pub confirm: bool,
    pub strict: bool,
}

pub async fn run_once(paths: &ConfigPaths, config: &AppConfig, options: RunOptions) -> Result<()> {
    let schema = load_schema(paths)?;
    let tools = load_tools(paths)?;
    let (tx, rx) = mpsc::channel(64);
    let printer = tokio::spawn(crate::term::run_event_printer(rx));
    let response = run_agent(
        paths,
        config,
        options.provider.as_deref(),
        options.model.as_deref(),
        &options.prompt,
        &tools,
        &schema,
        ExecutionContext {
            session_id: Uuid::new_v4().to_string(),
            safety: SafetyMode {
                read_only: options.read_only,
                dry_run: options.dry_run,
                confirm: options.confirm,
                strict: options.strict,
            },
        },
        Some(tx),
    )
    .await;
    let _ = printer.await;
    let response = response?;

    if !matches!(response, serde_json::Value::String(_)) {
        println!("{}", serde_json::to_string_pretty(&response)?);
    }
    Ok(())
}