routa-server 0.15.3

Routa.js HTTP Server — axum adapter on top of routa-core
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
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146

//! Docker-based ACP agent API routes.
//!
//! Provides endpoints for Docker environment status, image management,
//! and Docker-based agent execution.

use axum::{
    extract::{Query, State},
    routing::{get, post},
    Json, Router,
};
use serde::{Deserialize, Serialize};

use crate::error::ServerError;
use crate::state::AppState;
use routa_core::acp::docker::{DockerContainerConfig, DockerStatus};

pub fn router() -> Router<AppState> {
    Router::new()
        .route("/status", get(docker_status))
        .route("/pull", post(docker_pull))
        .route("/containers", get(list_containers))
        .route("/container/start", post(start_container))
        .route("/container/stop", post(stop_container))
}

/// Query params for Docker status.
#[derive(Debug, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct DockerStatusQuery {
    #[serde(default)]
    force_refresh: bool,
}

/// GET /api/acp/docker/status — Check Docker availability.
async fn docker_status(
    State(state): State<AppState>,
    Query(query): Query<DockerStatusQuery>,
) -> Result<Json<DockerStatus>, ServerError> {
    let status = state
        .docker_state
        .detector
        .check_availability(query.force_refresh)
        .await;

    Ok(Json(status))
}

/// Request body for Docker image pull.
#[derive(Debug, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct DockerPullRequest {
    pub image: String,
}

/// POST /api/acp/docker/pull — Pull a Docker image.
async fn docker_pull(
    State(state): State<AppState>,
    Json(body): Json<DockerPullRequest>,
) -> Result<Json<serde_json::Value>, ServerError> {
    let result = state.docker_state.detector.pull_image(&body.image).await;

    Ok(Json(serde_json::json!({
        "ok": result.ok,
        "image": result.image,
        "output": result.output,
        "error": result.error,
    })))
}

/// GET /api/acp/docker/containers — List running Docker containers.
async fn list_containers(
    State(state): State<AppState>,
) -> Result<Json<serde_json::Value>, ServerError> {
    let containers = state.docker_state.process_manager.list_containers().await;

    Ok(Json(serde_json::json!({
        "containers": containers,
    })))
}

/// Request body for starting a Docker container.
#[derive(Debug, Deserialize)]
#[serde(rename_all = "camelCase")]
pub struct StartContainerRequest {
    pub session_id: String,
    pub image: String,
    pub workspace_path: String,
    #[serde(skip_serializing_if = "Option::is_none")]
    pub auth_json: Option<String>,
}

/// POST /api/acp/docker/container/start — Start a Docker container for an agent session.
async fn start_container(
    State(state): State<AppState>,
    Json(body): Json<StartContainerRequest>,
) -> Result<Json<serde_json::Value>, ServerError> {
    let config = DockerContainerConfig {
        session_id: body.session_id.clone(),
        image: body.image,
        workspace_path: body.workspace_path,
        env: None,
        additional_volumes: None,
        labels: None,
        container_port: None,
        auth_json: body.auth_json,
    };

    match state
        .docker_state
        .process_manager
        .start_container(config)
        .await
    {
        Ok(info) => Ok(Json(serde_json::json!({
            "ok": true,
            "container": info,
        }))),
        Err(e) => Ok(Json(serde_json::json!({
            "ok": false,
            "error": e,
        }))),
    }
}

/// Request body for stopping a Docker container.
#[derive(Debug, Deserialize, Serialize)]
#[serde(rename_all = "camelCase")]
pub struct StopContainerRequest {
    pub session_id: String,
}

/// POST /api/acp/docker/container/stop — Stop a Docker container.
async fn stop_container(
    State(state): State<AppState>,
    Json(body): Json<StopContainerRequest>,
) -> Result<Json<serde_json::Value>, ServerError> {
    match state
        .docker_state
        .process_manager
        .stop_container(&body.session_id)
        .await
    {
        Ok(()) => Ok(Json(serde_json::json!({ "ok": true }))),
        Err(e) => Ok(Json(serde_json::json!({ "ok": false, "error": e }))),
    }
}