fix: handling invalid timestamp for adjust source

src/v0/sources/adjust/transform.js

@@ -7,6 +7,7 @@ const Message = require('../message');
 const { CommonUtils } = require('../../../util/common');
 const { excludedFieldList } = require('./config');
 const { extractCustomFields, generateUUID } = require('../../util');
+const { processTimestamp } = require('./utils');
 
 // ref : https://help.adjust.com/en/article/global-callbacks#general-recommended-placeholders
 // import mapping json using JSON.parse to preserve object key order
@@ -43,11 +44,10 @@ const processEvent = (inputEvent) => {
   message.properties = { ...message.properties, ...customProperties };
 
   if (formattedPayload.created_at) {
-    const ts = new Date(formattedPayload.created_at * 1000).toISOString();
+    const ts = processTimestamp(formattedPayload.created_at);
     message.setProperty('originalTimestamp', ts);
     message.setProperty('timestamp', ts);
   }
-
   // adjust does not has the concept of user but we need to set some random anonymousId in order to make the server accept the message
   message.anonymousId = generateUUID();
   return message;

src/v0/sources/adjust/utils.js

@@ -0,0 +1,14 @@
+const { TransformationError } = require('@rudderstack/integrations-lib');
+
+const processTimestamp = (rawTimestamp) => {
+  try {
+    const createdAt = Number(rawTimestamp);
+    return new Date(createdAt * 1000).toISOString();
+  } catch (error) {
+    throw new TransformationError(`[Adjust] Invalid timestamp "${rawTimestamp}": ${error.message}`);
+  }
+};
+
+module.exports = {
+  processTimestamp,
+};

test/integrations/sources/adjust/data.ts

@@ -125,4 +125,57 @@ export const data = [
       defaultMockFns();
     },
   },
+  {
+    name: 'adjust',
+    description: 'Simple track call with wrong created at',
+    module: 'source',
+    version: 'v0',
+    skipGo: 'FIXME',
+    input: {
+      request: {
+        body: [
+          {
+            id: 'adjust',
+            query_parameters: {
+              gps_adid: ['38400000-8cf0-11bd-b23e-10b96e40000d'],
+              adid: ['18546f6171f67e29d1cb983322ad1329'],
+              tracker_token: ['abc'],
+              custom: ['custom'],
+              tracker_name: ['dummy'],
+              created_at: ['test'],
+              event_name: ['Click'],
+            },
+            updated_at: '2023-02-10T12:16:07.251Z',
+            created_at: 'test',
+          },
+        ],
+        method: 'POST',
+        headers: {
+          'Content-Type': 'application/json',
+        },
+      },
+      pathSuffix: '',
+    },
+    output: {
+      response: {
+        status: 200,
+        body: [
+          {
+            error: '[Adjust] Invalid timestamp "test": Invalid time value',
+            statTags: {
+              destinationId: 'Non determinable',
+              errorCategory: 'transformation',
+              implementation: 'native',
+              module: 'source',
+              workspaceId: 'Non determinable',
+            },
+            statusCode: 400,
+          },
+        ],
+      },
+    },
+    mockFns: () => {
+      defaultMockFns();
+    },
+  },
 ];