feat(workflows): add track support for conditional chained prompts

add selectedTrack option to filter chained prompts by track
update related interfaces and functions to handle track filtering

Author: moazbuilds

src/agents/runner/chained.ts

@@ -217,6 +217,17 @@ function meetsConditions(entry: ChainedPathEntry, selectedConditions: string[]):
   return entry.conditions.every(c => selectedConditions.includes(c));
 }
 
+/**
+ * Check if track requirement is met
+ * If entry has tracks specified, selectedTrack must be one of them
+ */
+function meetsTracks(entry: ChainedPathEntry, selectedTrack: string | null): boolean {
+  if (typeof entry === 'string') return true;
+  if (!entry.tracks?.length) return true;
+  if (!selectedTrack) return false; // Has track requirement but no track selected
+  return entry.tracks.includes(selectedTrack);
+}
+
 /**
  * Extract path string from entry
  */
@@ -232,24 +243,34 @@ function getPath(entry: ChainedPathEntry): string {
  * @param chainedPromptsPath - Path or array of paths to file(s) or folder(s) containing .md files
  * @param projectRoot - Project root for resolving relative paths
  * @param selectedConditions - User-selected conditions for filtering conditional paths
+ * @param selectedTrack - User-selected track for filtering track-specific paths
  * @returns Array of ChainedPrompt objects sorted by filename within each folder
  */
 export async function loadChainedPrompts(
   chainedPromptsPath: ChainedPathEntry | ChainedPathEntry[],
   projectRoot: string,
-  selectedConditions: string[] = []
+  selectedConditions: string[] = [],
+  selectedTrack: string | null = null
 ): Promise<ChainedPrompt[]> {
   const entries = Array.isArray(chainedPromptsPath) ? chainedPromptsPath : [chainedPromptsPath];
   const allPrompts: ChainedPrompt[] = [];
 
   for (const entry of entries) {
+    // Check both conditions AND tracks (both must pass)
     if (!meetsConditions(entry, selectedConditions)) {
       const pathStr = getPath(entry);
       const conditions = isConditionalPath(entry) ? entry.conditions : [];
       debug(`Skipped chained path: ${pathStr} (unmet conditions: ${conditions?.join(', ')})`);
       continue;
     }
 
+    if (!meetsTracks(entry, selectedTrack)) {
+      const pathStr = getPath(entry);
+      const tracks = isConditionalPath(entry) ? entry.tracks : [];
+      debug(`Skipped chained path: ${pathStr} (unmet tracks: ${tracks?.join(', ')}, selected: ${selectedTrack})`);
+      continue;
+    }
+
     const inputPath = getPath(entry);
     const prompts = await loadPromptsFromPath(inputPath, projectRoot);
     allPrompts.push(...prompts);

src/agents/runner/runner.ts

@@ -144,6 +144,11 @@ export interface ExecuteAgentOptions {
    */
   selectedConditions?: string[];
 
+  /**
+   * Selected track for filtering track-specific chained prompt paths
+   */
+  selectedTrack?: string;
+
   /**
    * Skip writing to agent's log file (caller handles logging externally)
    */
@@ -208,7 +213,7 @@ export async function executeAgent(
   prompt: string,
   options: ExecuteAgentOptions,
 ): Promise<AgentExecutionOutput> {
-  const { workingDir, projectRoot, engine: engineOverride, model: modelOverride, logger, stderrLogger, onTelemetry, abortSignal, timeout, parentId, disableMonitoring, ui, uniqueAgentId, displayPrompt, resumeMonitoringId, resumePrompt, resumeSessionId: resumeSessionIdOption, selectedConditions } = options;
+  const { workingDir, projectRoot, engine: engineOverride, model: modelOverride, logger, stderrLogger, onTelemetry, abortSignal, timeout, parentId, disableMonitoring, ui, uniqueAgentId, displayPrompt, resumeMonitoringId, resumePrompt, resumeSessionId: resumeSessionIdOption, selectedConditions, selectedTrack } = options;
 
   debug(`[AgentRunner] executeAgent called: agentId=%s promptLength=%d`, agentId, prompt.length);
   debug(`[AgentRunner] Options: workingDir=%s engineOverride=%s modelOverride=%s parentId=%s`,
@@ -469,7 +474,8 @@ export async function executeAgent(
       chainedPrompts = await loadChainedPrompts(
         agentConfig.chainedPromptsPath,
         projectRoot ?? workingDir,
-        selectedConditions ?? []
+        selectedConditions ?? [],
+        selectedTrack ?? null
       );
       debug(`[ChainedPrompts] Loaded ${chainedPrompts.length} chained prompts for agent '${agentId}'`);
     } else {

src/shared/agents/config/types.ts

@@ -4,6 +4,7 @@
 export type ConditionalChainedPath = {
   path: string;
   conditions?: string[];
+  tracks?: string[];
 };
 
 /**

src/workflows/recovery/restore.ts

@@ -12,7 +12,7 @@ import { debug } from '../../shared/logging/logger.js';
 import { getNextChainIndex } from '../indexing/lifecycle.js';
 import { loadAgentConfig } from '../../agents/runner/index.js';
 import { loadChainedPrompts } from '../../agents/runner/chained.js';
-import { getSelectedConditions } from '../../shared/workflows/template.js';
+import { getSelectedConditions, getSelectedTrack } from '../../shared/workflows/template.js';
 import { StatusService } from '../../agents/monitoring/index.js';
 import type { CrashRestoreContext, CrashRestoreResult } from './types.js';
 
@@ -70,10 +70,12 @@ export async function restoreFromCrash(ctx: CrashRestoreContext): Promise<CrashR
 
   if (agentConfig?.chainedPromptsPath) {
     const selectedConditions = await getSelectedConditions(cmRoot);
+    const selectedTrack = await getSelectedTrack(cmRoot);
     const chainedPrompts = await loadChainedPrompts(
       agentConfig.chainedPromptsPath,
       cwd,
-      selectedConditions
+      selectedConditions,
+      selectedTrack
     );
 
     if (chainedPrompts.length > 0) {

src/workflows/step/execute.ts

@@ -46,6 +46,8 @@ export interface StepExecutorOptions {
   resumeSessionId?: string;
   /** Selected conditions for filtering conditional chained prompt paths */
   selectedConditions?: string[];
+  /** Selected track for filtering track-specific chained prompt paths */
+  selectedTrack?: string;
   /** Callback when monitoring ID is registered (for early access before execution completes) */
   onMonitoringRegistered?: (monitoringId: number) => void;
 }
@@ -144,6 +146,7 @@ export async function executeStep(
     resumePrompt: options.resumePrompt,
     resumeSessionId: options.resumeSessionId,
     selectedConditions: options.selectedConditions,
+    selectedTrack: options.selectedTrack,
     // Pass emitter as UI so runner can register monitoring ID immediately
     ui: options.emitter,
     // Telemetry auto-forwarding

src/workflows/step/run.ts

@@ -12,7 +12,7 @@ import { getUniqueAgentId } from '../context/index.js';
 import { executeStep } from './execute.js';
 import { selectEngine } from './engine.js';
 import { registry } from '../../infra/engines/index.js';
-import { getSelectedConditions } from '../../shared/workflows/template.js';
+import { getSelectedConditions, getSelectedTrack } from '../../shared/workflows/template.js';
 import { loadAgentConfig } from '../../agents/runner/index.js';
 import { loadChainedPrompts } from '../../agents/runner/chained.js';
 import { beforeRun, afterRun, cleanupRun } from './hooks.js';
@@ -115,14 +115,18 @@ export async function runStepFresh(ctx: RunnerContext): Promise<RunStepResult |
     ctx.emitter.updateAgentModel(uniqueAgentId, resolvedModel);
   }
 
+  // Fetch conditions and track for chained prompt filtering
+  const selectedConditions = await getSelectedConditions(ctx.cmRoot);
+  const selectedTrack = await getSelectedTrack(ctx.cmRoot);
+
   // Pre-load chained prompts from agent config so UI can show step info immediately
   const agentConfig = await loadAgentConfig(step.agentId, ctx.cwd);
   if (agentConfig?.chainedPromptsPath) {
-    const selectedConditions = await getSelectedConditions(ctx.cmRoot);
     const preloadedPrompts = await loadChainedPrompts(
       agentConfig.chainedPromptsPath,
       ctx.cwd,
-      selectedConditions
+      selectedConditions,
+      selectedTrack
     );
     if (preloadedPrompts.length > 0) {
       debug('[step/run] Pre-loaded %d chained prompts for UI', preloadedPrompts.length);
@@ -150,6 +154,8 @@ export async function runStepFresh(ctx: RunnerContext): Promise<RunStepResult |
       emitter: ctx.emitter,
       abortSignal: abortController.signal,
       uniqueAgentId,
+      selectedConditions,
+      selectedTrack: selectedTrack ?? undefined,
     });
 
     debug('[step/run] Step completed');
@@ -289,6 +295,10 @@ export async function runStepResume(
   ctx.machine.send({ type: 'RESUME' });
   ctx.emitter.setWorkflowStatus('running');
 
+  // Fetch conditions and track for chained prompt filtering
+  const selectedConditions = await getSelectedConditions(ctx.cmRoot);
+  const selectedTrack = await getSelectedTrack(ctx.cmRoot);
+
   try {
     const output = await executeStep(step, ctx.cwd, {
       logger: () => {},
@@ -299,6 +309,8 @@ export async function runStepResume(
       resumeMonitoringId: options.resumeMonitoringId,
       resumeSessionId: sessionId,
       resumePrompt: options.resumePrompt,
+      selectedConditions,
+      selectedTrack: selectedTrack ?? undefined,
     });
 
     // Update context with new output