Support snake payload

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/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',