fix: handling invalid timestamp for adjust source

src/v0/sources/adjust/transform.js

@@ -43,11 +43,18 @@ const processEvent = (inputEvent) => {
   message.properties = { ...message.properties, ...customProperties };
 
   if (formattedPayload.created_at) {
-    const ts = new Date(formattedPayload.created_at * 1000).toISOString();
-    message.setProperty('originalTimestamp', ts);
-    message.setProperty('timestamp', ts);
+    const rawTimestamp = formattedPayload.created_at;
+    try {
+      const createdAt = Number(rawTimestamp);
+      const ts = new Date(createdAt * 1000).toISOString();
+      message.setProperty('originalTimestamp', ts);
+      message.setProperty('timestamp', ts);
+    } catch (error) {
+      throw new TransformationError(
+        `[Adjust] Invalid timestamp "${rawTimestamp}": ${error.message}`,
+      );
+    }
   }
-
   // 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;

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();
+    },
+  },
 ];