Function executeLookupNode

src/nodeExecutor.ts:3391–3812

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

}

async function executeLookupNode(
  nodeId: string,
  textValue: string,
  inputData: any,
  config?: unknown,
  executionContext?: FlowExecutionContext,
): Promise<NodeExecutionResult> {
  console.log(`Lookup Node ${nodeId}: Processing with input tables:`, {
    sourceTableCount: inputData?.source?.tables?.length,
    indexedTableName: inputData?.indexed?.tableName,
  });

  // Parse configuration
  const parsed = getNodeConfig<{
    lookupColumn?: string;
    joinType?: "inner" | "left" | "nested" | "cross";
    indexColumns?: string[];
    indexJoinColumn?: string;
  }>(config, textValue);
  if (!parsed) {
    return { success: false, error: "Invalid lookup configuration" };
  }
  const lookupColumn = parsed.lookupColumn || "";
  const joinType = parsed.joinType || "inner";
  const indexColumns = parsed.indexColumns || [];
  const indexJoinColumn = parsed.indexJoinColumn || "";

  // For cross join, we don't need lookup columns
  if (joinType !== "cross" && !lookupColumn) {
    return { success: false, error: "No lookup column specified" };
  }

  // Input should be an array: [sourceData, indexedData]
  if (!Array.isArray(inputData) || inputData.length !== 2) {
    return { success: false, error: "Invalid input: Expected array with 2 inputs [source, index]" };
  }

  const [sourceData, rightInputData] = inputData;

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

  // Handle both IndexedTable and TableSelection for the second input
  let indexedData: any;

  if (rightInputData.type === "IndexedTable") {
    // Already indexed, use as-is
    indexedData = rightInputData;
  } else if (rightInputData.type === "TableSelection") {
    if (joinType === "cross") {
      const allRightRows: AmendedSchemaField[][] = [];
      let rightTable = rightInputData.tables[0];

      for (const table of rightInputData.tables) {
        if (!table.table.schemaFields || !table.table.tableSchema) {
          console.warn(`Lookup Node ${nodeId}: Skipping index table without schema data`);