From 6e3274bfba9e7838d1f81d845a070427b67e75f5 Mon Sep 17 00:00:00 2001
From: shrouti1507 <60211312+shrouti1507@users.noreply.github.com>
Date: Tue, 9 Apr 2024 17:31:10 +0530
Subject: [PATCH] fix: marketo bulk ignore null while checking data type
 mismatch (#3263)

---
 .../marketo_bulk_upload/marketo_bulk_upload.util.test.js  | 6 ++----
 src/v0/destinations/marketo_bulk_upload/util.js           | 8 ++++++--
 2 files changed, 8 insertions(+), 6 deletions(-)

diff --git a/src/v0/destinations/marketo_bulk_upload/marketo_bulk_upload.util.test.js b/src/v0/destinations/marketo_bulk_upload/marketo_bulk_upload.util.test.js
index aa4b3aacc4..13e1b3a09a 100644
--- a/src/v0/destinations/marketo_bulk_upload/marketo_bulk_upload.util.test.js
+++ b/src/v0/destinations/marketo_bulk_upload/marketo_bulk_upload.util.test.js
@@ -514,7 +514,7 @@ describe('checkEventStatusViaSchemaMatching', () => {
   });
 
   // The function correctly handles events with null values.
-  it('should correctly handle events with null values', () => {
+  it('should ignore event properties with null values', () => {
     const event = {
       input: [
         {
@@ -537,8 +537,6 @@ describe('checkEventStatusViaSchemaMatching', () => {
 
     const result = checkEventStatusViaSchemaMatching(event, fieldSchemaMapping);
 
-    expect(result).toEqual({
-      job1: 'invalid id',
-    });
+    expect(result).toEqual({});
   });
 });
diff --git a/src/v0/destinations/marketo_bulk_upload/util.js b/src/v0/destinations/marketo_bulk_upload/util.js
index 4c99ba7483..033239b5e4 100644
--- a/src/v0/destinations/marketo_bulk_upload/util.js
+++ b/src/v0/destinations/marketo_bulk_upload/util.js
@@ -3,6 +3,7 @@ const {
   RetryableError,
   NetworkError,
   TransformationError,
+  isDefinedAndNotNull,
 } = require('@rudderstack/integrations-lib');
 const { handleHttpRequest } = require('../../../adapters/network');
 const tags = require('../../util/tags');
@@ -360,7 +361,6 @@ const getFieldSchemaMap = async (accessToken, munchkinId) => {
       module: 'router',
     },
   );
-
   if (fieldSchemaMapping.response.errors) {
     handleCommonErrorResponse(
       fieldSchemaMapping,
@@ -411,7 +411,11 @@ const checkEventStatusViaSchemaMatching = (event, fieldMap) => {
       const expectedDataType = SCHEMA_DATA_TYPE_MAP[fieldMap[paramName]];
       const actualDataType = typeof paramValue;
 
-      if (!mismatchedFields[job_id] && actualDataType !== expectedDataType) {
+      if (
+        isDefinedAndNotNull(paramValue) &&
+        !mismatchedFields[job_id] &&
+        actualDataType !== expectedDataType
+      ) {
         mismatchedFields[job_id] = `invalid ${paramName}`;
       }
     });