Function validateWorkflowGraph

backend/src/dsl/validator.ts:40–152

(
  graph: WorkflowGraphDto,
  compiledDefinition: WorkflowDefinition,
)

 * Comprehensive DSL validation for workflow graphs
 */
export function validateWorkflowGraph(
  graph: WorkflowGraphDto,
  compiledDefinition: WorkflowDefinition,
): ValidationResult {
  const errors: ValidationError[] = [];
  const warnings: ValidationError[] = [];
  const actionPorts = new Map<string, ActionPortSnapshot>();

  // 1. Validate all components exist
  for (const node of graph.nodes) {
    const component = componentRegistry.get(node.type);
    if (!component) {
      errors.push({
        node: node.id,
        field: 'type',
        message: `Unknown component type: ${node.type}`,
        severity: 'error',
        suggestion:
          'Available components: ' +
          componentRegistry
            .list()
            .map((entry) => entry.id)
            .join(', '),
      });
    }
  }

  // 2. Validate component parameters against schemas
  for (const action of compiledDefinition.actions) {
    const component = componentRegistry.get(action.componentId);
    if (!component) continue; // Already reported above

    const portSnapshot = resolveActionPortSnapshot(action, component);
    actionPorts.set(action.ref, portSnapshot);

    const paramsForValidation = { ...(action.params ?? {}) } as Record<string, unknown>;
    const inputOverrides = { ...(action.inputOverrides ?? {}) } as Record<string, unknown>;
    const placeholderFields = new Set<string>();

    for (const inputPort of portSnapshot.inputs) {
      const hasStaticValue =
        Object.prototype.hasOwnProperty.call(inputOverrides, inputPort.id) &&
        inputOverrides[inputPort.id] !== undefined;
      const hasMapping = Object.prototype.hasOwnProperty.call(
        action.inputMappings ?? {},
        inputPort.id,
      );

      if (!hasStaticValue && hasMapping) {
        const connectionType = getPortConnectionType(inputPort);
        inputOverrides[inputPort.id] = createPlaceholderForConnectionType(connectionType);
        placeholderFields.add(inputPort.id);
      }
    }

    const paramValidation = component.parameters
      ? component.parameters.safeParse(paramsForValidation)
      : {