codetether-agent 4.5.7

A2A-native AI coding agent for the CodeTether ecosystem
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
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175

//! TUI application state — the central `AppState` struct and its methods.
//!
//! Methods are split into focused submodules by concern:
//!
//! - `agent_profile` — spawned agent types and profile lookup
//! - `profile_defs` — named profile constants
//! - `slash_commands` — `/command` constant table
//! - `input_cursor` — cursor movement and text editing
//! - `slash_suggest` — slash autocomplete suggestion methods
//! - `scroll` — chat scroll sentinel scheme and tool-preview scroll
//! - `session_nav` — session list filtering and selection
//! - `worker_bridge` — A2A worker connection state
//! - `history` — command history ↑/↓ navigation
//! - `model_picker` — async model refresh from providers
//! - `model_picker_nav` — synchronous model picker navigation
//! - `timing` — request latency tracking
//! - `steering` — queued steering messages
//! - `settings_nav` — settings selection and view-mode switching
//! - `message_cache` — render-line cache for performance

#![allow(dead_code)]

pub mod agent_profile;
pub mod default_impl;
pub mod history;
pub mod input_cursor;
pub mod input_edit;
pub mod message_cache;
pub mod model_picker;
pub mod model_picker_nav;
pub mod profile_defs;
pub mod scroll;
pub mod session_nav;
pub mod settings_nav;
pub mod slash_commands;
pub mod slash_suggest;
pub mod steering;
pub mod timing;
pub mod worker_bridge;

#[cfg(test)]
mod tests;

// Re-exports so external `use crate::tui::app::state::X` still works.
pub use agent_profile::{SpawnedAgent, agent_profile};
pub use profile_defs::AgentProfile;
pub use slash_commands::SLASH_COMMANDS;

use std::collections::{HashMap, HashSet, VecDeque};
use std::sync::Arc;
use std::time::Instant;

use crate::session::{ImageAttachment, SessionSummary};
use crate::tui::bus_log::BusLogState;
use crate::tui::chat::message::ChatMessage;
use crate::tui::help::HelpScrollState;
use crate::tui::models::{InputMode, ViewMode};
use crate::tui::ralph_view::RalphViewState;
use crate::tui::swarm_view::SwarmViewState;
use crate::tui::symbol_search::SymbolSearchState;
use crate::tui::worker_bridge::IncomingTask;

pub use crate::session::SessionEvent;

#[derive(Default)]
pub struct App {
    pub state: AppState,
}

pub struct AppState {
    pub view_mode: ViewMode,
    pub input_mode: InputMode,
    pub messages: Vec<ChatMessage>,
    pub input: String,
    pub input_cursor: usize,
    pub input_scroll: usize,
    pub chat_scroll: usize,
    pub chat_last_max_scroll: usize,
    pub tool_preview_scroll: usize,
    pub tool_preview_last_max_scroll: usize,
    pub status: String,
    pub processing: bool,
    pub session_id: Option<String>,
    pub sessions: Vec<SessionSummary>,
    pub selected_session: usize,
    pub session_filter: String,
    pub cwd_display: String,
    pub bus_log: BusLogState,
    pub swarm: SwarmViewState,
    pub ralph: RalphViewState,
    pub symbol_search: SymbolSearchState,
    pub slash_suggestions: Vec<String>,
    pub selected_slash_suggestion: usize,
    pub command_history: Vec<String>,
    pub history_index: Option<usize>,
    pub worker_id: Option<String>,
    pub worker_name: Option<String>,
    pub a2a_connected: bool,
    pub recent_tasks: Vec<String>,
    pub worker_bridge_registered_agents: HashSet<String>,
    pub worker_bridge_processing_state: Option<bool>,
    pub worker_task_queue: VecDeque<IncomingTask>,
    pub help_scroll: HelpScrollState,
    pub show_help: bool,
    pub available_models: Vec<String>,
    pub selected_model_index: usize,
    pub model_picker_active: bool,
    pub model_filter: String,
    pub streaming_text: String,
    pub processing_started_at: Option<Instant>,
    pub current_request_first_token_ms: Option<u64>,
    pub current_request_last_token_ms: Option<u64>,
    pub last_request_first_token_ms: Option<u64>,
    pub last_request_last_token_ms: Option<u64>,
    pub last_completion_model: Option<String>,
    pub last_completion_latency_ms: Option<u64>,
    pub last_completion_prompt_tokens: Option<usize>,
    pub last_completion_output_tokens: Option<usize>,
    pub last_tool_name: Option<String>,
    pub last_tool_latency_ms: Option<u64>,
    pub last_tool_success: Option<bool>,
    pub pending_images: Vec<ImageAttachment>,
    pub queued_steering: Vec<String>,
    pub auto_apply_edits: bool,
    pub allow_network: bool,
    pub slash_autocomplete: bool,
    pub use_worktree: bool,
    pub selected_settings_index: usize,
    pub mcp_registry: Arc<crate::tui::app::mcp::TuiMcpRegistry>,
    pub spawned_agents: HashMap<String, SpawnedAgent>,
    pub active_spawned_agent: Option<String>,
    pub streaming_agent_texts: HashMap<String, String>,
    pub cached_message_lines: Vec<ratatui::text::Line<'static>>,
    pub cached_messages_len: usize,
    pub cached_max_width: usize,
    pub cached_streaming_snapshot: Option<String>,
    pub cached_processing: bool,
    pub cached_frozen_len: usize,
    pub watchdog_notification: Option<super::watchdog::WatchdogNotification>,
    pub main_watchdog_root_prompt: Option<String>,
    pub main_last_event_at: Option<Instant>,
    pub main_watchdog_restart_count: u32,
    pub main_inflight_prompt: Option<String>,
    pub okr_repository: Option<Arc<crate::okr::OkrRepository>>,
    pub pending_okr_approval: Option<super::okr_gate::PendingOkrApproval>,
    pub pending_smart_switch_retry: Option<crate::tui::app::smart_switch::PendingSmartSwitchRetry>,
    pub smart_switch_retry_count: u32,
    pub smart_switch_attempted_models: Vec<String>,
    pub chat_sync_rx:
        Option<tokio::sync::mpsc::UnboundedReceiver<crate::tui::chat::sync::ChatSyncUiEvent>>,
    pub chat_sync_status: Option<String>,
    pub chat_sync_last_success: Option<String>,
    pub chat_sync_last_error: Option<String>,
    pub chat_sync_uploaded_bytes: u64,
    pub chat_sync_uploaded_batches: u64,
    pub autochat: super::autochat::state::AutochatState,
    pub file_picker_dir: std::path::PathBuf,
    pub file_picker_entries: Vec<crate::tui::app::file_picker::FilePickerEntry>,
    pub file_picker_selected: usize,
    pub file_picker_filter: String,
    pub file_picker_active: bool,
    pub workspace: crate::tui::models::WorkspaceSnapshot,
    pub chat_layout_mode: crate::tui::ui::webview::layout_mode::ChatLayoutMode,
    /// Cancel handle for the in-flight provider turn. Notifying this
    /// interrupts the current LLM stream so a user steering message can
    /// be applied immediately instead of waiting for the turn to finish.
    pub current_turn_cancel: Option<Arc<tokio::sync::Notify>>,
    /// Timestamp of the previous key event. Used to detect paste bursts
    /// on terminals that don't forward bracketed-paste markers — if a
    /// bare `Enter` arrives within `PASTE_BURST_WINDOW_MS` of the last
    /// key, we treat it as an embedded newline in pasted text instead
    /// of a submit, so pasting multi-line content doesn't emit one
    /// chat message per line.
    pub last_key_at: Option<Instant>,
}