Merge pull request #100 from import-ai/task

fix(task): fix task field camel

Author: LucienShui

src/resources/wizard-task/reader.service.ts

@@ -15,7 +15,7 @@ export class Reader {
         resource_id: resource.id,
       },
       payload: {
-        resourceId: resource.id,
+        resource_id: resource.id,
       },
       namespaceId: resource.namespaceId,
       userId: user.id,

src/wizard/internal.wizard.controller.ts

@@ -1,8 +1,9 @@
-import { Body, Controller, Get, Post, Res } from '@nestjs/common';
 import { Response } from 'express';
+import { WizardService } from 'src/wizard/wizard.service';
 import { Public } from 'src/auth/decorators/public.decorator';
+import { transformKeysToSnakeCase } from 'src/interceptor/utils';
 import { TaskCallbackDto } from 'src/wizard/dto/task-callback.dto';
-import { WizardService } from 'src/wizard/wizard.service';
+import { Body, Controller, Get, Post, Res } from '@nestjs/common';
 
 @Controller('internal/api/v1/wizard')
 export class InternalWizardController {
@@ -12,8 +13,7 @@ export class InternalWizardController {
   @Get('/task')
   async fetchTask(@Res() res: Response): Promise<void> {
     const task = await this.wizardService.fetchTask();
-    res.status(task ? 200 : 204).json(task);
-    return;
+    res.status(task ? 200 : 204).json(transformKeysToSnakeCase(task));
   }
 
   @Public()

src/wizard/processors/collect.processor.ts

@@ -13,10 +13,10 @@ export class CollectProcessor extends Processor {
   }
 
   async process(task: Task): Promise<Record<string, any>> {
-    if (!task.payload?.resourceId) {
+    const resourceId = task.payload?.resource_id || task.payload?.resourceId;
+    if (!resourceId) {
       throw new BadRequestException('Invalid task payload');
     }
-    const resourceId = task.payload.resourceId;
     if (task.exception) {
       const user = await this.userService.find(task.userId);
       if (user) {

src/wizard/wizard.service.ts

@@ -72,7 +72,7 @@ export class WizardService {
     const resource = await this.resourcesService.create(user, resourceDto);
     console.debug({ resource });
 
-    const payload = { resourceId: resource.id };
+    const payload = { resource_id: resource.id };
 
     const task = await this.create({
       function: 'collect',