fix: minor fixes in bulk delete and move ops

Author: naman-contentstack

packages/contentstack-bulk-operations/src/base-bulk-command.ts

@@ -28,6 +28,7 @@ import {
   buildBulkModeResult,
   handleOperationError,
   fillMissingFlags,
+  fillMissingAmFlags,
   getLogPaths,
   clearLogs,
   generateBulkPublishStatusUrl,
@@ -51,7 +52,7 @@ import {
  * Provides common functionality for bulk-entries and bulk-assets
  */
 export abstract class BaseBulkCommand extends Command {
-  protected abstract resourceType: ResourceType;
+  protected resourceType?: ResourceType;
 
   // Common flags for all bulk operations
   static baseFlags: FlagInput = {
@@ -145,6 +146,15 @@ export abstract class BaseBulkCommand extends Command {
 
     this.parsedFlags = flags;
 
+    // AM assets uses a different API surface — prompt for AM-specific flags and skip
+    // the publish/unpublish stack setup, queue init, and config build.
+    if (this.resourceType === ResourceType.AM_ASSET) {
+      this.logger = log;
+      this.loggerContext = { module: this.id };
+      this.parsedFlags = await fillMissingAmFlags(flags);
+      return;
+    }
+
     const commandName = `cm:stacks:bulk-${this.resourceType === ResourceType.ENTRY ? 'entries' : 'assets'}`;
     createLogContext(
       this.context?.info?.command || commandName,
@@ -177,7 +187,7 @@ export abstract class BaseBulkCommand extends Command {
     await this.setupStack();
     await this.initializeComponents();
 
-    this.logger.debug($t(messages.INITIALIZING, { resourceType: this.resourceType }), this.loggerContext);
+    this.logger.debug($t(messages.INITIALIZING, { resourceType: this.resourceType! }), this.loggerContext);
   }
 
   /**
@@ -189,7 +199,7 @@ export abstract class BaseBulkCommand extends Command {
     const isRetry = !!flags['retry-failed'];
 
     // Load config from log file
-    const logFileConfig = loadConfigFromLogFile(logPath, isRetry, this.resourceType);
+    const logFileConfig = loadConfigFromLogFile(logPath, isRetry, this.resourceType!);
 
     if (!logFileConfig) {
       throw new Error($t(messages.NO_CONFIG_IN_LOG));
@@ -334,7 +344,7 @@ export abstract class BaseBulkCommand extends Command {
         batchResults: this.batchResults,
         logger: this.logger,
         retryStrategy: this.retryStrategy,
-        resourceType: this.resourceType,
+        resourceType: this.resourceType!,
         logFolderPath: this.bulkOperationConfig.bulkOperationFolder,
         apiKey: this.bulkOperationConfig.apiKey || this.bulkOperationConfig.stackApiKey,
         branch: this.bulkOperationConfig.branch,
@@ -352,7 +362,7 @@ export abstract class BaseBulkCommand extends Command {
     const flags = this.parsedFlags || (await this.parse(this.constructor as typeof BaseBulkCommand)).flags;
     const itemCount = items?.length || 0;
 
-    return await confirmOperationUtil(this.bulkOperationConfig, itemCount, this.resourceType, flags.yes);
+    return await confirmOperationUtil(this.bulkOperationConfig, itemCount, this.resourceType!, flags.yes);
   }
 
   /**
@@ -493,7 +503,7 @@ export abstract class BaseBulkCommand extends Command {
     const result = await handleRevertOrRetry(
       logPath,
       isRetry,
-      this.resourceType,
+      this.resourceType!,
       this.bulkOperationConfig,
       flags.yes,
       this.executeBulkOperation.bind(this),
@@ -518,14 +528,14 @@ export abstract class BaseBulkCommand extends Command {
         targetEnvs: flags.environments as string[],
         locales: flags.locales as string[],
         contentTypes: flags['content-types'] as string[] | undefined,
-        resourceType: this.resourceType,
+        resourceType: this.resourceType!,
         deliveryStack: this.deliveryStack!, // Required: initialized via source-alias delivery token
       },
       this.logger
     );
 
     if (itemsToPublish.length === 0) {
-      this.logger.warn($t(messages.NO_ITEMS_FOUND, { resourceType: this.resourceType }), this.loggerContext);
+      this.logger.warn($t(messages.NO_ITEMS_FOUND, { resourceType: this.resourceType! }), this.loggerContext);
       return;
     }
 

packages/contentstack-bulk-operations/src/commands/cm/stacks/bulk-am-assets.ts

@@ -1,15 +1,15 @@
 import chalk from 'chalk';
-import { Command } from '@contentstack/cli-command';
-import { flags, log, createLogContext, handleAndLogError, cliux, FlagInput } from '@contentstack/cli-utilities';
+import { flags, log, createLogContext, cliux, handleAndLogError, FlagInput } from '@contentstack/cli-utilities';
 
 import messages, { $t } from '../../../messages';
+import { BaseBulkCommand } from '../../../base-bulk-command';
 import { AmAssetService } from '../../../services';
 import {
   loadAssetUidsFromFile,
   loadBulkDeleteItemsFromFile,
   LoadAssetUidsError,
 } from '../../../utils/asset-uids-from-file';
-import { AmBulkDeleteItem } from '../../../interfaces';
+import { AmBulkDeleteItem, ResourceType } from '../../../interfaces';
 
 const COMMAND_ID = 'cm:stacks:bulk-am-assets';
 
@@ -18,7 +18,7 @@ type RegionWithOptionalAmUrl = { csAssetsUrl?: string };
 /**
  * AM bulk delete (job) / bulk move — CS Assets API only; asset UIDs come from a JSON file `{ "uids": [...] }`.
  */
-export default class BulkAmAssets extends Command {
+export default class BulkAmAssets extends BaseBulkCommand {
   static description = messages.BULK_AM_ASSETS_DESCRIPTION;
 
   static examples = [
@@ -31,23 +31,19 @@ export default class BulkAmAssets extends Command {
     operation: flags.string({
       description: messages.AM_OPERATION_FLAG,
       options: ['delete', 'move'],
-      required: true,
     }),
     'space-uid': flags.string({
       description: messages.AM_SPACE_UID_FLAG,
-      required: true,
     }),
     'org-uid': flags.string({
       description: messages.AM_ORG_UID_FLAG,
-      required: true,
     }),
     workspace: flags.string({
       default: 'main',
       description: messages.AM_WORKSPACE_FLAG,
     }),
     'asset-uids-file': flags.string({
       description: messages.AM_ASSET_UIDS_FILE_FLAG,
-      required: true,
     }),
     locale: flags.string({
       description: messages.AM_LOCALE_FLAG,
@@ -62,7 +58,24 @@ export default class BulkAmAssets extends Command {
     }),
   };
 
-  private readonly loggerContext = { module: COMMAND_ID };
+  protected resourceType = ResourceType.AM_ASSET;
+
+  private printAmSummary(op: 'delete' | 'move', opts: { jobId?: string; count?: number; folderUid?: string; notice?: string; error?: string }): void {
+    if (opts.error) {
+      log.error($t(messages.AM_OPERATION_FAILED, { operation: op }), this.loggerContext);
+      log.error(opts.error, this.loggerContext);
+    } else if (op === 'delete') {
+      log.success($t(messages.AM_DELETE_SUCCESS), this.loggerContext);
+      if (opts.jobId) log.info($t(messages.AM_DELETE_JOB_ID, { jobId: opts.jobId }), this.loggerContext);
+      log.info($t(messages.AM_DELETE_ASYNC_NOTE), this.loggerContext);
+    } else {
+      log.success($t(messages.AM_MOVE_SUCCESS), this.loggerContext);
+      if (opts.count !== undefined && opts.folderUid) {
+        log.info($t(messages.AM_MOVE_ASSETS_COUNT, { count: opts.count, folderUid: opts.folderUid }), this.loggerContext);
+      }
+    }
+    if (opts.notice) log.info(opts.notice, this.loggerContext);
+  }
 
   private handleAssetUidsFileError(e: LoadAssetUidsError): void {
     const pathShown = e.filePath;
@@ -79,7 +92,7 @@ export default class BulkAmAssets extends Command {
 
   async run(): Promise<void> {
     try {
-      const { flags: f } = await this.parse(BulkAmAssets);
+      const f = this.parsedFlags;
 
       const amBaseUrl = (this.region as RegionWithOptionalAmUrl).csAssetsUrl?.trim();
       if (!amBaseUrl) {
@@ -166,16 +179,17 @@ export default class BulkAmAssets extends Command {
         log.info($t(messages.AM_DELETING_ASSETS, { count: deleteRows.length, spaceUid }), this.loggerContext);
         const result = await amService.bulkDelete(spaceUid, workspace, deleteRows);
         if (!result.success) {
-          log.error(result.error ?? 'AM bulk delete failed', this.loggerContext);
+          this.printAmSummary('delete', { error: result.error ?? 'AM bulk delete failed' });
           process.exitCode = 1;
           return;
         }
-        if (result.notice) {
-          log.info($t(messages.AM_OPERATION_NOTICE, { notice: result.notice }), this.loggerContext);
-        }
-        if (result.jobId) {
-          log.info($t(messages.AM_DELETE_SUBMITTED, { jobId: result.jobId }), this.loggerContext);
-        }
+        this.printAmSummary('delete', { jobId: result.jobId, notice: result.notice });
+        return;
+      }
+
+      if (f.locale) {
+        log.error($t(messages.AM_LOCALE_NOT_ALLOWED_FOR_MOVE), this.loggerContext);
+        process.exitCode = 1;
         return;
       }
 
@@ -231,14 +245,11 @@ export default class BulkAmAssets extends Command {
       );
       const result = await amService.bulkMove(spaceUid, workspace, uids, moveFolderUid);
       if (!result.success) {
-        log.error(result.error ?? 'AM bulk move failed', this.loggerContext);
+        this.printAmSummary('move', { error: result.error ?? 'AM bulk move failed' });
         process.exitCode = 1;
         return;
       }
-      if (result.notice) {
-        log.info($t(messages.AM_OPERATION_NOTICE, { notice: result.notice }), this.loggerContext);
-      }
-      log.info($t(messages.AM_MOVE_SUBMITTED), this.loggerContext);
+      this.printAmSummary('move', { count: uids.length, folderUid: moveFolderUid, notice: result.notice });
     } catch (error) {
       handleAndLogError(error);
     }

packages/contentstack-bulk-operations/src/interfaces/index.ts

@@ -20,6 +20,7 @@ export enum ResourceType {
   ENTRY = 'entry',
   ASSET = 'asset',
   TAXONOMY = 'taxonomy',
+  AM_ASSET = 'am-asset',
 }
 
 export enum FilterType {

packages/contentstack-bulk-operations/src/messages/index.ts

@@ -238,10 +238,25 @@ const amBulkAssetsMsg = {
   AM_WORKSPACE_FLAG: 'AM workspace query parameter (default: main)',
   AM_ASSET_UIDS_FILE_FLAG:
     'Path to UTF-8 JSON file: exactly `{ "uids": ["uid1", "uid2"] }` (non-empty string array, no trimming; large lists: see docs for NODE_OPTIONS)',
-  AM_LOCALE_FLAG: 'Locale code for bulk delete (single locale per run)',
-  AM_TARGET_FOLDER_FLAG: 'Destination AM folder UID (required for move)',
+  AM_LOCALE_FLAG: 'Locale code for bulk delete only (single locale per run). Not applicable for move — move always relocates all locale variants of an asset.',
+  AM_LOCALE_NOT_ALLOWED_FOR_MOVE: '--locale is not applicable for the move operation. Move always relocates all locale variants of an asset. Remove --locale and try again.',
+  AM_TARGET_FOLDER_FLAG: 'Destination AM folder UID for bulk move. Use "root" to move assets to the root folder.',
   AM_INVALID_OPERATION: 'Invalid operation: {operation}. Must be delete or move',
   AM_CONFIRM_SUMMARY: 'Proceed with AM {operation} on {count} item(s)?',
+  AM_DELETE_SUCCESS: 'AM bulk delete job submitted successfully!',
+  AM_DELETE_JOB_ID: 'Job ID: {jobId}',
+  AM_DELETE_ASYNC_NOTE: 'The job runs asynchronously — check the Asset Management console for status.',
+  AM_MOVE_SUCCESS: 'AM bulk move completed successfully!',
+  AM_MOVE_ASSETS_COUNT: '{count} asset(s) moved to folder: {folderUid}',
+  AM_OPERATION_FAILED: 'AM {operation} failed.',
+
+  // Interactive prompts
+  AM_SELECT_OPERATION: 'Select AM operation:',
+  AM_ENTER_SPACE_UID: 'Enter AM space UID:',
+  AM_ENTER_ORG_UID: 'Enter organization UID:',
+  AM_ENTER_ASSET_UIDS_FILE: 'Enter path to asset UIDs JSON file (e.g. ./assets.json):',
+  AM_ENTER_LOCALE: 'Enter locale code for bulk delete (e.g. en-us):',
+  AM_ENTER_TARGET_FOLDER: 'Enter target folder UID for bulk move (use "root" to move to the root folder):',
 };
 
 /**

packages/contentstack-bulk-operations/src/utils/index.ts

@@ -35,7 +35,7 @@ import {
   buildBulkModeResult,
   handleOperationError,
 } from './command-helpers';
-import { fillMissingFlags } from './interactive';
+import { fillMissingFlags, fillMissingAmFlags } from './interactive';
 import {
   RATE_LIMITER_CONSTANTS,
   RETRY_STRATEGY_CONSTANTS,
@@ -98,6 +98,7 @@ export {
   buildBulkModeResult,
   handleOperationError,
   fillMissingFlags,
+  fillMissingAmFlags,
   fetchTaxonomyList,
   RATE_LIMITER_CONSTANTS,
   RETRY_STRATEGY_CONSTANTS,

packages/contentstack-bulk-operations/src/utils/interactive.ts

@@ -223,3 +223,82 @@ export async function fillMissingFlags(flags: any): Promise<any> {
 
   return updatedFlags;
 }
+
+/**
+ * Fills in missing flags for the bulk-am-assets command by prompting the user.
+ * Handles AM-specific required flags including operation-conditional ones
+ * (locale for delete, target-folder-uid for move).
+ */
+export async function fillMissingAmFlags(flags: any): Promise<any> {
+  const f = { ...flags };
+
+  const needsLocale = f.operation === 'delete' && !f.locale;
+  const needsFolderUid = f.operation === 'move' && !f['target-folder-uid'];
+  const needsPrompt =
+    !f.operation || !f['space-uid'] || !f['org-uid'] || !f['asset-uids-file'] || needsLocale || needsFolderUid;
+
+  if (!needsPrompt) return f;
+
+  cliux.print(messages.INTERACTIVE_MODE_START, { color: 'cyan' });
+
+  if (!f.operation) {
+    f.operation = await cliux.inquire<string>({
+      type: 'list',
+      name: 'operation',
+      message: messages.AM_SELECT_OPERATION,
+      choices: [
+        { name: 'Delete (AM bulk delete)', value: 'delete' },
+        { name: 'Move (AM bulk move)', value: 'move' },
+      ],
+    });
+  }
+
+  if (!f['space-uid']) {
+    f['space-uid'] = await cliux.inquire<string>({
+      type: 'input',
+      name: 'spaceUid',
+      message: messages.AM_ENTER_SPACE_UID,
+      validate: (v: string) => (!v?.trim() ? messages.SPACE_UID_REQUIRED : true),
+    });
+  }
+
+  if (!f['org-uid']) {
+    f['org-uid'] = await cliux.inquire<string>({
+      type: 'input',
+      name: 'orgUid',
+      message: messages.AM_ENTER_ORG_UID,
+      validate: (v: string) => (!v?.trim() ? messages.ORG_UID_REQUIRED : true),
+    });
+  }
+
+  if (!f['asset-uids-file']) {
+    f['asset-uids-file'] = await cliux.inquire<string>({
+      type: 'input',
+      name: 'assetUidsFile',
+      message: messages.AM_ENTER_ASSET_UIDS_FILE,
+      validate: (v: string) => (!v?.trim() ? messages.AM_ASSET_UIDS_FILE_REQUIRED : true),
+    });
+  }
+
+  if (f.operation === 'delete' && !f.locale) {
+    f.locale = await cliux.inquire<string>({
+      type: 'input',
+      name: 'locale',
+      message: messages.AM_ENTER_LOCALE,
+      validate: (v: string) => (!v?.trim() ? messages.AM_LOCALE_REQUIRED : true),
+    });
+  }
+
+  if (f.operation === 'move' && !f['target-folder-uid']) {
+    f['target-folder-uid'] = await cliux.inquire<string>({
+      type: 'input',
+      name: 'targetFolderUid',
+      message: messages.AM_ENTER_TARGET_FOLDER,
+      validate: (v: string) => (!v?.trim() ? messages.TARGET_FOLDER_REQUIRED : true),
+    });
+  }
+
+  cliux.print(messages.INTERACTIVE_MODE_COMPLETE, { color: 'green' });
+
+  return f;
+}