packages/twenty-server/src/engine/metadata-modules/flat-view-field/utils/compute-flat-view-fields-from-fields-widgets.util.ts

import { ViewKey } from 'twenty-shared/types';
import { isDefined } from 'twenty-shared/utils';
import { v4 } from 'uuid';

import { type FlatPageLayoutWidgetMaps } from 'src/engine/metadata-modules/flat-page-layout-widget/types/flat-page-layout-widget-maps.type';
import { type FlatViewFieldGroupMaps } from 'src/engine/metadata-modules/flat-view-field-group/types/flat-view-field-group-maps.type';
import { DEFAULT_VIEW_FIELD_SIZE } from 'src/engine/metadata-modules/flat-view-field/constants/default-view-field-size.constant';
import { type FlatViewFieldMaps } from 'src/engine/metadata-modules/flat-view-field/types/flat-view-field-maps.type';
import { type FlatViewField } from 'src/engine/metadata-modules/flat-view-field/types/flat-view-field.type';
import { type FlatViewMaps } from 'src/engine/metadata-modules/flat-view/types/flat-view-maps.type';
import { type FieldsConfigurationDTO } from 'src/engine/metadata-modules/page-layout-widget/dtos/fields-configuration.dto';
import { WidgetConfigurationType } from 'src/engine/metadata-modules/page-layout-widget/enums/widget-configuration-type.type';
import { WidgetType } from 'src/engine/metadata-modules/page-layout-widget/enums/widget-type.enum';
import { type AllPageLayoutWidgetConfiguration } from 'src/engine/metadata-modules/page-layout-widget/types/all-page-layout-widget-configuration.type';
import { type UniversalFlatViewField } from 'src/engine/workspace-manager/workspace-migration/universal-flat-entity/types/universal-flat-view-field.type';

type FieldToCreateInfo = {
  objectMetadataUniversalIdentifier: string;
  fieldMetadataUniversalIdentifier: string;
};

type FieldViewTarget = {
  viewId: string;
  isVisible: boolean;
};

const isFieldsWidgetConfiguration = (
  configuration: AllPageLayoutWidgetConfiguration,
): configuration is FieldsConfigurationDTO => {
  return (
    isDefined(configuration) &&
    configuration.configurationType === WidgetConfigurationType.FIELDS
  );
};

const getFieldViewTargets = ({
  objectMetadataUniversalIdentifier,
  flatPageLayoutWidgetMaps,
  flatViewMaps,
}: {
  objectMetadataUniversalIdentifier: string;
  flatPageLayoutWidgetMaps: FlatPageLayoutWidgetMaps;
  flatViewMaps: FlatViewMaps;
}): FieldViewTarget[] => {
  const targets: FieldViewTarget[] = [];
  const seenViewIds = new Set<string>();

  for (const widget of Object.values(
    flatPageLayoutWidgetMaps.byUniversalIdentifier,
  ).filter(isDefined)) {
    if (
      !widget.isActive ||
      widget.type !== WidgetType.FIELDS ||
      widget.objectMetadataUniversalIdentifier !==
        objectMetadataUniversalIdentifier ||
      !isFieldsWidgetConfiguration(widget.configuration)
    ) {
      continue;
    }

    const { viewId, newFieldDefaultVisibility } = widget.configuration;

    if (
      !isDefined(viewId) ||
      !isDefined(newFieldDefaultVisibility) ||
      seenViewIds.has(viewId)
    ) {
      continue;
    }

    seenViewIds.add(viewId);
    targets.push({ viewId, isVisible: newFieldDefaultVisibility });
  }

  for (const view of Object.values(flatViewMaps.byUniversalIdentifier).filter(
    isDefined,
  )) {
    if (
      view.key !== ViewKey.INDEX ||
      !view.isActive ||
      isDefined(view.deletedAt) ||
      view.objectMetadataUniversalIdentifier !==
        objectMetadataUniversalIdentifier ||
      seenViewIds.has(view.id)
    ) {
      continue;
    }

    seenViewIds.add(view.id);
    targets.push({ viewId: view.id, isVisible: false });
  }

  return targets;
};

const findLastViewFieldGroupId = ({
  viewId,
  flatViewFieldGroupMaps,
}: {
  viewId: string;
  flatViewFieldGroupMaps: FlatViewFieldGroupMaps;
}): string | null => {
  const groupsForView = Object.values(
    flatViewFieldGroupMaps.byUniversalIdentifier,
  )
    .filter(isDefined)
    .filter((group) => group.isActive && group.viewId === viewId);

  if (groupsForView.length === 0) {
    return null;
  }

  const lastGroup = groupsForView.reduce((maxGroup, group) =>
    group.position > maxGroup.position ? group : maxGroup,
  );

  return lastGroup.id;
};

