packages/twenty-shared/src/workflow/layout/utils/compute-workflow-layout.util.ts

import Dagre from '@dagrejs/dagre';

import { WORKFLOW_LAYOUT_DEFAULT_OPTIONS } from '@/workflow/layout/constants/WorkflowLayoutDefaultOptions';

export type WorkflowLayoutNode = {
  id: string;
  width: number;
  height: number;
};

export type WorkflowLayoutEdge = {
  source: string;
  target: string;
};

export type WorkflowLayoutPosition = {
  id: string;
  position: { x: number; y: number };
};

export type WorkflowLayoutOptions = {
  ranksep: number;
  nodesep: number;
  rankdir: string;
};

export const computeWorkflowLayout = ({
  nodes,
  edges,
  options = WORKFLOW_LAYOUT_DEFAULT_OPTIONS,
}: {
  nodes: WorkflowLayoutNode[];
  edges: WorkflowLayoutEdge[];
  options?: WorkflowLayoutOptions;
}): WorkflowLayoutPosition[] => {
  const graph = new Dagre.graphlib.Graph().setDefaultEdgeLabel(() => ({}));

  graph.setGraph({
    ranksep: options.ranksep,
    nodesep: options.nodesep,
    rankdir: options.rankdir,
  });

  const nodeIds = new Set(nodes.map((node) => node.id));

  nodes.forEach((node) =>
    graph.setNode(node.id, {
      width: node.width,
      height: node.height,
    }),
  );

  edges.forEach((edge) => {
    if (nodeIds.has(edge.source) && nodeIds.has(edge.target)) {
      graph.setEdge(edge.source, edge.target);
    }
  });

  Dagre.layout(graph);

  return nodes.map((node) => {
    const layoutedNode = graph.node(node.id);

    const x = layoutedNode.x - layoutedNode.width / 2;
    const y = layoutedNode.y - layoutedNode.height / 2;

    return { id: node.id, position: { x, y } };
  });
};