Function executeTableSelectionDropdownNode

src/nodeExecutor.ts:674–759

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

}

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

  console.log(
    `TableSelection Dropdown Node ${nodeId}: Processing selected table "${selectedTable}" with input:`,
    inputData,
  );

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

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

  // Convert the selected table name to the db\ format if needed
  const tableName = selectedTable.startsWith("db\\") ? selectedTable : `db\\${selectedTable}`;
  const selectedTables = [] as DBTablesNodeTable[];

  for (const file of inputData.files) {
    if (!file.loaded) {
      console.warn(`Skipping unloaded file: ${file.path}`);
      continue;
    }

    try {
      const { pack, matchingTablesByName } = await getTableFilesForPackAndTables(
        file.path,
        [tableName],
        executionContext,
      );
      const matchingTables = matchingTablesByName.get(tableName) || [];

      for (const table of matchingTables) {
        // Limit to 300 rows for easier testing
        const limitedTable = table;
        // if (table.tableSchema && table.schemaFields) {
        //   const rows = chunkSchemaIntoRows(table.schemaFields, table.tableSchema) as AmendedSchemaField[][];

        //   if (rows.length > 300) {
        //     console.log(
        //       `TableSelection Dropdown Node ${nodeId}: Limiting ${tableName} from ${rows.length} rows to 300 rows`
        //     );
        //     const limitedRows = rows.slice(0, 300);
        //     const limitedSchemaFields = limitedRows.flat();

        //     limitedTable = {