routa-core 0.18.1

Routa.js core domain — models, stores, protocols, and JSON-RPC (transport-agnostic)
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

//! Shared application state for the axum server.

use std::sync::Arc;

use crate::acp::{
    docker::{DockerDetector, DockerProcessManager},
    AcpBinaryManager, AcpInstallationState, AcpManager, AcpPaths, AcpRuntimeManager,
    AcpWarmupService,
};
use crate::db::Database;
use crate::events::EventBus;
use crate::sandbox::SandboxManager;
use crate::skills::SkillRegistry;
use crate::store::{
    AcpSessionStore, AgentStore, ArtifactStore, CodebaseStore, ConversationStore, KanbanStore,
    NoteStore, ScheduleStore, TaskStore, WorkspaceStore, WorktreeStore,
};

/// Docker state for managing Docker-based agent execution.
#[derive(Default)]
pub struct DockerState {
    pub detector: DockerDetector,
    pub process_manager: DockerProcessManager,
}

/// Shared state accessible by all API handlers.
pub struct AppStateInner {
    pub db: Database,
    pub workspace_store: WorkspaceStore,
    pub codebase_store: CodebaseStore,
    pub worktree_store: WorktreeStore,
    pub agent_store: AgentStore,
    pub artifact_store: ArtifactStore,
    pub task_store: TaskStore,
    pub kanban_store: KanbanStore,
    pub note_store: NoteStore,
    pub schedule_store: ScheduleStore,
    pub conversation_store: ConversationStore,
    pub acp_session_store: AcpSessionStore,
    pub skill_registry: SkillRegistry,
    pub acp_manager: AcpManager,
    pub event_bus: EventBus,
    pub acp_paths: AcpPaths,
    pub acp_binary_manager: AcpBinaryManager,
    pub acp_installation_state: AcpInstallationState,
    pub acp_runtime_manager: AcpRuntimeManager,
    pub acp_warmup_service: AcpWarmupService,
    pub docker_state: DockerState,
    pub sandbox_manager: SandboxManager,
}

pub type AppState = Arc<AppStateInner>;

impl AppStateInner {
    pub fn new(db: Database) -> Self {
        let acp_paths = AcpPaths::new();
        let acp_binary_manager = AcpBinaryManager::new(acp_paths.clone());
        let acp_installation_state = AcpInstallationState::new(acp_paths.clone());
        let acp_runtime_manager = AcpRuntimeManager::new(acp_paths.clone());
        let acp_warmup_service = AcpWarmupService::new(acp_paths.clone());
        Self {
            workspace_store: WorkspaceStore::new(db.clone()),
            codebase_store: CodebaseStore::new(db.clone()),
            worktree_store: WorktreeStore::new(db.clone()),
            agent_store: AgentStore::new(db.clone()),
            artifact_store: ArtifactStore::new(db.clone()),
            task_store: TaskStore::new(db.clone()),
            kanban_store: KanbanStore::new(db.clone()),
            note_store: NoteStore::new(db.clone()),
            schedule_store: ScheduleStore::new(db.clone()),
            conversation_store: ConversationStore::new(db.clone()),
            acp_session_store: AcpSessionStore::new(db.clone()),
            skill_registry: SkillRegistry::new(),
            acp_manager: AcpManager::new(),
            event_bus: EventBus::new(),
            db,
            acp_paths,
            acp_binary_manager,
            acp_installation_state,
            acp_runtime_manager,
            acp_warmup_service,
            docker_state: DockerState::default(),
            sandbox_manager: SandboxManager::new(),
        }
    }
}