Switch to crud action

twentyhq · Nov 12, 2024 · 8435b54 · 8435b54
1 parent 6fb54ae
commit 8435b54
Show file tree

Hide file tree

Showing 9 changed files with 55 additions and 13 deletions.
diff --git a/...twenty-server/src/modules/workflow/workflow-executor/factories/workflow-action.factory.ts b/...twenty-server/src/modules/workflow/workflow-executor/factories/workflow-action.factory.ts
@@ -7,8 +7,8 @@ import {
   WorkflowStepExecutorExceptionCode,
 } from 'src/modules/workflow/workflow-executor/exceptions/workflow-step-executor.exception';
 import { CodeWorkflowAction } from 'src/modules/workflow/workflow-executor/workflow-actions/code/code.workflow-action';
-import { CreateRecordWorkflowAction } from 'src/modules/workflow/workflow-executor/workflow-actions/create-record/create-record.workflow-action';
 import { SendEmailWorkflowAction } from 'src/modules/workflow/workflow-executor/workflow-actions/mail-sender/send-email.workflow-action';
+import { CreateRecordWorkflowAction } from 'src/modules/workflow/workflow-executor/workflow-actions/record-operation/record-operation.workflow-action';
 import { WorkflowActionType } from 'src/modules/workflow/workflow-executor/workflow-actions/types/workflow-action.type';
 
 @Injectable()

diff --git a/...executor/workflow-actions/create-record/types/workflow-create-record-action-input.type.ts b/...executor/workflow-actions/create-record/types/workflow-create-record-action-input.type.ts
diff --git a/...ate-record/create-record-action.module.ts → .../record-operation/record-action.module.ts b/...ate-record/create-record-action.module.ts → .../record-operation/record-action.module.ts
@@ -1,6 +1,6 @@
 import { Module } from '@nestjs/common';
 
