diff --git a/packages/@aws-cdk/tmp-toolkit-helpers/src/api/io/private/messages.ts b/packages/@aws-cdk/tmp-toolkit-helpers/src/api/io/private/messages.ts
index ae5f57507..ba76c81c8 100644
--- a/packages/@aws-cdk/tmp-toolkit-helpers/src/api/io/private/messages.ts
+++ b/packages/@aws-cdk/tmp-toolkit-helpers/src/api/io/private/messages.ts
@@ -74,9 +74,10 @@ export const IO = {
   }),
 
   // 3: Import & Migrate
-  CDK_TOOLKIT_E3900: make.error({
+  CDK_TOOLKIT_E3900: make.error<ErrorPayload>({
     code: 'CDK_TOOLKIT_E3900',
     description: 'Resource import failed',
+    interface: 'ErrorPayload',
   }),
 
   // 4: Diff (4xxx)
@@ -92,9 +93,10 @@ export const IO = {
     description: 'Provides total time in deploy action, including synth and rollback',
     interface: 'Duration',
   }),
-  CDK_TOOLKIT_I5002: make.info({
+  CDK_TOOLKIT_I5002: make.info<Duration>({
     code: 'CDK_TOOLKIT_I5002',
     description: 'Provides time for resource migration',
+    interface: 'Duration',
   }),
   CDK_TOOLKIT_W5021: make.warn({
     code: 'CDK_TOOLKIT_W5021',
diff --git a/packages/@aws-cdk/toolkit-lib/docs/message-registry.md b/packages/@aws-cdk/toolkit-lib/docs/message-registry.md
index ec488a8bb..befcd4be8 100644
--- a/packages/@aws-cdk/toolkit-lib/docs/message-registry.md
+++ b/packages/@aws-cdk/toolkit-lib/docs/message-registry.md
@@ -16,10 +16,10 @@ group: Documents
 | `CDK_TOOLKIT_I1901` | Provides stack data | `result` | {@link StackAndAssemblyData} |
 | `CDK_TOOLKIT_I1902` | Successfully deployed stacks | `result` | {@link AssemblyData} |
 | `CDK_TOOLKIT_I2901` | Provides details on the selected stacks and their dependencies | `result` | {@link StackDetailsPayload} |
-| `CDK_TOOLKIT_E3900` | Resource import failed | `error` | n/a |
+| `CDK_TOOLKIT_E3900` | Resource import failed | `error` | {@link ErrorPayload} |
 | `CDK_TOOLKIT_I5000` | Provides deployment times | `info` | {@link Duration} |
 | `CDK_TOOLKIT_I5001` | Provides total time in deploy action, including synth and rollback | `info` | {@link Duration} |
-| `CDK_TOOLKIT_I5002` | Provides time for resource migration | `info` | n/a |
+| `CDK_TOOLKIT_I5002` | Provides time for resource migration | `info` | {@link Duration} |
 | `CDK_TOOLKIT_W5021` | Empty non-existent stack, deployment is skipped | `warn` | n/a |
 | `CDK_TOOLKIT_W5022` | Empty existing stack, stack will be destroyed | `warn` | n/a |
 | `CDK_TOOLKIT_I5031` | Informs about any log groups that are traced as part of the deployment | `info` | n/a |
diff --git a/packages/aws-cdk/lib/api/bootstrap/bootstrap-environment.ts b/packages/aws-cdk/lib/api/bootstrap/bootstrap-environment.ts
index f32fdaa68..7a731974f 100644
--- a/packages/aws-cdk/lib/api/bootstrap/bootstrap-environment.ts
+++ b/packages/aws-cdk/lib/api/bootstrap/bootstrap-environment.ts
@@ -1,12 +1,10 @@
-import { info } from 'console';
 import * as path from 'path';
 import type * as cxapi from '@aws-cdk/cx-api';
 import type { BootstrapEnvironmentOptions, BootstrappingParameters } from './bootstrap-props';
 import { BootstrapStack, bootstrapVersionFromTemplate } from './deploy-bootstrap';
 import { legacyBootstrapTemplate } from './legacy-template';
 import { ToolkitError } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api';
-import type { IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
-import { warn } from '../../cli/messages';
+import { IO, type IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
 import { bundledPackageRootDir, loadStructuredFile, serializeStructure } from '../../util';
 import type { SDK, SdkProvider } from '../aws-auth';
 import type { SuccessfulDeployStackResult } from '../deployments';
@@ -125,14 +123,16 @@ export class Bootstrapper {
       accounts.filter(acc => !params.untrustedAccounts?.map(String).includes(String(acc)));
 
     const trustedAccounts = removeUntrusted(params.trustedAccounts ?? splitCfnArray(current.parameters.TrustedAccounts));
-    info(`Trusted accounts for deployment: ${trustedAccounts.length > 0 ? trustedAccounts.join(', ') : '(none)'}`);
+    await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_INFO.msg(
+      `Trusted accounts for deployment: ${trustedAccounts.length > 0 ? trustedAccounts.join(', ') : '(none)'}`,
+    ));
 
     const trustedAccountsForLookup = removeUntrusted(
       params.trustedAccountsForLookup ?? splitCfnArray(current.parameters.TrustedAccountsForLookup),
     );
-    info(
+    await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_INFO.msg(
       `Trusted accounts for lookup: ${trustedAccountsForLookup.length > 0 ? trustedAccountsForLookup.join(', ') : '(none)'}`,
-    );
+    ));
 
     const cloudFormationExecutionPolicies =
       params.cloudFormationExecutionPolicies ?? splitCfnArray(current.parameters.CloudFormationExecutionPolicies);
@@ -151,7 +151,7 @@ export class Bootstrapper {
       // Would leave AdministratorAccess policies with a trust relationship, without the user explicitly
       // approving the trust policy.
       const implicitPolicy = `arn:${partition}:iam::aws:policy/AdministratorAccess`;
-      await this.ioHelper.notify(warn(
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_WARN.msg(
         `Using default execution policy of '${implicitPolicy}'. Pass '--cloudformation-execution-policies' to customize.`,
       ));
     } else if (cloudFormationExecutionPolicies.length === 0) {
@@ -160,7 +160,7 @@ export class Bootstrapper {
       );
     } else {
       // Remind people what the current settings are
-      info(`Execution policies: ${cloudFormationExecutionPolicies.join(', ')}`);
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_INFO.msg(`Execution policies: ${cloudFormationExecutionPolicies.join(', ')}`));
     }
 
     // * If an ARN is given, that ARN. Otherwise:
@@ -199,15 +199,15 @@ export class Bootstrapper {
     }
     if (currentPermissionsBoundary !== policyName) {
       if (!currentPermissionsBoundary) {
-        await this.ioHelper.notify(warn(
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_WARN.msg(
           `Adding new permissions boundary ${policyName}`,
         ));
       } else if (!policyName) {
-        await this.ioHelper.notify(warn(
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_WARN.msg(
           `Removing existing permissions boundary ${currentPermissionsBoundary}`,
         ));
       } else {
-        await this.ioHelper.notify(warn(
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_WARN.msg(
           `Changing permissions boundary from ${currentPermissionsBoundary} to ${policyName}`,
         ));
       }
diff --git a/packages/aws-cdk/lib/api/bootstrap/deploy-bootstrap.ts b/packages/aws-cdk/lib/api/bootstrap/deploy-bootstrap.ts
index e6011e323..f29be758f 100644
--- a/packages/aws-cdk/lib/api/bootstrap/deploy-bootstrap.ts
+++ b/packages/aws-cdk/lib/api/bootstrap/deploy-bootstrap.ts
@@ -11,8 +11,7 @@ import {
   BOOTSTRAP_VERSION_RESOURCE,
   DEFAULT_BOOTSTRAP_VARIANT,
 } from './bootstrap-props';
-import type { IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
-import { warn } from '../../cli/messages';
+import { IO, type IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
 import type { SDK, SdkProvider } from '../aws-auth';
 import type { SuccessfulDeployStackResult } from '../deployments';
 import { assertIsSuccessfulDeployStackResult } from '../deployments';
@@ -90,7 +89,7 @@ export class BootstrapStack {
       const currentVariant = this.currentToolkitInfo.variant;
       const newVariant = bootstrapVariantFromTemplate(template);
       if (currentVariant !== newVariant) {
-        await this.ioHelper.notify(warn(
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_WARN.msg(
           `Bootstrap stack already exists, containing '${currentVariant}'. Not overwriting it with a template containing '${newVariant}' (use --force if you intend to overwrite)`,
         ));
         return abortResponse;
@@ -100,13 +99,13 @@ export class BootstrapStack {
       const newVersion = bootstrapVersionFromTemplate(template);
       const currentVersion = this.currentToolkitInfo.version;
       if (newVersion < currentVersion) {
-        await this.ioHelper.notify(warn(
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_WARN.msg(
           `Bootstrap stack already at version ${currentVersion}. Not downgrading it to version ${newVersion} (use --force if you intend to downgrade)`,
         ));
         if (newVersion === 0) {
           // A downgrade with 0 as target version means we probably have a new-style bootstrap in the account,
           // and an old-style bootstrap as current target, which means the user probably forgot to put this flag in.
-          await this.ioHelper.notify(warn(
+          await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_WARN.msg(
             "(Did you set the '@aws-cdk/core:newStyleStackSynthesis' feature flag in cdk.json?)",
           ));
         }
diff --git a/packages/aws-cdk/lib/api/deployments/assets.ts b/packages/aws-cdk/lib/api/deployments/assets.ts
index 62fcd0578..f0c1fd727 100644
--- a/packages/aws-cdk/lib/api/deployments/assets.ts
+++ b/packages/aws-cdk/lib/api/deployments/assets.ts
@@ -5,8 +5,7 @@ import * as cxapi from '@aws-cdk/cx-api';
 import * as chalk from 'chalk';
 import type { AssetManifestBuilder } from './asset-manifest-builder';
 import { ToolkitError } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api';
-import type { IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
-import { debug } from '../../cli/messages';
+import { IO, type IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
 import type { EnvironmentResources } from '../environment';
 import type { ToolkitInfo } from '../toolkit-info';
 
@@ -44,11 +43,11 @@ export async function addMetadataAssetsToManifest(
     const reuseAsset = reuse.indexOf(asset.id) > -1;
 
     if (reuseAsset) {
-      await ioHelper.notify(debug(`Reusing asset ${asset.id}: ${JSON.stringify(asset)}`));
+      await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Reusing asset ${asset.id}: ${JSON.stringify(asset)}`));
       continue;
     }
 
-    await ioHelper.notify(debug(`Preparing asset ${asset.id}: ${JSON.stringify(asset)}`));
+    await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Preparing asset ${asset.id}: ${JSON.stringify(asset)}`));
     if (!stack.assembly) {
       throw new ToolkitError('Unexpected: stack assembly is required in order to find assets in assembly directory');
     }
@@ -98,7 +97,7 @@ async function prepareFileAsset(
   const key = `${s3Prefix}${baseName}`;
   const s3url = `s3://${toolkitInfo.bucketName}/${key}`;
 
-  await ioHelper.notify(debug(`Storing asset ${asset.path} at ${s3url}`));
+  await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Storing asset ${asset.path} at ${s3url}`));
 
   assetManifest.addFileAsset(asset.sourceHash, {
     path: asset.path,
diff --git a/packages/aws-cdk/lib/api/deployments/checks.ts b/packages/aws-cdk/lib/api/deployments/checks.ts
index e57e1d6e4..63ee6f40b 100644
--- a/packages/aws-cdk/lib/api/deployments/checks.ts
+++ b/packages/aws-cdk/lib/api/deployments/checks.ts
@@ -1,6 +1,5 @@
 import { ToolkitError } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api';
-import type { IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
-import { debug } from '../../cli/messages';
+import { IO, type IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
 import type { SDK } from '../aws-auth';
 
 export async function determineAllowCrossAccountAssetPublishing(
@@ -34,8 +33,8 @@ export async function determineAllowCrossAccountAssetPublishing(
     // of creating bootstrap resources. If they do, there's nothing for us to validate,
     // but we can't use that as a reason to disallow cross-account publishing. We'll just
     // have to trust they did their due diligence. So we fail open.
-    await ioHelper.notify(debug(`Error determining cross account asset publishing: ${e}`));
-    await ioHelper.notify(debug('Defaulting to allowing cross account asset publishing'));
+    await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Error determining cross account asset publishing: ${e}`));
+    await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg('Defaulting to allowing cross account asset publishing'));
     return true;
   }
 }
diff --git a/packages/aws-cdk/lib/api/deployments/cloudformation.ts b/packages/aws-cdk/lib/api/deployments/cloudformation.ts
index 7375d3287..290a312d7 100644
--- a/packages/aws-cdk/lib/api/deployments/cloudformation.ts
+++ b/packages/aws-cdk/lib/api/deployments/cloudformation.ts
@@ -15,8 +15,7 @@ import { AssetManifest } from 'cdk-assets';
 import { AssetManifestBuilder } from './asset-manifest-builder';
 import type { Deployments } from './deployments';
 import { ToolkitError } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api';
-import type { IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
-import { debug } from '../../cli/messages';
+import { IO, type IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
 import { formatErrorMessage, deserializeStructure } from '../../util';
 import type { ICloudFormationClient, SdkProvider } from '../aws-auth';
 import { StackStatus } from '../stack-events';
@@ -295,7 +294,7 @@ export async function waitForChangeSet(
   changeSetName: string,
   { fetchAll }: { fetchAll: boolean },
 ): Promise<DescribeChangeSetCommandOutput> {
-  await ioHelper.notify(debug(format('Waiting for changeset %s on stack %s to finish creating...', changeSetName, stackName)));
+  await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(format('Waiting for changeset %s on stack %s to finish creating...', changeSetName, stackName)));
   const ret = await waitFor(async () => {
     const description = await describeChangeSet(cfn, stackName, changeSetName, {
       fetchAll,
@@ -303,7 +302,7 @@ export async function waitForChangeSet(
     // The following doesn't use a switch because tsc will not allow fall-through, UNLESS it is allows
     // EVERYWHERE that uses this library directly or indirectly, which is undesirable.
     if (description.Status === 'CREATE_PENDING' || description.Status === 'CREATE_IN_PROGRESS') {
-      await ioHelper.notify(debug(format('Changeset %s on stack %s is still creating', changeSetName, stackName)));
+      await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(format('Changeset %s on stack %s is still creating', changeSetName, stackName)));
       return undefined;
     }
 
@@ -360,7 +359,7 @@ export async function createDiffChangeSet(
   // This causes CreateChangeSet to fail with `Template Error: Fn::Equals cannot be partially collapsed`.
   for (const resource of Object.values(options.stack.template.Resources ?? {})) {
     if ((resource as any).Type === 'AWS::CloudFormation::Stack') {
-      await ioHelper.notify(debug('This stack contains one or more nested stacks, falling back to template-only diff...'));
+      await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg('This stack contains one or more nested stacks, falling back to template-only diff...'));
 
       return undefined;
     }
@@ -430,7 +429,7 @@ async function uploadBodyParameterAndCreateChangeSet(
       role: executionRoleArn,
     });
   } catch (e: any) {
-    await ioHelper.notify(debug(e));
+    await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(e));
     options.stream.write(
       'Could not create a change set, will base the diff on template differences (run again with -v to see the reason)\n',
     );
@@ -472,7 +471,7 @@ export async function createChangeSet(
 ): Promise<DescribeChangeSetCommandOutput> {
   await cleanupOldChangeset(options.cfn, ioHelper, options.changeSetName, options.stack.stackName);
 
-  await ioHelper.notify(debug(`Attempting to create ChangeSet with name ${options.changeSetName} for stack ${options.stack.stackName}`));
+  await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Attempting to create ChangeSet with name ${options.changeSetName} for stack ${options.stack.stackName}`));
 
   const templateParams = TemplateParameters.fromTemplate(options.stack.template);
   const stackParams = templateParams.supplyAll(options.parameters);
@@ -492,7 +491,7 @@ export async function createChangeSet(
     Capabilities: ['CAPABILITY_IAM', 'CAPABILITY_NAMED_IAM', 'CAPABILITY_AUTO_EXPAND'],
   });
 
-  await ioHelper.notify(debug(format('Initiated creation of changeset: %s; waiting for it to finish creating...', changeSet.Id)));
+  await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(format('Initiated creation of changeset: %s; waiting for it to finish creating...', changeSet.Id)));
   // Fetching all pages if we'll execute, so we can have the correct change count when monitoring.
   const createdChangeSet = await waitForChangeSet(options.cfn, ioHelper, options.stack.stackName, options.changeSetName, {
     fetchAll: options.willExecute,
@@ -517,7 +516,7 @@ async function cleanupOldChangeset(
 ) {
   // Delete any existing change sets generated by CDK since change set names must be unique.
   // The delete request is successful as long as the stack exists (even if the change set does not exist).
-  await ioHelper.notify(debug(`Removing existing change set with name ${changeSetName} if it exists`));
+  await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Removing existing change set with name ${changeSetName} if it exists`));
   await cfn.deleteChangeSet({
     StackName: stackName,
     ChangeSetName: changeSetName,
@@ -619,16 +618,16 @@ export async function stabilizeStack(
   ioHelper: IoHelper,
   stackName: string,
 ) {
-  await ioHelper.notify(debug(format('Waiting for stack %s to finish creating or updating...', stackName)));
+  await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(format('Waiting for stack %s to finish creating or updating...', stackName)));
   return waitFor(async () => {
     const stack = await CloudFormationStack.lookup(cfn, stackName);
     if (!stack.exists) {
-      await ioHelper.notify(debug(format('Stack %s does not exist', stackName)));
+      await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(format('Stack %s does not exist', stackName)));
       return null;
     }
     const status = stack.stackStatus;
     if (status.isInProgress) {
-      await ioHelper.notify(debug(format('Stack %s has an ongoing operation in progress and is not stable (%s)', stackName, status)));
+      await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(format('Stack %s has an ongoing operation in progress and is not stable (%s)', stackName, status)));
       return undefined;
     } else if (status.isReviewInProgress) {
       // This may happen if a stack creation operation is interrupted before the ChangeSet execution starts. Recovering
@@ -637,7 +636,7 @@ export async function stabilizeStack(
       // "forever" we proceed as if the stack was existing and stable. If there is a concurrent operation that just
       // hasn't finished proceeding just yet, either this operation or the concurrent one may fail due to the other one
       // having made progress. Which is fine. I guess.
-      await ioHelper.notify(debug(format('Stack %s is in REVIEW_IN_PROGRESS state. Considering this is a stable status (%s)', stackName, status)));
+      await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(format('Stack %s is in REVIEW_IN_PROGRESS state. Considering this is a stable status (%s)', stackName, status)));
     }
 
     return stack;
diff --git a/packages/aws-cdk/lib/api/deployments/deployments.ts b/packages/aws-cdk/lib/api/deployments/deployments.ts
index fe664a391..c4bf1e83b 100644
--- a/packages/aws-cdk/lib/api/deployments/deployments.ts
+++ b/packages/aws-cdk/lib/api/deployments/deployments.ts
@@ -27,8 +27,7 @@ import {
   type RootTemplateWithNestedStacks,
 } from './nested-stack-helpers';
 import { ToolkitError } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api';
-import type { IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
-import { debug, warn } from '../../cli/messages';
+import { IO, type IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
 import { formatErrorMessage } from '../../util';
 import type { SdkProvider } from '../aws-auth/sdk-provider';
 import { type EnvironmentResources, EnvironmentAccess } from '../environment';
@@ -362,7 +361,7 @@ export class Deployments {
   }
 
   public async readCurrentTemplate(stackArtifact: cxapi.CloudFormationStackArtifact): Promise<Template> {
-    await this.ioHelper.notify(debug(`Reading existing template for stack ${stackArtifact.displayName}.`));
+    await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Reading existing template for stack ${stackArtifact.displayName}.`));
     const env = await this.envs.accessStackForLookupBestEffort(stackArtifact);
     return loadCurrentTemplate(stackArtifact, env.sdk);
   }
@@ -370,7 +369,7 @@ export class Deployments {
   public async resourceIdentifierSummaries(
     stackArtifact: cxapi.CloudFormationStackArtifact,
   ): Promise<ResourceIdentifierSummaries> {
-    await this.ioHelper.notify(debug(`Retrieving template summary for stack ${stackArtifact.displayName}.`));
+    await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Retrieving template summary for stack ${stackArtifact.displayName}.`));
     // Currently, needs to use `deploy-role` since it may need to read templates in the staging
     // bucket which have been encrypted with a KMS key (and lookup-role may not read encrypted things)
     const env = await this.envs.accessStackForReadOnlyStackOperations(stackArtifact);
@@ -400,7 +399,7 @@ export class Deployments {
 
     const response = await cfn.getTemplateSummary(cfnParam);
     if (!response.ResourceIdentifierSummaries) {
-      await this.ioHelper.notify(debug('GetTemplateSummary API call did not return "ResourceIdentifierSummaries"'));
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg('GetTemplateSummary API call did not return "ResourceIdentifierSummaries"'));
     }
     return response.ResourceIdentifierSummaries ?? [];
   }
@@ -485,11 +484,11 @@ export class Deployments {
 
       switch (cloudFormationStack.stackStatus.rollbackChoice) {
         case RollbackChoice.NONE:
-          await this.ioHelper.notify(warn(`Stack ${deployName} does not need a rollback: ${cloudFormationStack.stackStatus}`));
+          await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_WARN.msg(`Stack ${deployName} does not need a rollback: ${cloudFormationStack.stackStatus}`));
           return { notInRollbackableState: true };
 
         case RollbackChoice.START_ROLLBACK:
-          await this.ioHelper.notify(debug(`Initiating rollback of stack ${deployName}`));
+          await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Initiating rollback of stack ${deployName}`));
           await cfn.rollbackStack({
             StackName: deployName,
             RoleARN: executionRoleArn,
@@ -515,7 +514,7 @@ export class Deployments {
           }
 
           const skipDescription = resourcesToSkip.length > 0 ? ` (orphaning: ${resourcesToSkip.join(', ')})` : '';
-          await this.ioHelper.notify(warn(`Continuing rollback of stack ${deployName}${skipDescription}`));
+          await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_WARN.msg(`Continuing rollback of stack ${deployName}${skipDescription}`));
           await cfn.continueUpdateRollback({
             StackName: deployName,
             ClientRequestToken: randomUUID(),
@@ -525,7 +524,7 @@ export class Deployments {
           break;
 
         case RollbackChoice.ROLLBACK_FAILED:
-          await this.ioHelper.notify(warn(
+          await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_WARN.msg(
             `Stack ${deployName} failed creation and rollback. This state cannot be rolled back. You can recreate this stack by running 'cdk deploy'.`,
           ));
           return { notInRollbackableState: true };
diff --git a/packages/aws-cdk/lib/api/environment/environment-access.ts b/packages/aws-cdk/lib/api/environment/environment-access.ts
index a17fa3da9..b851f17a8 100644
--- a/packages/aws-cdk/lib/api/environment/environment-access.ts
+++ b/packages/aws-cdk/lib/api/environment/environment-access.ts
@@ -3,8 +3,7 @@ import type { SDK } from '../aws-auth';
 import type { EnvironmentResources } from './environment-resources';
 import { EnvironmentResourcesRegistry } from './environment-resources';
 import { ToolkitError } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api';
-import type { IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
-import { warn } from '../../cli/messages';
+import { IO, type IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
 import { formatErrorMessage } from '../../util';
 import type { CredentialsOptions, SdkForEnvironment, SdkProvider } from '../aws-auth/sdk-provider';
 import { Mode } from '../plugin/mode';
@@ -113,7 +112,7 @@ export class EnvironmentAccess {
     }
     if (lookupEnv.isFallbackCredentials) {
       const arn = await lookupEnv.replacePlaceholders(stack.lookupRole?.arn);
-      await this.ioHelper.notify(warn(`Lookup role ${arn} was not assumed. Proceeding with default credentials.`));
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_WARN.msg(`Lookup role ${arn} was not assumed. Proceeding with default credentials.`));
     }
     return lookupEnv;
   }
@@ -137,7 +136,7 @@ export class EnvironmentAccess {
     try {
       return await this.accessStackForLookup(stack);
     } catch (e: any) {
-      await this.ioHelper.notify(warn(`${formatErrorMessage(e)}`));
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_WARN.msg(`${formatErrorMessage(e)}`));
     }
     return this.accessStackForStackOperations(stack, Mode.ForReading);
   }
diff --git a/packages/aws-cdk/lib/api/environment/environment-resources.ts b/packages/aws-cdk/lib/api/environment/environment-resources.ts
index 56e44b476..8a9901d8d 100644
--- a/packages/aws-cdk/lib/api/environment/environment-resources.ts
+++ b/packages/aws-cdk/lib/api/environment/environment-resources.ts
@@ -1,7 +1,6 @@
 import type { Environment } from '@aws-cdk/cx-api';
 import { ToolkitError } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api';
-import type { IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
-import { debug, warn } from '../../cli/messages';
+import { IO, type IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
 import { Notices } from '../../notices';
 import { formatErrorMessage } from '../../util';
 import type { SDK } from '../aws-auth';
@@ -99,7 +98,7 @@ export class EnvironmentResources {
         // so let it fail as it would if we didn't have this fallback.
         const bootstrapStack = await this.lookupToolkit();
         if (bootstrapStack.found && bootstrapStack.version < BOOTSTRAP_TEMPLATE_VERSION_INTRODUCING_GETPARAMETER) {
-          await this.ioHelper.notify(warn(
+          await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_WARN.msg(
             `Could not read SSM parameter ${ssmParameterName}: ${formatErrorMessage(e)}, falling back to version from ${bootstrapStack}`,
           ));
           doValidate(bootstrapStack.version, this.environment);
@@ -170,7 +169,7 @@ export class EnvironmentResources {
 
     // check if repo already exists
     try {
-      await this.ioHelper.notify(debug(`${repositoryName}: checking if ECR repository already exists`));
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`${repositoryName}: checking if ECR repository already exists`));
       const describeResponse = await ecr.describeRepositories({
         repositoryNames: [repositoryName],
       });
@@ -185,7 +184,7 @@ export class EnvironmentResources {
     }
 
     // create the repo (tag it so it will be easier to garbage collect in the future)
-    await this.ioHelper.notify(debug(`${repositoryName}: creating ECR repository`));
+    await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`${repositoryName}: creating ECR repository`));
     const assetTag = { Key: 'awscdk:asset', Value: 'true' };
     const response = await ecr.createRepository({
       repositoryName,
@@ -197,7 +196,7 @@ export class EnvironmentResources {
     }
 
     // configure image scanning on push (helps in identifying software vulnerabilities, no additional charge)
-    await this.ioHelper.notify(debug(`${repositoryName}: enable image scanning`));
+    await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`${repositoryName}: enable image scanning`));
     await ecr.putImageScanningConfiguration({
       repositoryName,
       imageScanningConfiguration: { scanOnPush: true },
diff --git a/packages/aws-cdk/lib/api/garbage-collection/garbage-collector.ts b/packages/aws-cdk/lib/api/garbage-collection/garbage-collector.ts
index cccb9c52d..b4be1e1b7 100644
--- a/packages/aws-cdk/lib/api/garbage-collection/garbage-collector.ts
+++ b/packages/aws-cdk/lib/api/garbage-collection/garbage-collector.ts
@@ -8,8 +8,7 @@ import { DEFAULT_TOOLKIT_STACK_NAME, ToolkitInfo } from '../toolkit-info';
 import { ProgressPrinter } from './progress-printer';
 import { ActiveAssetCache, BackgroundStackRefresh, refreshStacks } from './stack-refresh';
 import { ToolkitError } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api';
-import type { IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
-import { debug, info } from '../../cli/messages';
+import { IO, type IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
 import { Mode } from '../plugin/mode';
 
 // Must use a require() otherwise esbuild complains
@@ -209,7 +208,7 @@ export class GarbageCollector {
    * Perform garbage collection on the resolved environment.
    */
   public async garbageCollect() {
-    await this.ioHelper.notify(debug(`${this.garbageCollectS3Assets} ${this.garbageCollectEcrAssets}`));
+    await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`${this.garbageCollectS3Assets} ${this.garbageCollectEcrAssets}`));
 
     // SDKs
     const sdk = (await this.props.sdkProvider.forEnvironment(this.props.resolvedEnvironment, Mode.ForWriting)).sdk;
@@ -253,7 +252,7 @@ export class GarbageCollector {
     const numImages = await this.numImagesInRepo(ecr, repo);
     const printer = new ProgressPrinter(this.ioHelper, numImages, 1000);
 
-    await this.ioHelper.notify(debug(`Found bootstrap repo ${repo} with ${numImages} images`));
+    await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Found bootstrap repo ${repo} with ${numImages} images`));
 
     try {
       // const batches = 1;
@@ -261,7 +260,7 @@ export class GarbageCollector {
       const currentTime = Date.now();
       const graceDays = this.props.rollbackBufferDays;
 
-      await this.ioHelper.notify(debug(`Parsing through ${numImages} images in batches`));
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Parsing through ${numImages} images in batches`));
 
       printer.start();
 
@@ -270,16 +269,16 @@ export class GarbageCollector {
 
         const { included: isolated, excluded: notIsolated } = partition(batch, asset => !asset.tags.some(t => activeAssets.contains(t)));
 
-        await this.ioHelper.notify(debug(`${isolated.length} isolated images`));
-        await this.ioHelper.notify(debug(`${notIsolated.length} not isolated images`));
-        await this.ioHelper.notify(debug(`${batch.length} images total`));
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`${isolated.length} isolated images`));
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`${notIsolated.length} not isolated images`));
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`${batch.length} images total`));
 
         let deletables: ImageAsset[] = isolated;
         let taggables: ImageAsset[] = [];
         let untaggables: ImageAsset[] = [];
 
         if (graceDays > 0) {
-          await this.ioHelper.notify(debug('Filtering out images that are not old enough to delete'));
+          await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg('Filtering out images that are not old enough to delete'));
 
           // We delete images that are not referenced in ActiveAssets and have the Isolated Tag with a date
           // earlier than the current time - grace period.
@@ -292,9 +291,9 @@ export class GarbageCollector {
           untaggables = notIsolated.filter(img => img.hasIsolatedTag());
         }
 
-        await this.ioHelper.notify(debug(`${deletables.length} deletable assets`));
-        await this.ioHelper.notify(debug(`${taggables.length} taggable assets`));
-        await this.ioHelper.notify(debug(`${untaggables.length} assets to untag`));
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`${deletables.length} deletable assets`));
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`${taggables.length} taggable assets`));
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`${untaggables.length} assets to untag`));
 
         if (this.permissionToDelete && deletables.length > 0) {
           await this.confirmationPrompt(printer, deletables, 'image');
@@ -327,14 +326,14 @@ export class GarbageCollector {
     const numObjects = await this.numObjectsInBucket(s3, bucket);
     const printer = new ProgressPrinter(this.ioHelper, numObjects, 1000);
 
-    await this.ioHelper.notify(debug(`Found bootstrap bucket ${bucket} with ${numObjects} objects`));
+    await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Found bootstrap bucket ${bucket} with ${numObjects} objects`));
 
     try {
       const batchSize = 1000;
       const currentTime = Date.now();
       const graceDays = this.props.rollbackBufferDays;
 
-      await this.ioHelper.notify(debug(`Parsing through ${numObjects} objects in batches`));
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Parsing through ${numObjects} objects in batches`));
 
       printer.start();
 
@@ -346,16 +345,16 @@ export class GarbageCollector {
 
         const { included: isolated, excluded: notIsolated } = partition(batch, asset => !activeAssets.contains(asset.fileName()));
 
-        await this.ioHelper.notify(debug(`${isolated.length} isolated assets`));
-        await this.ioHelper.notify(debug(`${notIsolated.length} not isolated assets`));
-        await this.ioHelper.notify(debug(`${batch.length} objects total`));
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`${isolated.length} isolated assets`));
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`${notIsolated.length} not isolated assets`));
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`${batch.length} objects total`));
 
         let deletables: ObjectAsset[] = isolated;
         let taggables: ObjectAsset[] = [];
         let untaggables: ObjectAsset[] = [];
 
         if (graceDays > 0) {
-          await this.ioHelper.notify(debug('Filtering out assets that are not old enough to delete'));
+          await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg('Filtering out assets that are not old enough to delete'));
           await this.parallelReadAllTags(s3, batch);
 
           // We delete objects that are not referenced in ActiveAssets and have the Isolated Tag with a date
@@ -369,9 +368,9 @@ export class GarbageCollector {
           untaggables = notIsolated.filter(obj => obj.hasIsolatedTag());
         }
 
-        await this.ioHelper.notify(debug(`${deletables.length} deletable assets`));
-        await this.ioHelper.notify(debug(`${taggables.length} taggable assets`));
-        await this.ioHelper.notify(debug(`${untaggables.length} assets to untag`));
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`${deletables.length} deletable assets`));
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`${taggables.length} taggable assets`));
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`${untaggables.length} assets to untag`));
 
         if (this.permissionToDelete && deletables.length > 0) {
           await this.confirmationPrompt(printer, deletables, 'object');
@@ -422,7 +421,7 @@ export class GarbageCollector {
       );
     }
 
-    await this.ioHelper.notify(debug(`Untagged ${untaggables.length} assets`));
+    await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Untagged ${untaggables.length} assets`));
   }
 
   /**
@@ -453,7 +452,7 @@ export class GarbageCollector {
       );
     }
 
-    await this.ioHelper.notify(debug(`Untagged ${untaggables.length} assets`));
+    await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Untagged ${untaggables.length} assets`));
   }
 
   /**
@@ -476,14 +475,14 @@ export class GarbageCollector {
           // This is a false negative -- an isolated asset is untagged
           // likely due to an imageTag collision. We can safely ignore,
           // and the isolated asset will be tagged next time.
-          await this.ioHelper.notify(debug(`Warning: unable to tag image ${JSON.stringify(img.tags)} with ${img.buildImageTag(i)} due to the following error: ${error}`));
+          await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Warning: unable to tag image ${JSON.stringify(img.tags)} with ${img.buildImageTag(i)} due to the following error: ${error}`));
         }
       };
       await limit(() => tagEcr());
     }
 
     printer.reportTaggedAsset(taggables);
-    await this.ioHelper.notify(debug(`Tagged ${taggables.length} assets`));
+    await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Tagged ${taggables.length} assets`));
   }
 
   /**
@@ -511,7 +510,7 @@ export class GarbageCollector {
     }
 
     printer.reportTaggedAsset(taggables);
-    await this.ioHelper.notify(debug(`Tagged ${taggables.length} assets`));
+    await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Tagged ${taggables.length} assets`));
   }
 
   /**
@@ -536,11 +535,11 @@ export class GarbageCollector {
         });
 
         const deletedCount = batch.length;
-        await this.ioHelper.notify(debug(`Deleted ${deletedCount} assets`));
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Deleted ${deletedCount} assets`));
         printer.reportDeletedAsset(deletables.slice(0, deletedCount));
       }
     } catch (err) {
-      await this.ioHelper.notify(info(chalk.red(`Error deleting images: ${err}`)));
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_ERROR.msg(`Error deleting images: ${err}`));
     }
   }
 
@@ -569,11 +568,11 @@ export class GarbageCollector {
         });
 
         const deletedCount = batch.length;
-        await this.ioHelper.notify(debug(`Deleted ${deletedCount} assets`));
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Deleted ${deletedCount} assets`));
         printer.reportDeletedAsset(deletables.slice(0, deletedCount));
       }
     } catch (err) {
-      await this.ioHelper.notify(debug(chalk.red(`Error deleting objects: ${err}`)));
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(chalk.red(`Error deleting objects: ${err}`)));
     }
   }
 
diff --git a/packages/aws-cdk/lib/api/garbage-collection/progress-printer.ts b/packages/aws-cdk/lib/api/garbage-collection/progress-printer.ts
index 978f5d89d..4db1b400a 100644
--- a/packages/aws-cdk/lib/api/garbage-collection/progress-printer.ts
+++ b/packages/aws-cdk/lib/api/garbage-collection/progress-printer.ts
@@ -1,8 +1,7 @@
 import * as chalk from 'chalk';
 import type { GcAsset as GCAsset } from './garbage-collector';
 import { ToolkitError } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api';
-import type { IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
-import { info } from '../../cli/messages';
+import { IO, type IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
 
 export class ProgressPrinter {
   private ioHelper: IoHelper;
@@ -79,9 +78,9 @@ export class ProgressPrinter {
     const percentage = ((this.assetsScanned / this.totalAssets) * 100).toFixed(2);
     // print in MiB until we hit at least 1 GiB of data tagged/deleted
     if (Math.max(this.taggedAssetsSizeMb, this.deletedAssetsSizeMb) >= 1000) {
-      void this.ioHelper.notify(info(chalk.green(`[${percentage}%] ${this.assetsScanned} files scanned: ${this.taggedAsset} assets (${(this.taggedAssetsSizeMb / 1000).toFixed(2)} GiB) tagged, ${this.deletedAssets} assets (${(this.deletedAssetsSizeMb / 1000).toFixed(2)} GiB) deleted.`)));
+      void this.ioHelper.notify(IO.DEFAULT_TOOLKIT_INFO.msg(chalk.green(`[${percentage}%] ${this.assetsScanned} files scanned: ${this.taggedAsset} assets (${(this.taggedAssetsSizeMb / 1000).toFixed(2)} GiB) tagged, ${this.deletedAssets} assets (${(this.deletedAssetsSizeMb / 1000).toFixed(2)} GiB) deleted.`)));
     } else {
-      void this.ioHelper.notify(info(chalk.green(`[${percentage}%] ${this.assetsScanned} files scanned: ${this.taggedAsset} assets (${this.taggedAssetsSizeMb.toFixed(2)} MiB) tagged, ${this.deletedAssets} assets (${this.deletedAssetsSizeMb.toFixed(2)} MiB) deleted.`)));
+      void this.ioHelper.notify(IO.DEFAULT_TOOLKIT_INFO.msg(chalk.green(`[${percentage}%] ${this.assetsScanned} files scanned: ${this.taggedAsset} assets (${this.taggedAssetsSizeMb.toFixed(2)} MiB) tagged, ${this.deletedAssets} assets (${this.deletedAssetsSizeMb.toFixed(2)} MiB) deleted.`)));
     }
   }
 }
diff --git a/packages/aws-cdk/lib/api/garbage-collection/stack-refresh.ts b/packages/aws-cdk/lib/api/garbage-collection/stack-refresh.ts
index 3b4330688..27224eb28 100644
--- a/packages/aws-cdk/lib/api/garbage-collection/stack-refresh.ts
+++ b/packages/aws-cdk/lib/api/garbage-collection/stack-refresh.ts
@@ -1,7 +1,6 @@
 import type { ParameterDeclaration } from '@aws-sdk/client-cloudformation';
 import { ToolkitError } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api';
-import type { IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
-import { debug } from '../../cli/messages';
+import { IO, type IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
 import type { ICloudFormationClient } from '../aws-auth';
 
 export class ActiveAssetCache {
@@ -53,7 +52,7 @@ async function fetchAllStackTemplates(cfn: ICloudFormationClient, ioHelper: IoHe
     return stacks.NextToken;
   });
 
-  await ioHelper.notify(debug(`Parsing through ${stackNames.length} stacks`));
+  await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`Parsing through ${stackNames.length} stacks`));
 
   const templates: string[] = [];
   for (const stack of stackNames) {
@@ -74,7 +73,7 @@ async function fetchAllStackTemplates(cfn: ICloudFormationClient, ioHelper: IoHe
     }
   }
 
-  await ioHelper.notify(debug('Done parsing through stacks'));
+  await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg('Done parsing through stacks'));
 
   return templates;
 }
diff --git a/packages/aws-cdk/lib/api/resource-import/importer.ts b/packages/aws-cdk/lib/api/resource-import/importer.ts
index c345f7d4c..d4f431dbc 100644
--- a/packages/aws-cdk/lib/api/resource-import/importer.ts
+++ b/packages/aws-cdk/lib/api/resource-import/importer.ts
@@ -6,8 +6,7 @@ import * as chalk from 'chalk';
 import * as fs from 'fs-extra';
 import * as promptly from 'promptly';
 import { ToolkitError } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api';
-import type { IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
-import { error, info, warn } from '../../cli/messages';
+import { IO, type IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
 import type { DeploymentMethod, ResourceIdentifierProperties, ResourcesToImport, Deployments } from '../deployments';
 import { assertIsSuccessfulDeployStackResult } from '../deployments';
 import type { Tag } from '../tags';
@@ -144,19 +143,19 @@ export class ResourceImporter {
       const descr = this.describeResource(resource.logicalId);
       const idProps = contents[resource.logicalId];
       if (idProps) {
-        await this.ioHelper.notify(info(format('%s: importing using %s', chalk.blue(descr), chalk.blue(fmtdict(idProps)))));
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_INFO.msg(format('%s: importing using %s', chalk.blue(descr), chalk.blue(fmtdict(idProps)))));
 
         ret.importResources.push(resource);
         ret.resourceMap[resource.logicalId] = idProps;
         delete contents[resource.logicalId];
       } else {
-        await this.ioHelper.notify(info(format('%s: skipping', chalk.blue(descr))));
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_INFO.msg(format('%s: skipping', chalk.blue(descr))));
       }
     }
 
     const unknown = Object.keys(contents);
     if (unknown.length > 0) {
-      await this.ioHelper.notify(warn(`Unrecognized resource identifiers in mapping file: ${unknown.join(', ')}`));
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_WARN.msg(`Unrecognized resource identifiers in mapping file: ${unknown.join(', ')}`));
     }
 
     return ret;
@@ -206,9 +205,9 @@ export class ResourceImporter {
         ? ' ✅  %s (no changes)'
         : ' ✅  %s';
 
-      await this.ioHelper.notify(info('\n' + chalk.green(format(message, this.stack.displayName))));
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_INFO.msg('\n' + chalk.green(format(message, this.stack.displayName))));
     } catch (e) {
-      await this.ioHelper.notify(error(format('\n ❌  %s failed: %s', chalk.bold(this.stack.displayName), e), 'CDK_TOOLKIT_E3900'));
+      await this.ioHelper.notify(IO.CDK_TOOLKIT_E3900.msg(format('\n ❌  %s failed: %s', chalk.bold(this.stack.displayName), e), { error: e as any }));
       throw e;
     }
   }
@@ -237,7 +236,7 @@ export class ResourceImporter {
       const offendingResources = nonAdditions.map(([logId, _]) => this.describeResource(logId));
 
       if (allowNonAdditions) {
-        await this.ioHelper.notify(warn(`Ignoring updated/deleted resources (--force): ${offendingResources.join(', ')}`));
+        await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_WARN.msg(`Ignoring updated/deleted resources (--force): ${offendingResources.join(', ')}`));
       } else {
         throw new ToolkitError('No resource updates or deletes are allowed on import operation. Make sure to resolve pending changes ' +
           `to existing resources, before attempting an import. Updated/deleted resources: ${offendingResources.join(', ')} (--force to override)`);
@@ -325,7 +324,7 @@ export class ResourceImporter {
     // Skip resources that do not support importing
     const resourceType = chg.resourceDiff.newResourceType;
     if (resourceType === undefined || !(resourceType in resourceIdentifiers)) {
-      await this.ioHelper.notify(warn(`${resourceName}: unsupported resource type ${resourceType}, skipping import.`));
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_WARN.msg(`${resourceName}: unsupported resource type ${resourceType}, skipping import.`));
       return undefined;
     }
 
@@ -351,7 +350,7 @@ export class ResourceImporter {
 
     // If we got here and the user rejected any available identifiers, then apparently they don't want the resource at all
     if (satisfiedPropSets.length > 0) {
-      await this.ioHelper.notify(info(chalk.grey(`Skipping import of ${resourceName}`)));
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_INFO.msg(chalk.grey(`Skipping import of ${resourceName}`)));
       return undefined;
     }
 
@@ -369,7 +368,7 @@ export class ResourceImporter {
 
     // Do the input loop here
     if (preamble) {
-      await this.ioHelper.notify(info(preamble));
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_INFO.msg(preamble));
     }
     for (const idProps of idPropSets) {
       const input: Record<string, string> = {};
@@ -404,7 +403,7 @@ export class ResourceImporter {
       }
     }
 
-    await this.ioHelper.notify(info(chalk.grey(`Skipping import of ${resourceName}`)));
+    await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_INFO.msg(chalk.grey(`Skipping import of ${resourceName}`)));
     return undefined;
   }
 
diff --git a/packages/aws-cdk/lib/api/resource-import/migrator.ts b/packages/aws-cdk/lib/api/resource-import/migrator.ts
index 439c1ef89..4cbbe8e3e 100644
--- a/packages/aws-cdk/lib/api/resource-import/migrator.ts
+++ b/packages/aws-cdk/lib/api/resource-import/migrator.ts
@@ -3,8 +3,7 @@ import * as chalk from 'chalk';
 import * as fs from 'fs-extra';
 import type { ImportDeploymentOptions } from './importer';
 import { ResourceImporter } from './importer';
-import type { IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
-import { info } from '../../cli/messages';
+import { IO, type IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
 import { formatTime } from '../../util';
 import type { StackCollection } from '../cxapp/cloud-assembly';
 import type { Deployments, ResourcesToImport } from '../deployments';
@@ -38,13 +37,13 @@ export class ResourceMigrator {
     const resourcesToImport = await this.tryGetResources(await migrateDeployment.resolveEnvironment());
 
     if (resourcesToImport) {
-      await this.ioHelper.notify(info(`${chalk.bold(stack.displayName)}: creating stack for resource migration...`));
-      await this.ioHelper.notify(info(`${chalk.bold(stack.displayName)}: importing resources into stack...`));
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_INFO.msg(`${chalk.bold(stack.displayName)}: creating stack for resource migration...`));
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_INFO.msg(`${chalk.bold(stack.displayName)}: importing resources into stack...`));
 
       await this.performResourceMigration(migrateDeployment, resourcesToImport, options);
 
       fs.rmSync('migrate.json');
-      await this.ioHelper.notify(info(`${chalk.bold(stack.displayName)}: applying CDKMetadata and Outputs to stack (if applicable)...`));
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_INFO.msg(`${chalk.bold(stack.displayName)}: applying CDKMetadata and Outputs to stack (if applicable)...`));
     }
   }
 
@@ -68,7 +67,7 @@ export class ResourceMigrator {
     });
 
     elapsedDeployTime = new Date().getTime() - startDeployTime;
-    await this.ioHelper.notify(info(`'\n✨  Resource migration time: ${formatTime(elapsedDeployTime)}s\n'`, 'CDK_TOOLKIT_I5002', {
+    await this.ioHelper.notify(IO.CDK_TOOLKIT_I5002.msg(`'\n✨  Resource migration time: ${formatTime(elapsedDeployTime)}s\n'`, {
       duration: elapsedDeployTime,
     }));
   }
diff --git a/packages/aws-cdk/lib/api/stack-events/stack-activity-monitor.ts b/packages/aws-cdk/lib/api/stack-events/stack-activity-monitor.ts
index 36fb26850..8b4cec4e1 100644
--- a/packages/aws-cdk/lib/api/stack-events/stack-activity-monitor.ts
+++ b/packages/aws-cdk/lib/api/stack-events/stack-activity-monitor.ts
@@ -1,15 +1,14 @@
 
 import * as util from 'util';
 import type { CloudFormationStackArtifact } from '@aws-cdk/cx-api';
-import type { StackActivity, StackMonitoringControlEvent } from '@aws-cdk/tmp-toolkit-helpers';
+import type { StackActivity } from '@aws-cdk/tmp-toolkit-helpers';
 import * as uuid from 'uuid';
 import { StackEventPoller } from './stack-event-poller';
 import { resourceMetadata } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/resource-metadata/resource-metadata';
-import { debug, error, info } from '../../cli/messages';
 import { stackEventHasErrorMessage } from '../../util';
 import type { ICloudFormationClient } from '../aws-auth';
 import { StackProgressMonitor } from './stack-progress-monitor';
-import type { IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
+import { IO, type IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
 
 export interface StackActivityMonitorProps {
   /**
@@ -119,12 +118,12 @@ export class StackActivityMonitor {
 
   public async start() {
     this.monitorId = uuid.v4();
-    await this.ioHelper.notify(debug(`Deploying ${this.stackName}`, 'CDK_TOOLKIT_I5501', {
+    await this.ioHelper.notify(IO.CDK_TOOLKIT_I5501.msg(`Deploying ${this.stackName}`, {
       deployment: this.monitorId,
       stack: this.stack,
       stackName: this.stackName,
       resourcesTotal: this.progressMonitor.total,
-    } as StackMonitoringControlEvent));
+    }));
     this.scheduleNextTick();
     return this;
   }
@@ -141,12 +140,12 @@ export class StackActivityMonitor {
     // up not printing the failure reason to users.
     await this.finalPollToEnd(oldMonitorId);
 
-    await this.ioHelper.notify(debug(`Completed ${this.stackName}`, 'CDK_TOOLKIT_I5503', {
+    await this.ioHelper.notify(IO.CDK_TOOLKIT_I5503.msg(`Completed ${this.stackName}`, {
       deployment: oldMonitorId,
       stack: this.stack,
       stackName: this.stackName,
       resourcesTotal: this.progressMonitor.total,
-    } as StackMonitoringControlEvent));
+    }));
   }
 
   private scheduleNextTick() {
@@ -172,10 +171,9 @@ export class StackActivityMonitor {
         return;
       }
     } catch (e) {
-      await this.ioHelper.notify(error(
+      await this.ioHelper.notify(IO.CDK_TOOLKIT_E5500.msg(
         util.format('Error occurred while monitoring stack: %s', e),
-        'CDK_TOOLKIT_E5500',
-        { error: e },
+        { error: e as any },
       ));
     }
     this.scheduleNextTick();
@@ -210,7 +208,7 @@ export class StackActivityMonitor {
       };
 
       this.checkForErrors(activity);
-      await this.ioHelper.notify(info(this.formatActivity(activity, true), 'CDK_TOOLKIT_I5502', activity));
+      await this.ioHelper.notify(IO.CDK_TOOLKIT_I5502.msg(this.formatActivity(activity, true), activity));
     }
   }
 
diff --git a/packages/aws-cdk/lib/api/toolkit-info.ts b/packages/aws-cdk/lib/api/toolkit-info.ts
index 2d65d7a8c..9faf9eaff 100644
--- a/packages/aws-cdk/lib/api/toolkit-info.ts
+++ b/packages/aws-cdk/lib/api/toolkit-info.ts
@@ -12,8 +12,7 @@ import {
 } from './bootstrap/bootstrap-props';
 import { type CloudFormationStack, stabilizeStack } from './deployments/cloudformation';
 import { ToolkitError } from '../../../@aws-cdk/tmp-toolkit-helpers/src/api';
-import type { IoHelper } from '../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
-import { debug } from '../cli/messages';
+import { IO, type IoHelper } from '../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
 
 export const DEFAULT_TOOLKIT_STACK_NAME = 'CDKToolkit';
 
@@ -56,7 +55,7 @@ export abstract class ToolkitInfo {
     try {
       const stack = await stabilizeStack(cfn, ioHelper, stackName);
       if (!stack) {
-        await ioHelper.notify(debug(
+        await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(
           format(
             "The environment %s doesn't have the CDK toolkit stack (%s) installed. Use %s to setup your environment for use with the toolkit.",
             environment.name,
@@ -68,7 +67,7 @@ export abstract class ToolkitInfo {
       }
       if (stack.stackStatus.isCreationFailure) {
         // Treat a "failed to create" bootstrap stack as an absent one.
-        await ioHelper.notify(debug(
+        await ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(
           format(
             'The environment %s has a CDK toolkit stack (%s) that failed to create. Use %s to try provisioning it again.',
             environment.name,
diff --git a/packages/aws-cdk/lib/api/work-graph/work-graph.ts b/packages/aws-cdk/lib/api/work-graph/work-graph.ts
index 7c0991a81..467933774 100644
--- a/packages/aws-cdk/lib/api/work-graph/work-graph.ts
+++ b/packages/aws-cdk/lib/api/work-graph/work-graph.ts
@@ -1,10 +1,8 @@
 import type { WorkNode, StackNode, AssetBuildNode, AssetPublishNode } from './work-graph-types';
 import { DeploymentState } from './work-graph-types';
 import { ToolkitError } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api';
-import type { IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
-import { debug, trace } from '../../cli/messages';
+import { IO, type IoHelper } from '../../../../@aws-cdk/tmp-toolkit-helpers/src/api/io/private';
 import { parallelPromises } from '../../util';
-
 export type Concurrency = number | Record<WorkNode['type'], number>;
 
 export class WorkGraph {
@@ -259,7 +257,7 @@ export class WorkGraph {
    * Do this in parallel, because there may be a lot of assets in an application (seen in practice: >100 assets)
    */
   public async removeUnnecessaryAssets(isUnnecessary: (x: AssetPublishNode) => Promise<boolean>) {
-    await this.ioHelper.notify(debug('Checking for previously published assets'));
+    await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg('Checking for previously published assets'));
 
     const publishes = this.nodesOfType('asset-publish');
 
@@ -272,7 +270,7 @@ export class WorkGraph {
       this.removeNode(assetNode);
     }
 
-    await this.ioHelper.notify(debug(`${publishes.length} total assets, ${publishes.length - alreadyPublished.length} still need to be published`));
+    await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_DEBUG.msg(`${publishes.length} total assets, ${publishes.length - alreadyPublished.length} still need to be published`));
 
     // Now also remove any asset build steps that don't have any dependencies on them anymore
     const unusedBuilds = this.nodesOfType('asset-build').filter(build => this.dependees(build).length === 0);
@@ -303,7 +301,7 @@ export class WorkGraph {
 
     if (this.readyPool.length === 0 && activeCount === 0 && pendingCount > 0) {
       const cycle = this.findCycle() ?? ['No cycle found!'];
-      await this.ioHelper.notify(trace(`Cycle ${cycle.join(' -> ')} in graph ${this}`));
+      await this.ioHelper.notify(IO.DEFAULT_TOOLKIT_TRACE.msg(`Cycle ${cycle.join(' -> ')} in graph ${this}`));
       throw new ToolkitError(`Unable to make progress anymore, dependency cycle between remaining artifacts: ${cycle.join(' -> ')} (run with -vv for full graph)`);
     }
   }