chore(tests): Fix e2e test

Author: LucienShui

src/minio/minio.service.ts

@@ -12,7 +12,7 @@ import { UploadedObjectInfo } from 'minio/dist/main/internal/type';
 
 export interface PutOptions {
   id?: string;
-  metadata?: Record<string, any>; // camel
+  metadata?: Record<string, any>;
   bucket?: string;
   folder?: string;
 }

src/tasks/task-pipeline.e2e-spec.ts

@@ -17,8 +17,11 @@ class MockWizardWorker {
   private isPolling = false;
   private pollingInterval: NodeJS.Timeout | null = null;
   private readonly pollIntervalMs = 500; // Fast polling for tests
+  private readonly namespaceId: string;
 
-  constructor(private readonly client: TestClient) {}
+  constructor(private readonly client: TestClient) {
+    this.namespaceId = client.namespace.id;
+  }
 
   /**
    * Starts polling for tasks and processing them
@@ -87,7 +90,7 @@ class MockWizardWorker {
   private async fetchTask(): Promise<TaskDto | null> {
     try {
       const response = await this.makeRequest()
-        .get('/internal/api/v1/wizard/task')
+        .get(`/internal/api/v1/wizard/task?namespace_id=${this.namespaceId}`)
         .timeout(5000); // 5 second timeout
 
       if (response.status === 204) {
@@ -282,20 +285,16 @@ describe('Task Pipeline (e2e)', () => {
   let client: TestClient;
   let mockWorker: MockWizardWorker;
 
-  beforeAll(async () => {
+  beforeEach(async () => {
     client = await TestClient.create();
     mockWorker = new MockWizardWorker(client);
   });
 
-  afterAll(async () => {
-    await mockWorker.deleteAllTasks();
+  afterEach(async () => {
+    mockWorker.stopPolling();
     await client.close();
   });
 
-  beforeEach(async () => {
-    await mockWorker.deleteAllTasks();
-  });
-
   describe('Basic Task Processing', () => {
     it('create resource trigger upsertIndex', async () => {
       mockWorker.startPolling();

src/wizard/internal.wizard.e2e-spec.ts

@@ -6,11 +6,11 @@ import { gzipSync } from 'zlib';
 describe('InternalWizardController (e2e)', () => {
   let client: TestClient;
 
-  beforeAll(async () => {
+  beforeEach(async () => {
     client = await TestClient.create();
   });
 
-  afterAll(async () => {
+  afterEach(async () => {
     await client.close();
   });
 
@@ -44,7 +44,8 @@ describe('InternalWizardController (e2e)', () => {
       .get(`/internal/api/v1/wizard/task?namespace_id=${client.namespace.id}`)
       .expect(HttpStatus.OK);
 
-    expect(task.body.input.html).toEqual(html);
+    expect(task.body.id).toBe(taskId);
+    expect(task.body.input.html).toBe(html);
 
     const response = await client
       .post('/internal/api/v1/wizard/callback')
@@ -86,7 +87,8 @@ describe('InternalWizardController (e2e)', () => {
       .get(`/internal/api/v1/wizard/task?namespace_id=${client.namespace.id}`)
       .expect(HttpStatus.OK);
 
-    expect(task.body.input.html).toEqual(collectData.html);
+    expect(task.body.id).toBe(taskId);
+    expect(task.body.input.html).toBe(collectData.html);
 
     const response = await client
       .post('/internal/api/v1/wizard/callback')