chore: fix search id function

src/cdk/v2/destinations/zoho/transformRecordV2.js

@@ -19,7 +19,7 @@ const {
   validatePresenceOfMandatoryProperties,
   formatMultiSelectFieldsV2,
   handleDuplicateCheckV2,
-  searchRecordId,
+  searchRecordIdV2,
   calculateTrigger,
 } = require('./utils');
 const { REFRESH_TOKEN } = require('../../../../adapters/networkhandler/authConstants');
@@ -197,10 +197,11 @@ const handleDeletion = async (
   input,
   fields,
   Config,
+  conConfig,
   transformedResponseToBeBatched,
   errorResponseList,
 ) => {
-  const searchResponse = await searchRecordId(fields, input.metadata, Config);
+  const searchResponse = await searchRecordIdV2(fields, input.metadata, Config, conConfig);
 
   if (searchResponse.erroneous) {
     const error = handleSearchError(searchResponse);
@@ -255,6 +256,7 @@ const processInput = async (
       input,
       allFields,
       Config,
+      conConfig,
       transformedResponseToBeBatched,
       errorResponseList,
     );

src/cdk/v2/destinations/zoho/utils.js

@@ -148,6 +148,17 @@ function transformToURLParams(fields, Config) {
   return `${regionBasedEndPoint}/crm/v6/Leads/search?criteria=${criteria}`;
 }
 
+function transformToURLParamsV2(fields, Config, object) {
+  const criteria = Object.entries(fields)
+    .map(([key, value]) => `(${key}:equals:${escapeAndEncode(value)})`)
+    .join('and');
+
+  const dataCenter = Config.region;
+  const regionBasedEndPoint = zohoConfig.DATA_CENTRE_BASE_ENDPOINTS_MAP[dataCenter];
+
+  return `${regionBasedEndPoint}/crm/v6/${object}/search?criteria=${criteria}`;
+}
+
 const searchRecordId = async (fields, metadata, Config) => {
   try {
     const searchURL = transformToURLParams(fields, Config);
@@ -197,6 +208,56 @@ const searchRecordId = async (fields, metadata, Config) => {
   }
 };
 
+const searchRecordIdV2 = async (fields, metadata, Config, conConfig) => {
+  try {
+    const { object } = conConfig.destination;
+    const searchURL = transformToURLParamsV2(fields, Config, object);
+    const searchResult = await handleHttpRequest(
+      'get',
+      searchURL,
+      {
+        headers: {
+          Authorization: `Zoho-oauthtoken ${metadata.secret.accessToken}`,
+        },
+      },
+      {
+        destType: 'zoho',
+        feature: 'deleteRecords',
+        requestMethod: 'GET',
+        endpointPath: `crm/v6/${object}/search?criteria=`,
+        module: 'router',
+      },
+    );
+
+    if (!isHttpStatusSuccess(searchResult.processedResponse.status)) {
+      return {
+        erroneous: true,
+        message: searchResult.processedResponse.response,
+      };
+    }
+
+    if (
+      searchResult.processedResponse.status === 204 ||
+      !CommonUtils.isNonEmptyArray(searchResult.processedResponse.response?.data)
+    ) {
+      return {
+        erroneous: true,
+        message: 'No contact is found with record details',
+      };
+    }
+
+    return {
+      erroneous: false,
+      message: searchResult.processedResponse.response.data.map((record) => record.id),
+    };
+  } catch (error) {
+    return {
+      erroneous: true,
+      message: error.message,
+    };
+  }
+};
+
 // ref : https://www.zoho.com/crm/developer/docs/api/v6/upsert-records.html#:~:text=The%20trigger%20input%20can%20be%20workflow%2C%20approval%2C%20or%20blueprint.%20If%20the%20trigger%20is%20not%20mentioned%2C%20the%20workflows%2C%20approvals%20and%20blueprints%20related%20to%20the%20API%20will%20get%20executed.%20Enter%20the%20trigger%20value%20as%20%5B%5D%20to%20not%20execute%20the%20workflows.
 const calculateTrigger = (trigger) => {
   if (trigger === 'Default') {
@@ -232,7 +293,9 @@ module.exports = {
   handleDuplicateCheck,
   handleDuplicateCheckV2,
   searchRecordId,
+  searchRecordIdV2,
   transformToURLParams,
+  transformToURLParamsV2,
   calculateTrigger,
   validateConfigurationIssue,
 };