bitrouter-providers 0.26.0

BitRouter provider adapters — HTTP client, auth, streaming
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
68
69
70
71

//! ACP-specific operational types.
//!
//! Protocol-neutral agent session types (events, permissions, stop reasons)
//! live in `bitrouter_core::agents::event`. This module retains types that
//! are specific to ACP agent discovery, installation, and subprocess
//! management.

use std::path::PathBuf;

use bitrouter_core::agents::event::{AgentEvent, PermissionRequestId, PermissionResponse};
use tokio::sync::mpsc;

/// Commands sent to an agent's dedicated OS thread.
pub(crate) enum AgentCommand {
    /// Submit a prompt. The agent thread sends events to `reply_tx` for
    /// this turn, then drops it when the turn ends.
    Prompt {
        text: String,
        reply_tx: mpsc::Sender<AgentEvent>,
    },
    /// Resolve a pending permission request.
    RespondPermission {
        request_id: PermissionRequestId,
        response: PermissionResponse,
    },
    /// Graceful shutdown.
    Disconnect,
}

/// How an agent was discovered and how it should be launched.
#[derive(Debug, Clone)]
pub enum AgentAvailability {
    /// Binary found on PATH at this location.
    OnPath(PathBuf),
    /// Not on PATH, but can be launched or installed via distribution metadata.
    Distributable,
}

/// An agent discovered during startup (on PATH or via distribution metadata).
#[derive(Debug, Clone)]
pub struct DiscoveredAgent {
    pub name: String,
    pub binary: PathBuf,
    pub args: Vec<String>,
    pub availability: AgentAvailability,
}

/// Progress of a binary agent installation.
#[derive(Debug, Clone)]
pub enum InstallProgress {
    /// Downloading the archive.
    Downloading {
        bytes_received: u64,
        total: Option<u64>,
    },
    /// Extracting the archive.
    Extracting,
    /// Installation completed successfully.
    Done(PathBuf),
    /// Installation failed.
    Failed(String),
}

// Compile-time assertions: all public types must be Send.
const _: () = {
    const fn _assert<T: Send>() {}
    _assert::<AgentCommand>();
    _assert::<AgentAvailability>();
    _assert::<DiscoveredAgent>();
    _assert::<InstallProgress>();
};