feat: conductor polish, semantic indexing, web app provider

Phase 5: Conductor Polish
- Enforce agent concurrency limits (Rust: count_running_agents vs preference)
- Live agent detection on kanban board (pulsing green badge)
- Per-issue workspace isolation (workspace_id FK on agent_tasks)
- Multi-turn agent sessions (--resume session_id in Claude Code adapter)
- Symphony-style orchestrator (plan→code→review pipeline with retry)

Phase 6: Semantic Indexing
- Regex-based symbol extraction (TS/JS/Python/Rust/Go)
- Jaccard similarity duplicate detection
- analyzeDiffForDuplicates() findings for review-core

Phase 7: Web App
- DataProvider abstraction (TauriProvider + HttpProvider)
- Auto-detect environment (Tauri vs browser)

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: sarthakagrawal927

apps/desktop/src-tauri/src/adapters/claude_code.rs

@@ -46,6 +46,7 @@ impl AgentAdapter for ClaudeCodeAdapter {
         project_path: PathBuf,
         role: Option<String>,
         task: Option<String>,
+        resume_session_id: Option<String>,
     ) -> Result<AgentHandle, String> {
         let cli_path =
             Self::detect_cli().ok_or("Claude Code CLI not found. Install it first.")?;
@@ -58,6 +59,12 @@ impl AgentAdapter for ClaudeCodeAdapter {
         });
 
         let mut cmd = Command::new(&cli_path);
+
+        if let Some(ref session_id) = resume_session_id {
+            // Resume a previous session with a new prompt
+            cmd.arg("--resume").arg(session_id);
+        }
+
         cmd.arg("-p")
             .arg(&task_prompt)
             .arg("--output-format")

apps/desktop/src-tauri/src/adapters/codex.rs

