Merge pull request #6 from moia-oss/handle-cancelled-state

Handle Cancelled State

README.md

@@ -25,14 +25,18 @@ user or role you login to needs the following permissions:
   "Statement": [
     {
       "Effect": "Allow",
-      "Action": ["codepipeline:StartPipelineExecution", "codepipeline:GetPipelineExecution"],
+      "Action": [
+        "codepipeline:StartPipelineExecution",
+        "codepipeline:GetPipelineExecution",
+        "codepipeline:ListPipelineExecutions"
+      ],
       "Resource": ["arn:aws:codepipeline:${AWS::Region}:${AWS::AccountId}:${PipelineName}"]
     }
   ]
 }
 ```
 
-`codepipeline:GetPipelineExecution` is only necessary, if you set `wait: true`,
+`codepipeline:GetPipelineExecution` and `codepipeline:ListPipelineExecutions` are only necessary, if you set `wait: true`,
 otherwise the GitHub Action Workflow continues without checking the pipeline
 state.
 

src/index.ts

@@ -4,12 +4,26 @@ import {
   StartPipelineExecutionCommand,
   GetPipelineExecutionCommand,
   PipelineExecutionStatus,
+  ListPipelineExecutionsCommand,
 } from '@aws-sdk/client-codepipeline';
 
 const CLIENT = new CodePipelineClient({});
 
 const sleep = (s: number) => new Promise((resolve) => setTimeout(resolve, s * 1000));
 
+const getNewestExecutionId = async (pipelineName: string): Promise<string> => {
+  const command = new ListPipelineExecutionsCommand({ pipelineName, maxResults: 1 });
+  const data = await CLIENT.send(command);
+  if (data.pipelineExecutionSummaries && data.pipelineExecutionSummaries.length > 0) {
+    const executionId = data.pipelineExecutionSummaries[0].pipelineExecutionId;
+    if (executionId) {
+      return executionId;
+    }
+    throw new Error(`Newest pipeline execution of '${pipelineName}' has no ID`);
+  }
+  throw new Error('No Pipeline executions found');
+};
+
 const waitForPipeline = async (pipelineName: string, pipelineExecutionId: string): Promise<boolean> => {
   await sleep(10);
   const command = new GetPipelineExecutionCommand({ pipelineName, pipelineExecutionId });
@@ -25,25 +39,27 @@ const waitForPipeline = async (pipelineName: string, pipelineExecutionId: string
       case PipelineExecutionStatus.InProgress:
         core.info(`Pipeline '${pipelineName}' in progress waiting for 10 more seconds.`);
         return await waitForPipeline(pipelineName, pipelineExecutionId);
+      case PipelineExecutionStatus.Cancelled: {
+        core.info(`Pipeline '${pipelineName}' was canceled. Trying to get new execution ID.`);
+        const newExecutionId = await getNewestExecutionId(pipelineName);
+        core.info(`Waiting on pipeline '${pipelineName}' with new execution id '${newExecutionId}`);
+        return await waitForPipeline(pipelineName, newExecutionId);
+      }
+      case PipelineExecutionStatus.Succeeded:
+        core.info(`Pipeline '${pipelineName}' succeeded.`);
+        return true;
       case PipelineExecutionStatus.Failed:
-        core.info(`Pipeline '${pipelineName}' failed.`);
+        core.error(`Pipeline '${pipelineName}' failed.`);
         return false;
       case PipelineExecutionStatus.Stopping || PipelineExecutionStatus.Stopped:
-        core.info(`Pipeline '${pipelineName}' stopped.`);
+        core.error(`Pipeline '${pipelineName}' stopped.`);
         return false;
       case PipelineExecutionStatus.Superseded:
-        core.info(`Pipeline '${pipelineName}' was superseded.`);
-        return false;
-      case PipelineExecutionStatus.Cancelled:
-        core.info(`Pipeline '${pipelineName}' was canceled. Trying to get new execution ID.`);
-        // TODO: To implement
+        core.error(`Pipeline '${pipelineName}' was superseded.`);
         return false;
-
-      case PipelineExecutionStatus.Succeeded:
-        core.info(`Pipeline '${pipelineName}' succeeded.`);
-        return true;
       default:
-        throw new Error(`Unexpected status: ${status} given.`);
+        core.error(`Unexpected status: ${status} given.`);
+        return false;
     }
   } catch (error) {
     core.error(