Add relations in database event trigger output data (#11820)

## Done
- add relations in dropdown variables
- add relations in worklfow run inputs
- use objectMetadataMaps in workflow folder

## To do
- does not work with rest api calls, will be fixed after
#11349 is merged
- waiting for crud action relation fields
twentyhq/core-team-issues#509

Author: martmull

packages/twenty-front/src/modules/object-record/record-field/components/FormFieldInput.tsx

@@ -14,6 +14,7 @@ import { FormRichTextV2FieldInput } from '@/object-record/record-field/form-type
 import { FormSelectFieldInput } from '@/object-record/record-field/form-types/components/FormSelectFieldInput';
 import { FormTextFieldInput } from '@/object-record/record-field/form-types/components/FormTextFieldInput';
 import { FormUuidFieldInput } from '@/object-record/record-field/form-types/components/FormUuidFieldInput';
+import { FormRelationToOneFieldInput } from '@/object-record/record-field/form-types/components/FormRelationToOneFieldInput';
 import { VariablePickerComponent } from '@/object-record/record-field/form-types/types/VariablePickerComponent';
 import { FieldDefinition } from '@/object-record/record-field/types/FieldDefinition';
 import {
@@ -24,6 +25,8 @@ import {
   FieldMetadata,
   FieldMultiSelectValue,
   FieldPhonesValue,
+  FieldRelationToOneValue,
+  FieldRelationValue,
   FieldRichTextV2Value,
   FormFieldCurrencyValue,
 } from '@/object-record/record-field/types/FieldMetadata';
@@ -43,6 +46,7 @@ import { isFieldRichTextV2 } from '@/object-record/record-field/types/guards/isF
 import { isFieldSelect } from '@/object-record/record-field/types/guards/isFieldSelect';
 import { isFieldText } from '@/object-record/record-field/types/guards/isFieldText';
 import { isFieldUuid } from '@/object-record/record-field/types/guards/isFieldUuid';
+import { isFieldRelationToOneObject } from '@/object-record/record-field/types/guards/isFieldRelationToOneObject';
 import { JsonValue } from 'type-fest';
 
 type FormFieldInputProps = {
@@ -205,5 +209,15 @@ export const FormFieldInput = ({
       readonly={readonly}
       placeholder={placeholder}
     />
+  ) : isFieldRelationToOneObject(field) ? (
+    <FormRelationToOneFieldInput
+      label={field.label}
+      objectNameSingular={field.metadata.relationObjectMetadataNameSingular}
+      defaultValue={defaultValue as FieldRelationValue<FieldRelationToOneValue>}
+      onChange={onChange}
+      VariablePicker={VariablePicker}
+      readonly={readonly}
+      placeholder={placeholder}
+    />
   ) : null;
 };

packages/twenty-front/src/modules/object-record/record-field/form-types/components/FormRelationToOneFieldInput.tsx

@@ -0,0 +1,44 @@
+import { VariablePickerComponent } from '@/object-record/record-field/form-types/types/VariablePickerComponent';
+import { FormSingleRecordPicker } from '@/object-record/record-field/form-types/components/FormSingleRecordPicker';
+import { isDefined } from 'twenty-shared/utils';
+import { JsonValue } from 'type-fest';
+import {
+  FieldRelationToOneValue,
+  FieldRelationValue,
+} from '@/object-record/record-field/types/FieldMetadata';
+
+export type FormRelationToOneFieldInputProps = {
+  label?: string;
+  objectNameSingular?: string;
+  defaultValue: FieldRelationValue<FieldRelationToOneValue>;
+  onChange: (value: JsonValue) => void;
+  readonly?: boolean;
+  VariablePicker?: VariablePickerComponent;
+  placeholder?: string;
+};
+
+export const FormRelationToOneFieldInput = ({
+  label,
+  objectNameSingular,
+  onChange,
+  defaultValue,
+  readonly,
+  VariablePicker,
+}: FormRelationToOneFieldInputProps) => {
+  return (
+    isDefined(objectNameSingular) && (
+      <FormSingleRecordPicker
+        label={label}
+        defaultValue={defaultValue?.id}
+        onChange={(recordId) => {
+          onChange({
+            id: recordId,
+          });
+        }}
+        objectNameSingular={objectNameSingular}
+        disabled={readonly}
+        VariablePicker={VariablePicker}
+      />
+    )
+  );
+};

packages/twenty-front/src/modules/object-record/record-field/form-types/components/FormSingleRecordPicker.tsx

@@ -58,7 +58,7 @@ type FormSingleRecordPickerValue =
 
 export type FormSingleRecordPickerProps = {
   label?: string;
-  defaultValue: RecordId | Variable;
+  defaultValue?: RecordId | Variable;
   onChange: (value: RecordId | Variable) => void;
   objectNameSingular: string;
   disabled?: boolean;
@@ -95,7 +95,7 @@ export const FormSingleRecordPicker = ({
         : '',
     objectNameSingular,
     withSoftDeleted: true,
-    skip: !isValidUuid(defaultValue),
+    skip: !isDefined(defaultValue) || !isValidUuid(defaultValue),
   });
 
   const dropdownId = `form-record-picker-${objectNameSingular}`;

packages/twenty-front/src/modules/workflow/workflow-steps/workflow-actions/components/WorkflowEditActionCreateRecord.tsx

@@ -17,7 +17,7 @@ import { HorizontalSeparator, useIcons } from 'twenty-ui/display';
 import { SelectOption } from 'twenty-ui/input';
 import { JsonValue } from 'type-fest';
 import { useDebouncedCallback } from 'use-debounce';
-import { FieldMetadataType } from '~/generated/graphql';
+import { shouldDisplayFormField } from '@/workflow/workflow-steps/workflow-actions/utils/shouldDisplayFormField';
 
 type WorkflowEditActionCreateRecordProps = {
   action: WorkflowCreateRecordAction;
@@ -92,11 +92,8 @@ export const WorkflowEditActionCreateRecord = ({
   const viewFields = indexView?.viewFields ?? [];
 
   const inlineFieldMetadataItems = objectMetadataItem?.fields
-    .filter(
-      (fieldMetadataItem) =>
-        fieldMetadataItem.type !== FieldMetadataType.RELATION &&
-        !fieldMetadataItem.isSystem &&
-        fieldMetadataItem.isActive,
+    .filter((fieldMetadataItem) =>
+      shouldDisplayFormField({ fieldMetadataItem, actionType: action.type }),
     )
     .map((fieldMetadataItem) => {
       const viewField = viewFields.find(

packages/twenty-front/src/modules/workflow/workflow-steps/workflow-actions/components/WorkflowEditActionUpdateRecord.tsx

@@ -18,7 +18,7 @@ import { HorizontalSeparator, useIcons } from 'twenty-ui/display';
 import { SelectOption } from 'twenty-ui/input';
 import { JsonValue } from 'type-fest';
 import { useDebouncedCallback } from 'use-debounce';
-import { FieldMetadataType } from '~/generated-metadata/graphql';
+import { shouldDisplayFormField } from '@/workflow/workflow-steps/workflow-actions/utils/shouldDisplayFormField';
 
 type WorkflowEditActionUpdateRecordProps = {
   action: WorkflowUpdateRecordAction;
@@ -39,24 +39,6 @@ type UpdateRecordFormData = {
   [field: string]: unknown;
 };
 
-const AVAILABLE_FIELD_METADATA_TYPES = [
-  FieldMetadataType.TEXT,
-  FieldMetadataType.NUMBER,
-  FieldMetadataType.DATE,
-  FieldMetadataType.BOOLEAN,
-  FieldMetadataType.SELECT,
-  FieldMetadataType.MULTI_SELECT,
-  FieldMetadataType.EMAILS,
-  FieldMetadataType.LINKS,
-  FieldMetadataType.FULL_NAME,
-  FieldMetadataType.ADDRESS,
-  FieldMetadataType.PHONES,
-  FieldMetadataType.CURRENCY,
-  FieldMetadataType.DATE_TIME,
-  FieldMetadataType.RAW_JSON,
-  FieldMetadataType.UUID,
-];
-
 export const WorkflowEditActionUpdateRecord = ({
   action,
   actionOptions,
@@ -102,11 +84,8 @@ export const WorkflowEditActionUpdateRecord = ({
   const objectNameSingular = selectedObjectMetadataItem?.nameSingular;
 
   const inlineFieldMetadataItems = selectedObjectMetadataItem?.fields
-    .filter(
-      (fieldMetadataItem) =>
-        !fieldMetadataItem.isSystem &&
-        fieldMetadataItem.isActive &&
-        AVAILABLE_FIELD_METADATA_TYPES.includes(fieldMetadataItem.type),
+    .filter((fieldMetadataItem) =>
+      shouldDisplayFormField({ fieldMetadataItem, actionType: action.type }),
     )
     .sort((fieldMetadataItemA, fieldMetadataItemB) =>
       fieldMetadataItemA.name.localeCompare(fieldMetadataItemB.name),

packages/twenty-front/src/modules/workflow/workflow-steps/workflow-actions/utils/shouldDisplayFormField.ts

@@ -0,0 +1,51 @@
+import { FieldMetadataItem } from '@/object-metadata/types/FieldMetadataItem';
+import { WorkflowActionType } from '@/workflow/types/Workflow';
+import { FieldMetadataType } from '~/generated/graphql';
+
+const DISPLAYABLE_FIELD_TYPES_FOR_UPDATE = [
+  FieldMetadataType.TEXT,
+  FieldMetadataType.NUMBER,
+  FieldMetadataType.DATE,
+  FieldMetadataType.BOOLEAN,
+  FieldMetadataType.SELECT,
+  FieldMetadataType.MULTI_SELECT,
+  FieldMetadataType.EMAILS,
+  FieldMetadataType.LINKS,
+  FieldMetadataType.FULL_NAME,
+  FieldMetadataType.ADDRESS,
+  FieldMetadataType.PHONES,
+  FieldMetadataType.CURRENCY,
+  FieldMetadataType.DATE_TIME,
+  FieldMetadataType.RAW_JSON,
+  FieldMetadataType.UUID,
+];
+
+export const shouldDisplayFormField = ({
+  fieldMetadataItem,
+  actionType,
+}: {
+  fieldMetadataItem: FieldMetadataItem;
+  actionType: WorkflowActionType;
+}) => {
+  let isTypeAllowedForAction = false;
+
+  switch (actionType) {
+    case 'CREATE_RECORD':
+      isTypeAllowedForAction =
+        fieldMetadataItem.type !== FieldMetadataType.RELATION;
+      break;
+    case 'UPDATE_RECORD':
+      isTypeAllowedForAction = DISPLAYABLE_FIELD_TYPES_FOR_UPDATE.includes(
+        fieldMetadataItem.type,
+      );
+      break;
+    default:
+      throw new Error(`Action "${actionType}" is not supported`);
+  }
+  return (
+    (isTypeAllowedForAction ||
+      fieldMetadataItem.settings?.['relationType'] === 'MANY_TO_ONE') &&
+    !fieldMetadataItem.isSystem &&
+    fieldMetadataItem.isActive
+  );
+};

packages/twenty-server/src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-create-many-resolver.service.ts

@@ -321,8 +321,8 @@ export class GraphqlQueryCreateManyResolverService extends GraphqlQueryBaseResol
       );
 
       this.apiEventEmitterService.emitUpdateEvents({
-        existingRecords: [existingRecord],
-        records: [record],
+        existingRecords: structuredClone([existingRecord]),
+        records: structuredClone([record]),
         updatedFields: Object.keys(formattedPartialRecordToUpdate),
         authContext,
         objectMetadataItem: objectMetadataItemWithFieldMaps,
@@ -366,7 +366,7 @@ export class GraphqlQueryCreateManyResolverService extends GraphqlQueryBaseResol
     }
 
     this.apiEventEmitterService.emitCreateEvents({
-      records: formattedInsertedRecords,
+      records: structuredClone(formattedInsertedRecords),
       authContext,
       objectMetadataItem: objectMetadataItemWithFieldMaps,
     });

packages/twenty-server/src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-create-one-resolver.service.ts

@@ -54,7 +54,7 @@ export class GraphqlQueryCreateOneResolverService extends GraphqlQueryBaseResolv
     );
 
     this.apiEventEmitterService.emitCreateEvents({
-      records: upsertedRecords,
+      records: structuredClone(upsertedRecords),
       authContext,
       objectMetadataItem: objectMetadataItemWithFieldMaps,
     });

packages/twenty-server/src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-delete-many-resolver.service.ts

@@ -56,7 +56,7 @@ export class GraphqlQueryDeleteManyResolverService extends GraphqlQueryBaseResol
     );
 
     this.apiEventEmitterService.emitDeletedEvents({
-      records: formattedDeletedRecords,
+      records: structuredClone(formattedDeletedRecords),
       authContext,
       objectMetadataItem: objectMetadataItemWithFieldMaps,
     });

packages/twenty-server/src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-delete-one-resolver.service.ts

@@ -48,12 +48,6 @@ export class GraphqlQueryDeleteOneResolverService extends GraphqlQueryBaseResolv
       objectMetadataMaps,
     );
 
-    this.apiEventEmitterService.emitDeletedEvents({
-      records: formattedDeletedRecords,
-      authContext,
-      objectMetadataItem: objectMetadataItemWithFieldMaps,
-    });
-
     if (formattedDeletedRecords.length === 0) {
       throw new GraphqlQueryRunnerException(
         'Record not found',
@@ -63,6 +57,12 @@ export class GraphqlQueryDeleteOneResolverService extends GraphqlQueryBaseResolv
 
     const deletedRecord = formattedDeletedRecords[0];
 
+    this.apiEventEmitterService.emitDeletedEvents({
+      records: structuredClone(formattedDeletedRecords),
+      authContext,
+      objectMetadataItem: objectMetadataItemWithFieldMaps,
+    });
+
     if (executionArgs.graphqlQuerySelectedFieldsResult.relations) {
       await this.processNestedRelationsHelper.processNestedRelations({
         objectMetadataMaps,

packages/twenty-server/src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-destroy-many-resolver.service.ts

@@ -54,7 +54,7 @@ export class GraphqlQueryDestroyManyResolverService extends GraphqlQueryBaseReso
     );
 
     this.apiEventEmitterService.emitDestroyEvents({
-      records: deletedRecords,
+      records: structuredClone(deletedRecords),
       authContext,
       objectMetadataItem: objectMetadataItemWithFieldMaps,
     });

packages/twenty-server/src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-destroy-one-resolver.service.ts

@@ -54,7 +54,7 @@ export class GraphqlQueryDestroyOneResolverService extends GraphqlQueryBaseResol
     );
 
     this.apiEventEmitterService.emitDestroyEvents({
-      records: deletedRecords,
+      records: structuredClone(deletedRecords),
       authContext,
       objectMetadataItem: objectMetadataItemWithFieldMaps,
     });

packages/twenty-server/src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-restore-many-resolver.service.ts

@@ -56,7 +56,7 @@ export class GraphqlQueryRestoreManyResolverService extends GraphqlQueryBaseReso
     );
 
     this.apiEventEmitterService.emitRestoreEvents({
-      records: formattedRestoredRecords,
+      records: structuredClone(formattedRestoredRecords),
       authContext,
       objectMetadataItem: objectMetadataItemWithFieldMaps,
     });

packages/twenty-server/src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-restore-one-resolver.service.ts

@@ -48,12 +48,6 @@ export class GraphqlQueryRestoreOneResolverService extends GraphqlQueryBaseResol
       objectMetadataMaps,
     );
 
-    this.apiEventEmitterService.emitRestoreEvents({
-      records: formattedRestoredRecords,
-      authContext,
-      objectMetadataItem: objectMetadataItemWithFieldMaps,
-    });
-
     if (formattedRestoredRecords.length === 0) {
       throw new GraphqlQueryRunnerException(
         'Record not found',
@@ -63,6 +57,12 @@ export class GraphqlQueryRestoreOneResolverService extends GraphqlQueryBaseResol
 
     const restoredRecord = formattedRestoredRecords[0];
 
+    this.apiEventEmitterService.emitRestoreEvents({
+      records: structuredClone(formattedRestoredRecords),
+      authContext,
+      objectMetadataItem: objectMetadataItemWithFieldMaps,
+    });
+
     if (executionArgs.graphqlQuerySelectedFieldsResult.relations) {
       await this.processNestedRelationsHelper.processNestedRelations({
         objectMetadataMaps,

packages/twenty-server/src/engine/api/graphql/graphql-query-runner/resolvers/graphql-query-update-many-resolver.service.ts

@@ -90,8 +90,8 @@ export class GraphqlQueryUpdateManyResolverService extends GraphqlQueryBaseResol
     );
 
     this.apiEventEmitterService.emitUpdateEvents({
-      existingRecords: formattedExistingRecords,
-      records: formattedUpdatedRecords,
+      existingRecords: structuredClone(formattedExistingRecords),
+      records: structuredClone(formattedUpdatedRecords),
       updatedFields: Object.keys(executionArgs.args.data),
       authContext,
       objectMetadataItem: objectMetadataItemWithFieldMaps,
@@ -101,7 +101,10 @@ export class GraphqlQueryUpdateManyResolverService extends GraphqlQueryBaseResol
       await this.processNestedRelationsHelper.processNestedRelations({
         objectMetadataMaps,
         parentObjectMetadataItem: objectMetadataItemWithFieldMaps,
-        parentObjectRecords: formattedUpdatedRecords,
+        parentObjectRecords: [
+          ...formattedExistingRecords,
+          ...formattedUpdatedRecords,
+        ],
         relations: executionArgs.graphqlQuerySelectedFieldsResult.relations,
         limit: QUERY_MAX_RECORDS,
         authContext,