fix: Rename 'data-dir' to 'backup-dir' in asset publishing commands and update related logic

Author: naman-contentstack

packages/contentstack-bulk-publish/src/commands/cm/assets/publish.js

@@ -15,12 +15,12 @@ class AssetsPublishCommand extends Command {
     assetsFlags.folderUid = assetsFlags['folder-uid'] || assetsFlags.folderUid;
     assetsFlags.bulkPublish = assetsFlags['bulk-publish'] || assetsFlags.bulkPublish;
     assetsFlags.apiVersion = assetsFlags['api-version'] || '3'; // setting default value for apiVersion
-    assetsFlags.dataDir = assetsFlags['data-dir'] || assetsFlags.dataDir;
+    assetsFlags.backupDir = assetsFlags['backup-dir'] || assetsFlags.backupDir;
     delete assetsFlags['api-version'];
     delete assetsFlags['retry-failed'];
     delete assetsFlags['folder-uid'];
     delete assetsFlags['bulk-publish'];
-    delete assetsFlags['data-dir'];
+    delete assetsFlags['backup-dir'];
 
     let updatedFlags;
     try {
@@ -113,15 +113,15 @@ class AssetsPublishCommand extends Command {
     }
   }
 
-  validate({ environments, retryFailed, locales, dataDir, 'source-env': sourceEnv, 'delivery-token': deliveryToken }) {
+  validate({ environments, retryFailed, locales, backupDir, 'source-env': sourceEnv, 'delivery-token': deliveryToken }) {
     let missing = [];
     if (retryFailed) {
       return true;
     }
 
-    // In data-dir mode, environments and locales are derived per-asset from the
+    // In backup-dir mode, environments and locales are derived per-asset from the
     // backup publish_details, so they are not required on the command line.
-    if (dataDir) {
+    if (backupDir) {
       return true;
     }
 
@@ -189,7 +189,7 @@ AssetsPublishCommand.flags = {
       '(optional) The UID of the Assets’ folder from which the assets need to be published. The default value is cs_root.',
     exclusive: ['source-env'],
   }),
-  'data-dir': flags.string({
+  'backup-dir': flags.string({
     description:
       '(optional) Path to the import backup directory. When set, each imported asset is published only to the environments and locales it was published to in the source stack (read from the backup’s publish details and asset UID mapping), with asset-scan gating applied. Intended for the post-import publish flow.',
     exclusive: ['source-env', 'folder-uid', 'environments', 'locales'],
@@ -273,13 +273,13 @@ AssetsPublishCommand.examples = [
   'Using --stack-api-key flag',
   'csdx cm:assets:publish --environments [ENVIRONMENT 1] [ENVIRONMENT 2] --locales [LOCALE] --stack-api-key [STACK API KEY]',
   '',
-  'Using --data-dir flag (publish imported assets to their original environments after asset scanning)',
-  'csdx cm:assets:publish --data-dir [PATH TO IMPORT BACKUP DIR] --stack-api-key [STACK API KEY]',
+  'Using --backup-dir flag (publish imported assets to their original environments after asset scanning)',
+  'csdx cm:assets:publish --backup-dir [PATH TO IMPORT BACKUP DIR] --stack-api-key [STACK API KEY]',
 ];
 
 AssetsPublishCommand.aliases = ['cm:bulk-publish:assets'];
 
 AssetsPublishCommand.usage =
-  'cm:assets:publish [-a <value>] [--retry-failed <value>] [-e <value>] [--folder-uid <value>] [--data-dir <value>] [--bulk-publish <value>] [-c <value>] [-y] [--locales <value>] [--branch <value>] [--delivery-token <value>] [--source-env <value>]';
+  'cm:assets:publish [-a <value>] [--retry-failed <value>] [-e <value>] [--folder-uid <value>] [--backup-dir <value>] [--bulk-publish <value>] [-c <value>] [-y] [--locales <value>] [--branch <value>] [--delivery-token <value>] [--source-env <value>]';
 
 module.exports = AssetsPublishCommand;

packages/contentstack-bulk-publish/src/consumer/publish.js

@@ -61,12 +61,12 @@ function displayEntriesDetails(sanitizedData, action, mapping = []) {
 function displayAssetsDetails(sanitizedData, action, mapping) {
   if (action === 'bulk_publish') {
     sanitizedData.forEach((asset) => {
-      asset?.publish_details.forEach((pd) => {
+      asset?.publish_details?.forEach((pd) => {
         if (Object.keys(mapping).includes(pd.environment)) {
         console.log(
           chalk.green(
             `Asset UID: '${asset.uid}'${pd.version ? `, Version: '${pd.version}'` : ''}${
-              asset.locale ? `, Locale: '${asset.locale}'` : ''
+              asset.locale ? `, Locale: '${asset.locale}'` : ''}
             }, Environment: ${pd.environment}`,
           ),
         );

packages/contentstack-bulk-publish/src/producer/publish-assets.js

@@ -256,16 +256,16 @@ async function processPendingAssets(pendingItems, stack, bulkPublish, environmen
  * subset). The single in-memory floor is the asset uid-mapping file itself (same
  * as import's publish()); for very large stacks raise Node's --max-old-space-size.
  */
-async function getAssetsFromBackup(stack, dataDir, bulkPublish, apiVersion, bulkPublishLimit) {
-  const assetsPath = path.join(dataDir, 'assets');
+async function getAssetsFromBackup(stack, backupDir, bulkPublish, apiVersion, bulkPublishLimit) {
+  const assetsPath = path.join(backupDir, 'assets');
   const assetsIndexPath = path.join(assetsPath, 'assets.json');
-  const assetUidMapperPath = path.join(dataDir, 'mapper', 'assets', 'uid-mapping.json');
-  const envUidMapperPath = path.join(dataDir, 'mapper', 'environments', 'uid-mapping.json');
-  const environmentsPath = path.join(dataDir, 'environments', 'environments.json');
+  const assetUidMapperPath = path.join(backupDir, 'mapper', 'assets', 'uid-mapping.json');
+  const envUidMapperPath = path.join(backupDir, 'mapper', 'environments', 'uid-mapping.json');
+  const environmentsPath = path.join(backupDir, 'environments', 'environments.json');
 
   // A backup with no assets is a legitimate outcome of a successful import that
   // had 0 assets (assets.json is never produced) — exit cleanly, not as a crash.
-  // A genuinely wrong --data-dir surfaces via the uid-mapping/environments guards below.
+  // A genuinely wrong --backup-dir surfaces via the uid-mapping/environments guards below.
   if (!existsSync(assetsPath) || !existsSync(assetsIndexPath)) {
     console.log(chalk.yellow('No assets found in backup — nothing to publish.'));
     return;
@@ -457,7 +457,7 @@ function setConfig(conf, bp) {
   scanSummary = { clean: 0, quarantined: 0, inQueue: 0, noStatus: 0 };
 }
 
-async function start({ retryFailed, bulkPublish, environments, folderUid, locales, apiVersion, dataDir }, stack, config) {
+async function start({ retryFailed, bulkPublish, environments, folderUid, locales, apiVersion, backupDir }, stack, config) {
   process.on('beforeExit', async () => {
     // Print the scan summary here (not inline after enqueueing):
     printScanSummary(scanSummary);
@@ -498,12 +498,12 @@ async function start({ retryFailed, bulkPublish, environments, folderUid, locale
     } else {
       await retryFailedLogs(retryFailed, { assetQueue: queue }, 'publish');
     }
-  } else if (dataDir) {
+  } else if (backupDir) {
     // Post-import flow: publish each imported asset only to its original
     // environments/locales (from backup publish_details), scan-gated.
     setConfig(config, bulkPublish);
     const bulkPublishLimit = fetchBulkPublishLimit(stack?.org_uid);
-    await getAssetsFromBackup(stack, dataDir, bulkPublish, apiVersion, bulkPublishLimit);
+    await getAssetsFromBackup(stack, backupDir, bulkPublish, apiVersion, bulkPublishLimit);
   } else if (folderUid) {
     setConfig(config, bulkPublish);
     const bulkPublishLimit = fetchBulkPublishLimit(stack?.org_uid);

packages/contentstack-import/src/commands/cm/stacks/import.ts

@@ -200,7 +200,7 @@ export default class ImportCommand extends Command {
       // covers the scanning case, since detecting scanning sets skipAssetsPublish.
       if (!result?.noSuccessMsg && assetsImported && importConfig.skipAssetsPublish) {
         log.info(
-          `Note: assets were imported but not published asset scanning is enabled and must complete first. To publish them, run:\n  csdx cm:assets:publish --data-dir ${backupDir} --stack-api-key ${importConfig.apiKey}`,
+          `Note: assets were imported but not published asset scanning is enabled and must complete first. To publish them, run:\n  csdx cm:assets:publish --backup-dir ${backupDir} --stack-api-key ${importConfig.apiKey}`,
           importConfig.context,
         );
       }