Function executeMathCeilNode

src/nodeExecutor.ts:2361–2526

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

}

async function executeMathCeilNode(
  nodeId: string,
  inputData: DBNumericAdjustmentNodeData | DBNumericAdjustmentNodeData[],
  executionContext?: FlowExecutionContext,
): Promise<NodeExecutionResult> {
  console.log(`MathCeil Node ${nodeId}: Processing 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." };
  }

  // 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`,
      };
    }
  }

  // Merge all inputs if there are multiple
  let mergedInputData: DBColumnSelectionNodeData;
  let originalData: DBColumnSelectionNodeData;

  if (inputs.length === 1) {
    mergedInputData = inputs[0].adjustedInputData;
    originalData = inputs[0].originalData;
  } else {
    // Start with a deep clone of the first input as the base
    mergedInputData = structuredClone(inputs[0].adjustedInputData);
    originalData = inputs[0].originalData;

    // 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 mergedInputData
      for (const currentColumn of currentInput.columns) {
        // Find if this table already exists in mergedInputData
        const existingColumn = mergedInputData.columns.find(
          (col) => col.tableName === currentColumn.tableName && col.fileName === currentColumn.fileName,
        );

        if (existingColumn) {
          // Merge the changes from currentColumn into existingColumn
          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);