Filter by creation date

Fixes Codex-/return-dispatch#264

Author: carlobeltrame

dist/index.mjs

@@ -358,7 +358,7 @@ describe("API", () => {
       );
 
       // Behaviour
-      await expect(fetchWorkflowRunIds(0, branch)).resolves.toStrictEqual(
+      await expect(fetchWorkflowRunIds(0, branch, Date.now())).resolves.toStrictEqual(
         mockData.workflow_runs.map((run) => run.id),
       );
 
@@ -389,7 +389,7 @@ describe("API", () => {
       );
 
       // Behaviour
-      await expect(fetchWorkflowRunIds(0, branch)).rejects.toThrow(
+      await expect(fetchWorkflowRunIds(0, branch, Date.now())).rejects.toThrow(
         `Failed to fetch Workflow runs, expected 200 but received ${errorStatus}`,
       );
 
@@ -417,7 +417,7 @@ describe("API", () => {
       );
 
       // Behaviour
-      await expect(fetchWorkflowRunIds(0, branch)).resolves.toStrictEqual([]);
+      await expect(fetchWorkflowRunIds(0, branch, Date.now())).resolves.toStrictEqual([]);
 
       // Logging
       assertOnlyCalled(coreDebugLogMock);
@@ -453,7 +453,7 @@ describe("API", () => {
       );
 
       // Behaviour
-      await expect(fetchWorkflowRunIds(0, branch)).resolves.not.toThrow();
+      await expect(fetchWorkflowRunIds(0, branch, Date.now())).resolves.not.toThrow();
       expect(parsedRef).toStrictEqual("master");
 
       // Logging
@@ -490,7 +490,7 @@ describe("API", () => {
       );
 
       // Behaviour
-      await expect(fetchWorkflowRunIds(0, branch)).resolves.not.toThrow();
+      await expect(fetchWorkflowRunIds(0, branch, Date.now())).resolves.not.toThrow();
       expect(parsedRef).toBeUndefined();
 
       // Logging
@@ -527,7 +527,7 @@ describe("API", () => {
       );
 
       // Behaviour
-      await expect(fetchWorkflowRunIds(0, branch)).resolves.not.toThrow();
+      await expect(fetchWorkflowRunIds(0, branch, Date.now())).resolves.not.toThrow();
       expect(parsedRef).toBeUndefined();
 
       // Logging

src/api.spec.ts

@@ -158,18 +158,24 @@ export async function fetchWorkflowRunUrl(runId: number): Promise<string> {
 export async function fetchWorkflowRunIds(
   workflowId: number,
   branch: BranchNameResult,
+  startTime: number,
 ): Promise<number[]> {
   try {
     const useBranchFilter =
       !branch.isTag &&
       branch.branchName !== undefined &&
       branch.branchName !== "";
 
+    const startTimeDate = new Date();
+    startTimeDate.setTime(startTime);
+    const startTimeISO = startTimeDate.toISOString();
+
     // https://docs.github.com/en/rest/actions/workflow-runs#list-workflow-runs-for-a-repository
     const response = await octokit.rest.actions.listWorkflowRuns({
       owner: config.owner,
       repo: config.repo,
       workflow_id: workflowId,
+      created: '>' + startTimeISO,
       ...(useBranchFilter
         ? {
             branch: branch.branchName,

src/api.ts

@@ -151,7 +151,7 @@ export async function getRunIdAndUrl({
 
     // Get all runs for a given workflow ID
     const fetchWorkflowRunIds = await api.retryOrTimeout(
-      () => api.fetchWorkflowRunIds(workflowId, branch),
+      () => api.fetchWorkflowRunIds(workflowId, branch, startTime),
       retryTimeout,
     );
     if (!fetchWorkflowRunIds.success) {