Function executeMergeChangesNode

src/nodeExecutor.ts:2528–2640

(
  nodeId: string,
  inputData: DBNumericAdjustmentNodeData | DBNumericAdjustmentNodeData[],
  executionContext?: FlowExecutionContext,
)

}

async function executeMergeChangesNode(
  nodeId: string,
  inputData: DBNumericAdjustmentNodeData | DBNumericAdjustmentNodeData[],
  executionContext?: FlowExecutionContext,
): Promise<NodeExecutionResult> {
  console.log(`MergeChanges Node ${nodeId}: Merging multiple ChangedColumnSelection inputs`);

  // Convert single input to array for uniform handling
  const inputs = Array.isArray(inputData) ? inputData : [inputData];

  // Validate all inputs are ChangedColumnSelection
  for (let i = 0; i < inputs.length; i++) {
    if (!inputs[i] || inputs[i].type !== "ChangedColumnSelection") {
      return {
        success: false,
        error: `Invalid input at index ${i}: Expected ChangedColumnSelection data`,
      };
    }
  }

  if (inputs.length === 0) {
    return {
      success: false,
      error: "No inputs to merge. Connect at least one ChangedColumnSelection node.",
    };
  }

  // Start with a deep clone of the first input as the base
  const mergedData = structuredClone(inputs[0].adjustedInputData);

  // Merge all subsequent inputs
  for (let i = 1; i < inputs.length; i++) {
    const currentInput = inputs[i].adjustedInputData;

    // For each table in the current input, merge with the corresponding table in mergedData
    for (const currentColumn of currentInput.columns) {
      // Find if this table already exists in mergedData
      const existingColumn = mergedData.columns.find(
        (col) => col.tableName === currentColumn.tableName && col.fileName === currentColumn.fileName,
      );

      if (existingColumn) {
        // Merge the changes from currentColumn into existingColumn
        // Update the schemaFields to reflect the changes from the current input
        if (
          currentColumn.sourceTable.schemaFields &&
          existingColumn.sourceTable.schemaFields &&
          currentColumn.sourceTable.tableSchema &&
          existingColumn.sourceTable.tableSchema
        ) {
          // Merge schemaFields row by row
          const currentRows = getRowsForPackedFile(currentColumn.sourceTable, executionContext);
          const existingRows = getRowsForPackedFile(existingColumn.sourceTable, executionContext);

          // Use Set for O(1) lookup
          const currentSelectedSet = new Set(currentColumn.selectedColumns);

          // Update cells in existingRows with values from currentRows if they were changed