Function executeIndexTableNode

src/nodeExecutor.ts:3293–3389

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

}

async function executeIndexTableNode(
  nodeId: string,
  textValue: string,
  inputData: DBTablesNodeData,
  config?: unknown,
): Promise<NodeExecutionResult> {
  console.log(`Index Table Node ${nodeId}: Processing ${inputData?.tables?.length || 0} table(s)`);

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

  // Parse index columns from textValue
  const parsed = getNodeConfig<{ indexColumns?: string[] }>(config, textValue);
  if (!parsed) {
    return { success: false, error: "Invalid index configuration" };
  }
  const indexColumns = parsed.indexColumns || [];

  if (indexColumns.length === 0) {
    return { success: false, error: "No index columns specified" };
  }

  console.log(`Index Table Node ${nodeId}: Indexing by columns: ${indexColumns.join(", ")}`);

  // Combine rows from all tables
  if (inputData.tables.length === 0) {
    return { success: false, error: "No tables in input data" };
  }

  const allRows: AmendedSchemaField[][] = [];
  const sourceTable = inputData.tables[0]; // Keep first for metadata

  for (const table of inputData.tables) {
    if (!table.table.schemaFields || !table.table.tableSchema) {
      console.warn(`Index Table Node ${nodeId}: Skipping table without schema data`);
      continue;
    }

    const rows = getRowsForPackedFile(table.table);

    allRows.push(...rows);
  }

  const rows = allRows;
  console.log(
    `Index Table Node ${nodeId}: Indexing ${rows.length} rows from ${inputData.tables.length} pack file(s)`,
  );

  // Build the index map
  const indexMap = new Map<string, any[]>();

  for (const row of rows) {
    // Extract values for the index columns
    const keyParts: string[] = [];
    let allColumnsFound = true;

    for (const columnName of indexColumns) {