feat(core): Adding "storeAllOutputs" property in SM input (aws-samples#554)

- Adding "storeAllOutputs" property in SM Input which will load all outputs from cfn stacks to DDB tables irrespective of existing entries.

Author: naveenkoppula

src/core/cdk/src/initial-setup.ts

@@ -155,6 +155,7 @@ export namespace InitialSetup {
           s3Bucket: props.configS3Bucket,
           branchName: props.configBranchName,
           acceleratorVersion: props.acceleratorVersion!,
+          'inputConfig.$': '$',
         },
         resultPath: '$.configuration',
       });
@@ -185,6 +186,7 @@ export namespace InitialSetup {
           'configCommitId.$': '$.configuration.configCommitId',
           'acceleratorVersion.$': '$.configuration.acceleratorVersion',
           outputTableName: outputsTable.tableName,
+          'storeAllOutputs.$': '$.configuration.storeAllOutputs',
         },
         resultPath: '$.configuration.baselineOutput',
       });

src/core/runtime/src/get-baseline-step.ts

@@ -7,6 +7,7 @@ export interface GetBaseLineInput {
   configCommitId: string;
   outputTableName: string;
   acceleratorVersion?: string;
+  storeAllOutputs?: boolean;
 }
 
 export interface ConfigurationOrganizationalUnit {
@@ -27,7 +28,7 @@ export const handler = async (input: GetBaseLineInput): Promise<GetBaseelineOutp
   console.log(`Loading configuration...`);
   console.log(JSON.stringify(input, null, 2));
 
-  const { configFilePath, configRepositoryName, configCommitId, outputTableName } = input;
+  const { configFilePath, configRepositoryName, configCommitId, outputTableName, storeAllOutputs } = input;
 
   // Retrieve Configuration from Code Commit with specific commitId
   const config = await loadAcceleratorConfig({
@@ -47,11 +48,25 @@ export const handler = async (input: GetBaseLineInput): Promise<GetBaseelineOutp
     throw new Error(`Both "alz-baseline" and "ct-baseline" can't be true`);
   }
 
-  // Checking whether DynamoDB outputs table is empty or not
-  const storeAllOutputs = await dynamoDB.isEmpty(outputTableName);
+  let runStoreAllOutputs: boolean = !!storeAllOutputs;
+  if (!runStoreAllOutputs) {
+    // Checking whether DynamoDB outputs table is empty or not
+    runStoreAllOutputs = await dynamoDB.isEmpty(outputTableName);
+  }
+  console.log(
+    JSON.stringify(
+      {
+        baseline,
+        storeAllOutputs: runStoreAllOutputs,
+        phases: [-1, 0, 1, 2, 3],
+      },
+      null,
+      2,
+    ),
+  );
   return {
     baseline,
-    storeAllOutputs,
+    storeAllOutputs: runStoreAllOutputs,
     phases: [-1, 0, 1, 2, 3],
   };
 };

src/core/runtime/src/get-or-create-config.ts

@@ -8,6 +8,9 @@ interface GetOrCreateConfigInput {
   s3Bucket: string;
   branchName: string;
   acceleratorVersion?: string;
+  // Taking entire input to replace any default paramaters in SM Input
+  // eslint-disable-next-line @typescript-eslint/no-explicit-any
+  inputConfig?: any;
 }
 
 const codecommit = new CodeCommit();
@@ -17,7 +20,8 @@ export const handler = async (input: GetOrCreateConfigInput) => {
   console.log(`Get or Create Config from S3 file...`);
   console.log(JSON.stringify(input, null, 2));
 
-  const { repositoryName, s3Bucket, branchName, acceleratorVersion } = input;
+  const { repositoryName, s3Bucket, branchName, acceleratorVersion, inputConfig } = input;
+  const storeAllOutputs: boolean = !!inputConfig.storeAllOutputs;
   const configRepository = await codecommit.batchGetRepositories([repositoryName]);
   if (!configRepository.repositories || configRepository.repositories?.length === 0) {
     console.log(`Creating repository "${repositoryName}" for Config file`);
@@ -58,6 +62,7 @@ export const handler = async (input: GetOrCreateConfigInput) => {
           {
             ...s3LoadResponse,
             acceleratorVersion,
+            storeAllOutputs,
           },
           null,
           2,
@@ -66,6 +71,7 @@ export const handler = async (input: GetOrCreateConfigInput) => {
       return {
         ...s3LoadResponse,
         acceleratorVersion,
+        storeAllOutputs,
       };
     }
     const currentCommit = await codecommit.getBranch(repositoryName, branchName);
@@ -107,6 +113,7 @@ export const handler = async (input: GetOrCreateConfigInput) => {
           configCommitId: configCommitId || currentCommit.branch?.commitId,
           acceleratorVersion,
           configRootFilePath: filePath,
+          storeAllOutputs,
         },
         null,
         2,
@@ -119,6 +126,7 @@ export const handler = async (input: GetOrCreateConfigInput) => {
       configCommitId: configCommitId || currentCommit.branch?.commitId,
       acceleratorVersion,
       configRootFilePath: filePath,
+      storeAllOutputs,
     };
   } catch (e) {
     if (e.code !== 'FileDoesNotExistException' && e.code !== 'CommitDoesNotExistException') {
@@ -135,6 +143,7 @@ export const handler = async (input: GetOrCreateConfigInput) => {
         {
           ...s3LoadResponse,
           acceleratorVersion,
+          storeAllOutputs,
         },
         null,
         2,
@@ -144,6 +153,7 @@ export const handler = async (input: GetOrCreateConfigInput) => {
     return {
       ...s3LoadResponse,
       acceleratorVersion,
+      storeAllOutputs,
     };
   }
 };