Function indexPRIntoGraph

ui/src/pr/indexer.ts:62–206

(
  store: GraphStore,
  pr: PRDetail,
  meta: RepoMeta,
)

}

export async function indexPRIntoGraph(
  store: GraphStore,
  pr: PRDetail,
  meta: RepoMeta,
): Promise<{ nodes_created: number; relationships_created: number }> {
  const repoId = `${meta.owner}/${meta.repo}`;
  const prId = `${repoId}/pr/${pr.number}`;

  const batch: ImportBatchRequest = {
    nodes: [
      {
        id: prId,
        type: 'PullRequest',
        name: `#${pr.number}: ${pr.title}`,
        properties: {
          number: pr.number,
          title: pr.title,
          state: pr.state,
          author: pr.author,
          url: pr.url,
          createdAt: pr.created_at,
          baseBranch: pr.base_branch,
          headBranch: pr.head_branch,
          additions: pr.additions,
          deletions: pr.deletions,
          filesChanged: pr.files.length,
        },
      },
    ],
    relationships: [
      {
        id: `${prId}->repo:${repoId}`,
        type: 'TARGETS_REPO',
        source_id: prId,
        target_id: repoId,
      },
    ],
  };

  // Build the set of File/Directory IDs we need, then check which already
  // exist in the store so we only create genuinely new nodes. The store's
  // COPY FROM does not support MERGE, so duplicate primary keys throw.
  const ensuredDirs = new Set<string>();
  const neededIds = new Set<string>();

  for (const file of pr.files) {
    neededIds.add(`${repoId}/${file.path}`);
    const parts = file.path.split('/');
    for (let i = parts.length - 1; i >= 1; i--) {
      neededIds.add(`${repoId}/${parts.slice(0, i).join('/')}`);
    }
  }

  // Probe the store for existing nodes — getNode returns null for missing
  const existingIds = new Set<string>();
  await Promise.all(
    [...neededIds].map(async (id) => {
      try {