feat: 新增端到端烟雾测试脚本，增强项目连接和任务初始化验证

DeadWaveWave · DeadWaveWave · commit a897933a7be2 · 2025-10-08T22:28:55.000+08:00
- 在 scripts 目录下新增 e2e-smoke.mjs 和 e2e-smoke.ts 文件，提供端到端烟雾测试功能
- 测试项目连接和任务初始化，确保文档正确落在连接的项目 .wave 目录下
- 更新现有测试用例，确保路径和面板内容的正确性
- 所有相关测试通过，确保代码质量和功能一致性
diff --git a/scripts/e2e-smoke.mjs b/scripts/e2e-smoke.mjs
@@ -0,0 +1,61 @@
+import fs from 'fs-extra';
+import path from 'path';
+import { fileURLToPath } from 'url';
+import { ProjectManager } from '../dist/esm/core/project-manager.js';
+import { TaskManager } from '../dist/esm/core/task-manager.js';
+import { ConnectProjectTool } from '../dist/esm/tools/handshake-tools.js';
+import { CurrentTaskInitTool } from '../dist/esm/tools/task-tools.js';
+
+const __dirname = path.dirname(fileURLToPath(import.meta.url));
+
+async function main() {
+  const base = path.join(process.cwd(), 'test-temp', 'e2e-smoke-js');
+  const projectDir = path.join(base, 'my-project');
+  await fs.remove(base).catch(() => {});
+  await fs.ensureDir(projectDir);
+
+  const pm = new ProjectManager();
+  const tm = new TaskManager(path.join(projectDir, '.wave'), pm);
+
+  const connect = new ConnectProjectTool(pm, tm);
+  const res = await connect.handle({ project_path: projectDir });
+  const conn = JSON.parse(res.content[0].text);
+  if (!conn.success || !conn.data.connected) {
+    console.error('Connect failed:', conn);
+    process.exit(1);
+  }
+
+  const init = new CurrentTaskInitTool(tm);
+  const initRes = await init.handle({
+    title: 'E2E Smoke Task',
+    goal: 'Ensure docs land under connected project .wave',
+    overall_plan: [],
+    knowledge_refs: [],
+  });
+  const initPayload = JSON.parse(initRes.content[0].text);
+  if (!initPayload.success) {
+    console.error('Init task failed:', initPayload);
+    process.exit(1);
+  }
+
+  const waveDir = path.join(projectDir, '.wave');
+  const jsonPath = path.join(waveDir, 'current-task.json');
+  const mdPath = path.join(waveDir, 'current-task.md');
+
+  const exists = {
+    waveDir: await fs.pathExists(waveDir),
+    currentTaskJson: await fs.pathExists(jsonPath),
+    currentTaskMd: await fs.pathExists(mdPath),
+  };
+
+  const tasksDir = path.join(waveDir, 'tasks');
+  const hasTasksDir = await fs.pathExists(tasksDir);
+
+  console.log(JSON.stringify({ projectDir, waveDir, exists, hasTasksDir }, null, 2));
+}
+
+main().catch((e) => {
+  console.error('E2E smoke failed:', e);
+  process.exit(1);
+});
+
diff --git a/scripts/e2e-smoke.ts b/scripts/e2e-smoke.ts
@@ -0,0 +1,71 @@
+import * as fs from 'fs-extra';
+import * as path from 'path';
+import { ProjectManager } from '../src/core/project-manager.js';
+import { TaskManager } from '../src/core/task-manager.js';
+import { ConnectProjectTool } from '../src/tools/handshake-tools.js';
+import { CurrentTaskInitTool } from '../src/tools/task-tools.js';
+
+async function main() {
+  const base = path.join(process.cwd(), 'test-temp', 'e2e-smoke');
+  const projectDir = path.join(base, 'my-project');
+  await fs.remove(base).catch(() => {});
+  await fs.ensureDir(projectDir);
+
+  const projectManager = new ProjectManager();
+  const taskManager = new TaskManager(path.join(projectDir, '.wave'), projectManager);
+
+  const connect = new ConnectProjectTool(projectManager, taskManager);
+  const res = await connect.handle({ project_path: projectDir });
+  const conn = JSON.parse(res.content[0].text);
+  if (!conn.success || !conn.data.connected) {
+    console.error('Connect failed:', conn);
+    process.exit(1);
+  }
+
+  const init = new CurrentTaskInitTool(taskManager);
+  const initRes = await init.handle({
+    title: 'E2E Smoke Task',
+    goal: 'Ensure docs land under connected project .wave',
+    overall_plan: [],
+    knowledge_refs: [],
+  });
+  const initPayload = JSON.parse(initRes.content[0].text);
+  if (!initPayload.success) {
+    console.error('Init task failed:', initPayload);
+    process.exit(1);
+  }
+
+  const waveDir = path.join(projectDir, '.wave');
+  const jsonPath = path.join(waveDir, 'current-task.json');
+  const mdPath = path.join(waveDir, 'current-task.md');
+
+  const exists = {
+    waveDir: await fs.pathExists(waveDir),
+    currentTaskJson: await fs.pathExists(jsonPath),
+    currentTaskMd: await fs.pathExists(mdPath),
+  };
+
+  // Also verify multi-task directory
+  const tasksDir = path.join(waveDir, 'tasks');
+  const hasTasksDir = await fs.pathExists(tasksDir);
+  let taskSubDirCount = 0;
+  if (hasTasksDir) {
+    const years = (await fs.readdir(tasksDir)).filter(async (y) => (await fs.stat(path.join(tasksDir, y))).isDirectory());
+    // Best-effort: count nested directories
+    taskSubDirCount = (await fs.readdir(tasksDir)).length;
+  }
+
+  console.log(JSON.stringify({
+    projectDir,
+    waveDir,
+    exists,
+    hasTasksDir,
+    taskSubDirCount,
+  }, null, 2));
+}
+
+main().catch((e) => {
+  console.error('E2E smoke failed:', e);
+  process.exit(1);
+});
+
diff --git a/src/core/project-manager.ts b/src/core/project-manager.ts
@@ -110,10 +110,30 @@ export class ProjectManager {
 
     try {
       // 验证项目是否仍然有效
-      const projectRecord = await this.projectRegistry.resolveProject(
+      let projectRecord = await this.projectRegistry.resolveProject(
         this.activeBinding.project_id
       );
 
+      // 当全局注册表不可用或未持久化时，回退到本地 .wave/project.json 验证
+      if (!projectRecord && this.activeBinding.root) {
+        try {
+          const localInfo = await this.projectRegistry.loadByPath(
+            this.activeBinding.root
+          );
+          if (localInfo && localInfo.id === this.activeBinding.project_id) {
+            projectRecord = {
+              id: localInfo.id,
+              root: this.activeBinding.root,
+              slug: localInfo.slug,
+              origin: localInfo.origin,
+              last_seen: new Date().toISOString(),
+            };
+          }
+        } catch {
+          // ignore and keep projectRecord as null
+        }
+      }
+
       if (!projectRecord) {
         // 项目已失效，清除绑定
         this.activeBinding = null;
diff --git a/src/core/project-registry.ts b/src/core/project-registry.ts
@@ -213,12 +213,19 @@ export class ProjectRegistry {
         error: error instanceof Error ? error.message : String(error),
       });
 
-      // 如果是超时错误，不抛出异常，只记录警告
-      if (error instanceof Error && error.message.includes('超时')) {
+      // 以下错误视为非致命：超时、权限不足、只读文件系统
+      const msg = error instanceof Error ? error.message : String(error);
+      if (
+        msg.includes('超时') ||
+        msg.includes('EPERM') ||
+        msg.includes('EACCES') ||
+        msg.toLowerCase().includes('permission') ||
+        msg.toLowerCase().includes('read-only')
+      ) {
         logger.warning(
           LogCategory.Task,
           LogAction.Update,
-          '全局注册表更新超时，跳过此操作',
+          '全局注册表不可写，跳过更新（不影响主要功能）',
           {
             projectId: record.id,
           }
diff --git a/src/core/task-manager.ts b/src/core/task-manager.ts
@@ -206,12 +206,14 @@ export class TaskManager {
    */
   getCurrentTaskPanelPath(): string | null {
     try {
-      // current-task.md 应该在 .wave 目录下
-      const panelPath = path.join(this.docsPath, 'current-task.md');
+      // 如果有活跃项目，优先使用该项目的 .wave 目录
+      const active = this.projectManager?.getActiveProject();
+      if (active?.root) {
+        return path.join(active.root, '.wave', 'current-task.md');
+      }
 
-      // 不检查文件是否存在，直接返回路径
-      // 这样在同步检测时可以正确找到路径
-      return panelPath;
+      // 回退到初始化时的 docsPath
+      return path.join(this.docsPath, 'current-task.md');
     } catch (error) {
       return null;
     }
@@ -286,7 +288,8 @@ export class TaskManager {
     if (!effectiveProjectId) {
       const activeProject = this.projectManager.getActiveProject();
       if (activeProject) {
-        effectiveProjectId = activeProject.root;
+        // 使用项目ID而不是root路径以兼容 resolveProject 要求
+        effectiveProjectId = activeProject.project_id;
       } else {
         // 没有活动项目,使用默认路径
         return this.docsPath;
@@ -456,7 +459,8 @@ export class TaskManager {
         expectedResults: task.expectedResults || [],
         createdAt: task.created_at,
         updatedAt: task.updated_at,
-        projectId: this.projectManager?.getActiveProject()?.root || '',
+        // 使用活动项目的ID作为 projectId，避免与路径混淆
+        projectId: this.projectManager?.getActiveProject()?.project_id || '',
         panelModTime, // 传递面板修改时间
       };
 
@@ -809,7 +813,7 @@ export class TaskManager {
 
       // 如果没有传入 projectId，尝试从当前活动项目获取
       const effectiveProjectId =
-        projectId || this.projectManager?.getActiveProject()?.root;
+        projectId || this.projectManager?.getActiveProject()?.project_id;
 
       const taskPath = await this.resolveTaskPath(effectiveProjectId);
 
@@ -1168,19 +1172,19 @@ export class TaskManager {
 
     // 同时保存到多任务目录结构
     try {
+      // 使用当前项目的 .wave 路径初始化目录管理器，避免写入服务器启动目录
+      const docsPathForProject = await this.resolveProjectPath(projectId);
+      const projectDirManager = new MultiTaskDirectoryManager(docsPathForProject);
+
       // 检查任务是否已经存在于多任务目录中
-      const existingTaskDir =
-        await this.multiTaskDirectoryManager.findTaskDirectory(task.id);
+      const existingTaskDir = await projectDirManager.findTaskDirectory(task.id);
 
       if (existingTaskDir) {
         // 更新现有任务
-        await this.multiTaskDirectoryManager.updateTaskInDirectory(
-          task,
-          existingTaskDir
-        );
+        await projectDirManager.updateTaskInDirectory(task, existingTaskDir);
       } else {
         // 创建新的任务目录
-        await this.multiTaskDirectoryManager.saveTaskToDirectory(task);
+        await projectDirManager.saveTaskToDirectory(task);
       }
     } catch (error) {
       // 多任务目录保存失败不应该影响主要功能
@@ -1787,7 +1791,18 @@ export class TaskManager {
    */
   async getTaskHistory(): Promise<any[]> {
     try {
-      const historyDir = path.join(this.docsPath, 'history');
+      // 优先使用当前绑定项目的 .wave 路径
+      let activeProjectId: string | undefined;
+      try {
+        // 访问活跃项目（存在则使用其 project_id）
+        const active = this.projectManager?.getActiveProject();
+        if (active?.project_id) {
+          activeProjectId = active.project_id;
+        }
+      } catch {}
+
+      const docsPath = await this.resolveProjectPath(activeProjectId);
+      const historyDir = path.join(docsPath, 'history');
 
       if (!(await fs.pathExists(historyDir))) {
         return [];
diff --git a/src/tests/deep-e2e-test.test.ts b/src/tests/deep-e2e-test.test.ts
@@ -59,7 +59,8 @@ describe('深度端到端测试 - 设计文档符合性验证', () => {
 
   // 辅助函数：读取并显示面板内容
   async function readAndLogPanel(stepName: string): Promise<string> {
-    const panelPath = path.join(tempDir, '.wave', 'current-task.md');
+    // 文档现按绑定项目落在 testProjectPath/.wave 下
+    const panelPath = path.join(testProjectPath, '.wave', 'current-task.md');
     if (await fs.pathExists(panelPath)) {
       const content = await fs.readFile(panelPath, 'utf-8');
       console.log(`\n========== ${stepName} - current-task.md 内容 ==========`);
@@ -73,7 +74,7 @@ describe('深度端到端测试 - 设计文档符合性验证', () => {
 
   // 辅助函数：手动编辑面板
   async function editPanel(modifier: (content: string) => string): Promise<void> {
-    const panelPath = path.join(tempDir, '.wave', 'current-task.md');
+    const panelPath = path.join(testProjectPath, '.wave', 'current-task.md');
     const content = await fs.readFile(panelPath, 'utf-8');
     const modified = modifier(content);
     await fs.writeFile(panelPath, modified, 'utf-8');
diff --git a/src/tests/design-consistency-verification.test.ts b/src/tests/design-consistency-verification.test.ts
diff --git a/src/tests/task-e2e-user-workflow.test.ts b/src/tests/task-e2e-user-workflow.test.ts
diff --git a/src/tools/multi-task-tools.ts b/src/tools/multi-task-tools.ts
