feat: handled field integrity exception

Author: shaurabh-tiwari-git

messages/migrate.json

@@ -260,6 +260,7 @@
   "omniStudioSettingsMetadataEnabled": "The Omnistudio Metadata setting is enabled with standard data model.",
   "timeoutEnablingOmniStudioSettingsMetadata": "Timeout while checking the metadata enablement status. Tried for %s seconds.",
   "errorEnablingOmniStudioSettingsMetadata": "Error while enabling the Omnistudio Metadata setting: %s. Enable it manually.",
+  "fieldIntegrityException": "Field integrity Exception while deleting metadata records from %s: %s",
   "manuallyEnableOmniStudioSettingsMetadata": "Manually enable the Omnistudio Metadata setting in your org’s Omnistudio Settings page.",
   "omniStudioMetadataEnableConsentNotGiven": "You’ve not consented to proceed with enabling the Omnistudio Metadata setting. We’ll not be able to proceed with the migration.",
   "enablingOmniStudioSettingsMetadataStatus": "Enabling Omnistudio Metadata setting…",

src/utils/config/OmniStudioMetadataCleanupService.ts

@@ -97,7 +97,11 @@ export class OmniStudioMetadataCleanupService {
       return 0;
     }
 
-    const deleteSuccess = await NetUtils.delete(this.connection, recordIds);
-    return deleteSuccess ? recordIds.length : -1;
+    const deleteResult = await NetUtils.deleteWithFieldIntegrityException(this.connection, recordIds);
+    if (!deleteResult.success && deleteResult.statusCode === 'FIELD_INTEGRITY_EXCEPTION') {
+      Logger.error(this.messages.getMessage('fieldIntegrityException', [tableName, deleteResult.message || '']));
+      return -1;
+    }
+    return deleteResult.success ? recordIds.length : -1;
   }
 }

src/utils/net/index.ts

@@ -124,6 +124,52 @@ class NetUtils {
     return true;
   }
 
+  public static async deleteWithFieldIntegrityException(
+    connection: Connection,
+    data: string[]
+  ): Promise<{ success: boolean; statusCode?: string; message?: string }> {
+    // Metadata API only accepts 200 records per request
+    const chunks = chunk(data, NetUtils.CHUNK_SIZE);
+    let hasFieldIntegrityException = false;
+    let hasErrors = false;
+    let errorCode: string | undefined;
+    let message: string | undefined;
+
+    for (let curr of chunks) {
+      const deleteUrl = 'composite/sobjects?allOrNone=true&ids=' + curr.join(',');
+
+      const response = await this.request<DeleteResponse[]>(connection, deleteUrl, [], RequestMethod.DELETE);
+      // Check each response for errors
+      response.forEach((result) => {
+        if (!result.success && result.errors && result.errors.length > 0) {
+          result.errors.forEach((error) => {
+            hasErrors = true;
+            // Check if this error is a FIELD_INTEGRITY_EXCEPTION
+            if (error.statusCode === 'FIELD_INTEGRITY_EXCEPTION') {
+              hasFieldIntegrityException = true;
+              message = error.message;
+              return;
+            } else {
+              errorCode = error.statusCode;
+            }
+          });
+        }
+      });
+    }
+
+    // If there are failed records, return failure with status code
+    if (hasErrors) {
+      return {
+        success: false,
+        // Override with FIELD_INTEGRITY_EXCEPTION if found, otherwise use first encountered
+        statusCode: hasFieldIntegrityException ? 'FIELD_INTEGRITY_EXCEPTION' : errorCode,
+        message: message,
+      };
+    }
+
+    return { success: true };
+  }
+
   public static async request<TResultType>(
     connection: Connection,
     url: string,
@@ -156,4 +202,14 @@ interface TreeResult {
   results: UploadRecordResult[];
 }
 
+interface DeleteResponse {
+  id: string;
+  success: boolean;
+  errors: Array<{
+    statusCode: string;
+    message: string;
+    fields: string[];
+  }>;
+}
+
 export { NetUtils, RequestMethod, TreeResult };