Function extractConnectionData

src/nodeGraphExecutor.ts:185–206

(
  connection: SerializedConnection,
  executionResults: Map<string, NodeExecutionResult>,
  nodeMap: Map<string, SerializedNode>,
)

  return node.data.textValue || "";
};
const extractConnectionData = (
  connection: SerializedConnection,
  executionResults: Map<string, NodeExecutionResult>,
  nodeMap: Map<string, SerializedNode>,
) => {
  const sourceResult = executionResults.get(connection.sourceId);
  if (!sourceResult) return null;
  if (connection.sourceHandle === "else" && sourceResult.elseData) {
    return sourceResult.elseData;
  }
  const sourceNode = nodeMap.get(connection.sourceId);
  if (
    isMultiOutputNodeType(sourceNode?.type) &&
    connection.sourceHandle &&
    sourceResult.data &&
    typeof sourceResult.data === "object" &&
    !Array.isArray(sourceResult.data)
  ) {
    return (sourceResult.data as Record<string, any>)[connection.sourceHandle] ?? null;
  }
  return sourceResult.data ?? null;
};
const mergeTableSelectionInputs = (
  targetIncomingConnections: SerializedConnection[],
  executionResults: Map<string, NodeExecutionResult>,