Function buildInputDataForTarget

src/nodeGraphExecutor.ts:234–317

(
  targetNode: SerializedNode,
  targetIncomingConnections: SerializedConnection[],
  executionResults: Map<string, NodeExecutionResult>,
  nodeMap: Map<string, SerializedNode>,
)

  };
};
const buildInputDataForTarget = (
  targetNode: SerializedNode,
  targetIncomingConnections: SerializedConnection[],
  executionResults: Map<string, NodeExecutionResult>,
  nodeMap: Map<string, SerializedNode>,
) => {
  if (
    targetNode.type === "mergechanges" ||
    targetNode.type === "numericadjustment" ||
    targetNode.type === "mathmax" ||
    targetNode.type === "mathceil"
  ) {
    const allInputs = targetIncomingConnections
      .map((connection) => extractConnectionData(connection, executionResults, nodeMap))
      .filter((data) => data !== null && data !== undefined);
    return allInputs.length > 0 ? allInputs : null;
  }
  if (targetNode.type === "savechanges") {
    const allTables: any[] = [];
    const allSourceFiles: any[] = [];
    let changedColumnSelectionData = null;
    let textData = null;
    for (const connection of targetIncomingConnections) {
      const inputData = extractConnectionData(connection, executionResults, nodeMap);
      if (inputData?.type === "Text" && !textData) {
        textData = inputData;
      } else if (inputData?.type === "TableSelection") {
        if (inputData.tables) {
          allTables.push(...inputData.tables);
        }
        if (inputData.sourceFiles) {
          allSourceFiles.push(...inputData.sourceFiles);
        }
      } else if (inputData?.type === "ChangedColumnSelection" && !changedColumnSelectionData) {
        changedColumnSelectionData = inputData;
      }
    }
    if (textData) return textData;
    if (changedColumnSelectionData) return changedColumnSelectionData;
    if (allTables.length > 0) {
      return {
        type: "TableSelection",
        tables: allTables,
        sourceFiles: allSourceFiles,
        tableCount: allTables.length,
      };
    }
    return null;
  }
  if (targetNode.type === "lookup") {
    const sourceConnection = targetIncomingConnections.find((connection) => connection.targetHandle === "input-source");
    const indexConnection = targetIncomingConnections.find((connection) => connection.targetHandle === "input-index");
    if (!sourceConnection || !indexConnection) {
      return null;
    }
    return [
      extractConnectionData(sourceConnection, executionResults, nodeMap),
      extractConnectionData(indexConnection, executionResults, nodeMap),