Adds properties to ImagePipeline construct

* allow adding a schedule to the image pipeline
* subscribe to the pipeline SNS from outside the component

Author: hanseartic

src/index.ts

@@ -129,6 +129,8 @@ export interface ImagePipelineProps {
 
 export class ImagePipeline extends Construct {
   imageRecipeComponents: imagebuilder.CfnImageRecipe.ComponentConfigurationProperty[];
+  readonly pipeline: imagebuilder.CfnImagePipeline;
+  readonly builderSnsTopic: sns.Topic;
 
   constructor(scope: Construct, id: string, props: ImagePipelineProps) {
     super(scope, id);
@@ -140,13 +142,13 @@ export class ImagePipeline extends Construct {
     const profileName = `${uid}Profile`;
 
     // Construct code below
-    const topic = new sns.Topic(this, 'ImageBuilderTopic', {
+    this.builderSnsTopic = new sns.Topic(this, 'ImageBuilderTopic', {
       displayName: 'Image Builder Notify',
       masterKey: props.kmsKey,
     });
 
     if (props.email != null) {
-      topic.addSubscription(new subscriptions.EmailSubscription(props.email));
+      this.builderSnsTopic.addSubscription(new subscriptions.EmailSubscription(props.email));
     }
 
     const role = new iam.Role(this, 'Role', {
@@ -174,15 +176,15 @@ export class ImagePipeline extends Construct {
         name: `${uid}InfraConfig`,
         description: 'Example Infrastructure Configuration for Image Builder',
         instanceTypes: props.instanceTypes ?? ['t3.medium', 'm5.large', 'm5.xlarge'],
-        snsTopicArn: topic.topicArn,
+        snsTopicArn: this.builderSnsTopic.topicArn,
       });
     } else {
       infrastructureConfig = new imagebuilder.CfnInfrastructureConfiguration(this, 'InfrastructureConfiguration', {
         instanceProfileName: profileName,
         name: `${uid}InfraConfig`,
         description: 'Example Infrastructure Configuration for Image Builder',
         instanceTypes: props.instanceTypes ?? ['t3.medium', 'm5.large', 'm5.xlarge'],
-        snsTopicArn: topic.topicArn,
+        snsTopicArn: this.builderSnsTopic.topicArn,
         securityGroupIds: props.securityGroups,
         subnetId: props.subnetId,
       });
@@ -325,9 +327,9 @@ export class ImagePipeline extends Construct {
         },
         memorySize: 256,
       });
-      amiSsmUpdateLambda.addEventSource(new SnsEventSource(topic, {}));
+      amiSsmUpdateLambda.addEventSource(new SnsEventSource(this.builderSnsTopic, {}));
     }
-    new imagebuilder.CfnImagePipeline(this, 'ImagePipeline', imagePipelineProps);
+    this.pipeline = new imagebuilder.CfnImagePipeline(this, 'ImagePipeline', imagePipelineProps);
   }
 
   /**

test/imagepipeline.test.ts

@@ -237,3 +237,17 @@ test('Image Pipeline has Inspector vulnerability scans configured', () => {
     },
   });
 });
+
+
+test('ImagePipeline exposes components as properties', () => {
+  const app = new cdk.App();
+  const testStack = new cdk.Stack(app, 'testStack', {
+    env: {
+      account: process.env.CDK_DEFAULT_ACCOUNT,
+      region: process.env.CDK_DEFAULT_REGION,
+    },
+  });
+  const sut = new ImagePipeline(testStack, 'ImagePipelineStack', props);
+  expect(sut.pipeline).toBeDefined();
+  expect(sut.builderSnsTopic).toBeDefined();
+});