Function executeGroupByColumnsNode

src/nodeExecutor.ts:817–923

(
  nodeId: string,
  textValue: string,
  inputData: DBTablesNodeData,
  config?: unknown,
)

}

async function executeGroupByColumnsNode(
  nodeId: string,
  textValue: string,
  inputData: DBTablesNodeData,
  config?: unknown,
): Promise<NodeExecutionResult> {
  console.log(`GroupByColumns Node ${nodeId}: Processing with textValue:`, textValue);
  console.log(`GroupByColumns Node ${nodeId}: Input data:`, inputData);

  if (!inputData || inputData.type !== "TableSelection") {
    return { success: false, error: "Invalid input: Expected TableSelection data" };
  }

  // Parse the column selections from textValue
  const parsed = getNodeConfig<{ column1?: string; column2?: string; onlyForMultiple?: boolean }>(config, textValue);
  if (!parsed) {
    return {
      success: false,
      error: "Invalid column configuration. Expected JSON with column1 and column2 fields.",
    };
  }
  const column1 = parsed.column1 || "";
  const column2 = parsed.column2 || "";
  const onlyForMultiple = parsed.onlyForMultiple || false;

  if (!column1 || column1.trim() === "" || !column2 || column2.trim() === "") {
    return {
      success: false,
      error: `Both column1 and column2 must be selected. Received: column1="${column1}", column2="${column2}"`,
    };
  }

  // Process each table
  const groupedData = new Map<string, string[]>();

  for (const tableData of inputData.tables) {
    if (
      !tableData.table.tableSchema ||
      !tableData.table.schemaFields ||
      tableData.table.schemaFields.length === 0
    ) {
      console.log(`Missing table data, skipping ${tableData.name}!`);
      continue;
    }

    const rows = getRowsForPackedFile(tableData.table);

    // Find the column indices
    const column1Index = getColumnIndexForPackedFile(tableData.table, column1);
    const column2Index = getColumnIndexForPackedFile(tableData.table, column2);

    if (column1Index === -1 || column2Index === -1) {
      console.warn(
        `Columns ${column1} or ${column2} not found in table ${tableData.name}. Skipping this table.`,
      );
      continue;
    }