feat: add codex support and optimize runtime transport

.gitignore

@@ -20,6 +20,12 @@ playwright-report/
 !.env.example
 !.env.sample
 
+# Local provider config
+.claude/
+.codex/
+.codex
+.superpowers/
+
 # Logs
 *.log
 npm-debug.log*
@@ -38,5 +44,6 @@ Thumbs.db
 output
 .tmp
 .playwright-cli
+.playwright-mcp
 .artifacts/
 .worktrees/

apps/server/Cargo.toml

@@ -17,5 +17,6 @@ serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 sha2 = "0.10"
 tokio = { version = "1.40", features = ["rt-multi-thread", "macros", "process", "signal", "time"] }
+toml = "0.8"
 tower-http = { version = "0.6", features = ["cors", "fs"] }
 url = "2"

apps/server/src/app.rs

@@ -13,7 +13,11 @@ use tokio::sync::broadcast;
 
 use crate::{
     auth::{ip_guard::IpGuardMap, AuthRuntime},
-    models::{ExecTarget, TransportEvent},
+    models::{
+        ExecTarget, GitChangeEntry, GitStatus, SessionInfo, TransportEvent, WorkspaceTree,
+        WorktreeInfo,
+    },
+    services::artifact_cache::TimedCache,
     AppHandle,
 };
 
@@ -36,6 +40,8 @@ pub(crate) struct TerminalRuntime {
     pub killer: Mutex<Box<dyn ChildKiller + Send + Sync>>,
     pub writer: Mutex<Option<Box<dyn Write + Send>>>,
     pub master: Mutex<Box<dyn MasterPty + Send>>,
+    pub output: Mutex<String>,
+    pub persist_workspace_terminal: bool,
     pub process_id: Option<u32>,
     pub process_group_leader: Option<i32>,
 }
@@ -52,19 +58,44 @@ pub(crate) struct WorkspaceWatchSuppression {
     pub until: Instant,
 }
 
+#[derive(Clone)]
+pub(crate) struct ArtifactCaches {
+    pub git_status: TimedCache<GitStatus>,
+    pub git_changes: TimedCache<Vec<GitChangeEntry>>,
+    pub workspace_tree: TimedCache<WorkspaceTree>,
+    pub worktree_list: TimedCache<Vec<WorktreeInfo>>,
+}
+
+impl Default for ArtifactCaches {
+    fn default() -> Self {
+        Self {
+            git_status: Arc::new(Mutex::new(HashMap::new())),
+            git_changes: Arc::new(Mutex::new(HashMap::new())),
+            workspace_tree: Arc::new(Mutex::new(HashMap::new())),
+            worktree_list: Arc::new(Mutex::new(HashMap::new())),
+        }
+    }
+}
+
 pub(crate) struct AppState {
     pub db: Mutex<Option<Connection>>,
     pub auth: Mutex<AuthRuntime>,
     pub agents: Mutex<HashMap<String, Arc<AgentRuntime>>>,
     pub terminals: Mutex<HashMap<String, Arc<TerminalRuntime>>>,
+    pub live_sessions: Mutex<HashMap<String, SessionInfo>>,
+    pub session_runtime_bindings: Mutex<HashMap<String, u64>>,
+    pub terminal_runtime_bindings: Mutex<HashMap<u64, String>>,
     pub workspace_client_connections: Mutex<HashMap<String, usize>>,
     pub workspace_watches: Mutex<HashMap<String, WorkspaceWatch>>,
     pub workspace_watch_suppressions: Arc<Mutex<HashMap<String, WorkspaceWatchSuppression>>>,
     pub next_terminal_id: Mutex<u64>,
     pub ip_guard: Mutex<IpGuardMap>,
     pub hook_endpoint: Mutex<Option<String>>,
     pub http_endpoint: Mutex<Option<String>>,
+    pub artifact_caches: ArtifactCaches,
     pub transport_events: broadcast::Sender<TransportEvent>,
+    #[cfg(test)]
+    pub terminal_write_log: Mutex<Vec<(String, u64, String, crate::models::TerminalWriteOrigin)>>,
 }
 
 impl Default for AppState {
@@ -75,14 +106,20 @@ impl Default for AppState {
             auth: Mutex::new(AuthRuntime::default()),
             agents: Mutex::new(HashMap::new()),
             terminals: Mutex::new(HashMap::new()),
+            live_sessions: Mutex::new(HashMap::new()),
+            session_runtime_bindings: Mutex::new(HashMap::new()),
+            terminal_runtime_bindings: Mutex::new(HashMap::new()),
             workspace_client_connections: Mutex::new(HashMap::new()),
             workspace_watches: Mutex::new(HashMap::new()),
             workspace_watch_suppressions: Arc::new(Mutex::new(HashMap::new())),
             next_terminal_id: Mutex::new(1),
             ip_guard: Mutex::new(HashMap::new()),
             hook_endpoint: Mutex::new(None),
             http_endpoint: Mutex::new(None),
+            artifact_caches: ArtifactCaches::default(),
             transport_events,
+            #[cfg(test)]
+            terminal_write_log: Mutex::new(Vec::new()),
         }
     }
 }