refactor:refactored the wordpress migration code

Author: AishDani

api/src/constants/index.ts

@@ -212,6 +212,7 @@ export const MIGRATION_DATA_CONFIG = {
   ASSETS_SCHEMA_FILE: "index.json",
   ASSETS_FAILED_FILE: "cs_failed.json",
   ASSETS_METADATA_FILE: "metadata.json",
+  ASSETS_FOLDER_FILE_NAME: "folders.json",
 
   ENTRIES_DIR_NAME: "entries",
   ENTRIES_MASTER_FILE: "index.json",

api/src/models/FieldMapper.ts

@@ -5,7 +5,7 @@ import path from "path";
 /**
  * Represents the advanced configuration options for a field mapper.
  */
-interface Advanced {
+export interface Advanced {
   validationRegex: string;
   mandatory: boolean;
   multiple: boolean;

api/src/services/contentMapper.service.ts

@@ -49,8 +49,8 @@ const putTestData = async (req: Request) => {
   */
   contentTypes.map((type: any, index: any) => {
     const fieldIds: string[] = [];
-    const fields = type?.fieldMapping?.map?.((field: any) => {
-      const id = field?.id?.replace(/[{}]/g, "")?.toLowerCase() || uuidv4();
+    const fields = type?.fieldMapping?.filter((field: any) => field)?.map?.((field: any) => {
+      const id = field?.id ? field?.id?.replace(/[{}]/g, "")?.toLowerCase() : uuidv4();
       field.id = id;
       fieldIds.push(id);
       return { id, projectId, isDeleted: false, ...field };

api/src/services/migration.service.ts

@@ -225,34 +225,27 @@ const startTestMigration = async (req: Request): Promise<any> => {
       case CMS.SITECORE_V9:
       case CMS.SITECORE_V10: {
       if (packagePath) {
-        const contentTypes = await fieldAttacher({ orgId, projectId, destinationStackId: project?.current_test_stack_id });
-
-            await siteCoreService?.createEntry({ packagePath, contentTypes, destinationStackId: project?.current_test_stack_id, projectId });
+            await siteCoreService?.createEntry({ packagePath, contentTypes, destinationStackId: project?.current_test_stack_id, projectId,keyMapper: project?.mapperKeys });
             await siteCoreService?.createLocale(req, project?.current_test_stack_id, projectId);
             await siteCoreService?.createVersionFile(project?.current_test_stack_id);
           } 
           break;
       }
       case CMS.WORDPRESS: {
         if (packagePath) {
-          await wordpressService?.getAllAssets(affix, packagePath, project?.current_test_stack_id, projectId)
-          await wordpressService?.createAssetFolderFile(affix, project?.current_test_stack_id, projectId)
-          await wordpressService?.getAllreference(affix, packagePath, project?.current_test_stack_id, projectId)
-          await wordpressService?.extractChunks(affix, packagePath, project?.current_test_stack_id, projectId)
-          await wordpressService?.getAllAuthors(affix, packagePath,project?.current_test_stack_id, projectId)
-          await wordpressService?.extractContentTypes(projectId, project?.current_test_stack_id)
-          await wordpressService?.getAllTerms(affix, packagePath,project?.current_test_stack_id, projectId)
-          await wordpressService?.getAllTags(affix, packagePath,project?.current_test_stack_id, projectId)
-          await wordpressService?.getAllCategories(affix, packagePath,project?.current_test_stack_id, projectId)
-          await wordpressService?.extractPosts( packagePath,project?.current_test_stack_id, projectId)
+          await wordpressService?.getAllAssets(file_path, packagePath, project?.current_test_stack_id, projectId)
+          await wordpressService?.createAssetFolderFile(file_path, project?.current_test_stack_id, projectId)
+          await wordpressService?.getAllreference(file_path, packagePath, project?.current_test_stack_id, projectId)
+          await wordpressService?.extractChunks(file_path, packagePath, project?.current_test_stack_id, projectId)
+          await wordpressService?.getAllAuthors(file_path, packagePath,project?.current_test_stack_id, projectId,contentTypes, project?.mapperKeys)
+          //await wordpressService?.extractContentTypes(projectId, project?.current_test_stack_id, contentTypes)
+          await wordpressService?.getAllTerms(file_path, packagePath,project?.current_test_stack_id, projectId,contentTypes, project?.mapperKeys)
+          await wordpressService?.getAllTags(file_path, packagePath,project?.current_test_stack_id, projectId,contentTypes, project?.mapperKeys)
+          await wordpressService?.getAllCategories(file_path, packagePath,project?.current_test_stack_id, projectId,contentTypes, project?.mapperKeys)
+          await wordpressService?.extractPosts( packagePath,project?.current_test_stack_id, projectId,contentTypes, project?.mapperKeys)
           await wordpressService?.extractGlobalFields(project?.current_test_stack_id, projectId)
           await wordpressService?.createVersionFile(project?.current_test_stack_id, projectId);
         }
-        if (packagePath) {
-          await siteCoreService?.createEntry({ packagePath, contentTypes, master_locale: project?.stackDetails?.master_locale, destinationStackId: project?.current_test_stack_id, projectId, keyMapper: project?.mapperKeys });
-          await siteCoreService?.createLocale(req, project?.current_test_stack_id, projectId);
-          await siteCoreService?.createVersionFile(project?.current_test_stack_id);
-        }
         break;
       }
       case CMS.CONTENTFUL: {
@@ -319,12 +312,12 @@ const startMigration = async (req: Request): Promise<any> => {
           await wordpressService?.createAssetFolderFile(file_path, project?.destination_stack_id, projectId)
           await wordpressService?.getAllreference(file_path, packagePath, project?.destination_stack_id, projectId)
           await wordpressService?.extractChunks(file_path, packagePath, project?.destination_stack_id, projectId)
-          await wordpressService?.getAllAuthors(file_path, packagePath,project?.destination_stack_id, projectId)
-          await wordpressService?.extractContentTypes(projectId, project?.destination_stack_id)
-          await wordpressService?.getAllTerms(file_path, packagePath,project?.destination_stack_id, projectId)
-          await wordpressService?.getAllTags(file_path, packagePath,project?.destination_stack_id, projectId)
-          await wordpressService?.getAllCategories(file_path, packagePath,project?.destination_stack_id, projectId)
-          await wordpressService?.extractPosts( packagePath,project?.destination_stack_id, projectId)
+          await wordpressService?.getAllAuthors(file_path, packagePath,project?.destination_stack_id, projectId,contentTypes, project?.mapperKeys)
+          //await wordpressService?.extractContentTypes(projectId, project?.destination_stack_id)
+          await wordpressService?.getAllTerms(file_path, packagePath,project?.destination_stack_id, projectId,contentTypes, project?.mapperKeys)
+          await wordpressService?.getAllTags(file_path, packagePath,project?.destination_stack_id, projectId,contentTypes, project?.mapperKeys)
+          await wordpressService?.getAllCategories(file_path, packagePath,project?.destination_stack_id, projectId,contentTypes, project?.mapperKeys)
+          await wordpressService?.extractPosts( packagePath,project?.destination_stack_id, projectId,contentTypes, project?.mapperKeys)
           await wordpressService?.extractGlobalFields(project?.destination_stack_id, projectId)
           await wordpressService?.createVersionFile(project?.destination_stack_id, projectId);