Merge pull request #341 from contentstack/feature/migration-wordpress-integration

Feature/migration wordpress integration

Author: RohitKini

api/src/constants/index.ts

@@ -212,10 +212,34 @@ 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",
 
+  AUTHORS_DIR_NAME : "authors",
+  AUTHORS_FILE_NAME : "en-us.json",
+  AUTHORS_MASTER_FILE : "authors.json",
+
+  CATEGORIES_DIR_NAME: "categories",
+  CATEGORIES_FILE_NAME: "en-us.json",
+  CATEGORIES_MASTER_FILE: "categories.json",
+
+  TAG_DIR_NAME: "tags",
+  TAG_FILE_NAME: "en-us.json",
+  TAG_MASTER_FILE: "tag.json",
+
+  TERMS_DIR_NAME: "terms",
+  TERMS_FILE_NAME: "en-us.json",
+  TERMS_MASTER_FILE: "terms.json",
+
+  POSTS_DIR_NAME: "posts",
+  POSTS_FOLDER_NAME: "en-us",
+  POSTS_FILE_NAME: "en-us.json",
+  POSTS_MASTER_FILE: "posts.json",
+
+  CHUNKS_DIR_NAME: "chunks",
+
   GLOBAL_FIELDS_DIR_NAME: "global_fields",
   GLOBAL_FIELDS_FILE_NAME: "globalfields.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

@@ -11,6 +11,7 @@ import { HTTP_TEXTS, HTTP_CODES, LOCALE_MAPPER, STEPPER_STEPS, CMS } from "../co
 import { BadRequestError, ExceptionFunction } from "../utils/custom-errors.utils.js";
 import { fieldAttacher } from "../utils/field-attacher.utils.js";
 import { siteCoreService } from "./sitecore.service.js";
+import { wordpressService } from "./wordpress.service.js";
 import { testFolderCreator } from "../utils/test-folder-creator.utils.js";
 import { utilsCli } from './runCli.service.js';
 import customLogger from "../utils/custom-logger.utils.js";
@@ -223,10 +224,27 @@ const startTestMigration = async (req: Request): Promise<any> => {
       case CMS.SITECORE_V8:
       case CMS.SITECORE_V9:
       case CMS.SITECORE_V10: {
+      if (packagePath) {
+            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 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);
+          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);
         }
         break;
       }
@@ -288,6 +306,25 @@ const startMigration = async (req: Request): Promise<any> => {
         }
         break;
       }
+      case CMS.WORDPRESS: {
+        if (packagePath) {
+          await wordpressService?.getAllAssets(file_path, packagePath, project?.destination_stack_id, projectId)
+          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,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);
+
+
+        }
+        break;
+      }
       case CMS.CONTENTFUL: {
         await contentfulService?.createLocale(file_path, project?.destination_stack_id, projectId);
         await contentfulService?.createRefrence(file_path, project?.destination_stack_id, projectId);