@@ -43,6 +43,7 @@ impl AgentAdapter for CodexAdapter {
         project_path: PathBuf,
         role: Option<String>,
         task: Option<String>,
+        _resume_session_id: Option<String>,
     ) -> Result<AgentHandle, String> {
         let cli_path =
             Self::detect_cli().ok_or("Codex CLI not found. Install it first.")?;

apps/desktop/src-tauri/src/adapters/mod.rs

@@ -28,11 +28,13 @@ pub trait AgentAdapter: Send + Sync {
 
     /// Spawn an agent process in the given project directory, optionally
     /// scoped to a role and initial task prompt.
+    /// If `resume_session_id` is provided, continue a previous session.
     async fn launch(
         &self,
         project_path: PathBuf,
         role: Option<String>,
         task: Option<String>,
+        resume_session_id: Option<String>,
     ) -> Result<AgentHandle, String>;
 
     /// Gracefully stop a running agent by its ID / PID.

apps/desktop/src-tauri/src/commands/agents.rs

@@ -26,16 +26,34 @@ pub async fn launch_agent(
     role: Option<String>,
     task: Option<String>,
     review_id: Option<String>,
+    resume_session_id: Option<String>,
 ) -> Result<Value, String> {
+    // ── Concurrency check ─────────────────────────────────────────────────
+    {
+        let conn = db.0.lock().map_err(|e| e.to_string())?;
+        let running = queries::count_running_agents(&conn).unwrap_or(0);
+        let max = queries::get_preference(&conn, "max_concurrent_agents")
+            .ok()
+            .flatten()
+            .and_then(|v| v.parse::<i64>().ok())
+            .unwrap_or(3);
+        if running >= max {
+            return Err(format!(
+                "Concurrency limit reached ({running}/{max} agents running). \
+                 Wait for an agent to finish or increase the limit in Settings."
+            ));
+        }
+    }
+
     let handle = match adapter.as_str() {
         "claude-code" => {
             let a = ClaudeCodeAdapter::new();
-            a.launch(PathBuf::from(&project_path), role.clone(), task.clone())
+            a.launch(PathBuf::from(&project_path), role.clone(), task.clone(), resume_session_id.clone())
                 .await?
         }
         "codex" => {
             let a = CodexAdapter::new();
-            a.launch(PathBuf::from(&project_path), role.clone(), task.clone())
+            a.launch(PathBuf::from(&project_path), role.clone(), task.clone(), resume_session_id.clone())
                 .await?
         }
         other => return Err(format!("Unknown adapter: {other}")),

apps/desktop/src-tauri/src/commands/linear.rs

@@ -635,6 +635,7 @@ pub async fn import_linear_issues(
             description: Some(task_description),
             acceptance_criteria: Some(format!("Source: Linear {}", identifier)),
             project_path: None,
+            workspace_id: None,
             status: Some("backlog".to_string()),
         };
 

apps/desktop/src-tauri/src/commands/mission.rs

@@ -11,12 +11,14 @@ pub async fn create_task(
     description: Option<String>,
     acceptance_criteria: Option<String>,
     project_path: Option<String>,
+    workspace_id: Option<String>,
 ) -> Result<Value, String> {
     let input = AgentTaskInput {
         title: title.clone(),
         description,
         acceptance_criteria,
         project_path: project_path.clone(),
+        workspace_id: workspace_id.clone(),
         status: Some("backlog".to_string()),
     };
 

apps/desktop/src-tauri/src/db/schema.rs

@@ -9,6 +9,7 @@ pub fn run_migrations(conn: &Connection) -> Result<(), rusqlite::Error> {
     let _ = conn.execute("ALTER TABLE agent_tasks ADD COLUMN project_path TEXT", []);
     let _ = conn.execute("ALTER TABLE provider_accounts ADD COLUMN plan TEXT", []);
     let _ = conn.execute("ALTER TABLE provider_accounts ADD COLUMN weekly_limit REAL", []);
+    let _ = conn.execute("ALTER TABLE agent_tasks ADD COLUMN workspace_id TEXT REFERENCES workspaces(id)", []);
 
     Ok(())
 }

apps/desktop/src/components/kanban-board.tsx

@@ -1,4 +1,4 @@
-import type { Task } from "@/lib/tauri-ipc";
+import type { Task, AgentProcess } from "@/lib/tauri-ipc";
 import type { LoopState } from "@/lib/review-loop";
 import { Card, CardContent } from "@/components/ui/card";
 import { Badge } from "@/components/ui/badge";
@@ -7,6 +7,7 @@ import { Button } from "@/components/ui/button";
 interface KanbanBoardProps {
   tasks: Task[];
   loopStates?: Map<string, LoopState>;
+  runningAgents?: AgentProcess[];
   onTaskClick?: (task: Task) => void;
   onAddTask?: (column: string) => void;
   onAssignAgent?: (task: Task) => void;
@@ -70,11 +71,13 @@ function ScoreTrend({ history }: { history: LoopState["reviewHistory"] }) {
 function TaskCard({
   task,
   loopState,
+  isAgentRunning,
   onClick,
   onAssign,
 }: {
   task: Task;
   loopState?: LoopState;
+  isAgentRunning?: boolean;
   onClick?: () => void;
   onAssign?: () => void;
 }) {
@@ -102,10 +105,15 @@ function TaskCard({
         <div className="mt-2 flex items-center gap-2">
           {task.assigned_agent ? (
             <div className="flex items-center gap-1">
-              <span className="h-1.5 w-1.5 rounded-full bg-amber-400" />
-              <span className="mono text-[10px] text-amber-400">
+              <span className={`h-1.5 w-1.5 rounded-full ${isAgentRunning ? "bg-emerald-400 animate-pulse" : "bg-amber-400"}`} />
+              <span className={`mono text-[10px] ${isAgentRunning ? "text-emerald-400" : "text-amber-400"}`}>
                 {task.assigned_agent.slice(0, 8)}
               </span>
+              {isAgentRunning && (
+                <span className="text-[9px] font-semibold uppercase tracking-wider text-emerald-400/80">
+                  Live
+                </span>
+              )}
             </div>
           ) : onAssign ? (
             <Button
@@ -128,7 +136,17 @@ function TaskCard({
   );
 }
 
-export default function KanbanBoard({ tasks, loopStates, onTaskClick, onAddTask, onAssignAgent }: KanbanBoardProps) {
+/** Check if a task's assigned agent is currently running by matching project_path. */
+function isTaskAgentRunning(task: Task, runningAgents?: AgentProcess[]): boolean {
+  if (!task.assigned_agent || !runningAgents) return false;
+  return runningAgents.some(
+    (a) =>
+      a.status === "running" &&
+      a.project_path === task.project_path
+  );
+}
+
+export default function KanbanBoard({ tasks, loopStates, runningAgents, onTaskClick, onAddTask, onAssignAgent }: KanbanBoardProps) {
   return (
     <div className="grid grid-cols-5 gap-3 min-w-[750px]">
       {columns.map((col) => {
@@ -176,6 +194,7 @@ export default function KanbanBoard({ tasks, loopStates, onTaskClick, onAddTask,
                     key={task.id}
                     task={task}
                     loopState={loopStates?.get(task.id)}
+                    isAgentRunning={isTaskAgentRunning(task, runningAgents)}
                     onClick={() => onTaskClick?.(task)}
                     onAssign={onAssignAgent ? () => onAssignAgent(task) : undefined}
                   />