feat(kanban): add task queueing mechanism with priority support (ACS-220)

.github/workflows/test-azure-auth.yml

@@ -0,0 +1,21 @@
+name: Test Azure Auth
+
+on:
+  workflow_dispatch:
+
+jobs:
+  test-auth:
+    runs-on: windows-latest
+    permissions:
+      id-token: write
+      contents: read
+    steps:
+      - name: Azure Login (OIDC)
+        uses: azure/login@v2
+        with:
+          client-id: ${{ secrets.AZURE_CLIENT_ID }}
+          tenant-id: ${{ secrets.AZURE_TENANT_ID }}
+          subscription-id: ${{ secrets.AZURE_SUBSCRIPTION_ID }}
+
+      - name: Success
+        run: echo "Azure authentication successful!"

README.md

@@ -22,11 +22,12 @@
 <!-- STABLE_DOWNLOADS -->
 | Platform | Download |
 |----------|----------|
-| **Windows** | [Auto-Claude-2.7.2-win32-x64.exe](https://github.com/AndyMik90/Auto-Claude/releases/download/v2.7.2/Auto-Claude-2.7.2-win32-x64.exe) |
-| **macOS (Apple Silicon)** | [Auto-Claude-2.7.2-darwin-arm64.dmg](https://github.com/AndyMik90/Auto-Claude/releases/download/v2.7.2/Auto-Claude-2.7.2-darwin-arm64.dmg) |
-| **macOS (Intel)** | [Auto-Claude-2.7.2-darwin-x64.dmg](https://github.com/AndyMik90/Auto-Claude/releases/download/v2.7.2/Auto-Claude-2.7.2-darwin-x64.dmg) |
-| **Linux** | [Auto-Claude-2.7.2-linux-x86_64.AppImage](https://github.com/AndyMik90/Auto-Claude/releases/download/v2.7.2/Auto-Claude-2.7.2-linux-x86_64.AppImage) |
-| **Linux (Debian)** | [Auto-Claude-2.7.2-linux-amd64.deb](https://github.com/AndyMik90/Auto-Claude/releases/download/v2.7.2/Auto-Claude-2.7.2-linux-amd64.deb) |
+| **Windows** | [Auto-Claude-2.7.3-win32-x64.exe](https://github.com/AndyMik90/Auto-Claude/releases/download/v2.7.3/Auto-Claude-2.7.3-win32-x64.exe) |
+| **macOS (Apple Silicon)** | [Auto-Claude-2.7.3-darwin-arm64.dmg](https://github.com/AndyMik90/Auto-Claude/releases/download/v2.7.3/Auto-Claude-2.7.3-darwin-arm64.dmg) |
+| **macOS (Intel)** | [Auto-Claude-2.7.3-darwin-x64.dmg](https://github.com/AndyMik90/Auto-Claude/releases/download/v2.7.3/Auto-Claude-2.7.3-darwin-x64.dmg) |
+| **Linux** | [Auto-Claude-2.7.3-linux-x86_64.AppImage](https://github.com/AndyMik90/Auto-Claude/releases/download/v2.7.3/Auto-Claude-2.7.3-linux-x86_64.AppImage) |
+| **Linux (Debian)** | [Auto-Claude-2.7.3-linux-amd64.deb](https://github.com/AndyMik90/Auto-Claude/releases/download/v2.7.3/Auto-Claude-2.7.3-linux-amd64.deb) |
+| **Linux (Flatpak)** | [Auto-Claude-2.7.3-linux-x86_64.flatpak](https://github.com/AndyMik90/Auto-Claude/releases/download/v2.7.3/Auto-Claude-2.7.3-linux-x86_64.flatpak) |
 <!-- STABLE_DOWNLOADS_END -->
 
 ### Beta Release

apps/backend/core/worktree.py

@@ -647,7 +647,29 @@ def merge_worktree(
         result = self._run_git(merge_args)
 
         if result.returncode != 0:
-            print("Merge conflict! Aborting merge...")
+            # Check if it's "already up to date" - not an error
+            output = (result.stdout + result.stderr).lower()
+            if "already up to date" in output or "already up-to-date" in output:
+                print(f"Branch {info.branch} is already up to date.")
+                if no_commit:
+                    print("No changes to stage.")
+                if delete_after:
+                    self.remove_worktree(spec_name, delete_branch=True)
+                return True
+            # Check for actual conflicts
+            if "conflict" in output:
+                print("Merge conflict! Aborting merge...")
+                self._run_git(["merge", "--abort"])
+                return False
+            # Other error - show details
+            stderr_msg = (
+                result.stderr[:200]
+                if result.stderr
+                else result.stdout[:200]
+                if result.stdout
+                else "<no output>"
+            )
+            print(f"Merge failed: {stderr_msg}")
             self._run_git(["merge", "--abort"])
             return False
 

apps/frontend/src/main/index.ts

@@ -28,6 +28,7 @@ import { setupIpcHandlers } from './ipc-setup';
 import { AgentManager } from './agent';
 import { TerminalManager } from './terminal-manager';
 import { pythonEnvManager } from './python-env-manager';
+import { TaskQueueManager } from './task-queue-manager';
 import { getUsageMonitor } from './claude-profile/usage-monitor';
 import { initializeUsageMonitorForwarding } from './ipc-handlers/terminal-handlers';
 import { initializeAppUpdater } from './app-updater';
@@ -122,6 +123,7 @@ function getIconPath(): string {
 // Keep a global reference of the window object to prevent garbage collection
 let mainWindow: BrowserWindow | null = null;
 let agentManager: AgentManager | null = null;
+let taskQueueManager: TaskQueueManager | null = null;
 let terminalManager: TerminalManager | null = null;
 
 function createWindow(): void {
@@ -265,6 +267,12 @@ app.whenReady().then(() => {
   // Initialize agent manager
   agentManager = new AgentManager();
 
+  // Initialize task queue manager (must be after agentManager)
+  // agentManager is passed twice because: (1) it's the task execution manager,
+  // and (2) AgentManager extends EventEmitter and emits task lifecycle events
+  // that TaskQueueManager listens to (e.g., 'exit' events)
+  taskQueueManager = new TaskQueueManager(agentManager, agentManager);
+
   // Load settings and configure agent manager with Python and auto-claude paths
   // Uses EAFP pattern (try/catch) instead of LBYL (existsSync) to avoid TOCTOU race conditions
   const settingsPath = join(app.getPath('userData'), 'settings.json');
@@ -345,7 +353,7 @@ app.whenReady().then(() => {
   terminalManager = new TerminalManager(() => mainWindow);
 
   // Setup IPC handlers (pass pythonEnvManager for Python path management)
-  setupIpcHandlers(agentManager, terminalManager, () => mainWindow, pythonEnvManager);
+  setupIpcHandlers(agentManager, terminalManager, () => mainWindow, pythonEnvManager, taskQueueManager);
 
   // Create window
   createWindow();
@@ -430,6 +438,11 @@ app.on('before-quit', async () => {
   usageMonitor.stop();
   console.warn('[main] Usage monitor stopped');
 
+  // Clean up task queue manager
+  if (taskQueueManager) {
+    taskQueueManager.stop();
+  }
+
   // Kill all running agent processes
   if (agentManager) {
     await agentManager.killAll();

apps/frontend/src/main/ipc-handlers/agent-events-handlers.ts

@@ -15,6 +15,7 @@ import type {
   TaskStatus,
   Project,
   ImplementationPlan,
+  QueueStatus,
 } from "../../shared/types";
 import { AgentManager } from "../agent";
 import type { ProcessType, ExecutionProgressData } from "../agent";
@@ -354,4 +355,12 @@ export function registerAgenteventsHandlers(
     const { project } = findTaskAndProject(taskId);
     safeSendToRenderer(getMainWindow, IPC_CHANNELS.TASK_ERROR, taskId, error, project?.id);
   });
+
+  // ============================================
+  // Queue Events → Renderer
+  // ============================================
+
+  agentManager.on('queue-status-update', (projectId: string, status: QueueStatus) => {
+    safeSendToRenderer(getMainWindow, IPC_CHANNELS.QUEUE_STATUS_UPDATE, projectId, status);
+  });
 }

apps/frontend/src/main/ipc-handlers/index.ts

@@ -9,6 +9,7 @@ import type { BrowserWindow } from 'electron';
 import { AgentManager } from '../agent';
 import { TerminalManager } from '../terminal-manager';
 import { PythonEnvManager } from '../python-env-manager';
+import { TaskQueueManager } from '../task-queue-manager';
 
 // Import all handler registration functions
 import { registerProjectHandlers } from './project-handlers';
@@ -34,6 +35,7 @@ import { registerMcpHandlers } from './mcp-handlers';
 import { registerProfileHandlers } from './profile-handlers';
 import { registerTerminalWorktreeIpcHandlers } from './terminal';
 import { notificationService } from '../notification-service';
+import { registerQueueHandlers } from './queue-handlers';
 
 /**
  * Setup all IPC handlers across all domains
@@ -42,12 +44,14 @@ import { notificationService } from '../notification-service';
  * @param terminalManager - The terminal manager instance
  * @param getMainWindow - Function to get the main BrowserWindow
  * @param pythonEnvManager - The Python environment manager instance
+ * @param taskQueueManager - The task queue manager instance (optional)
  */
 export function setupIpcHandlers(
   agentManager: AgentManager,
   terminalManager: TerminalManager,
   getMainWindow: () => BrowserWindow | null,
-  pythonEnvManager: PythonEnvManager
+  pythonEnvManager: PythonEnvManager,
+  taskQueueManager: TaskQueueManager | null = null
 ): void {
   // Initialize notification service
   notificationService.initialize(getMainWindow);
@@ -58,6 +62,13 @@ export function setupIpcHandlers(
   // Task handlers
   registerTaskHandlers(agentManager, pythonEnvManager, getMainWindow);
 
+  // Queue handlers (must be after task handlers)
+  if (taskQueueManager) {
+    registerQueueHandlers(taskQueueManager);
+  } else {
+    console.warn('[IPC] TaskQueueManager is null, skipping queue handler registration');
+  }
+
   // Terminal and Claude profile handlers
   registerTerminalHandlers(terminalManager, getMainWindow);
 
@@ -144,5 +155,6 @@ export {
   registerDebugHandlers,
   registerClaudeCodeHandlers,
   registerMcpHandlers,
-  registerProfileHandlers
+  registerProfileHandlers,
+  registerQueueHandlers
 };

apps/frontend/src/main/ipc-handlers/queue-handlers.ts

@@ -0,0 +1,114 @@
+/**
+ * Queue IPC Handlers
+ *
+ * Handles IPC communication for queue configuration and status operations.
+ * These handlers bridge the renderer process queue store with the main process
+ * TaskQueueManager.
+ */
+
+import { ipcMain } from 'electron';
+import { TaskQueueManager } from '../task-queue-manager';
+import { projectStore } from '../project-store';
+import { QUEUE_MIN_CONCURRENT, QUEUE_MAX_CONCURRENT } from '../../shared/constants/task';
+import { IPC_CHANNELS } from '../../shared/constants/ipc';
+import type { QueueConfig, QueueStatus } from '../../shared/types';
+import { debugLog, debugError } from '../../shared/utils/debug-logger';
+
+/**
+ * Register queue-related IPC handlers
+ */
+export function registerQueueHandlers(taskQueueManager: TaskQueueManager): void {
+  debugLog('[IPC] Registering queue handlers...');
+  /**
+   * Get queue configuration for a project
+   */
+  ipcMain.handle(IPC_CHANNELS.QUEUE_GET_CONFIG, async (_event, projectId: string) => {
+    try {
+      const project = projectStore.getProject(projectId);
+      if (!project?.settings.queueConfig) {
+        return {
+          success: true,
+          data: { enabled: false, maxConcurrent: QUEUE_MIN_CONCURRENT }
+        };
+      }
+      return {
+        success: true,
+        data: project.settings.queueConfig
+      };
+    } catch (error) {
+      return {
+        success: false,
+        error: error instanceof Error ? error.message : 'Failed to get queue config'
+      };
+    }
+  });
+
+  /**
+   * Set queue configuration for a project
+   */
+  ipcMain.handle(IPC_CHANNELS.QUEUE_SET_CONFIG, async (_event, projectId: string, config: QueueConfig) => {
+    try {
+      const project = projectStore.getProject(projectId);
+      if (!project) {
+        return {
+          success: false,
+          error: 'Project not found'
+        };
+      }
+
+      // Validate maxConcurrent is an integer between MIN and MAX
+      if (!Number.isInteger(config.maxConcurrent)) {
+        return {
+          success: false,
+          error: `maxConcurrent must be an integer`
+        };
+      }
+      if (config.maxConcurrent < QUEUE_MIN_CONCURRENT || config.maxConcurrent > QUEUE_MAX_CONCURRENT) {
+        return {
+          success: false,
+          error: `maxConcurrent must be between ${QUEUE_MIN_CONCURRENT} and ${QUEUE_MAX_CONCURRENT}`
+        };
+      }
+
+      // Update project settings
+      projectStore.updateProjectSettings(projectId, {
+        queueConfig: config
+      });
+
+      // Trigger queue if enabled (starts tasks from backlog)
+      if (config.enabled) {
+        // Trigger asynchronously, don't wait for it
+        taskQueueManager.triggerQueue(projectId).catch((error) => {
+          debugError('[IPC] Failed to trigger queue:', error);
+        });
+      }
+
+      return { success: true };
+    } catch (error) {
+      return {
+        success: false,
+        error: error instanceof Error ? error.message : 'Failed to set queue config'
+      };
+    }
+  });
+
+  /**
+   * Get queue status for a project (includes running/backlog counts)
+   */
+  ipcMain.handle(IPC_CHANNELS.QUEUE_GET_STATUS, async (_event, projectId: string) => {
+    try {
+      const status = taskQueueManager.getQueueStatus(projectId);
+      return {
+        success: true,
+        data: status
+      };
+    } catch (error) {
+      return {
+        success: false,
+        error: error instanceof Error ? error.message : 'Failed to get queue status'
+      };
+    }
+  });
+
+  debugLog('[IPC] Queue handlers registered successfully');
+}

apps/frontend/src/main/ipc-setup.ts

@@ -9,6 +9,7 @@ import type { BrowserWindow } from 'electron';
 import { AgentManager } from './agent';
 import { TerminalManager } from './terminal-manager';
 import { PythonEnvManager } from './python-env-manager';
+import { TaskQueueManager } from './task-queue-manager';
 import { setupIpcHandlers as setupModularHandlers } from './ipc-handlers';
 
 /**
@@ -32,18 +33,21 @@ import { setupIpcHandlers as setupModularHandlers } from './ipc-handlers';
  * - ideation-handlers.ts: Ideation generation
  * - changelog-handlers.ts: Changelog operations
  * - insights-handlers.ts: AI insights chat
+ * - queue-handlers.ts: Task queue configuration and status
  *
  * @param agentManager - The agent manager instance
  * @param terminalManager - The terminal manager instance
  * @param getMainWindow - Function to get the main BrowserWindow
  * @param pythonEnvManager - The Python environment manager instance
+ * @param taskQueueManager - The task queue manager instance (optional)
  */
 export function setupIpcHandlers(
   agentManager: AgentManager,
   terminalManager: TerminalManager,
   getMainWindow: () => BrowserWindow | null,
-  pythonEnvManager: PythonEnvManager
+  pythonEnvManager: PythonEnvManager,
+  taskQueueManager: TaskQueueManager | null = null
 ): void {
   // Delegate to modular handler setup
-  setupModularHandlers(agentManager, terminalManager, getMainWindow, pythonEnvManager);
+  setupModularHandlers(agentManager, terminalManager, getMainWindow, pythonEnvManager, taskQueueManager);
 }