fix(deduplicate): only run once!

Author: ahmadnassri

action/lib/deduplicate.js

@@ -0,0 +1,41 @@
+/* eslint-disable camelcase */
+
+import core from '@actions/core'
+import github from '@actions/github'
+
+export default async function (octokit) {
+  // extract sha
+  const { sha, runId: run_id } = github.context
+
+  // get workflow id from run id
+  const { data: { workflow_id } } = await octokit.request('GET /repos/{owner}/{repo}/actions/runs/{run_id}', {
+    ...github.context.repo,
+    run_id
+  })
+
+  // get current run of this workflow
+  const { data: { workflow_runs } } = await octokit.request('GET /repos/{owner}/{repo}/actions/runs', {
+    ...github.context.repo
+  })
+
+  // find any instances of the same workflow
+  workflow_runs
+    // filter to relevant runs
+    .filter(run => run.workflow_id === workflow_id && run.head_sha === sha)
+    // pick relevant properties
+    .map(run => ({ id: run.id, name: run.name, created_at: run.created_at }))
+    // sort
+    .sort(run => (a, b) => new Date(b.created_at) - new Date(a.created_at))
+    // remove last one
+    .pop()
+
+  // sort
+  for (const run of workflow_runs) {
+    core.info(`${run.id}: ${run.name} => ${run.created_at}`)
+
+    await octokit.request('POST /repos/{owner}/{repo}/actions/runs/{run_id}/cancel', {
+      ...github.context.repo,
+      run_id: run.id
+    })
+  }
+}

action/lib/index.js

@@ -1,6 +1,7 @@
 // packages
 import core from '@actions/core'
 import github from '@actions/github'
+import deduplicate from './deduplicate.js'
 
 import runs from './runs.js'
 import workflows from './workflows.js'
@@ -9,15 +10,17 @@ import workflows from './workflows.js'
 const sleep = ms => new Promise(resolve => setTimeout(resolve, ms))
 
 export default async function ({ token, delay, timeout }) {
+  let timer = 0
+
   // init octokit
   const octokit = github.getOctokit(token)
 
-  let timer = 0
+  await deduplicate(octokit)
 
-  const flows = await workflows(octokit)
+  const dependencies = await workflows(octokit)
 
   // check runs
-  let result = await runs(octokit, flows)
+  let result = await runs(octokit, dependencies)
 
   while (result.find(run => run.conclusion !== 'success')) {
     timer += delay
@@ -38,7 +41,7 @@ export default async function ({ token, delay, timeout }) {
     await sleep(delay)
 
     // get the data again
-    result = await runs(octokit, flows)
+    result = await runs(octokit, dependencies)
   }
 
   for (const run of result) {

action/lib/runs.js

@@ -1,6 +1,6 @@
 import github from '@actions/github'
 
-export default async function (octokit, workflows) {
+export default async function (octokit, dependencies) {
   // extract sha
   const { sha } = github.context
 
@@ -10,7 +10,7 @@ export default async function (octokit, workflows) {
 
   return workflow_runs
     // filter to relevant runs
-    .filter(run => workflows.includes(run.name) && run.head_sha === sha)
+    .filter(run => dependencies.includes(run.name) && run.head_sha === sha)
     // pick properties
     .map(run => ({ id: run.id, name: run.name, conclusion: run.conclusion }))
 }

action/lib/workflows.js

@@ -7,24 +7,21 @@ export default async function (octokit) {
 
   // get workflow id from run id
   const { data: { workflow_id } } = await octokit.request('GET /repos/{owner}/{repo}/actions/runs/{run_id}', { // eslint-disable-line camelcase
-    owner: 'hashtagpaid',
-    repo: 'template-api',
+    ...github.context.repo,
     run_id
   })
 
   // get the file name from the workflow
   const { data: { path } } = await octokit.request('GET /repos/{owner}/{repo}/actions/workflows/{workflow_id}', {
-    owner: 'hashtagpaid',
-    repo: 'template-api',
+    ...github.context.repo,
     workflow_id
   })
 
   // get the workflow content
   const { data: { content } } = await octokit.request('GET /repos/{owner}/{repo}/contents/{path}', {
-    owner: 'hashtagpaid',
-    repo: 'template-api',
-    ref,
-    path
+    ...github.context.repo,
+    path,
+    ref
   })
 
   const { on: { workflow_run: { workflows } } } = yaml.parse(Buffer.from(content, 'base64').toString())