Function computeDagInfo

packages/mcp/src/tools/reading.ts:83–133

(file: DeepnoteFile, notebookFilter?: string)

}

async function computeDagInfo(file: DeepnoteFile, notebookFilter?: string) {
  const dagInfo: Array<{
    notebook: string
    blocks: Array<{
      id: string
      shortId: string
      defines: string[]
      uses: string[]
      dependsOn: string[]
    }>
  }> = []

  for (const notebook of file.project.notebooks) {
    if (notebookFilter && notebook.name !== notebookFilter && notebook.id !== notebookFilter) {
      continue
    }

    try {
      const blockDeps = await getBlockDependencies(notebook.blocks)
      const varToBlock = new Map<string, string>()

      for (const block of blockDeps) {
        for (const v of block.definedVariables) varToBlock.set(v, block.id)
        for (const m of block.importedModules || []) varToBlock.set(m, block.id)
      }

      const blocks = blockDeps.map(block => {
        const deps = new Set<string>()
        for (const usedVar of block.usedVariables) {
          const definingBlock = varToBlock.get(usedVar)
          if (definingBlock && definingBlock !== block.id) {
            deps.add(definingBlock)
          }
        }
        return {
          id: block.id,
          shortId: block.id.slice(0, 8),
          defines: block.definedVariables,
          uses: block.usedVariables,
          dependsOn: Array.from(deps),
        }
      })

      dagInfo.push({ notebook: notebook.name, blocks })
    } catch {
      dagInfo.push({ notebook: notebook.name, blocks: [] })
    }
  }

  return dagInfo
}

// --- End internal helpers ---