fix: locale reading issue in entries module

Author: aman19K

packages/contentstack-export/src/export/modules/entries.ts

@@ -1,11 +1,5 @@
 import * as path from 'path';
-import {
-  ContentstackClient,
-  FsUtility,
-  handleAndLogError,
-  messageHandler,
-  log,
-} from '@contentstack/cli-utilities';
+import { ContentstackClient, FsUtility, handleAndLogError, messageHandler, log } from '@contentstack/cli-utilities';
 import { Export, ExportProjects } from '@contentstack/cli-variants';
 import { sanitizePath } from '@contentstack/cli-utilities';
 
@@ -65,12 +59,15 @@ export default class EntriesExport extends BaseClass {
     try {
       log.debug('Starting entries export process...', this.exportConfig.context);
       const locales = fsUtil.readFile(this.localesFilePath) as Array<Record<string, unknown>>;
+      if (!locales || locales.length === 0) {
+        log.debug(`No locales found in ${this.localesFilePath}`, this.exportConfig.context);
+      }
       log.debug(`Loaded ${locales?.length} locales from ${this.localesFilePath}`, this.exportConfig.context);
-      
+
       const contentTypes = fsUtil.readFile(this.schemaFilePath) as Array<Record<string, unknown>>;
       log.debug(`Loaded ${contentTypes?.length} content types from ${this.schemaFilePath}`, this.exportConfig.context);
-      
-      if (contentTypes.length === 0) {
+
+      if (!contentTypes || contentTypes?.length === 0) {
         log.info(messageHandler.parse('CONTENT_TYPE_NO_TYPES'), this.exportConfig.context);
         return;
       }
@@ -95,18 +92,20 @@ export default class EntriesExport extends BaseClass {
       }
 
       const entryRequestOptions = this.createRequestObjects(locales, contentTypes);
-      log.debug(`Created ${entryRequestOptions.length} entry request objects for processing`, this.exportConfig.context);
-      
+      log.debug(
+        `Created ${entryRequestOptions.length} entry request objects for processing`,
+        this.exportConfig.context,
+      );
+
       for (let entryRequestOption of entryRequestOptions) {
-        log.debug(`Processing entries for content type: ${entryRequestOption.contentType}, locale: ${entryRequestOption.locale}`, this.exportConfig.context);
+        log.debug(
+          `Processing entries for content type: ${entryRequestOption.contentType}, locale: ${entryRequestOption.locale}`,
+          this.exportConfig.context,
+        );
         await this.getEntries(entryRequestOption);
         this.entriesFileHelper?.completeFile(true);
         log.success(
-          messageHandler.parse(
-            'ENTRIES_EXPORT_COMPLETE',
-            entryRequestOption.contentType,
-            entryRequestOption.locale,
-          ),
+          messageHandler.parse('ENTRIES_EXPORT_COMPLETE', entryRequestOption.contentType, entryRequestOption.locale),
           this.exportConfig.context,
         );
       }
@@ -120,8 +119,11 @@ export default class EntriesExport extends BaseClass {
     locales: Array<Record<string, unknown>>,
     contentTypes: Array<Record<string, unknown>>,
   ): Array<Record<string, any>> {
-    log.debug(`Creating request objects for ${contentTypes.length} content types and ${locales.length} locales`, this.exportConfig.context);
-    
+    log.debug(
+      `Creating request objects for ${contentTypes.length} content types and ${locales.length} locales`,
+      this.exportConfig.context,
+    );
+
     let requestObjects: Array<Record<string, any>> = [];
     contentTypes.forEach((contentType) => {
       if (Object.keys(locales).length !== 0) {
@@ -165,8 +167,11 @@ export default class EntriesExport extends BaseClass {
         .entry()
         .query(requestObject)
         .find();
-      
-      log.debug(`Fetched ${entriesSearchResponse.items?.length || 0} entries out of total ${entriesSearchResponse.count}`, this.exportConfig.context);
+
+      log.debug(
+        `Fetched ${entriesSearchResponse.items?.length || 0} entries out of total ${entriesSearchResponse.count}`,
+        this.exportConfig.context,
+      );
     } catch (error) {
       handleAndLogError(error, {
         ...this.exportConfig.context,
@@ -194,10 +199,10 @@ export default class EntriesExport extends BaseClass {
         });
         log.debug('Initialized FsUtility for writing entries', this.exportConfig.context);
       }
-      
+
       log.debug(`Writing ${entriesSearchResponse.items.length} entries to file`, this.exportConfig.context);
       this.entriesFileHelper.writeIntoFile(entriesSearchResponse.items, { mapKeyVal: true });
-      
+
       if (this.entriesConfig.exportVersions) {
         log.debug('Exporting entry versions is enabled', this.exportConfig.context);
         let versionedEntryPath = path.join(
@@ -227,7 +232,10 @@ export default class EntriesExport extends BaseClass {
 
       options.skip += this.entriesConfig.limit || 100;
       if (options.skip >= entriesSearchResponse.count) {
-        log.debug(`Completed fetching all entries for content type: ${options.contentType}, locale: ${options.locale}`, this.exportConfig.context);
+        log.debug(
+          `Completed fetching all entries for content type: ${options.contentType}, locale: ${options.locale}`,
+          this.exportConfig.context,
+        );
         return Promise.resolve(true);
       }
       log.debug(`Continuing to fetch entries with skip: ${options.skip}`, this.exportConfig.context);
@@ -240,7 +248,7 @@ export default class EntriesExport extends BaseClass {
     options: { locale: string; contentType: string; versionedEntryPath: string },
   ): Promise<void> {
     log.debug(`Fetching versions for ${entries.length} entries`, this.exportConfig.context);
-    
+
     const onSuccess = ({ response, apiData: entry }: any) => {
       const versionFilePath = path.join(sanitizePath(options.versionedEntryPath), sanitizePath(`${entry.uid}.json`));
       log.debug(`Writing versioned entry to: ${versionFilePath}`, this.exportConfig.context);
@@ -262,7 +270,10 @@ export default class EntriesExport extends BaseClass {
       );
     };
 
-    log.debug(`Starting concurrent calls for versioned entries with batch limit: ${this.entriesConfig.batchLimit}`, this.exportConfig.context);
+    log.debug(
+      `Starting concurrent calls for versioned entries with batch limit: ${this.entriesConfig.batchLimit}`,
+      this.exportConfig.context,
+    );
     return await this.makeConcurrentCall(
       {
         apiBatches: [entries],
@@ -289,7 +300,7 @@ export default class EntriesExport extends BaseClass {
     isLastRequest: boolean;
   }) {
     log.debug(`Processing versioned entry: ${entry.uid}`, this.exportConfig.context);
-    
+
     return new Promise(async (resolve, reject) => {
       return await this.getEntryByVersion(apiParams.queryParam, entry)
         .then((response) => {
@@ -323,21 +334,27 @@ export default class EntriesExport extends BaseClass {
       },
       version: entry._version,
     };
-    
+
     log.debug(`Fetching entry version ${entry._version} for uid: ${entry.uid}`, this.exportConfig.context);
-    
+
     const entryResponse = await this.stackAPIClient
       .contentType(options.contentType)
       .entry(entry.uid)
       .fetch(queryRequestObject);
     entries.push(entryResponse);
-    
+
     if (--entry._version > 0) {
-      log.debug(`Continuing to fetch previous version ${entry._version} for entry: ${entry.uid}`, this.exportConfig.context);
+      log.debug(
+        `Continuing to fetch previous version ${entry._version} for entry: ${entry.uid}`,
+        this.exportConfig.context,
+      );
       return await this.getEntryByVersion(options, entry, entries);
     }
-    
-    log.debug(`Completed fetching all versions for entry: ${entry.uid}, total versions: ${entries.length}`, this.exportConfig.context);
+
+    log.debug(
+      `Completed fetching all versions for entry: ${entry.uid}, total versions: ${entries.length}`,
+      this.exportConfig.context,
+    );
     return entries;
   }
 }