From c17e18b1e928eac02afaee12ff04cbf51f48e712 Mon Sep 17 00:00:00 2001
From: Baptiste Devessier <baptiste@devessier.fr>
Date: Mon, 18 Nov 2024 18:23:46 +0100
Subject: [PATCH] Add Record Create action in the frontend (#8514)

In this PR:

- Updated the front-end types for workflows to include CRUD actions and
global naming changes
- Allow users to create a Record Create action
- Scaffold the edit for Record Create action; for now, I render a
`<VariableTagInput />` component for every editable field; it's likely
we'll change it soon

Closes https://github.com/twentyhq/private-issues/issues/142

Demo:


https://github.com/user-attachments/assets/6f0b207a-b7d2-46d9-b5ab-9e32bde55d76
---
 .../components/FormFieldInput.tsx             |  26 +++
 .../WorkflowDiagramStepNodeBase.tsx           |  23 ++-
 .../WorkflowEditActionFormRecordCreate.tsx    | 167 ++++++++++++++++++
 .../WorkflowEditActionFormSendEmail.tsx       |  56 +++---
 ...rkflowEditActionFormServerlessFunction.tsx |  75 ++++----
 .../WorkflowEditTriggerDatabaseEventForm.tsx  |  38 ++--
 .../WorkflowEditTriggerManualForm.tsx         |  38 ++--
 .../components/WorkflowStepDetail.tsx         |  26 ++-
 .../src/modules/workflow/constants/Actions.ts |  11 +-
 .../modules/workflow/hooks/useCreateStep.ts   |  10 +-
 .../src/modules/workflow/types/Workflow.ts    |  76 ++++++--
 .../workflow/utils/generateWorkflowDiagram.ts |  24 ++-
 .../utils/getStepDefaultDefinition.ts         |  39 +++-
 .../utils/isWorkflowRecordCreateAction.ts     |  12 ++
 .../icon/components/IconAddressBook.tsx       |  14 +-
 15 files changed, 503 insertions(+), 132 deletions(-)
 create mode 100644 packages/twenty-front/src/modules/object-record/record-field/components/FormFieldInput.tsx
 create mode 100644 packages/twenty-front/src/modules/workflow/components/WorkflowEditActionFormRecordCreate.tsx
 create mode 100644 packages/twenty-front/src/modules/workflow/utils/isWorkflowRecordCreateAction.ts

diff --git a/packages/twenty-front/src/modules/object-record/record-field/components/FormFieldInput.tsx b/packages/twenty-front/src/modules/object-record/record-field/components/FormFieldInput.tsx
new file mode 100644
index 0000000000..993dd28634
--- /dev/null
+++ b/packages/twenty-front/src/modules/object-record/record-field/components/FormFieldInput.tsx
@@ -0,0 +1,26 @@
+import VariableTagInput from '@/workflow/search-variables/components/VariableTagInput';
+
+type FormFieldInputProps = {
+  recordFieldInputdId: string;
+  label: string;
+  value: string;
+  onChange: (value: string) => void;
+  isReadOnly?: boolean;
+};
+
+export const FormFieldInput = ({
+  recordFieldInputdId,
+  label,
+  onChange,
+  value,
+}: FormFieldInputProps) => {
+  return (
+    <VariableTagInput
+      inputId={recordFieldInputdId}
+      label={label}
+      placeholder="Enter value (use {{variable}} for dynamic content)"
+      value={value}
+      onChange={onChange}
+    />
+  );
+};
diff --git a/packages/twenty-front/src/modules/workflow/components/WorkflowDiagramStepNodeBase.tsx b/packages/twenty-front/src/modules/workflow/components/WorkflowDiagramStepNodeBase.tsx
index 04c6a62be9..cccb23a12a 100644
--- a/packages/twenty-front/src/modules/workflow/components/WorkflowDiagramStepNodeBase.tsx
+++ b/packages/twenty-front/src/modules/workflow/components/WorkflowDiagramStepNodeBase.tsx
@@ -3,7 +3,13 @@ import { WorkflowDiagramStepNodeData } from '@/workflow/types/WorkflowDiagram';
 import { assertUnreachable } from '@/workflow/utils/assertUnreachable';
 import { useTheme } from '@emotion/react';
 import styled from '@emotion/styled';
-import { IconCode, IconHandMove, IconMail, IconPlaylistAdd } from 'twenty-ui';
+import {
+  IconAddressBook,
+  IconCode,
+  IconHandMove,
+  IconMail,
+  IconPlaylistAdd,
+} from 'twenty-ui';
 
 const StyledStepNodeLabelIconContainer = styled.div`
   align-items: center;
@@ -70,6 +76,21 @@ export const WorkflowDiagramStepNodeBase = ({
               </StyledStepNodeLabelIconContainer>
             );
           }
+          case 'RECORD_CRUD.CREATE': {
+            return (
+              <StyledStepNodeLabelIconContainer>
+                <IconAddressBook
+                  size={theme.icon.size.lg}
+                  color={theme.font.color.tertiary}
+                  stroke={theme.icon.stroke.sm}
+                />
+              </StyledStepNodeLabelIconContainer>
+            );
+          }
+          case 'RECORD_CRUD.DELETE':
+          case 'RECORD_CRUD.UPDATE': {
+            return null;
+          }
         }
       }
     }
diff --git a/packages/twenty-front/src/modules/workflow/components/WorkflowEditActionFormRecordCreate.tsx b/packages/twenty-front/src/modules/workflow/components/WorkflowEditActionFormRecordCreate.tsx
new file mode 100644
index 0000000000..647dfe240a
--- /dev/null
+++ b/packages/twenty-front/src/modules/workflow/components/WorkflowEditActionFormRecordCreate.tsx
@@ -0,0 +1,167 @@
+import { useFilteredObjectMetadataItems } from '@/object-metadata/hooks/useFilteredObjectMetadataItems';
+import { FormFieldInput } from '@/object-record/record-field/components/FormFieldInput';
+import { Select, SelectOption } from '@/ui/input/components/Select';
+import { WorkflowEditGenericFormBase } from '@/workflow/components/WorkflowEditGenericFormBase';
+import { WorkflowRecordCreateAction } from '@/workflow/types/Workflow';
+import { useTheme } from '@emotion/react';
+import { useEffect, useState } from 'react';
+import {
+  HorizontalSeparator,
+  IconAddressBook,
+  isDefined,
+  useIcons,
+} from 'twenty-ui';
+import { useDebouncedCallback } from 'use-debounce';
+import { FieldMetadataType } from '~/generated/graphql';
+
+type WorkflowEditActionFormRecordCreateProps = {
+  action: WorkflowRecordCreateAction;
+  actionOptions:
+    | {
+        readonly: true;
+      }
+    | {
+        readonly?: false;
+        onActionUpdate: (action: WorkflowRecordCreateAction) => void;
+      };
+};
+
+type SendEmailFormData = {
+  objectName: string;
+  [field: string]: unknown;
+};
+
+export const WorkflowEditActionFormRecordCreate = ({
+  action,
+  actionOptions,
+}: WorkflowEditActionFormRecordCreateProps) => {
+  const theme = useTheme();
+  const { getIcon } = useIcons();
+
+  const { activeObjectMetadataItems } = useFilteredObjectMetadataItems();
+
+  const availableMetadata: Array<SelectOption<string>> =
+    activeObjectMetadataItems.map((item) => ({
+      Icon: getIcon(item.icon),
+      label: item.labelPlural,
+      value: item.nameSingular,
+    }));
+
+  const [formData, setFormData] = useState<SendEmailFormData>({
+    objectName: action.settings.input.objectName,
+    ...action.settings.input.objectRecord,
+  });
+  const isFormDisabled = actionOptions.readonly;
+
+  const handleFieldChange = (
+    fieldName: keyof SendEmailFormData,
+    updatedValue: string,
+  ) => {
+    const newFormData: SendEmailFormData = {
+      ...formData,
+      [fieldName]: updatedValue,
+    };
+
+    setFormData(newFormData);
+
+    saveAction(newFormData);
+  };
+
+  useEffect(() => {
+    setFormData({
+      objectName: action.settings.input.objectName,
+      ...action.settings.input.objectRecord,
+    });
+  }, [action.settings.input]);
+
+  const selectedObjectMetadataItemNameSingular = formData.objectName;
+
+  const selectedObjectMetadataItem = activeObjectMetadataItems.find(
+    (item) => item.nameSingular === selectedObjectMetadataItemNameSingular,
+  );
+  if (!isDefined(selectedObjectMetadataItem)) {
+    throw new Error('Should have found the metadata item');
+  }
+
+  const editableFields = selectedObjectMetadataItem.fields.filter(
+    (field) =>
+      field.type !== FieldMetadataType.Relation &&
+      !field.isSystem &&
+      field.isActive,
+  );
+
+  const saveAction = useDebouncedCallback(
+    async (formData: SendEmailFormData) => {
+      if (actionOptions.readonly === true) {
+        return;
+      }
+
+      const { objectName: updatedObjectName, ...updatedOtherFields } = formData;
+
+      actionOptions.onActionUpdate({
+        ...action,
+        settings: {
+          ...action.settings,
+          input: {
+            type: 'CREATE',
+            objectName: updatedObjectName,
+            objectRecord: updatedOtherFields,
+          },
+        },
+      });
+    },
+    1_000,
+  );
+
+  useEffect(() => {
+    return () => {
+      saveAction.flush();
+    };
+  }, [saveAction]);
+
+  return (
+    <WorkflowEditGenericFormBase
+      HeaderIcon={
+        <IconAddressBook
+          color={theme.font.color.tertiary}
+          stroke={theme.icon.stroke.sm}
+        />
+      }
+      headerTitle="Record Create"
+      headerType="Action"
+    >
+      <Select
+        dropdownId="workflow-edit-action-record-create-object-name"
+        label="Object"
+        fullWidth
+        disabled={isFormDisabled}
+        value={formData.objectName}
+        emptyOption={{ label: 'Select an option', value: '' }}
+        options={availableMetadata}
+        onChange={(updatedObjectName) => {
+          const newFormData: SendEmailFormData = {
+            objectName: updatedObjectName,
+          };
+
+          setFormData(newFormData);
+
+          saveAction(newFormData);
+        }}
+      />
+
+      <HorizontalSeparator noMargin />
+
+      {editableFields.map((field) => (
+        <FormFieldInput
+          key={field.id}
+          recordFieldInputdId={field.id}
+          label={field.label}
+          value={formData[field.name] as string}
+          onChange={(value) => {
+            handleFieldChange(field.name, value);
+          }}
+        />
+      ))}
+    </WorkflowEditGenericFormBase>
+  );
+};
diff --git a/packages/twenty-front/src/modules/workflow/components/WorkflowEditActionFormSendEmail.tsx b/packages/twenty-front/src/modules/workflow/components/WorkflowEditActionFormSendEmail.tsx
index 4dafbc3b4a..9a1389c19e 100644
--- a/packages/twenty-front/src/modules/workflow/components/WorkflowEditActionFormSendEmail.tsx
+++ b/packages/twenty-front/src/modules/workflow/components/WorkflowEditActionFormSendEmail.tsx
@@ -7,7 +7,7 @@ import { Select, SelectOption } from '@/ui/input/components/Select';
 import { WorkflowEditGenericFormBase } from '@/workflow/components/WorkflowEditGenericFormBase';
 import { VariableTagInput } from '@/workflow/search-variables/components/VariableTagInput';
 import { workflowIdState } from '@/workflow/states/workflowIdState';
-import { WorkflowSendEmailStep } from '@/workflow/types/Workflow';
+import { WorkflowSendEmailAction } from '@/workflow/types/Workflow';
 import { useTheme } from '@emotion/react';
 import { useEffect } from 'react';
 import { Controller, useForm } from 'react-hook-form';
@@ -15,16 +15,17 @@ import { useRecoilValue } from 'recoil';
 import { IconMail, IconPlus, isDefined } from 'twenty-ui';
 import { useDebouncedCallback } from 'use-debounce';
 
-type WorkflowEditActionFormSendEmailProps =
-  | {
-      action: WorkflowSendEmailStep;
-      readonly: true;
-    }
-  | {
-      action: WorkflowSendEmailStep;
-      readonly?: false;
-      onActionUpdate: (action: WorkflowSendEmailStep) => void;
-    };
+type WorkflowEditActionFormSendEmailProps = {
+  action: WorkflowSendEmailAction;
+  actionOptions:
+    | {
+        readonly: true;
+      }
+    | {
+        readonly?: false;
+        onActionUpdate: (action: WorkflowSendEmailAction) => void;
+      };
+};
 
 type SendEmailFormData = {
   connectedAccountId: string;
@@ -33,9 +34,10 @@ type SendEmailFormData = {
   body: string;
 };
 
-export const WorkflowEditActionFormSendEmail = (
-  props: WorkflowEditActionFormSendEmailProps,
-) => {
+export const WorkflowEditActionFormSendEmail = ({
+  action,
+  actionOptions,
+}: WorkflowEditActionFormSendEmailProps) => {
   const theme = useTheme();
   const currentWorkspaceMember = useRecoilValue(currentWorkspaceMemberState);
   const { triggerApisOAuth } = useTriggerApisOAuth();
@@ -50,7 +52,7 @@ export const WorkflowEditActionFormSendEmail = (
       subject: '',
       body: '',
     },
-    disabled: props.readonly,
+    disabled: actionOptions.readonly,
   });
 
   const checkConnectedAccountScopes = async (
@@ -77,23 +79,23 @@ export const WorkflowEditActionFormSendEmail = (
   useEffect(() => {
     form.setValue(
       'connectedAccountId',
-      props.action.settings.input.connectedAccountId ?? '',
+      action.settings.input.connectedAccountId ?? '',
     );
-    form.setValue('email', props.action.settings.input.email ?? '');
-    form.setValue('subject', props.action.settings.input.subject ?? '');
-    form.setValue('body', props.action.settings.input.body ?? '');
-  }, [props.action.settings, form]);
+    form.setValue('email', action.settings.input.email ?? '');
+    form.setValue('subject', action.settings.input.subject ?? '');
+    form.setValue('body', action.settings.input.body ?? '');
+  }, [action.settings, form]);
 
   const saveAction = useDebouncedCallback(
     async (formData: SendEmailFormData, checkScopes = false) => {
-      if (props.readonly === true) {
+      if (actionOptions.readonly === true) {
         return;
       }
 
-      props.onActionUpdate({
-        ...props.action,
+      actionOptions.onActionUpdate({
+        ...action,
         settings: {
-          ...props.action.settings,
+          ...action.settings,
           input: {
             connectedAccountId: formData.connectedAccountId,
             email: formData.email,
@@ -132,12 +134,12 @@ export const WorkflowEditActionFormSendEmail = (
   };
 
   if (
-    isDefined(props.action.settings.input.connectedAccountId) &&
-    props.action.settings.input.connectedAccountId !== ''
+    isDefined(action.settings.input.connectedAccountId) &&
+    action.settings.input.connectedAccountId !== ''
   ) {
     filter.or.push({
       id: {
-        eq: props.action.settings.input.connectedAccountId,
+        eq: action.settings.input.connectedAccountId,
       },
     });
   }
diff --git a/packages/twenty-front/src/modules/workflow/components/WorkflowEditActionFormServerlessFunction.tsx b/packages/twenty-front/src/modules/workflow/components/WorkflowEditActionFormServerlessFunction.tsx
index 95bbcd3f93..9025788cdf 100644
--- a/packages/twenty-front/src/modules/workflow/components/WorkflowEditActionFormServerlessFunction.tsx
+++ b/packages/twenty-front/src/modules/workflow/components/WorkflowEditActionFormServerlessFunction.tsx
@@ -1,17 +1,17 @@
-import { ReactNode } from 'react';
-import styled from '@emotion/styled';
 import { useGetManyServerlessFunctions } from '@/settings/serverless-functions/hooks/useGetManyServerlessFunctions';
-import { setNestedValue } from '@/workflow/utils/setNestedValue';
 import { Select, SelectOption } from '@/ui/input/components/Select';
 import { WorkflowEditGenericFormBase } from '@/workflow/components/WorkflowEditGenericFormBase';
 import VariableTagInput from '@/workflow/search-variables/components/VariableTagInput';
-import { WorkflowCodeStep } from '@/workflow/types/Workflow';
-import { useTheme } from '@emotion/react';
-import { IconCode, isDefined, HorizontalSeparator } from 'twenty-ui';
-import { useDebouncedCallback } from 'use-debounce';
-import { getDefaultFunctionInputFromInputSchema } from '@/workflow/utils/getDefaultFunctionInputFromInputSchema';
 import { FunctionInput } from '@/workflow/types/FunctionInput';
+import { WorkflowCodeAction } from '@/workflow/types/Workflow';
+import { getDefaultFunctionInputFromInputSchema } from '@/workflow/utils/getDefaultFunctionInputFromInputSchema';
 import { mergeDefaultFunctionInputAndFunctionInput } from '@/workflow/utils/mergeDefaultFunctionInputAndFunctionInput';
+import { setNestedValue } from '@/workflow/utils/setNestedValue';
+import { useTheme } from '@emotion/react';
+import styled from '@emotion/styled';
+import { ReactNode } from 'react';
+import { HorizontalSeparator, IconCode, isDefined } from 'twenty-ui';
+import { useDebouncedCallback } from 'use-debounce';
 
 const StyledContainer = styled.div`
   display: inline-flex;
@@ -37,20 +37,22 @@ const StyledInputContainer = styled.div`
   position: relative;
 `;
 
-type WorkflowEditActionFormServerlessFunctionProps =
-  | {
-      action: WorkflowCodeStep;
-      readonly: true;
-    }
-  | {
-      action: WorkflowCodeStep;
-      readonly?: false;
-      onActionUpdate: (action: WorkflowCodeStep) => void;
-    };
+type WorkflowEditActionFormServerlessFunctionProps = {
+  action: WorkflowCodeAction;
+  actionOptions:
+    | {
+        readonly: true;
+      }
+    | {
+        readonly?: false;
+        onActionUpdate: (action: WorkflowCodeAction) => void;
+      };
+};
 
-export const WorkflowEditActionFormServerlessFunction = (
-  props: WorkflowEditActionFormServerlessFunctionProps,
-) => {
+export const WorkflowEditActionFormServerlessFunction = ({
+  action,
+  actionOptions,
+}: WorkflowEditActionFormServerlessFunctionProps) => {
   const theme = useTheme();
   const { serverlessFunctions } = useGetManyServerlessFunctions();
 
@@ -66,8 +68,7 @@ export const WorkflowEditActionFormServerlessFunction = (
     const defaultFunctionInput =
       getDefaultFunctionInputFromInputSchema(inputSchema);
 
-    const existingFunctionInput =
-      props.action.settings.input.serverlessFunctionInput;
+    const existingFunctionInput = action.settings.input.serverlessFunctionInput;
 
     return mergeDefaultFunctionInputAndFunctionInput({
       defaultFunctionInput,
@@ -76,21 +77,21 @@ export const WorkflowEditActionFormServerlessFunction = (
   };
 
   const functionInput = getFunctionInput(
-    props.action.settings.input.serverlessFunctionId,
+    action.settings.input.serverlessFunctionId,
   );
 
   const updateFunctionInput = useDebouncedCallback(
     async (newFunctionInput: object) => {
-      if (props.readonly === true) {
+      if (actionOptions.readonly === true) {
         return;
       }
 
-      props.onActionUpdate({
-        ...props.action,
+      actionOptions.onActionUpdate({
+        ...action,
         settings: {
-          ...props.action.settings,
+          ...action.settings,
           input: {
-            ...props.action.settings.input,
+            ...action.settings.input,
             serverlessFunctionInput: newFunctionInput,
           },
         },
@@ -116,14 +117,18 @@ export const WorkflowEditActionFormServerlessFunction = (
   ];
 
   const handleFunctionChange = (newServerlessFunctionId: string) => {
+    if (actionOptions.readonly === true) {
+      return;
+    }
+
     const serverlessFunction = serverlessFunctions.find(
       (f) => f.id === newServerlessFunctionId,
     );
 
     const newProps = {
-      ...props.action,
+      ...action,
       settings: {
-        ...props.action.settings,
+        ...action.settings,
         input: {
           serverlessFunctionId: newServerlessFunctionId,
           serverlessFunctionVersion:
@@ -133,9 +138,7 @@ export const WorkflowEditActionFormServerlessFunction = (
       },
     };
 
-    if (!props.readonly) {
-      props.onActionUpdate(newProps);
-    }
+    actionOptions.onActionUpdate(newProps);
   };
 
   const renderFields = (
@@ -203,10 +206,10 @@ export const WorkflowEditActionFormServerlessFunction = (
         dropdownId="select-serverless-function-id"
         label="Function"
         fullWidth
-        value={props.action.settings.input.serverlessFunctionId}
+        value={action.settings.input.serverlessFunctionId}
         options={availableFunctions}
         emptyOption={{ label: 'None', value: '' }}
-        disabled={props.readonly}
+        disabled={actionOptions.readonly}
         onChange={handleFunctionChange}
       />
       {renderFields(functionInput)}
diff --git a/packages/twenty-front/src/modules/workflow/components/WorkflowEditTriggerDatabaseEventForm.tsx b/packages/twenty-front/src/modules/workflow/components/WorkflowEditTriggerDatabaseEventForm.tsx
index 7475810ce9..507afd9151 100644
--- a/packages/twenty-front/src/modules/workflow/components/WorkflowEditTriggerDatabaseEventForm.tsx
+++ b/packages/twenty-front/src/modules/workflow/components/WorkflowEditTriggerDatabaseEventForm.tsx
@@ -45,22 +45,22 @@ const StyledTriggerSettings = styled.div`
   row-gap: ${({ theme }) => theme.spacing(4)};
 `;
 
-type WorkflowEditTriggerDatabaseEventFormProps =
-  | {
-      trigger: WorkflowDatabaseEventTrigger;
-      readonly: true;
-      onTriggerUpdate?: undefined;
-    }
-  | {
-      trigger: WorkflowDatabaseEventTrigger;
-      readonly?: false;
-      onTriggerUpdate: (trigger: WorkflowDatabaseEventTrigger) => void;
-    };
+type WorkflowEditTriggerDatabaseEventFormProps = {
+  trigger: WorkflowDatabaseEventTrigger;
+  triggerOptions:
+    | {
+        readonly: true;
+        onTriggerUpdate?: undefined;
+      }
+    | {
+        readonly?: false;
+        onTriggerUpdate: (trigger: WorkflowDatabaseEventTrigger) => void;
+      };
+};
 
 export const WorkflowEditTriggerDatabaseEventForm = ({
   trigger,
-  readonly,
-  onTriggerUpdate,
+  triggerOptions,
 }: WorkflowEditTriggerDatabaseEventFormProps) => {
   const theme = useTheme();
 
@@ -112,16 +112,16 @@ export const WorkflowEditTriggerDatabaseEventForm = ({
           dropdownId="workflow-edit-trigger-record-type"
           label="Record Type"
           fullWidth
-          disabled={readonly}
+          disabled={triggerOptions.readonly}
           value={triggerEvent?.objectType}
           emptyOption={{ label: 'Select an option', value: '' }}
           options={availableMetadata}
           onChange={(updatedRecordType) => {
-            if (readonly === true) {
+            if (triggerOptions.readonly === true) {
               return;
             }
 
-            onTriggerUpdate(
+            triggerOptions.onTriggerUpdate(
               isDefined(trigger) && isDefined(triggerEvent)
                 ? {
                     ...trigger,
@@ -147,13 +147,13 @@ export const WorkflowEditTriggerDatabaseEventForm = ({
           value={triggerEvent?.event}
           emptyOption={{ label: 'Select an option', value: '' }}
           options={OBJECT_EVENT_TRIGGERS}
-          disabled={readonly}
+          disabled={triggerOptions.readonly}
           onChange={(updatedEvent) => {
-            if (readonly === true) {
+            if (triggerOptions.readonly === true) {
               return;
             }
 
-            onTriggerUpdate(
+            triggerOptions.onTriggerUpdate(
               isDefined(trigger) && isDefined(triggerEvent)
                 ? {
                     ...trigger,
diff --git a/packages/twenty-front/src/modules/workflow/components/WorkflowEditTriggerManualForm.tsx b/packages/twenty-front/src/modules/workflow/components/WorkflowEditTriggerManualForm.tsx
index ee66a39241..3863767653 100644
--- a/packages/twenty-front/src/modules/workflow/components/WorkflowEditTriggerManualForm.tsx
+++ b/packages/twenty-front/src/modules/workflow/components/WorkflowEditTriggerManualForm.tsx
@@ -10,22 +10,22 @@ import { getManualTriggerDefaultSettings } from '@/workflow/utils/getManualTrigg
 import { useTheme } from '@emotion/react';
 import { IconHandMove, isDefined, useIcons } from 'twenty-ui';
 
-type WorkflowEditTriggerManualFormProps =
-  | {
-      trigger: WorkflowManualTrigger;
-      readonly: true;
-      onTriggerUpdate?: undefined;
-    }
-  | {
-      trigger: WorkflowManualTrigger;
-      readonly?: false;
-      onTriggerUpdate: (trigger: WorkflowManualTrigger) => void;
-    };
+type WorkflowEditTriggerManualFormProps = {
+  trigger: WorkflowManualTrigger;
+  triggerOptions:
+    | {
+        readonly: true;
+        onTriggerUpdate?: undefined;
+      }
+    | {
+        readonly?: false;
+        onTriggerUpdate: (trigger: WorkflowManualTrigger) => void;
+      };
+};
 
 export const WorkflowEditTriggerManualForm = ({
   trigger,
-  readonly,
-  onTriggerUpdate,
+  triggerOptions,
 }: WorkflowEditTriggerManualFormProps) => {
   const theme = useTheme();
   const { getIcon } = useIcons();
@@ -54,15 +54,15 @@ export const WorkflowEditTriggerManualForm = ({
         dropdownId="workflow-edit-manual-trigger-availability"
         label="Available"
         fullWidth
-        disabled={readonly}
+        disabled={triggerOptions.readonly}
         value={manualTriggerAvailability}
         options={MANUAL_TRIGGER_AVAILABILITY_OPTIONS}
         onChange={(updatedTriggerType) => {
-          if (readonly === true) {
+          if (triggerOptions.readonly === true) {
             return;
           }
 
-          onTriggerUpdate({
+          triggerOptions.onTriggerUpdate({
             ...trigger,
             settings: getManualTriggerDefaultSettings({
               availability: updatedTriggerType,
@@ -79,13 +79,13 @@ export const WorkflowEditTriggerManualForm = ({
           fullWidth
           value={trigger.settings.objectType}
           options={availableMetadata}
-          disabled={readonly}
+          disabled={triggerOptions.readonly}
           onChange={(updatedObject) => {
-            if (readonly === true) {
+            if (triggerOptions.readonly === true) {
               return;
             }
 
-            onTriggerUpdate({
+            triggerOptions.onTriggerUpdate({
               ...trigger,
               settings: {
                 objectType: updatedObject,
diff --git a/packages/twenty-front/src/modules/workflow/components/WorkflowStepDetail.tsx b/packages/twenty-front/src/modules/workflow/components/WorkflowStepDetail.tsx
index b3e1509235..00914401bb 100644
--- a/packages/twenty-front/src/modules/workflow/components/WorkflowStepDetail.tsx
+++ b/packages/twenty-front/src/modules/workflow/components/WorkflowStepDetail.tsx
@@ -1,3 +1,4 @@
+import { WorkflowEditActionFormRecordCreate } from '@/workflow/components/WorkflowEditActionFormRecordCreate';
 import { WorkflowEditActionFormSendEmail } from '@/workflow/components/WorkflowEditActionFormSendEmail';
 import { WorkflowEditActionFormServerlessFunction } from '@/workflow/components/WorkflowEditActionFormServerlessFunction';
 import { WorkflowEditTriggerDatabaseEventForm } from '@/workflow/components/WorkflowEditTriggerDatabaseEventForm';
@@ -9,6 +10,7 @@ import {
 } from '@/workflow/types/Workflow';
 import { assertUnreachable } from '@/workflow/utils/assertUnreachable';
 import { getStepDefinitionOrThrow } from '@/workflow/utils/getStepDefinitionOrThrow';
+import { isWorkflowRecordCreateAction } from '@/workflow/utils/isWorkflowRecordCreateAction';
 import { isDefined } from 'twenty-ui';
 
 type WorkflowStepDetailProps =
@@ -53,8 +55,7 @@ export const WorkflowStepDetail = ({
           return (
             <WorkflowEditTriggerDatabaseEventForm
               trigger={stepDefinition.definition}
-              // eslint-disable-next-line react/jsx-props-no-spreading
-              {...props}
+              triggerOptions={props}
             />
           );
         }
@@ -62,8 +63,7 @@ export const WorkflowStepDetail = ({
           return (
             <WorkflowEditTriggerManualForm
               trigger={stepDefinition.definition}
-              // eslint-disable-next-line react/jsx-props-no-spreading
-              {...props}
+              triggerOptions={props}
             />
           );
         }
@@ -80,8 +80,7 @@ export const WorkflowStepDetail = ({
           return (
             <WorkflowEditActionFormServerlessFunction
               action={stepDefinition.definition}
-              // eslint-disable-next-line react/jsx-props-no-spreading
-              {...props}
+              actionOptions={props}
             />
           );
         }
@@ -89,11 +88,22 @@ export const WorkflowStepDetail = ({
           return (
             <WorkflowEditActionFormSendEmail
               action={stepDefinition.definition}
-              // eslint-disable-next-line react/jsx-props-no-spreading
-              {...props}
+              actionOptions={props}
             />
           );
         }
+        case 'RECORD_CRUD': {
+          if (isWorkflowRecordCreateAction(stepDefinition.definition)) {
+            return (
+              <WorkflowEditActionFormRecordCreate
+                action={stepDefinition.definition}
+                actionOptions={props}
+              />
+            );
+          }
+
+          return null;
+        }
       }
 
       return assertUnreachable(
diff --git a/packages/twenty-front/src/modules/workflow/constants/Actions.ts b/packages/twenty-front/src/modules/workflow/constants/Actions.ts
index b3415d391f..c4a9bae489 100644
--- a/packages/twenty-front/src/modules/workflow/constants/Actions.ts
+++ b/packages/twenty-front/src/modules/workflow/constants/Actions.ts
@@ -1,5 +1,9 @@
 import { WorkflowStepType } from '@/workflow/types/Workflow';
-import { IconComponent, IconSettingsAutomation } from 'twenty-ui';
+import {
+  IconAddressBook,
+  IconComponent,
+  IconSettingsAutomation,
+} from 'twenty-ui';
 
 export const ACTIONS: Array<{
   label: string;
@@ -16,4 +20,9 @@ export const ACTIONS: Array<{
     type: 'SEND_EMAIL',
     icon: IconSettingsAutomation,
   },
+  {
+    label: 'Create Record',
+    type: 'RECORD_CRUD.CREATE',
+    icon: IconAddressBook,
+  },
 ];
diff --git a/packages/twenty-front/src/modules/workflow/hooks/useCreateStep.ts b/packages/twenty-front/src/modules/workflow/hooks/useCreateStep.ts
index b5d793258c..b67f06139c 100644
--- a/packages/twenty-front/src/modules/workflow/hooks/useCreateStep.ts
+++ b/packages/twenty-front/src/modules/workflow/hooks/useCreateStep.ts
@@ -1,7 +1,9 @@
+import { useFilteredObjectMetadataItems } from '@/object-metadata/hooks/useFilteredObjectMetadataItems';
 import { CoreObjectNameSingular } from '@/object-metadata/types/CoreObjectNameSingular';
 import { useUpdateOneRecord } from '@/object-record/hooks/useUpdateOneRecord';
 import { useRightDrawer } from '@/ui/layout/right-drawer/hooks/useRightDrawer';
 import { RightDrawerPages } from '@/ui/layout/right-drawer/types/RightDrawerPages';
+import { useComputeStepOutputSchema } from '@/workflow/hooks/useComputeStepOutputSchema';
 import { useCreateNewWorkflowVersion } from '@/workflow/hooks/useCreateNewWorkflowVersion';
 import { workflowCreateStepFromParentStepIdState } from '@/workflow/states/workflowCreateStepFromParentStepIdState';
 import { workflowDiagramTriggerNodeSelectionState } from '@/workflow/states/workflowDiagramTriggerNodeSelectionState';
@@ -16,7 +18,6 @@ import { getStepDefaultDefinition } from '@/workflow/utils/getStepDefaultDefinit
 import { insertStep } from '@/workflow/utils/insertStep';
 import { useRecoilValue, useSetRecoilState } from 'recoil';
 import { isDefined } from 'twenty-ui';
-import { useComputeStepOutputSchema } from '@/workflow/hooks/useComputeStepOutputSchema';
 
 export const useCreateStep = ({
   workflow,
@@ -43,6 +44,8 @@ export const useCreateStep = ({
 
   const { computeStepOutputSchema } = useComputeStepOutputSchema();
 
+  const { activeObjectMetadataItems } = useFilteredObjectMetadataItems();
+
   const insertNodeAndSave = async ({
     parentNodeId,
     nodeToAdd,
@@ -86,7 +89,10 @@ export const useCreateStep = ({
       throw new Error('Select a step to create a new step from first.');
     }
 
-    const newStep = getStepDefaultDefinition(newStepType);
+    const newStep = getStepDefaultDefinition({
+      type: newStepType,
+      activeObjectMetadataItems,
+    });
 
     const outputSchema = (
       await computeStepOutputSchema({
diff --git a/packages/twenty-front/src/modules/workflow/types/Workflow.ts b/packages/twenty-front/src/modules/workflow/types/Workflow.ts
index 75235034f1..ef496712ef 100644
--- a/packages/twenty-front/src/modules/workflow/types/Workflow.ts
+++ b/packages/twenty-front/src/modules/workflow/types/Workflow.ts
@@ -1,4 +1,4 @@
-type BaseWorkflowStepSettings = {
+type BaseWorkflowActionSettings = {
   input: object;
   outputSchema: object;
   errorHandlingOptions: {
@@ -11,7 +11,7 @@ type BaseWorkflowStepSettings = {
   };
 };
 
-export type WorkflowCodeStepSettings = BaseWorkflowStepSettings & {
+export type WorkflowCodeActionSettings = BaseWorkflowActionSettings & {
   input: {
     serverlessFunctionId: string;
     serverlessFunctionVersion: string;
@@ -21,7 +21,7 @@ export type WorkflowCodeStepSettings = BaseWorkflowStepSettings & {
   };
 };
 
-export type WorkflowSendEmailStepSettings = BaseWorkflowStepSettings & {
+export type WorkflowSendEmailActionSettings = BaseWorkflowActionSettings & {
   input: {
     connectedAccountId: string;
     email: string;
@@ -30,29 +30,83 @@ export type WorkflowSendEmailStepSettings = BaseWorkflowStepSettings & {
   };
 };
 
-type BaseWorkflowStep = {
+type ObjectRecord = Record<string, any>;
+
+export type WorkflowCreateRecordActionInput = {
+  type: 'CREATE';
+  objectName: string;
+  objectRecord: ObjectRecord;
+};
+
+export type WorkflowUpdateRecordActionInput = {
+  type: 'UPDATE';
+  objectName: string;
+  objectRecord: ObjectRecord;
+  objectRecordId: string;
+};
+
+export type WorkflowDeleteRecordActionInput = {
+  type: 'DELETE';
+  objectName: string;
+  objectRecordId: string;
+};
+
+export type WorkflowRecordCRUDActionInput =
+  | WorkflowCreateRecordActionInput
+  | WorkflowUpdateRecordActionInput
+  | WorkflowDeleteRecordActionInput;
+
+export type WorkflowRecordCRUDType = WorkflowRecordCRUDActionInput['type'];
+
+export type WorkflowRecordCRUDActionSettings = BaseWorkflowActionSettings & {
+  input: WorkflowRecordCRUDActionInput;
+};
+
+type BaseWorkflowAction = {
   id: string;
   name: string;
   valid: boolean;
 };
 
-export type WorkflowCodeStep = BaseWorkflowStep & {
+export type WorkflowCodeAction = BaseWorkflowAction & {
   type: 'CODE';
-  settings: WorkflowCodeStepSettings;
+  settings: WorkflowCodeActionSettings;
 };
 
-export type WorkflowSendEmailStep = BaseWorkflowStep & {
+export type WorkflowSendEmailAction = BaseWorkflowAction & {
   type: 'SEND_EMAIL';
-  settings: WorkflowSendEmailStepSettings;
+  settings: WorkflowSendEmailActionSettings;
 };
 
-export type WorkflowAction = WorkflowCodeStep | WorkflowSendEmailStep;
+export type WorkflowRecordCRUDAction = BaseWorkflowAction & {
+  type: 'RECORD_CRUD';
+  settings: WorkflowRecordCRUDActionSettings;
+};
+
+export type WorkflowRecordCreateAction = WorkflowRecordCRUDAction & {
+  settings: { input: { type: 'CREATE' } };
+};
+
+export type WorkflowRecordUpdateAction = WorkflowRecordCRUDAction & {
+  settings: { input: { type: 'UPDATE' } };
+};
+
+export type WorkflowRecordDeleteAction = WorkflowRecordCRUDAction & {
+  settings: { input: { type: 'DELETE' } };
+};
+
+export type WorkflowAction =
+  | WorkflowCodeAction
+  | WorkflowSendEmailAction
+  | WorkflowRecordCRUDAction;
 
 export type WorkflowStep = WorkflowAction;
 
-export type WorkflowActionType = WorkflowAction['type'];
+export type WorkflowActionType =
+  | Exclude<WorkflowAction['type'], WorkflowRecordCRUDAction['type']>
+  | `${WorkflowRecordCRUDAction['type']}.${WorkflowRecordCRUDType}`;
 
-export type WorkflowStepType = WorkflowStep['type'];
+export type WorkflowStepType = WorkflowActionType;
 
 type BaseTrigger = {
   type: string;
diff --git a/packages/twenty-front/src/modules/workflow/utils/generateWorkflowDiagram.ts b/packages/twenty-front/src/modules/workflow/utils/generateWorkflowDiagram.ts
index 93fdaae51b..99f1a49895 100644
--- a/packages/twenty-front/src/modules/workflow/utils/generateWorkflowDiagram.ts
+++ b/packages/twenty-front/src/modules/workflow/utils/generateWorkflowDiagram.ts
@@ -1,5 +1,9 @@
 import { TRIGGER_STEP_ID } from '@/workflow/constants/TriggerStepId';
-import { WorkflowStep, WorkflowTrigger } from '@/workflow/types/Workflow';
+import {
+  WorkflowActionType,
+  WorkflowStep,
+  WorkflowTrigger,
+} from '@/workflow/types/Workflow';
 import {
   WorkflowDiagram,
   WorkflowDiagramEdge,
@@ -30,12 +34,26 @@ export const generateWorkflowDiagram = ({
     yPos: number,
   ) => {
     const nodeId = step.id;
+
+    let nodeActionType: WorkflowActionType;
+    if (step.type === 'RECORD_CRUD') {
+      nodeActionType = `RECORD_CRUD.${step.settings.input.type}`;
+    } else {
+      nodeActionType = step.type;
+    }
+
+    let nodeLabel = step.name;
+    if (step.type === 'RECORD_CRUD') {
+      // FIXME: use activeObjectMetadataItems to get labelSingular
+      nodeLabel = `${capitalize(step.settings.input.type.toLowerCase())} ${capitalize(step.settings.input.objectName)}`;
+    }
+
     nodes.push({
       id: nodeId,
       data: {
         nodeType: 'action',
-        actionType: step.type,
-        label: step.name,
+        actionType: nodeActionType,
+        label: nodeLabel,
       },
       position: {
         x: xPos,
diff --git a/packages/twenty-front/src/modules/workflow/utils/getStepDefaultDefinition.ts b/packages/twenty-front/src/modules/workflow/utils/getStepDefaultDefinition.ts
index 2be6a4cffb..7abe92d20b 100644
--- a/packages/twenty-front/src/modules/workflow/utils/getStepDefaultDefinition.ts
+++ b/packages/twenty-front/src/modules/workflow/utils/getStepDefaultDefinition.ts
@@ -1,10 +1,15 @@
+import { ObjectMetadataItem } from '@/object-metadata/types/ObjectMetadataItem';
 import { WorkflowStep, WorkflowStepType } from '@/workflow/types/Workflow';
 import { assertUnreachable } from '@/workflow/utils/assertUnreachable';
 import { v4 } from 'uuid';
 
-export const getStepDefaultDefinition = (
-  type: WorkflowStepType,
-): WorkflowStep => {
+export const getStepDefaultDefinition = ({
+  type,
+  activeObjectMetadataItems,
+}: {
+  type: WorkflowStepType;
+  activeObjectMetadataItems: ObjectMetadataItem[];
+}): WorkflowStep => {
   const newStepId = v4();
 
   switch (type) {
@@ -57,6 +62,34 @@ export const getStepDefaultDefinition = (
         },
       };
     }
+    case 'RECORD_CRUD.CREATE': {
+      return {
+        id: newStepId,
+        name: 'Record Create',
+        type: 'RECORD_CRUD',
+        valid: false,
+        settings: {
+          input: {
+            type: 'CREATE',
+            objectName: activeObjectMetadataItems[0].nameSingular,
+            objectRecord: {},
+          },
+          outputSchema: {},
+          errorHandlingOptions: {
+            continueOnFailure: {
+              value: false,
+            },
+            retryOnFailure: {
+              value: false,
+            },
+          },
+        },
+      };
+    }
+    case 'RECORD_CRUD.DELETE':
+    case 'RECORD_CRUD.UPDATE': {
+      throw new Error('Not implemented yet');
+    }
     default: {
       return assertUnreachable(type, `Unknown type: ${type}`);
     }
diff --git a/packages/twenty-front/src/modules/workflow/utils/isWorkflowRecordCreateAction.ts b/packages/twenty-front/src/modules/workflow/utils/isWorkflowRecordCreateAction.ts
new file mode 100644
index 0000000000..774a2a3974
--- /dev/null
+++ b/packages/twenty-front/src/modules/workflow/utils/isWorkflowRecordCreateAction.ts
@@ -0,0 +1,12 @@
+import {
+  WorkflowAction,
+  WorkflowRecordCreateAction,
+} from '@/workflow/types/Workflow';
+
+export const isWorkflowRecordCreateAction = (
+  action: WorkflowAction,
+): action is WorkflowRecordCreateAction => {
+  return (
+    action.type === 'RECORD_CRUD' && action.settings.input.type === 'CREATE'
+  );
+};
diff --git a/packages/twenty-ui/src/display/icon/components/IconAddressBook.tsx b/packages/twenty-ui/src/display/icon/components/IconAddressBook.tsx
index aa331c1735..82066d131b 100644
--- a/packages/twenty-ui/src/display/icon/components/IconAddressBook.tsx
+++ b/packages/twenty-ui/src/display/icon/components/IconAddressBook.tsx
@@ -3,12 +3,22 @@ import { useTheme } from '@emotion/react';
 import IconAddressBookRaw from '@ui/display/icon/assets/address-book.svg?react';
 import { IconComponentProps } from '@ui/display/icon/types/IconComponent';
 
-type IconAddressBookProps = Pick<IconComponentProps, 'size' | 'stroke'>;
+type IconAddressBookProps = Pick<
+  IconComponentProps,
+  'size' | 'stroke' | 'color'
+>;
 
 export const IconAddressBook = (props: IconAddressBookProps) => {
   const theme = useTheme();
   const size = props.size ?? 24;
   const stroke = props.stroke ?? theme.icon.stroke.md;
 
-  return <IconAddressBookRaw height={size} width={size} strokeWidth={stroke} />;
+  return (
+    <IconAddressBookRaw
+      height={size}
+      width={size}
+      stroke={props.color ?? 'currentColor'}
+      strokeWidth={stroke}
+    />
+  );
 };