Merge pull request #28 from gammarers/feature/add-pipeline-execution-…

…change-state-filter feat: add pipeline execution change state filter
gammarers · Nov 15, 2024 · 9f5c0e2 · 9f5c0e2
2 parents 581c557 + 5a34060
commit 9f5c0e2
Show file tree

Hide file tree

Showing 4 changed files with 209 additions and 1 deletion.
diff --git a/API.md b/API.md
diff --git a/src/codepipeline-execution-state-change-detection-event-rule.ts b/src/codepipeline-execution-state-change-detection-event-rule.ts
@@ -9,7 +9,20 @@ import { Construct } from 'constructs';
  * export interface CodePipelineStateChangeDetectionEventRuleProps extends Omit<events.RuleProps, 'eventPattern'> {}
  */
 
-export interface CodePipelineExecutionStateChangeDetectionEventRuleProps extends events.RuleProps {}
+export enum CodePipelineExecutionState {
+  CANCELED = 'CANCELED',
+  FAILED = 'FAILED',
+  RESUMED = 'RESUMED',
+  STARTED = 'STARTED',
+  STOPPED = 'STOPPED',
+  STOPPING = 'STOPPING',
+  SUCCEEDED = 'SUCCEEDED',
+  SUPERSEDED = 'SUPERSEDED',
+}
+
+export interface CodePipelineExecutionStateChangeDetectionEventRuleProps extends events.RuleProps {
+  readonly targetStates?: CodePipelineExecutionState[];
+}
 
 export class CodePipelineExecutionStateChangeDetectionEventRule extends events.Rule {
   constructor(scope: Construct, id: string, props: CodePipelineExecutionStateChangeDetectionEventRuleProps) {
@@ -22,6 +35,17 @@ export class CodePipelineExecutionStateChangeDetectionEventRule extends events.R
         return {
           source: ['aws.codepipeline'],
           detailType: ['CodePipeline Pipeline Execution State Change'],
+          //          detail: {
+          //            state: props.targetStates,
+          //          },
+          detail: (() => {
+            if (props.targetStates) {
+              return {
+                state: props.targetStates,
+              };
+            }
+            return undefined;
+          })(),
         };
       })(),
     });

diff --git a/test/__snapshots__/rule.options.test.ts.snap b/test/__snapshots__/rule.options.test.ts.snap
diff --git a/test/rule.options.test.ts b/test/rule.options.test.ts
@@ -0,0 +1,52 @@
+import { App, Stack } from 'aws-cdk-lib';
+import { Template, Match } from 'aws-cdk-lib/assertions';
+import * as events from 'aws-cdk-lib/aws-events';
+import { CodePipelineExecutionState, CodePipelineExecutionStateChangeDetectionEventRule } from '../src';
+
+describe('Default Rule Check', () => {
+
+  const app = new App();
+  const stack = new Stack(app, 'TestingStack', {
+    env: {
+      account: '123456789012',
+      region: 'us-east-1',
+    },
+  });
+
+  const rule = new CodePipelineExecutionStateChangeDetectionEventRule(stack, 'CodePipelineExecutionStateChangeDetectionEventRule', {
+    ruleName: 'codepipeline-state-change-detection-event-rule',
+    targetStates: [
+      CodePipelineExecutionState.FAILED,
+      CodePipelineExecutionState.CANCELED,
+    ],
+  });
+
+  it('Is Rule', async () => {
+    expect(rule).toBeInstanceOf(events.Rule);
+  });
+
+  const template = Template.fromStack(stack);
+
+  it('Should match event rule.', async () => {
+    template.hasResourceProperties('AWS::Events::Rule', Match.objectEquals({
+      Name: 'codepipeline-state-change-detection-event-rule',
+      State: 'ENABLED',
+      EventPattern: Match.objectEquals({
+        'source': [
+          'aws.codepipeline',
+        ],
+        'detail-type': [
+          'CodePipeline Pipeline Execution State Change',
+        ],
+        'detail': {
+          state: Match.arrayEquals(['FAILED', 'CANCELED']),
+        },
+      }),
+    }));
+  });
+
+  it('Should match snapshot.', async () => {
+    expect(template.toJSON()).toMatchSnapshot();
+  });
+
+});