Function executeColumnSelectionDropdownNode

src/nodeExecutor.ts:1922–1989

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

}

async function executeColumnSelectionDropdownNode(
  nodeId: string,
  textValue: string,
  inputData: DBTablesNodeData,
  executionContext?: FlowExecutionContext,
  config?: unknown,
): Promise<NodeExecutionResult> {
  const parsedConfig = getNodeConfig<{ selectedColumn?: string }>(config, textValue);
  const selectedColumn = parsedConfig?.selectedColumn ?? textValue;

  console.log(
    `ColumnSelection Dropdown Node ${nodeId}: Processing selected column "${selectedColumn}" with num input tables:`,
    inputData.tables.length,
    `table names:`,
    inputData.tables.map((t) => t.name),
  );

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

  if (!selectedColumn || selectedColumn.trim() === "") {
    return {
      success: false,
      error: "No column selected. Please select a column from the dropdown.",
    };
  }

  const selectedColumns = [selectedColumn.trim()];
  const selectedColumnsSet = new Set(selectedColumns);
  const columnData = [] as DBColumnSelectionTableValues[];

  for (const tableData of inputData.tables) {
    if (
      tableData.table.tableSchema &&
      tableData.table.schemaFields &&
      tableData.table.schemaFields.length != 0
    ) {
      const rows = getRowsForPackedFile(tableData.table, executionContext);
      const cellData = [] as { col: string; data: string }[];
      for (const row of rows) {
        for (const cell of row) {
          if (selectedColumnsSet.has(cell.name)) {
            cellData.push({ col: cell.name, data: cell.resolvedKeyValue });
          }
        }
      }
      columnData.push({
        tableName: tableData.name,
        fileName: tableData.fileName,
        sourcePack: tableData.sourceFile,
        sourceTable: tableData.table,
        selectedColumns: selectedColumns,
        data: cellData,
      } as DBColumnSelectionTableValues);
    }
  }