refactor(cli): stack monitor uses io-host

Author: mrgrain

packages/@aws-cdk/toolkit-lib/lib/api/io/private/codes.ts

@@ -109,6 +109,24 @@ export const CODES = {
     description: 'Confirm deploy security sensitive changes',
     level: 'info',
   }),
+
+  CDK_TOOLKIT_I5501: codeInfo({
+    code: 'CDK_TOOLKIT_I5501',
+    description: 'Stack Monitoring Start',
+    level: 'debug',
+  }),
+  CDK_TOOLKIT_I5502: codeInfo({
+    code: 'CDK_TOOLKIT_I5502',
+    description: 'Stack Monitoring Activity event',
+    level: 'info',
+    interface: 'StackActivity',
+  }),
+  CDK_TOOLKIT_I5503: codeInfo({
+    code: 'CDK_TOOLKIT_I5503',
+    description: 'Stack Monitoring End',
+    level: 'debug',
+  }),
+
   CDK_TOOLKIT_I5900: codeInfo({
     code: 'CDK_TOOLKIT_I5900',
     description: 'Deployment results on success',
@@ -121,6 +139,11 @@ export const CODES = {
     description: 'No stacks found',
     level: 'error',
   }),
+  CDK_TOOLKIT_E5500: codeInfo({
+    code: 'CDK_TOOLKIT_E5500',
+    description: 'Stack Monitoring error',
+    level: 'error',
+  }),
 
   // 6: Rollback
   CDK_TOOLKIT_I6000: codeInfo({

packages/aws-cdk/lib/api/deployments/deploy-stack.ts

@@ -36,7 +36,7 @@ import type { SDK, SdkProvider, ICloudFormationClient } from '../aws-auth';
 import type { EnvironmentResources } from '../environment';
 import { CfnEvaluationException } from '../evaluate-cloudformation-template';
 import { HotswapMode, HotswapPropertyOverrides, ICON } from '../hotswap/common';
-import { StackActivityMonitor, type StackActivityProgress } from '../stack-events';
+import { StackActivityMonitor } from '../stack-events';
 import { StringWithoutPlaceholders } from '../util/placeholders';
 import { type TemplateBodyParameter, makeBodyParameter } from '../util/template-body-parameter';
 
@@ -153,14 +153,6 @@ export interface DeployStackOptions {
    */
   readonly usePreviousParameters?: boolean;
 
-  /**
-   * Display mode for stack deployment progress.
-   *
-   * @default StackActivityProgress.Bar stack events will be displayed for
-   *   the resource currently being deployed.
-   */
-  readonly progress?: StackActivityProgress;
-
   /**
    * Deploy even if the deployed template is identical to the one we are about to deploy.
    * @default false
@@ -612,14 +604,16 @@ class FullCloudFormationDeployment {
   }
 
   private async monitorDeployment(startTime: Date, expectedChanges: number | undefined): Promise<SuccessfulDeployStackResult> {
-    const monitor = this.options.quiet
-      ? undefined
-      : StackActivityMonitor.withDefaultPrinter(this.cfn, this.stackName, this.stackArtifact, {
-        resourcesTotal: expectedChanges,
-        progress: this.options.progress,
-        changeSetCreationTime: startTime,
-        ci: this.options.ci,
-      }).start();
+    const monitor = new StackActivityMonitor({
+      cfn: this.cfn,
+      stack: this.stackArtifact,
+      stackName: this.stackName,
+      resourcesTotal: expectedChanges,
+      ioHost: this.ioHost,
+      action: this.action,
+      changeSetCreationTime: startTime,
+    });
+    await monitor.start();
 
     let finalState = this.cloudFormationStack;
     try {
@@ -631,9 +625,9 @@ class FullCloudFormationDeployment {
       }
       finalState = successStack;
     } catch (e: any) {
-      throw new ToolkitError(suffixWithErrors(formatErrorMessage(e), monitor?.errors));
+      throw new ToolkitError(suffixWithErrors(formatErrorMessage(e), monitor.errors));
     } finally {
-      await monitor?.stop();
+      await monitor.stop();
     }
     debug(this.action, format('Stack %s has completed updating', this.stackName));
     return {
@@ -696,11 +690,14 @@ export async function destroyStack(options: DestroyStackOptions, { ioHost, actio
   if (!currentStack.exists) {
     return;
   }
-  const monitor = options.quiet
-    ? undefined
-    : StackActivityMonitor.withDefaultPrinter(cfn, deployName, options.stack, {
-      ci: options.ci,
-    }).start();
+  const monitor = new StackActivityMonitor({
+    cfn,
+    stack: options.stack,
+    stackName: deployName,
+    ioHost,
+    action,
+  });
+  await monitor.start();
 
   try {
     await cfn.deleteStack({ StackName: deployName, RoleARN: options.roleArn });
@@ -709,7 +706,7 @@ export async function destroyStack(options: DestroyStackOptions, { ioHost, actio
       throw new ToolkitError(`Failed to destroy ${deployName}: ${destroyedStack.stackStatus}`);
     }
   } catch (e: any) {
-    throw new ToolkitError(suffixWithErrors(formatErrorMessage(e), monitor?.errors));
+    throw new ToolkitError(suffixWithErrors(formatErrorMessage(e), monitor.errors));
   } finally {
     if (monitor) {
       await monitor.stop();

packages/aws-cdk/lib/api/deployments/deployments.ts

@@ -31,7 +31,7 @@ import { formatErrorMessage } from '../../util/format-error';
 import type { SdkProvider } from '../aws-auth/sdk-provider';
 import { type EnvironmentResources, EnvironmentAccess } from '../environment';
 import { HotswapMode, HotswapPropertyOverrides } from '../hotswap/common';
-import { StackActivityMonitor, StackActivityProgress, StackEventPoller, RollbackChoice } from '../stack-events';
+import { StackActivityMonitor, StackEventPoller, RollbackChoice } from '../stack-events';
 import type { Tag } from '../tags';
 import { DEFAULT_TOOLKIT_STACK_NAME } from '../toolkit-info';
 import { makeBodyParameter } from '../util/template-body-parameter';
@@ -135,14 +135,6 @@ export interface DeployStackOptions {
    */
   readonly usePreviousParameters?: boolean;
 
-  /**
-   * Display mode for stack deployment progress.
-   *
-   * @default - StackActivityProgress.Bar - stack events will be displayed for
-   *   the resource currently being deployed.
-   */
-  readonly progress?: StackActivityProgress;
-
   /**
    * Whether we are on a CI system
    *
@@ -255,14 +247,6 @@ export interface RollbackStackOptions {
    */
   readonly orphanLogicalIds?: string[];
 
-  /**
-   * Display mode for stack deployment progress.
-   *
-   * @default - StackActivityProgress.Bar - stack events will be displayed for
-   *   the resource currently being deployed.
-   */
-  readonly progress?: StackActivityProgress;
-
   /**
    * Whether to validate the version of the bootstrap stack permissions
    *
@@ -474,7 +458,6 @@ export class Deployments {
       force: options.force,
       parameters: options.parameters,
       usePreviousParameters: options.usePreviousParameters,
-      progress: options.progress,
       ci: options.ci,
       rollback: options.rollback,
       hotswap: options.hotswap,
@@ -565,11 +548,14 @@ export class Deployments {
           throw new ToolkitError(`Unexpected rollback choice: ${cloudFormationStack.stackStatus.rollbackChoice}`);
       }
 
-      const monitor = options.quiet
-        ? undefined
-        : StackActivityMonitor.withDefaultPrinter(cfn, deployName, options.stack, {
-          ci: options.ci,
-        }).start();
+      const monitor = new StackActivityMonitor({
+        cfn,
+        stack: options.stack,
+        stackName: deployName,
+        ioHost: this.ioHost,
+        action: this.action,
+      });
+      await monitor.start();
 
       let stackErrorMessage: string | undefined = undefined;
       let finalStackState = cloudFormationStack;
@@ -582,14 +568,14 @@ export class Deployments {
         }
         finalStackState = successStack;
 
-        const errors = monitor?.errors?.join(', ');
+        const errors = monitor.errors.join(', ');
         if (errors) {
           stackErrorMessage = errors;
         }
       } catch (e: any) {
-        stackErrorMessage = suffixWithErrors(formatErrorMessage(e), monitor?.errors);
+        stackErrorMessage = suffixWithErrors(formatErrorMessage(e), monitor.errors);
       } finally {
-        await monitor?.stop();
+        await monitor.stop();
       }
 
       if (finalStackState.stackStatus.isRollbackSuccess || !stackErrorMessage) {

packages/aws-cdk/lib/api/resource-import/importer.ts

@@ -9,7 +9,6 @@ import { error, info, warn } from '../../cli/messages';
 import { IIoHost, ToolkitAction } from '../../toolkit/cli-io-host';
 import { ToolkitError } from '../../toolkit/error';
 import { assertIsSuccessfulDeployStackResult, type Deployments, DeploymentMethod, ResourceIdentifierProperties, ResourcesToImport } from '../deployments';
-import type { StackActivityProgress } from '../stack-events';
 import type { Tag } from '../tags';
 
 export interface ResourceImporterProps {
@@ -49,14 +48,6 @@ export interface ImportDeploymentOptions {
    */
   readonly usePreviousParameters?: boolean;
 
-  /**
-   * Display mode for stack deployment progress.
-   *
-   * @default - StackActivityProgress.Bar - stack events will be displayed for
-   *   the resource currently being deployed.
-   */
-  readonly progress?: StackActivityProgress;
-
   /**
    * Rollback failed deployments
    *

packages/aws-cdk/lib/api/resource-import/migrator.ts

@@ -67,7 +67,6 @@ export class ResourceMigrator {
       roleArn: options.roleArn,
       deploymentMethod: options.deploymentMethod,
       usePreviousParameters: true,
-      progress: options.progress,
       rollback: options.rollback,
     });