Split function

Author: Ludovic TOURMAN

README.md

@@ -21,7 +21,7 @@ For details of the `workflow_dispatch` even see [this blog post introducing this
 
 ### `token`
 
-> **Required.** A GitHub access token (PAT) with write access to the repo in question. 
+> **Required.** A GitHub access token (PAT) with write access to the repo in question.
 >
 > **NOTE.** The automatically provided token e.g. `${{ secrets.GITHUB_TOKEN }}` can not be used, GitHub prevents this token from being able to fire the  `workflow_dispatch` and `repository_dispatch` event. [The reasons are explained in the docs](https://docs.github.com/en/actions/reference/events-that-trigger-workflows#triggering-new-workflows-using-a-personal-access-token).  
 > The solution is to manually create a PAT and store it as a secret e.g. `${{ secrets.PERSONAL_TOKEN }}`

dist/index.js

@@ -10089,11 +10089,8 @@ class WorkflowHandler {
             }
         });
     }
-    getWorkflowRunId() {
+    findAllWorkflowRuns() {
         return __awaiter(this, void 0, void 0, function* () {
-            if (this.workflowRunId) {
-                return this.workflowRunId;
-            }
             try {
                 const workflowId = yield this.getWorkflowId();
                 const response = yield this.octokit.rest.actions.listWorkflowRuns({
@@ -10104,24 +10101,30 @@ class WorkflowHandler {
                     created: `>=${new Date(this.triggerDate).toISOString()}`
                 });
                 (0, debug_1.debug)('List Workflow Runs', response);
-                let runs = response.data.workflow_runs;
+                return response.data.workflow_runs;
+            }
+            catch (error) {
+                (0, debug_1.debug)('Fin all workflow runs error', error);
+                throw new Error(`Failed to list workflow runs. Cause: ${error}`);
+            }
+        });
+    }
+    getWorkflowRunId() {
+        return __awaiter(this, void 0, void 0, function* () {
+            if (this.workflowRunId) {
+                return this.workflowRunId;
+            }
+            try {
+                let runs = yield this.findAllWorkflowRuns();
                 if (this.runName) {
-                    runs = response.data.workflow_runs
-                        .filter((r) => r.name == this.runName);
+                    runs = runs.filter((r) => r.name == this.runName);
                 }
                 if (runs.length == 0) {
                     throw new Error('Run not found');
                 }
                 if (runs.length > 1) {
                     core.warning(`Found ${runs.length} runs. Using the last one.`);
-                    (0, debug_1.debug)(`Filtered Workflow Runs (after trigger date: ${new Date(this.triggerDate).toISOString()})`, runs.map((r) => ({
-                        id: r.id,
-                        name: r.name,
-                        created_at: r.created_at,
-                        triggerDate: new Date(this.triggerDate).toISOString(),
-                        created_at_ts: new Date(r.created_at).valueOf(),
-                        triggerDateTs: this.triggerDate
-                    })));
+                    yield this.debugFoundWorkflowRuns(runs);
                 }
                 this.workflowRunId = runs[0].id;
                 return this.workflowRunId;
@@ -10166,6 +10169,16 @@ class WorkflowHandler {
     isFilename(workflowRef) {
         return /.+\.ya?ml$/.test(workflowRef);
     }
+    debugFoundWorkflowRuns(runs) {
+        (0, debug_1.debug)(`Filtered Workflow Runs (after trigger date: ${new Date(this.triggerDate).toISOString()})`, runs.map((r) => ({
+            id: r.id,
+            name: r.name,
+            created_at: r.created_at,
+            triggerDate: new Date(this.triggerDate).toISOString(),
+            created_at_ts: new Date(r.created_at).valueOf(),
+            triggerDateTs: this.triggerDate
+        })));
+    }
 }
 exports.WorkflowHandler = WorkflowHandler;
 

src/workflow-handler.ts

@@ -124,14 +124,9 @@ export class WorkflowHandler {
     }
   }
 
-
-  async getWorkflowRunId(): Promise<number> {
-    if (this.workflowRunId) {
-      return this.workflowRunId;
-    }
+  private async findAllWorkflowRuns() {
     try {
       const workflowId = await this.getWorkflowId();
-
       const response = await this.octokit.rest.actions.listWorkflowRuns({
         owner: this.owner,
         repo: this.repo,
@@ -142,10 +137,21 @@ export class WorkflowHandler {
 
       debug('List Workflow Runs', response);
 
-      let runs = response.data.workflow_runs;
+      return response.data.workflow_runs
+    } catch (error) {
+      debug('Fin all workflow runs error', error);
+      throw new Error(`Failed to list workflow runs. Cause: ${error}`)
+    }
+  }
+
+  async getWorkflowRunId(): Promise<number> {
+    if (this.workflowRunId) {
+      return this.workflowRunId;
+    }
+    try {
+      let runs = await this.findAllWorkflowRuns();
       if (this.runName) {
-        runs = response.data.workflow_runs
-          .filter((r: any) => r.name == this.runName)
+        runs = runs.filter((r: any) => r.name == this.runName)
       }
 
       if (runs.length == 0) {
@@ -154,14 +160,7 @@ export class WorkflowHandler {
 
       if (runs.length > 1) {
         core.warning(`Found ${runs.length} runs. Using the last one.`);
-        debug(`Filtered Workflow Runs (after trigger date: ${new Date(this.triggerDate).toISOString()})`, runs.map((r: any) => ({
-          id: r.id,
-          name: r.name,
-          created_at: r.created_at,
-          triggerDate: new Date(this.triggerDate).toISOString(),
-          created_at_ts: new Date(r.created_at).valueOf(),
-          triggerDateTs: this.triggerDate
-        })));
+        await this.debugFoundWorkflowRuns(runs);
       }
 
       this.workflowRunId = runs[0].id as number;
@@ -206,5 +205,16 @@ export class WorkflowHandler {
     return /.+\.ya?ml$/.test(workflowRef);
   }
 
+  private debugFoundWorkflowRuns(runs: any){
+    debug(`Filtered Workflow Runs (after trigger date: ${new Date(this.triggerDate).toISOString()})`, runs.map((r: any) => ({
+      id: r.id,
+      name: r.name,
+      created_at: r.created_at,
+      triggerDate: new Date(this.triggerDate).toISOString(),
+      created_at_ts: new Date(r.created_at).valueOf(),
+      triggerDateTs: this.triggerDate
+    })));
+  }
+
 }