Function getUpstreamBlocksForBlocksIds

packages/reactivity/src/dag-analyzer.ts:47–61

(dag: BlockDependencyDag, blocksIds: string[])

 * The method finds dependencies in upstream mode - we are filtering out nodes from the DAG that are defined after the target blocks.
 */
export function getUpstreamBlocksForBlocksIds(dag: BlockDependencyDag, blocksIds: string[]): string[] {
  const targetBlocks = dag.nodes.filter(node => blocksIds.includes(node.id))

  if (targetBlocks.length === 0) {
    return []
  }

  const maxOrder = Math.max(...targetBlocks.map(node => node.order))
  const filteredDag = {
    ...dag,
    nodes: dag.nodes.filter(node => node.order <= maxOrder),
  }

  return getUpstreamBlocks(filteredDag, blocksIds)
}

function getUpstreamBlocks(dag: BlockDependencyDag, blocksIds: string[], visited: Set<string> = new Set()): string[] {
  const inputVariables = dag.nodes.filter(node => blocksIds.includes(node.id)).flatMap(node => node.inputVariables)