Simplify paginated octokit queries (#28)

- **Simplify listJobsForWorkflowRun**
- **Simplify listWorkflowRunArtifacts**
- **update changelog**

Author: corentinmusard

CHANGELOG.md

@@ -9,6 +9,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Changed
 
+- Simplify paginated octokit queries
 - Use global tracer instead of passing it around
 - tests: Add a replay client
 - Migrate to ESM

dist/index.js

@@ -49115,19 +49115,12 @@ async function listWorkflowRunArtifacts(context, octokit, runId) {
 }
 const artifactNameRegex = /\{(?<jobName>.*)\}\{(?<stepName>.*)\}/;
 async function getWorkflowRunArtifactMap(context, octokit, runId) {
-    const artifactsList = [];
-    const pageSize = 100;
-    for (let page = 1, hasNext = true; hasNext; page++) {
-        const listArtifactsResponse = await octokit.rest.actions.listWorkflowRunArtifacts({
-            ...context.repo,
-            run_id: runId,
-            page,
-            per_page: pageSize,
-        });
-        artifactsList.push(...listArtifactsResponse.data.artifacts);
-        hasNext = artifactsList.length < listArtifactsResponse.data.total_count;
-    }
-    const artifactsLookup = await artifactsList.reduce(async (resultP, artifact) => {
+    const artifacts = await octokit.paginate(octokit.rest.actions.listWorkflowRunArtifacts, {
+        ...context.repo,
+        run_id: runId,
+        per_page: 100,
+    });
+    const artifactsLookup = await artifacts.reduce(async (resultP, artifact) => {
         const result = await resultP;
         const match = artifact.name.match(artifactNameRegex);
         const next = { ...result };
@@ -49202,20 +49195,12 @@ async function getSelfArtifactMap() {
     return artifactsMap;
 }
 async function listJobsForWorkflowRun(context, octokit, runId) {
-    const jobs = [];
-    const pageSize = 100;
-    for (let page = 1, hasNext = true; hasNext; page++) {
-        const listJobsForWorkflowRunResponse = await octokit.rest.actions.listJobsForWorkflowRun({
-            ...context.repo,
-            run_id: runId,
-            filter: "latest", // risk of missing a run if re-run happens between Action trigger and this query
-            page,
-            per_page: pageSize,
-        });
-        jobs.push(...listJobsForWorkflowRunResponse.data.jobs);
-        hasNext = jobs.length < listJobsForWorkflowRunResponse.data.total_count;
-    }
-    return jobs;
+    return await octokit.paginate(octokit.rest.actions.listJobsForWorkflowRun, {
+        ...context.repo,
+        run_id: runId,
+        filter: "latest", // risk of missing a run if re-run happens between Action trigger and this query
+        per_page: 100,
+    });
 }
 async function getWorkflowRunJobs(context, octokit, runId) {
     const getWorkflowRunResponse = await octokit.rest.actions.getWorkflowRun({

dist/index.js.map

@@ -3,19 +3,20 @@ import * as path from "node:path";
 import * as url from "node:url";
 import type { Context } from "@actions/github/lib/context";
 import { jest } from "@jest/globals";
+import type { components } from "@octokit/openapi-types";
 import type { RestEndpointMethodTypes } from "@octokit/plugin-rest-endpoint-methods";
 import fetchMock from "jest-fetch-mock";
 import { mock, mockDeep } from "jest-mock-extended";
 import type { Octokit } from "./github";
-import { type WorkflowArtifact, type WorkflowArtifactDownload, listWorkflowRunArtifacts } from "./github";
+import { type WorkflowArtifactDownload, listWorkflowRunArtifacts } from "./github";
 
 const __filename = url.fileURLToPath(import.meta.url);
 const __dirname = path.dirname(__filename);
 
 jest.mock("@actions/github");
 jest.mock("@actions/core");
 
-type ListWorkflowRunArtifactsResponse = RestEndpointMethodTypes["actions"]["listWorkflowRunArtifacts"]["response"];
+type Artifacts = components["schemas"]["artifact"][];
 type DownloadArtifactResponse = RestEndpointMethodTypes["actions"]["downloadArtifact"]["response"];
 
 describe("listWorkflowRunArtifacts", () => {
@@ -26,25 +27,18 @@ describe("listWorkflowRunArtifacts", () => {
   beforeAll(async () => {
     mockContext = mockDeep<Context>();
     mockOctokit = mockDeep<Octokit>();
-    const mockListWorkflowRunArtifacts = mockOctokit.rest.actions.listWorkflowRunArtifacts as jest.MockedFunction<
-      typeof mockOctokit.rest.actions.listWorkflowRunArtifacts
-    >;
+    const mockPaginate = mockOctokit.paginate as jest.MockedFunction<typeof mockOctokit.paginate>;
     const mockDownloadArtifact = mockOctokit.rest.actions.downloadArtifact as jest.MockedFunction<
       typeof mockOctokit.rest.actions.downloadArtifact
     >;
 
-    mockListWorkflowRunArtifacts.mockResolvedValue(
-      mock<ListWorkflowRunArtifactsResponse>({
-        data: {
-          total_count: 1,
-          artifacts: [
-            mock<WorkflowArtifact>({
-              id: 1,
-              name: "{lint-and-test}{run tests}",
-            }),
-          ],
+    mockPaginate.mockResolvedValue(
+      mock<Artifacts>([
+        {
+          id: 1,
+          name: "{lint-and-test}{run tests}",
         },
-      }),
+      ]),
     );
     mockDownloadArtifact.mockResolvedValue(mock<DownloadArtifactResponse>({ url: "localhost" }));
     const filePath = path.join(__dirname, "__assets__", "{lint-and-test}{run tests}.zip");

src/__assets__/run.rec

@@ -12,11 +12,6 @@ type ListJobsForWorkflowRunType = RestEndpointMethodTypes["actions"]["listJobsFo
 type WorkflowRunJob = ListJobsForWorkflowRunType["data"]["jobs"][number];
 type WorkflowRun = RestEndpointMethodTypes["actions"]["getWorkflowRun"]["response"]["data"];
 
-interface WorkflowArtifact {
-  id: number;
-  name: string;
-}
-
 type WorkflowArtifactMap = {
   [job: string]: {
     [step: string]: WorkflowArtifactDownload;
@@ -55,21 +50,13 @@ async function listWorkflowRunArtifacts(
 const artifactNameRegex = /\{(?<jobName>.*)\}\{(?<stepName>.*)\}/;
 
 async function getWorkflowRunArtifactMap(context: Context, octokit: Octokit, runId: number) {
-  const artifactsList: WorkflowArtifact[] = [];
-  const pageSize = 100;
-
-  for (let page = 1, hasNext = true; hasNext; page++) {
-    const listArtifactsResponse = await octokit.rest.actions.listWorkflowRunArtifacts({
-      ...context.repo,
-      run_id: runId,
-      page,
-      per_page: pageSize,
-    });
-    artifactsList.push(...listArtifactsResponse.data.artifacts);
-    hasNext = artifactsList.length < listArtifactsResponse.data.total_count;
-  }
+  const artifacts = await octokit.paginate(octokit.rest.actions.listWorkflowRunArtifacts, {
+    ...context.repo,
+    run_id: runId,
+    per_page: 100,
+  });
 
-  const artifactsLookup: WorkflowArtifactMap = await artifactsList.reduce(async (resultP, artifact) => {
+  const artifactsLookup: WorkflowArtifactMap = await artifacts.reduce(async (resultP, artifact) => {
     const result = await resultP;
     const match = artifact.name.match(artifactNameRegex);
     const next: WorkflowArtifactMap = { ...result };
@@ -150,24 +137,13 @@ async function getSelfArtifactMap() {
   return artifactsMap;
 }
 
-async function listJobsForWorkflowRun(context: Context, octokit: Octokit, runId: number): Promise<WorkflowRunJob[]> {
-  const jobs: WorkflowRunJob[] = [];
-  const pageSize = 100;
-
-  for (let page = 1, hasNext = true; hasNext; page++) {
-    const listJobsForWorkflowRunResponse = await octokit.rest.actions.listJobsForWorkflowRun({
-      ...context.repo,
-      run_id: runId,
-      filter: "latest", // risk of missing a run if re-run happens between Action trigger and this query
-      page,
-      per_page: pageSize,
-    });
-
-    jobs.push(...listJobsForWorkflowRunResponse.data.jobs);
-    hasNext = jobs.length < listJobsForWorkflowRunResponse.data.total_count;
-  }
-
-  return jobs;
+async function listJobsForWorkflowRun(context: Context, octokit: Octokit, runId: number) {
+  return await octokit.paginate(octokit.rest.actions.listJobsForWorkflowRun, {
+    ...context.repo,
+    run_id: runId,
+    filter: "latest", // risk of missing a run if re-run happens between Action trigger and this query
+    per_page: 100,
+  });
 }
 
 type WorkflowRunJobs = {
@@ -216,7 +192,6 @@ export {
   getPRLabels,
   getPRsLabels,
   type Octokit,
-  type WorkflowArtifact,
   type WorkflowArtifactDownload,
   type WorkflowArtifactLookup,
   type WorkflowRunJob,