spec-ai 0.6.12

A framework for building AI agents with structured outputs, policy enforcement, and execution tracking
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
61
62
63
64
65
66
67

mod backend;
mod handlers;
mod models;
mod state;
mod ui;

use anyhow::Result;
use backend::{spawn_backend, BackendEvent, BackendHandle, BackendRequest};
use handlers::{handle_event, on_tick};
use crate::spec_ai_tui::{
    app::{App, AppRunner},
    buffer::Buffer,
    event::Event,
    geometry::Rect,
};
use state::AppState;
use std::path::PathBuf;
use std::sync::Mutex;

struct SpecAiTuiApp {
    backend_tx: tokio::sync::mpsc::UnboundedSender<BackendRequest>,
    backend_rx: Mutex<Option<tokio::sync::mpsc::UnboundedReceiver<BackendEvent>>>,
}

impl SpecAiTuiApp {
    fn new(handle: BackendHandle) -> Self {
        Self {
            backend_tx: handle.request_tx,
            backend_rx: Mutex::new(Some(handle.event_rx)),
        }
    }
}

impl App for SpecAiTuiApp {
    type State = AppState;

    fn init(&self) -> Self::State {
        let rx = self
            .backend_rx
            .lock()
            .expect("backend receiver poisoned")
            .take()
            .expect("backend receiver already taken");
        AppState::new(rx)
    }

    fn handle_event(&mut self, event: Event, state: &mut Self::State) -> bool {
        handle_event(event, state, &self.backend_tx)
    }

    fn on_tick(&mut self, state: &mut Self::State) {
        on_tick(state);
    }

    fn render(&self, state: &Self::State, area: Rect, buf: &mut Buffer) {
        ui::render(state, area, buf);
    }
}

/// Run the spec-ai TUI app, optionally providing an explicit config path.
pub async fn run_tui(config_path: Option<PathBuf>) -> Result<()> {
    let backend = spawn_backend(config_path)?;
    let app = SpecAiTuiApp::new(backend);
    let mut runner = AppRunner::new(app)?;
    runner.run().await?;
    Ok(())
}