added solution for pagination issue

Author: khushail

src/GithubDiscussionClient.ts

@@ -124,15 +124,16 @@ export class GithubDiscussionClient {
     return result.data.repository?.discussion?.comments as DiscussionCommentConnection;
   }
 
-  public async getDiscussionsMetaData(categoryID: string): Promise<DiscussionConnection> {
+  public async getDiscussionsMetaData(categoryID: string, pageSize: number, afterCursor: string): Promise<DiscussionConnection> {
     const discussionsCount = await this.getTotalDiscussionCount(categoryID);
     const result = await this.githubClient.query<GetDiscussionDataQuery, GetDiscussionDataQueryVariables>({
       query: GetDiscussionData,
       variables: {
         owner: this.owner,
         name: this.repo,
         categoryID: categoryID,
-        count: discussionsCount!,
+        pageSize: pageSize,
+        after: afterCursor,
       },
     })
 

src/index.ts

@@ -33,33 +33,42 @@ export async function processDiscussions(githubClient: GithubDiscussionClient) {
   const discussionCategoryIDList: string[] = await githubClient.getAnswerableDiscussionCategoryIDs();
 
   for (const discussionCategoryID of discussionCategoryIDList) {
-    const discussions = await githubClient.getDiscussionsMetaData(discussionCategoryID);
-    for (const discussion of discussions.edges!) {
-      var discussionId = discussion?.node?.id ? discussion?.node?.id : "";
-      var discussionNum = discussion?.node?.number ? discussion.node.number : 0;
-      core.debug(`Processing discussionId: ${discussionId} with number: ${discussionNum} and bodyText: ${discussion?.node?.bodyText}`);
-      if (discussionId === "" || discussionNum === 0) {
-        core.warning(`Can not proceed checking discussion, discussionId is null!`);
-        continue;
-      }
-      else if (discussion?.node?.locked && CLOSE_LOCKED_DISCUSSIONS) {
-        core.info(`Discussion ${discussionId} is locked, closing it as resolved`);
-        githubClient.closeDiscussionAsResolved(discussionId);
-        continue;
-      }
-      else if (discussion?.node?.answer != null && CLOSE_ANSWERED_DISCUSSIONS) {
-        core.info(`Discussion ${discussionId} is already answered, so closing it as resolved.`);
-        githubClient.closeDiscussionAsResolved(discussionId);
-        continue;
-      }
-      else if (discussion?.node?.closed) {
-        core.debug(`Discussion ${discussionId} is closed, so no action needed.`);
-        continue;
-      }
-      else {
-        await processComments(discussion!, githubClient);
+    const pageSize = 50;
+    let hasNextPage = true;
+    let afterCursor: string | null = null;
+
+    while (hasNextPage) {
+      const discussions = await githubClient.getDiscussionsMetaData(discussionCategoryID, pageSize, afterCursor!);
+      hasNextPage = discussions.pageInfo.hasNextPage;
+      afterCursor = discussions.pageInfo.endCursor!;
+    
+      for (const discussion of discussions.edges!) {
+        var discussionId = discussion?.node?.id ? discussion?.node?.id : "";
+        var discussionNum = discussion?.node?.number ? discussion.node.number : 0;
+        core.debug(`Processing discussionId: ${discussionId} with number: ${discussionNum} and bodyText: ${discussion?.node?.bodyText}`);
+        if (discussionId === "" || discussionNum === 0) {
+          core.warning(`Can not proceed checking discussion, discussionId is null!`);
+          continue;
+        }
+        else if (discussion?.node?.locked && CLOSE_LOCKED_DISCUSSIONS) {
+          core.info(`Discussion ${discussionId} is locked, closing it as resolved`);
+          githubClient.closeDiscussionAsResolved(discussionId);
+          continue;
+        }
+        else if (discussion?.node?.answer != null && CLOSE_ANSWERED_DISCUSSIONS) {
+          core.info(`Discussion ${discussionId} is already answered, so closing it as resolved.`);
+          githubClient.closeDiscussionAsResolved(discussionId);
+          continue;
+        }
+        else if (discussion?.node?.closed) {
+          core.debug(`Discussion ${discussionId} is closed, so no action needed.`);
+          continue;
+        }
+        else {
+          await processComments(discussion!, githubClient);
+        }
       }
-    };
+    }
   }
 }
 

src/queries/get-discussion-data.graphql

@@ -1,22 +1,31 @@
-query GetDiscussionData($owner: String!, $name: String!,$categoryID: ID!, $count: Int!) {
+query GetDiscussionData($owner: String!, $name: String!,$categoryID: ID!, $after: String, $pageSize: Int! ) {
   repository(owner: $owner, name: $name) {
-    discussions(categoryId: $categoryID last:$count) {
-      edges {
-        node {
-          locked
-          id
-          bodyText
-          number
-          closed
-          author{
-            login
-          }
-          answer{
+    discussions(
+      categoryId: $categoryID,
+      after: $after,
+      first: $pageSize,
+      orderBy: { field: UPDATED_AT, direction: DESC}
+      ) {
+        pageInfo {
+          hasNextPage
+          endCursor
+        }
+        edges {
+          node {
+            locked
             id
             bodyText
+            number
+            closed
+            author{
+              login
+            }
+            answer{
+              id
+              bodyText
+            }
           }
         }
       }
     }
-  }
-}
+  }