Function normalizeNode

backend/src/__tests__/backend-integration.test.ts:28–43

(override: Partial<WorkflowNodeDto> = {})

const api = (path: string) => `${baseUrl}${path}`;

const normalizeNode = (override: Partial<WorkflowNodeDto> = {}): WorkflowNodeDto => ({
  id: override.id ?? 'node-1',
  type: override.type ?? 'core.workflow.entrypoint',
  position: override.position ?? { x: 0, y: 0 },
  data: {
    label: override.data?.label ?? 'Entry Point',
    config: {
      params: override.data?.config?.params ?? {},
      inputOverrides: override.data?.config?.inputOverrides ?? {},
      joinStrategy: override.data?.config?.joinStrategy,
      streamId: override.data?.config?.streamId,
      groupId: override.data?.config?.groupId,
      maxConcurrency: override.data?.config?.maxConcurrency,
    },
  },
});

type WorkflowGraphOverrides = Partial<Omit<WorkflowGraphDto, 'nodes'>> & {
  nodes?: Partial<WorkflowNodeDto>[];