-import { CreateRecordWorkflowAction } from 'src/modules/workflow/workflow-executor/workflow-actions/create-record/create-record.workflow-action';
+import { CreateRecordWorkflowAction } from 'src/modules/workflow/workflow-executor/workflow-actions/record-operation/record-operation.workflow-action';
 
 @Module({
   providers: [CreateRecordWorkflowAction],

diff --git a/...e-record/create-record.workflow-action.ts → ...ation/record-operation.workflow-action.ts b/...e-record/create-record.workflow-action.ts → ...ation/record-operation.workflow-action.ts
@@ -3,14 +3,31 @@ import { Injectable } from '@nestjs/common';
 import { WorkflowAction } from 'src/modules/workflow/workflow-executor/interfaces/workflow-action.interface';
 
 import { TwentyORMManager } from 'src/engine/twenty-orm/twenty-orm.manager';
-import { WorkflowCreateRecordActionInput } from 'src/modules/workflow/workflow-executor/workflow-actions/create-record/types/workflow-create-record-action-input.type';
+import {
+  WorkflowCreateRecordActionInput,
+  WorkflowRecordActionInput,
+  WorkflowRecordOperationType,
+} from 'src/modules/workflow/workflow-executor/workflow-actions/record-operation/types/workflow-record-action-input.type';
 import { WorkflowActionResult } from 'src/modules/workflow/workflow-executor/workflow-actions/types/workflow-action-result.type';
 
 @Injectable()
 export class CreateRecordWorkflowAction implements WorkflowAction {
   constructor(private readonly twentyORMManager: TwentyORMManager) {}
 
   async execute(
+    workflowActionInput: WorkflowRecordActionInput,
+  ): Promise<WorkflowActionResult> {
+    switch (workflowActionInput.type) {
+      case WorkflowRecordOperationType.CREATE:
+        return this.createRecord(workflowActionInput);
+      default:
+        throw new Error(
+          `Unknown record operation type: ${workflowActionInput.type}`,
+        );
+    }
+  }
+
+  private async createRecord(
     workflowActionInput: WorkflowCreateRecordActionInput,
   ): Promise<WorkflowActionResult> {
     const repository = await this.twentyORMManager.getRepository(

diff --git a/...low-executor/workflow-actions/record-operation/types/workflow-record-action-input.type.ts b/...low-executor/workflow-actions/record-operation/types/workflow-record-action-input.type.ts
@@ -0,0 +1,31 @@
+type ObjectRecord = Record<string, any>;
+
+export enum WorkflowRecordOperationType {
+  CREATE = 'Create',
+  UPDATE = 'Update',
+  DELETE = 'Delete',
+}
+
+export type WorkflowCreateRecordActionInput = {
+  type: WorkflowRecordOperationType.CREATE;
+  objectName: string;
+  objectRecord: ObjectRecord;
+};
+
+export type WorkflowUpdateRecordActionInput = {
+  type: WorkflowRecordOperationType.UPDATE;
+  objectName: string;
+  objectRecord: ObjectRecord;
+  objectRecordId: string;
+};
+
+export type WorkflowDeleteRecordActionInput = {
+  type: WorkflowRecordOperationType.DELETE;
+  objectName: string;
+  objectRecordId: string;
+};
+
+export type WorkflowRecordActionInput =
+  | WorkflowCreateRecordActionInput
+  | WorkflowUpdateRecordActionInput
+  | WorkflowDeleteRecordActionInput;
diff --git a/...low-create-record-action-settings.type.ts → ...s/workflow-record-action-settings.type.ts b/...low-create-record-action-settings.type.ts → ...s/workflow-record-action-settings.type.ts
@@ -1,4 +1,4 @@
-import { WorkflowCreateRecordActionInput } from 'src/modules/workflow/workflow-executor/workflow-actions/create-record/types/workflow-create-record-action-input.type';
+import { WorkflowCreateRecordActionInput } from 'src/modules/workflow/workflow-executor/workflow-actions/record-operation/types/workflow-record-action-input.type';
 import { BaseWorkflowActionSettings } from 'src/modules/workflow/workflow-executor/workflow-actions/types/workflow-action-settings.type';
 
 export type WorkflowCreateRecordActionSettings = BaseWorkflowActionSettings & {

diff --git a/...odules/workflow/workflow-executor/workflow-actions/types/workflow-action-settings.type.ts b/...odules/workflow/workflow-executor/workflow-actions/types/workflow-action-settings.type.ts
@@ -1,6 +1,6 @@
 import { WorkflowCodeActionSettings } from 'src/modules/workflow/workflow-executor/workflow-actions/code/types/workflow-code-action-settings.type';
-import { WorkflowCreateRecordActionSettings } from 'src/modules/workflow/workflow-executor/workflow-actions/create-record/types/workflow-create-record-action-settings.type';
 import { WorkflowSendEmailActionSettings } from 'src/modules/workflow/workflow-executor/workflow-actions/mail-sender/types/workflow-send-email-action-settings.type';
+import { WorkflowCreateRecordActionSettings } from 'src/modules/workflow/workflow-executor/workflow-actions/record-operation/types/workflow-record-action-settings.type';
 
 export type OutputSchema = object;
 

diff --git a/...ver/src/modules/workflow/workflow-executor/workflow-actions/types/workflow-action.type.ts b/...ver/src/modules/workflow/workflow-executor/workflow-actions/types/workflow-action.type.ts
@@ -1,6 +1,6 @@
 import { WorkflowCodeActionSettings } from 'src/modules/workflow/workflow-executor/workflow-actions/code/types/workflow-code-action-settings.type';
-import { WorkflowCreateRecordActionSettings } from 'src/modules/workflow/workflow-executor/workflow-actions/create-record/types/workflow-create-record-action-settings.type';
 import { WorkflowSendEmailActionSettings } from 'src/modules/workflow/workflow-executor/workflow-actions/mail-sender/types/workflow-send-email-action-settings.type';
+import { WorkflowCreateRecordActionSettings } from 'src/modules/workflow/workflow-executor/workflow-actions/record-operation/types/workflow-record-action-settings.type';
 import { WorkflowActionSettings } from 'src/modules/workflow/workflow-executor/workflow-actions/types/workflow-action-settings.type';
 
 export enum WorkflowActionType {

diff --git a/packages/twenty-server/src/modules/workflow/workflow-executor/workflow-executor.module.ts b/packages/twenty-server/src/modules/workflow/workflow-executor/workflow-executor.module.ts
@@ -4,8 +4,8 @@ import { ScopedWorkspaceContextFactory } from 'src/engine/twenty-orm/factories/s
 import { WorkflowCommonModule } from 'src/modules/workflow/common/workflow-common.module';
 import { WorkflowActionFactory } from 'src/modules/workflow/workflow-executor/factories/workflow-action.factory';
 import { CodeActionModule } from 'src/modules/workflow/workflow-executor/workflow-actions/code/code-action.module';
-import { CreateRecordActionModule } from 'src/modules/workflow/workflow-executor/workflow-actions/create-record/create-record-action.module';
 import { SendEmailActionModule } from 'src/modules/workflow/workflow-executor/workflow-actions/mail-sender/send-email-action.module';
+import { CreateRecordActionModule } from 'src/modules/workflow/workflow-executor/workflow-actions/record-operation/record-action.module';
 import { WorkflowExecutorWorkspaceService } from 'src/modules/workflow/workflow-executor/workspace-services/workflow-executor.workspace-service';
 
 @Module({