feat(task-orchestration): add task orchestration console

lib/task-orchestrator.js

@@ -100,6 +100,22 @@ function buildTaskTitle(target, explicitTitle = '') {
     return truncateText(normalizedTarget.replace(/\s+/g, ' '), 96);
 }
 
+
+function normalizeTaskEngine(value) {
+    const normalized = normalizeId(value, 'openai-chat');
+    if (normalized === 'workflow') return 'workflow';
+    // Legacy plans used the name `codex`; the execution base is now OpenAI Chat compatible.
+    return 'openai-chat';
+}
+
+function normalizeTaskNodeKind(value) {
+    const normalized = normalizeId(value, 'openai-chat');
+    if (normalized === 'workflow') return 'workflow';
+    if (normalized === 'codex') return 'openai-chat';
+    if (normalized === 'openai' || normalized === 'openai-chat' || normalized === 'chat') return 'openai-chat';
+    return normalized;
+}
+
 function normalizeDependencyIds(value = []) {
     return uniqueStringList(value)
         .map((depId) => normalizeId(depId, ''))
@@ -193,7 +209,7 @@ function detectDependencyCycle(nodes = []) {
     return false;
 }
 
-function buildCodexNodePrompt(kind, context = {}) {
+function buildOpenAiChatNodePrompt(kind, context = {}) {
     const title = normalizeText(context.title, 160);
     const target = normalizeText(context.target, 4000);
     const item = normalizeText(context.item, 1200);
@@ -267,7 +283,7 @@ function buildTaskPlan(request = {}, options = {}) {
     const workflowMap = normalizeWorkflowCatalog(options.workflowCatalog || []);
     const target = normalizeText(request.target, 4000);
     const title = buildTaskTitle(target, request.title);
-    const engine = normalizeId(request.engine, 'codex') === 'workflow' ? 'workflow' : 'codex';
+    const engine = normalizeTaskEngine(request.engine);
     const allowWrite = request.allowWrite === true;
     const dryRun = request.dryRun === true;
     const concurrency = normalizePositiveInteger(request.concurrency, 2, 1, 8);
@@ -313,8 +329,8 @@ function buildTaskPlan(request = {}, options = {}) {
         nodes.push({
             id: analysisId,
             title: '现状分析',
-            kind: 'codex',
-            prompt: buildCodexNodePrompt('analysis', {
+            kind: 'openai-chat',
+            prompt: buildOpenAiChatNodePrompt('analysis', {
                 title,
                 target,
                 allowWrite: false
@@ -333,8 +349,8 @@ function buildTaskPlan(request = {}, options = {}) {
             nodes.push({
                 id: nodeId,
                 title: truncateText(item, 72) || `执行 ${executionNodeIds.length}`,
-                kind: 'codex',
-                prompt: buildCodexNodePrompt('work', {
+                kind: 'openai-chat',
+                prompt: buildOpenAiChatNodePrompt('work', {
                     title,
                     target,
                     item,
@@ -351,8 +367,8 @@ function buildTaskPlan(request = {}, options = {}) {
         nodes.push({
             id: verifyId,
             title: '验证与总结',
-            kind: 'codex',
-            prompt: buildCodexNodePrompt('verify', {
+            kind: 'openai-chat',
+            prompt: buildOpenAiChatNodePrompt('verify', {
                 title,
                 target,
                 allowWrite: false
@@ -371,8 +387,8 @@ function buildTaskPlan(request = {}, options = {}) {
             nodes.push({
                 id: nodeId,
                 title: truncateText(followUp, 72) || `Follow-up ${nodes.length + 1}`,
-                kind: 'codex',
-                prompt: buildCodexNodePrompt('follow-up', {
+                kind: 'openai-chat',
+                prompt: buildOpenAiChatNodePrompt('follow-up', {
                     title,
                     target,
                     allowWrite,
@@ -417,7 +433,7 @@ function validateTaskPlan(plan, options = {}) {
     }
 
     const workflowMap = normalizeWorkflowCatalog(options.workflowCatalog || []);
-    const engine = normalizeId(plan.engine, 'codex') === 'workflow' ? 'workflow' : 'codex';
+    const engine = normalizeTaskEngine(plan.engine);
     const workflowIds = uniqueStringList(plan.workflowIds || []).map((id) => normalizeId(id, '')).filter(Boolean);
     const nodes = Array.isArray(plan.nodes) ? plan.nodes : [];
     if (engine === 'workflow' && workflowIds.length === 0) {
@@ -445,8 +461,8 @@ function validateTaskPlan(plan, options = {}) {
             continue;
         }
         nodeIds.add(id);
-        const kind = normalizeId(node.kind, '');
-        if (kind !== 'workflow' && kind !== 'codex') {
+        const kind = normalizeTaskNodeKind(node.kind);
+        if (kind !== 'workflow' && kind !== 'openai-chat') {
             issues.push({ code: 'task-node-kind-invalid', message: `task node ${id} has unsupported kind: ${node.kind || ''}` });
         }
         if (kind === 'workflow') {
@@ -457,7 +473,7 @@ function validateTaskPlan(plan, options = {}) {
                 issues.push({ code: 'task-node-workflow-unknown', message: `task node ${id} references unknown workflow: ${workflowId}` });
             }
         }
-        if (kind === 'codex' && !normalizeText(node.prompt, 12000)) {
+        if (kind === 'openai-chat' && !normalizeText(node.prompt, 12000)) {
             issues.push({ code: 'task-node-prompt-required', message: `task node ${id} missing prompt` });
         }
     }
@@ -492,7 +508,7 @@ function createNodeRunRecord(node, dependencyNodeIds = []) {
     return {
         id: normalizeId(node && node.id, ''),
         title: normalizeText(node && node.title, 160),
-        kind: normalizeId(node && node.kind, ''),
+        kind: normalizeTaskNodeKind(node && node.kind),
         workflowId: normalizeId(node && node.workflowId, ''),
         dependsOn: normalizeDependencyIds(node && node.dependsOn),
         dependencyNodeIds: uniqueStringList(dependencyNodeIds),