Function fetchPRNodes

packages/scripts/lib/commit-graph.ts:298–361

(args: {
  prNumbers: number[]
  githubToken: string
  fnLabel: string
  selection: string
  nodeSchema: z.ZodType<T>
})

// finalize comments. We therefore fail loud when any error is present, and warn
// on the (genuine) drops so they leave a trace.
export async function fetchPRNodes<T extends { number: number }>(args: {
  prNumbers: number[]
  githubToken: string
  fnLabel: string
  selection: string
  nodeSchema: z.ZodType<T>
}): Promise<T[]> {
  const { prNumbers, githubToken, fnLabel, selection, nodeSchema } = args
  if (prNumbers.length === 0) return []
  const aliases = prNumbers
    .map(
      number => `
      pr${number}: pullRequest(number: ${number}) {
        ${selection}
      }`
    )
    .join('\n')
  const query = `query { repository(owner: "47ng", name: "nuqs") { ${aliases} } }`

  const response = await fetch(`https://api.github.com/graphql?fn=${fnLabel}`, {
    method: 'POST',
    headers: {
      Authorization: `Bearer ${githubToken}`,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({ query })
  })
  if (!response.ok) {
    throw new Error(
      `${fnLabel}: GitHub API error ${response.status} ${response.statusText} for PRs [${prNumbers.join(', ')}]`
    )
  }
  const envelopeSchema = z.object({
    data: z.object({
      repository: z.record(z.string(), nodeSchema.nullable())
    }),
    errors: z.array(z.object({ message: z.string() })).optional()
  })
  const envelope = envelopeSchema.safeParse(await response.json())
  if (!envelope.success) {
    throw new Error(
      `${fnLabel}: unexpected GraphQL response shape for PRs [${prNumbers.join(', ')}]: ${envelope.error.message}`
    )
  }
  const { data, errors } = envelope.data
  if (errors && errors.length > 0) {
    // A null node here is a fetch failure, not a nonexistent PR — dropping it
    // would silently lose a real change. Fail the release instead.
    throw new Error(
      `${fnLabel}: GraphQL errors for PRs [${prNumbers.join(', ')}]: ${errors.map(e => e.message).join('; ')}`
    )
  }
  const resolved = Object.values(data.repository).filter(
    (node): node is T => node !== null
  )
  if (resolved.length < prNumbers.length) {
    const returned = new Set(resolved.map(node => node.number))
    const dropped = prNumbers.filter(number => !returned.has(number))