Function executeNumericAdjustmentNode

src/nodeExecutor.ts:1991–2182

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

}

async function executeNumericAdjustmentNode(
  nodeId: string,
  textValue: string,
  inputData:
    | DBColumnSelectionNodeData
    | DBColumnSelectionNodeData[]
    | DBNumericAdjustmentNodeData
    | DBNumericAdjustmentNodeData[],
  executionContext?: FlowExecutionContext,
): Promise<NodeExecutionResult> {
  console.log(`NumericAdjustment Node ${nodeId}: Processing formula "${textValue}" with input:`, inputData);

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

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

  // Extract ColumnSelection data from inputs (handle both ColumnSelection and ChangedColumnSelection)
  const columnSelectionInputs: DBColumnSelectionNodeData[] = [];
  for (let i = 0; i < inputs.length; i++) {
    const input = inputs[i];
    if (!input) {
      return { success: false, error: `Invalid input at index ${i}: No data provided` };
    }

    if (input.type === "ColumnSelection") {
      columnSelectionInputs.push(input as DBColumnSelectionNodeData);
    } else if (input.type === "ChangedColumnSelection") {
      columnSelectionInputs.push((input as DBNumericAdjustmentNodeData).adjustedInputData);
    } else {
      return {
        success: false,
        error: `Invalid input at index ${i}: Expected ColumnSelection or ChangedColumnSelection data`,
      };
    }
  }

  // Merge all inputs if there are multiple
  let mergedInput: DBColumnSelectionNodeData;
  if (columnSelectionInputs.length === 1) {
    mergedInput = columnSelectionInputs[0];
  } else {
    hotPathLog(executionContext, `NumericAdjustment Node ${nodeId}: Merging ${columnSelectionInputs.length} inputs`);

    // Collect unique tables and merge selectedColumns/data WITHOUT cloning yet
    // We'll clone once at the end when we apply the formula
    const tableMap = new Map<
      string,
      { column: any; selectedColumns: Set<string>; dataMap: Map<string, any> }
    >();
    const allSourceTables: any[] = [];
    const seenSourceTables = new Set<string>();

    for (const input of columnSelectionInputs) {
      for (const column of input.columns) {
        const key = `${column.tableName}|${column.fileName}`;