RA-26080 remove properties

newReindexAuditLogs.js

@@ -21,8 +21,6 @@ async function callBulkAPI(elindex) {
 async function bulkIndexAuditLogs(rideId, auditLogs, rideRange) {   
     const elindex = [];
     auditLogs.forEach((value) => {
-      utils.filterObject(value, 'legToFlatFeeMapping ');
-      utils.filterObject(value, 'changed_legs');
 
       elindex.push({
         index: {

newUtils.js

@@ -72,8 +72,7 @@ const createIndex = async function createIndex(indexName, fromIndex) {
       }
     });
 
-    filterObject(properties, 'legToFlatFeeMapping');
-    filterObject(properties, 'changed_legs');
+    removeProperty(properties);
 
     await elasticClient.indices.putMapping({
       index: indexName, type: 'doc', body: { properties, dynamic: false },
@@ -127,6 +126,8 @@ const createLogstashIndex = async function createLogstashIndex(indexName, fromIn
       });
     }
   });
+
+  removeProperty(properties);
   await elasticClient.indices.putMapping({
     index: indexName, type: 'doc', body: { properties, dynamic: false },
   });
@@ -153,6 +154,26 @@ function filterObject(obj, key) {
           filterObject(obj[i], key);
       }
   }
+
+}
+
+
+function removeProperty(obj){
+   if(obj?.meta?.data?.vendor_lists?.latest_flat_rate?.legToFlatFeeMapping){
+      delete obj.meta.data.vendor_lists.latest_flat_rate.legToFlatFeeMapping
+   }
+
+   if(obj?.meta?.data?.orderUpdateDiff?.changed_legs){
+      delete obj.meta.data.orderUpdateDiff.changed_legs
+   }
+
+   if(obj?.meta?.billingWriteBack?.legs?.fare_breakdown){
+      delete obj.meta.billingWriteBack.legs.fare_breakdown
+   }
+
+   if(obj?.receipt?.fare_breakdown){
+     delete obj.receipt.fare_breakdown
+   }
 }
 
 module.exports = {createIndex, createLogstashIndex, filterObject};