feat: error handling for skippedSourceRecordsFilterWarning

Author: nktnet1

messages/resources.json

@@ -191,7 +191,7 @@
     "writingToFile": "{%s} Creating the file %s ...",
     "nothingUpdated": "Nothing was updated.",
     "skippedUpdatesWarning": "{%s} %s target records remained untouched, since they do not differ from the corresponding source records.",
-    "skippedsSourceRecordsFilterWarning": "One 'sourceRecordsFilter' could not be applied: %s.",
+    "skippedSourceRecordsFilterWarning": "One 'sourceRecordsFilter' could not be applied: %s.",
     "skippedTargetRecordsFilterWarning": "One 'targetRecordsFilter' could not be applied: %s.",
     "missingParentLookupsPrompt": "{%s} %s missing parent lookup records were found. See %s file for the details.",
     "updatingSummary": "Data processing summary.",

src/modules/models/job_models/migrationJobTask.ts

@@ -639,8 +639,12 @@ export default class MigrationJobTask {
       ___filterTargetQuery(tempQuery);
     } else if (this.scriptObject.sourceRecordsFilter) {
       // Add any extra filter conditions to the source query
-      const additionalWhereClause = parseQuery(`SELECT Id FROM ${this.sObjectName} WHERE ${this.scriptObject.sourceRecordsFilter}`).where;
-      tempQuery.where = Common.mergeWhereClauses(tempQuery.where, additionalWhereClause);
+      try {
+        const additionalWhereClause = parseQuery(`SELECT Id FROM ${this.sObjectName} WHERE ${this.scriptObject.sourceRecordsFilter}`).where;
+        tempQuery.where = Common.mergeWhereClauses(tempQuery.where, additionalWhereClause);
+      } catch (ex) {
+        self.logger.warn(RESOURCES.skippedSourceRecordsFilterWarning, ex.message);
+      }
     }
 
     let query = composeQuery(tempQuery);