Skip to content

feat: enhance AEM service and content type utilities to support UID r… #979

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
umeshmore45 merged 2 commits into from
Feb 25, 2026
Merged

feat: enhance AEM service and content type utilities to support UID r… #979

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
d7c7b0d
feat: enhance AEM service and content type utilities to support UID r…
shobhitupadhyayy Feb 25, 2026
3db33eb
feat: add UID remapping utility and enhance ContentMapper to prevent …
shobhitupadhyayy Feb 25, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 7 additions & 2 deletions api/src/services/aem.service.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1355,15 +1355,20 @@ const createEntry = async ({
for await (const [locale, entries] of entriesLocale) {
for (const entry of entries) {
const flatData = deepFlattenObject(entry);
const km = keyMapper as Record<string, string> | undefined;
for (const [key, value] of Object.entries(flatData)) {
if (key.endsWith('._content_type_uid') && typeof value === 'string') {
const uidField = key?.replace('._content_type_uid', '');
const refs: string[] = entryMapping?.[value];
const mappedCtUid = km?.[value] && km[value] !== '' ? km[value] : value;
if (mappedCtUid !== value) {
_.set(entry, key, mappedCtUid);
}
const refs: string[] = entryMapping?.[mappedCtUid];

if (refs?.length) {
_.set(entry, `${uidField}.uid`, refs?.[0]);
} else {
console.info(`No entry found for content type: ${value}`);
console.info(`No entry found for content type: ${mappedCtUid}`);
}
}
}
Expand Down
26 changes: 16 additions & 10 deletions api/src/utils/content-type-creator.utils.ts
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -102,7 +102,12 @@ const uidCorrector = ({ uid } : {uid : string}) => {
};


function buildFieldSchema(item: any, marketPlacePath: string, parentUid = ''): any {
function remapReferenceUids(uids: string[], keyMapper?: Record<string, string>): string[] {
if (!keyMapper || !Object.keys(keyMapper).length) return uids;
return uids.map(uid => keyMapper[uid] ?? keyMapper[uidCorrector({ uid })] ?? uid);
}

function buildFieldSchema(item: any, marketPlacePath: string, parentUid = '', keyMapper?: Record<string, string>): any {
if (item?.isDeleted === true) return null;

const getCleanUid = (uid: string): string => {
Expand Down Expand Up @@ -155,7 +160,7 @@ function buildFieldSchema(item: any, marketPlacePath: string, parentUid = ''): a
const blockElements = blockItem?.schema || [];
for (const element of blockElements) {
if (element?.isDeleted === false) {
const fieldSchema = buildFieldSchema(element, marketPlacePath, '');
const fieldSchema = buildFieldSchema(element, marketPlacePath, '', keyMapper);
if (fieldSchema) blockSchema.push(fieldSchema);
}
}
Expand Down Expand Up @@ -186,7 +191,7 @@ function buildFieldSchema(item: any, marketPlacePath: string, parentUid = ''): a

for (const element of elements) {
if (element?.isDeleted === false) {
const fieldSchema = buildFieldSchema(element, marketPlacePath, '');
const fieldSchema = buildFieldSchema(element, marketPlacePath, '', keyMapper);
if (fieldSchema) groupSchema.push(fieldSchema);
}
}
Expand All @@ -210,7 +215,8 @@ function buildFieldSchema(item: any, marketPlacePath: string, parentUid = ''): a
title: item?.display_name || rawUid, // Keep original for display
uid: itemUid // Snake case uid
},
marketPlacePath
marketPlacePath,
keyMapper
});
}

Expand Down Expand Up @@ -470,10 +476,10 @@ export const convertToSchemaFormate = ({ field, advanced = false, marketPlacePat
"error_messages": {
"format": field?.advanced?.validationErrorMessage ?? '',
},
"reference_to": field?.advanced?.embedObjects?.length ? [
"reference_to": field?.advanced?.embedObjects?.length ? remapReferenceUids([
"sys_assets",
...field?.advanced?.embedObjects?.map?.((item: any) => uidCorrector({ uid: item })) ?? [],
] : [
], keyMapper) : [
"sys_assets"
],
"multiple": field?.advanced?.multiple ?? false,
Expand Down Expand Up @@ -736,7 +742,7 @@ export const convertToSchemaFormate = ({ field, advanced = false, marketPlacePat
return {
"data_type": "global_field",
"display_name": field?.title,
"reference_to": field?.refrenceTo ?? [],
"reference_to": remapReferenceUids(field?.refrenceTo ?? [], keyMapper),
"uid": cleanedUid,
"mandatory": field?.advanced?.mandatory ?? false,
"multiple": field?.advanced?.multiple ?? false,
Expand All @@ -748,7 +754,7 @@ export const convertToSchemaFormate = ({ field, advanced = false, marketPlacePat
return {
data_type: "reference",
display_name: field?.title,
reference_to: field?.refrenceTo ?? [],
reference_to: remapReferenceUids(field?.refrenceTo ?? [], keyMapper),
field_metadata: {
ref_multiple: true,
ref_multiple_content_types: true
Expand Down Expand Up @@ -816,7 +822,7 @@ export const convertToSchemaFormate = ({ field, advanced = false, marketPlacePat
"mandatory": field?.advanced?.mandatory ?? false,
"unique": field?.advanced?.unique ?? false,
"non_localizable": field.advanced?.nonLocalizable ?? false,
"reference_to": field?.advanced?.embedObjects?.length ? field?.advanced?.embedObjects?.map?.((item: any) => uidCorrector({ uid: item })) : []
"reference_to": field?.advanced?.embedObjects?.length ? remapReferenceUids(field?.advanced?.embedObjects?.map?.((item: any) => uidCorrector({ uid: item })), keyMapper) : []
}
if ((field?.advanced?.embedObjects?.length === undefined) ||
(field?.advanced?.embedObjects?.length === 0) ||
Expand Down Expand Up @@ -1177,7 +1183,7 @@ export const contenTypeMaker = async ({ contentType, destinationStackId, project
for (const item of ctData) {
if (item?.isDeleted === true) continue;

const fieldSchema = buildFieldSchema(item, marketPlacePath, '');
const fieldSchema = buildFieldSchema(item, marketPlacePath, '', keyMapper);
if (fieldSchema) {
ct?.schema.push(fieldSchema);
}
Expand Down
54 changes: 32 additions & 22 deletions ui/src/components/ContentMapper/index.tsx
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1450,21 +1450,29 @@ const ContentMapper = forwardRef(({ handleStepChange }: contentMapperProps, ref:
)

if (groupArray?.[0]?.child && previousSelectedValue !== selectedValue?.label && groupArray?.[0]?.uid === rowIndex) {
for (const item of groupArray?.[0]?.child ?? []) {
deletedExstingField[item?.backupFieldUid] = {
label: item?.uid,
value: existingField[item?.backupFieldUid]

}
setIsFieldDeleted(true);
const index = selectedOptions?.indexOf(existingField[item?.backupFieldUid]?.value?.label);

if (index > -1) {
selectedOptions?.splice(index, 1);
}
delete existingField[item?.backupFieldUid]

}
const collectAllDescendants = (children: FieldMapType[]): FieldMapType[] => {
return children.flatMap((child) => [
child,
...collectAllDescendants(child?.child ?? [])
]);
};

const allDescendants = collectAllDescendants(groupArray[0].child);
const labelsToRemove = new Set<string>(
allDescendants
.map((item) => existingField[item?.backupFieldUid]?.label)
.filter(Boolean) as string[]
);

setExistingField((prev) => {
const next = { ...prev };
allDescendants.forEach((item) => delete next[item?.backupFieldUid]);
return next;
});

setIsFieldDeleted(true); // once, outside loop

setSelectedOptions((prev) => prev.filter((opt) => !labelsToRemove.has(opt)));
}
else {
setIsFieldDeleted(false);
Expand Down Expand Up @@ -2012,18 +2020,20 @@ const ContentMapper = forwardRef(({ handleStepChange }: contentMapperProps, ref:
const OptionsForRow: OptionsType[] = [];

// If OtherContentType label and contentModels are present, set the contentTypeSchema
let resolvedSchema = contentTypeSchema;
if (otherContentType?.label && contentModels) {
const ContentType: ContentTypeList | undefined = contentModels?.find(
({ title }) => title === otherContentType?.label
);
setContentTypeSchema(ContentType?.schema);
resolvedSchema = ContentType?.schema;
setContentTypeSchema(resolvedSchema);
}

if (contentTypeSchema && validateArray(contentTypeSchema)) {
if (resolvedSchema && validateArray(resolvedSchema)) {
const fieldTypeToMatch = Fields[data?.backupFieldType as keyof Mapping]?.type;

// Check for UID match first
for (const value of contentTypeSchema) {
for (const value of resolvedSchema) {
if (data?.uid === value?.uid && data?.backupFieldType === value?.data_type && fieldTypeToMatch) {
OptionsForRow.push({ label: value?.display_name, value, isDisabled: false });
break;
Expand All @@ -2032,7 +2042,7 @@ const ContentMapper = forwardRef(({ handleStepChange }: contentMapperProps, ref:

// If no exact match, process schema including modular blocks
if (OptionsForRow?.length === 0) {
for (const value of contentTypeSchema) {
for (const value of resolvedSchema) {
const groupArray = nestedList.filter(item =>
item?.child?.some(e => e?.id === data?.id)
);
Expand All @@ -2053,7 +2063,7 @@ const ContentMapper = forwardRef(({ handleStepChange }: contentMapperProps, ref:
processSchema(value, data, array, groupArray, OptionsForRow, fieldsOfContentstack);
}
// Process leaf fields
else if (!array?.some(item => item?.id === data?.id) && checkConditions(fieldTypeToMatch, value, data) && !parentBlock) {
else if (!array?.some(item => item?.id === data?.id) && checkConditions(fieldTypeToMatch, value, data) && !parentBlock?.length) {
OptionsForRow.push(getMatchingOption(value, true, value?.display_name || '', value?.uid ?? ''));
}
}
Expand Down Expand Up @@ -2165,7 +2175,7 @@ const ContentMapper = forwardRef(({ handleStepChange }: contentMapperProps, ref:
isDisabled: false
};

const adjustedOptions: OptionsType[] | OptionsType = (OptionsForRow.length === 0 && !contentTypeSchema) ? option :
const adjustedOptions: OptionsType[] | OptionsType = (OptionsForRow.length === 0 && !resolvedSchema) ? option :
(OptionsForRow?.length > 0 && OptionsForRow?.every((item) => item?.isDisabled) && OptionValue?.label === Fields[data?.contentstackFieldType]?.label) ? []
: OptionsForRow.map((option: OptionsType) => ({
...option,
Expand Down Expand Up @@ -2213,7 +2223,7 @@ const ContentMapper = forwardRef(({ handleStepChange }: contentMapperProps, ref:
>
<Button
buttonType="light"
disabled={(contentTypeSchema && existingField[data?.backupFieldUid]) || newMigrationData?.project_current_step > 4}
disabled={(resolvedSchema && existingField[data?.backupFieldUid]) || newMigrationData?.project_current_step > 4}
onClick={() => {
handleAdvancedSetting(initialOption?.label, data?.advanced || {}, data?.uid, data);
}}
Expand Down