const computeNextPosition = ({
  viewId,
  viewFieldGroupId,
  flatViewFieldMaps,
}: {
  viewId: string;
  viewFieldGroupId: string | null;
  flatViewFieldMaps: FlatViewFieldMaps;
}): number => {
  const existingViewFields = Object.values(
    flatViewFieldMaps.byUniversalIdentifier,
  )
    .filter(isDefined)
    .filter(
      (viewField: FlatViewField) =>
        viewField.isActive && viewField.viewId === viewId,
    )
    .filter(
      (viewField: FlatViewField) =>
        viewField.viewFieldGroupId === viewFieldGroupId,
    );

  if (existingViewFields.length === 0) {
    return 0;
  }

  const maxPosition = Math.max(
    ...existingViewFields.map((viewField) => viewField.position),
  );

  return maxPosition + 1;
};

export const computeFlatViewFieldsFromFieldsWidgets = ({
  fieldsToCreate,
  flatPageLayoutWidgetMaps,
  flatViewFieldMaps,
  flatViewMaps,
  flatViewFieldGroupMaps,
  applicationUniversalIdentifier,
}: {
  fieldsToCreate: FieldToCreateInfo[];
  flatPageLayoutWidgetMaps: FlatPageLayoutWidgetMaps;
  flatViewFieldMaps: FlatViewFieldMaps;
  flatViewMaps: FlatViewMaps;
  flatViewFieldGroupMaps: FlatViewFieldGroupMaps;
  applicationUniversalIdentifier: string;
}): UniversalFlatViewField[] => {
  const flatViewFieldsToCreate: UniversalFlatViewField[] = [];
  const now = new Date().toISOString();

  const objectMetadataUniversalIdentifiers = [
    ...new Set(
      fieldsToCreate.map((field) => field.objectMetadataUniversalIdentifier),
    ),
  ];

  const nextPositionByKey = new Map<string, number>();
  const queuedViewFieldKeys = new Set<string>();

  for (const objectMetadataUniversalIdentifier of objectMetadataUniversalIdentifiers) {
    const targets = getFieldViewTargets({
      objectMetadataUniversalIdentifier,
      flatPageLayoutWidgetMaps,
      flatViewMaps,
    });

    const fieldsForObject = fieldsToCreate.filter(
      (field) =>
        field.objectMetadataUniversalIdentifier ===
        objectMetadataUniversalIdentifier,
    );

    for (const { viewId, isVisible } of targets) {
      const viewUniversalIdentifier =
        flatViewMaps.universalIdentifierById[viewId] ?? null;

      if (!isDefined(viewUniversalIdentifier)) {
        continue;
      }

      const isSystemSideEffect =
        flatViewMaps.byUniversalIdentifier[viewUniversalIdentifier]
          ?.isSystemSideEffect ?? false;

      const viewFieldGroupId = findLastViewFieldGroupId({
        viewId,
        flatViewFieldGroupMaps,
      });

      const viewFieldGroupUniversalIdentifier = isDefined(viewFieldGroupId)
        ? (flatViewFieldGroupMaps.universalIdentifierById[viewFieldGroupId] ??
          null)
        : null;

      const positionKey = `${viewId}:${viewFieldGroupId ?? 'null'}`;

      if (!nextPositionByKey.has(positionKey)) {
        nextPositionByKey.set(
          positionKey,
          computeNextPosition({
            viewId,
            viewFieldGroupId,
            flatViewFieldMaps,
          }),
        );
      }

      for (const field of fieldsForObject) {
        const dedupKey = `${viewId}:${field.fieldMetadataUniversalIdentifier}`;

        if (queuedViewFieldKeys.has(dedupKey)) {
          continue;
        }

        queuedViewFieldKeys.add(dedupKey);

        const position = nextPositionByKey.get(positionKey)!;

        nextPositionByKey.set(positionKey, position + 1);

        flatViewFieldsToCreate.push({
          universalIdentifier: v4(),
          applicationUniversalIdentifier,
          fieldMetadataUniversalIdentifier:
            field.fieldMetadataUniversalIdentifier,
          viewUniversalIdentifier,
          viewFieldGroupUniversalIdentifier,
          isVisible,
          size: DEFAULT_VIEW_FIELD_SIZE,
          position,
          aggregateOperation: null,
          isActive: true,
          isSystemSideEffect,
          universalOverrides: null,
          createdAt: now,
          updatedAt: now,
          deletedAt: null,
        });
      }
    }
  }

  return flatViewFieldsToCreate;
};