Use GraphQL cursors

Author: axelrindle

packages/core/src/query/graphql.ts

@@ -22,18 +22,42 @@ export default async function graphql(options: CheckOptions): Promise<ReleaseDes
         }
     })
 
-    const { repository } = await octokit.graphql<GraphQlQueryResponseData>(theQuery, {
-        repo: options.repo,
-        owner: options.owner
-    })
+    async function fetch(cursor: string|undefined = undefined) {
+        const { repository } = await octokit.graphql<GraphQlQueryResponseData>(theQuery, {
+            repo: options.repo,
+            owner: options.owner,
+            cursor
+        })
+        return repository
+    }
+
+    let cursor: string|undefined = undefined
+    const found = false
+    while (! found) {
+        const repository: any = await fetch(cursor)
+        const entries: any[] = options.fetchTags ? repository.refs.nodes : repository.releases.nodes
+
+        if (entries.length == 0) {
+            return undefined
+        }
 
-    // Retrieve newer version name
-    const newer = options.fetchTags ? repository.refs.nodes[0] : repository.releases.nodes[0]
+        // no drafts please
+        if (! options.fetchTags) {
+            if (entries[0].isDraft && repository.releases.pageInfo.hasNextPage) {
+                cursor = repository.releases.pageInfo.endCursor
+                continue
+            }
+        }
 
-    // Compare versions
-    if (gt((options.fetchTags ? newer.name : newer.tag.name), options.currentVersion)) {
-        return newer
-    } else {
-        return undefined
+        // Retrieve newer version name
+        const newer = entries[0]
+        const fetchedVersion = options.fetchTags ? newer.name : newer.tagName
+        if (gt(fetchedVersion, options.currentVersion)) {
+            return newer
+        } else {
+            return undefined
+        }
     }
+
+    return undefined
 }

packages/core/src/types.ts

@@ -1,6 +1,6 @@
 /// <reference types="node/http" />
 
-import { IncomingMessage } from "http"
+import { IncomingMessage } from 'node:http'
 
 export interface CheckOptions {
     /**
@@ -73,6 +73,11 @@ export interface ReleaseDescriptor {
      */
     isPrerelease: boolean
 
+    /**
+     * Whether this release is a draft.
+     */
+    isDraft: boolean
+
     /**
      * A datetime string indicating the time this release was published.
      */

packages/core/src/util/graphql.ts

@@ -1,13 +1,20 @@
 export const releases = `
-{
+query($repo: String!, $owner: String!, $cursor: String = null) {
     repository(name: $repo, owner: $owner) {
-        releases(last: 1, { field: CREATED_AT, direction: ASC }) {
+        releases(
+          	after: $cursor,
+            first: 1,
+            orderBy: { field: CREATED_AT, direction: DESC }
+        ) {
+            pageInfo {
+              	hasNextPage
+              	endCursor
+            }
             nodes {
                 name
-                tag {
-                    name
-                }
+                tagName
                 isPrerelease
+              	isDraft
                 publishedAt
                 url
             }
@@ -17,7 +24,7 @@ export const releases = `
 `
 
 export const tags = `
-{
+query($repo: String!, $owner: String!) {
     repository(name: $repo, owner: $owner) {
         refs(
             last: 1