chore: rt_batch_tests

rudderlabs · Jan 22, 2024 · efe00ca · efe00ca
1 parent 0dbb307
commit efe00ca
Show file tree

Hide file tree

Showing 181 changed files with 19,960 additions and 31,091 deletions.
diff --git a/test/__tests__/data/af_router_input.json b/test/__tests__/data/af_router_input.json
@@ -56,7 +56,8 @@
       }
     },
     "metadata": {
-      "jobId": 1
+      "jobId": 1,
+      "userId": "u1"
     },
     "destination": {
       "Config": {
@@ -119,7 +120,8 @@
       }
     },
     "metadata": {
-      "jobId": 2
+      "jobId": 2,
+      "userId": "u1"
     },
     "destination": {
       "Config": {
@@ -186,7 +188,8 @@
       }
     },
     "metadata": {
-      "jobId": 3
+      "jobId": 3,
+      "userId": "u1"
     },
     "destination": {
       "Config": {

diff --git a/test/__tests__/data/af_router_output.json b/test/__tests__/data/af_router_output.json
@@ -29,7 +29,8 @@
     },
     "metadata": [
       {
-        "jobId": 1
+        "jobId": 1,
+        "userId": "u1"
       }
     ],
     "batched": false,
@@ -72,7 +73,8 @@
     },
     "metadata": [
       {
-        "jobId": 2
+        "jobId": 2,
+        "userId": "u1"
       }
     ],
     "batched": false,
@@ -116,7 +118,8 @@
     },
     "metadata": [
       {
-        "jobId": 3
+        "jobId": 3,
+        "userId": "u1"
       }
     ],
     "batched": false,

diff --git a/test/__tests__/data/leanplum_router_input.json b/test/__tests__/data/leanplum_router_input.json
@@ -57,7 +57,8 @@
       "sentAt": "2020-03-12T09:05:13.042Z"
     },
     "metadata": {
-      "jobId": 1
+      "jobId": 1,
+      "userId": "u1"
     },
     "destination": {
       "Config": {
@@ -127,7 +128,8 @@
       "sentAt": "2020-03-12T09:05:13.042Z"
     },
     "metadata": {
-      "jobId": 2
+      "jobId": 2,
+      "userId": "u1"
     },
     "destination": {
       "Config": {

diff --git a/test/__tests__/data/leanplum_router_output.json b/test/__tests__/data/leanplum_router_output.json
@@ -71,7 +71,8 @@
     ],
     "metadata": [
       {
-        "jobId": 1
+        "jobId": 1,
+        "userId": "u1"
       }
     ],
     "batched": false,
@@ -158,7 +159,8 @@
     ],
     "metadata": [
       {
-        "jobId": 2
+        "jobId": 2,
+        "userId": "u1"
       }
     ],
     "batched": false,

diff --git a/test/__tests__/data/lemnisk_router.json b/test/__tests__/data/lemnisk_router.json
@@ -81,7 +81,8 @@
           "isProcessorEnabled": true
         },
         "metadata": {
-          "jobId": 1
+          "jobId": 1,
+          "userId": "u1"
         }
       },
       {
@@ -176,7 +177,8 @@
           "destinationType": "DISCORD",
           "jobId": 123,
           "messageId": "4aaecff2-a513-4bbf-9824-c471f4ac9777",
-          "sourceId": "1YhwKyDcKstudlGxkeN5p2wgsrp"
+          "sourceId": "1YhwKyDcKstudlGxkeN5p2wgsrp",
+          "userId": "u1"
         }
       },
       {
@@ -294,7 +296,8 @@
           "destinationType": "DISCORD",
           "jobId": 129,
           "messageId": "8b8d5937-09bc-49dc-a35e-8cd6370575f8",
-          "sourceId": "1YhwKyDcKstudlGxkeN5p2wgsrp"
+          "sourceId": "1YhwKyDcKstudlGxkeN5p2wgsrp",
+          "userId": "u1"
         }
       }
     ],
@@ -369,7 +372,8 @@
         },
         "metadata": [
           {
-            "jobId": 1
+            "jobId": 1,
+            "userId": "u1"
           }
         ],
         "statTags": {
@@ -489,7 +493,8 @@
             "destinationType": "DISCORD",
             "jobId": 123,
             "messageId": "4aaecff2-a513-4bbf-9824-c471f4ac9777",
-            "sourceId": "1YhwKyDcKstudlGxkeN5p2wgsrp"
+            "sourceId": "1YhwKyDcKstudlGxkeN5p2wgsrp",
+            "userId": "u1"
           }
         ],
         "batched": false,
@@ -628,7 +633,8 @@
             "destinationType": "DISCORD",
             "jobId": 129,
             "messageId": "8b8d5937-09bc-49dc-a35e-8cd6370575f8",
-            "sourceId": "1YhwKyDcKstudlGxkeN5p2wgsrp"
+            "sourceId": "1YhwKyDcKstudlGxkeN5p2wgsrp",
+            "userId": "u1"
           }
         ],
         "batched": false,

diff --git a/test/__tests__/data/lytics_router_input.json b/test/__tests__/data/lytics_router_input.json
@@ -113,7 +113,8 @@
       "userId": "rudder123"
     },
     "metadata": {
-      "jobId": 1
+      "jobId": 1,
+      "userId": "u1"
     },
     "destination": {
       "Config": {
@@ -179,7 +180,8 @@
       "userId": "rudder123"
     },
     "metadata": {
-      "jobId": 2
+      "jobId": 2,
+      "userId": "u1"
     },
     "destination": {
       "Config": {

diff --git a/test/__tests__/data/lytics_router_output.json b/test/__tests__/data/lytics_router_output.json
@@ -71,7 +71,8 @@
     },
     "metadata": [
       {
-        "jobId": 1
+        "jobId": 1,
+        "userId": "u1"
       }
     ],
     "batched": false,
@@ -113,7 +114,8 @@
     },
     "metadata": [
       {
-        "jobId": 2
+        "jobId": 2,
+        "userId": "u1"
       }
     ],
     "batched": false,

diff --git a/test/__tests__/data/mailjet_router.json b/test/__tests__/data/mailjet_router.json
@@ -11,7 +11,8 @@
           }
         },
         "metadata": {
-          "jobId": 1
+          "jobId": 1,
+          "userId": "u1"
         },
         "message": {
           "userId": "user@45",
@@ -62,7 +63,8 @@
         },
         "metadata": [
           {
-            "jobId": 1
+            "jobId": 1,
+            "userId": "u1"
           }
         ],
         "batched": true,

diff --git a/test/__tests__/data/mailmodo_router_input.json b/test/__tests__/data/mailmodo_router_input.json
@@ -24,7 +24,8 @@
       "originalTimestamp": "2020-08-28T16:26:06.468Z"
     },
     "metadata": {
-      "jobId": 2
+      "jobId": 2,
+      "userId": "u1"
     },
     "destination": {
       "Config": {
@@ -59,7 +60,8 @@
       "originalTimestamp": "2020-08-28T16:26:06.468Z"
     },
     "metadata": {
-      "jobId": 3
+      "jobId": 3,
+      "userId": "u1"
     },
     "destination": {
       "Config": {
@@ -94,7 +96,8 @@
       "timestamp": "2020-02-02T00:23:09.544Z"
     },
     "metadata": {
-      "jobId": 4
+      "jobId": 4,
+      "userId": "u1"
     },
     "destination": {
       "Config": {
@@ -128,7 +131,8 @@
       "originalTimestamp": "2020-08-28T16:26:06.468Z"
     },
     "metadata": {
-      "jobId": 5
+      "jobId": 5,
+      "userId": "u1"
     },
     "destination": {
       "Config": {

diff --git a/test/__tests__/data/mailmodo_router_output.json b/test/__tests__/data/mailmodo_router_output.json
@@ -38,10 +38,12 @@
     },
     "metadata": [
       {
-        "jobId": 2
+        "jobId": 2,
+        "userId": "u1"
       },
       {
-        "jobId": 4
+        "jobId": 4,
+        "userId": "u1"
       }
     ],
     "batched": true,
@@ -84,7 +86,8 @@
     },
     "metadata": [
       {
-        "jobId": 3
+        "jobId": 3,
+        "userId": "u1"
       }
     ],
     "batched": false,
@@ -102,7 +105,8 @@
     "error": "Missing required value from [\"traits.email\",\"context.traits.email\",\"properties.email\"]",
     "metadata": [
       {
-        "jobId": 5
+        "jobId": 5,
+        "userId": "u1"
       }
     ],
     "statTags": {

diff --git a/test/__tests__/data/moengage_router_input.json b/test/__tests__/data/moengage_router_input.json
@@ -115,7 +115,8 @@
       "userId": "rudder123"
     },
     "metadata": {
-      "jobId": 1
+      "jobId": 1,
+      "userId": "u1"
     },
     "destination": {
       "ID": "1iuTZs6eEZVMm6GjRBe6bNShaL3",
@@ -199,7 +200,8 @@
       "userId": "rudder123"
     },
     "metadata": {
-      "jobId": 2
+      "jobId": 2,
+      "userId": "u1"
     },
     "destination": {
       "ID": "1iuTZs6eEZVMm6GjRBe6bNShaL3",

diff --git a/test/__tests__/data/moengage_router_output.json b/test/__tests__/data/moengage_router_output.json
@@ -86,7 +86,8 @@
     },
     "metadata": [
       {
-        "jobId": 1
+        "jobId": 1,
+        "userId": "u1"
       }
     ],
     "batched": false,
@@ -153,7 +154,8 @@
     },
     "metadata": [
       {
-        "jobId": 2
+        "jobId": 2,
+        "userId": "u1"
       }
     ],
     "batched": false,

diff --git a/test/__tests__/data/monetate_router_input.json b/test/__tests__/data/monetate_router_input.json
@@ -49,7 +49,8 @@
       "userId": "newUser"
     },
     "metadata": {
-      "jobId": 1
+      "jobId": 1,
+      "userId": "u1"
     },
     "destination": {
       "Config": {
@@ -116,7 +117,8 @@
       "userId": "newUser"
     },
     "metadata": {
-      "jobId": 2
+      "jobId": 2,
+      "userId": "u1"
     },
     "destination": {
       "Config": {

diff --git a/test/__tests__/data/monetate_router_output.json b/test/__tests__/data/monetate_router_output.json
@@ -43,7 +43,8 @@
     },
     "metadata": [
       {
-        "jobId": 1
+        "jobId": 1,
+        "userId": "u1"
       }
     ],
     "batched": false,
@@ -95,7 +96,8 @@
     },
     "metadata": [
       {
-        "jobId": 2
+        "jobId": 2,
+        "userId": "u1"
       }
     ],
     "batched": false,

diff --git a/test/__tests__/data/ometria_batch_input.json b/test/__tests__/data/ometria_batch_input.json
@@ -63,7 +63,7 @@
       },
       "originalTimestamp": "2021-10-25T09:40:08.879Z"
     },
-    "metadata": { "jobId": 1 },
+    "metadata": { "jobId": 1, "userId": "u1" },
     "destination": {
       "ID": "1zzHtStW2ZPlullmz6L7DGnmk9V",
       "Name": "ometria-dev",
@@ -172,7 +172,7 @@
       },
       "originalTimestamp": "2021-10-25T09:40:08.879Z"
     },
-    "metadata": { "jobId": 2 },
+    "metadata": { "jobId": 2, "userId": "u1" },
     "destination": {
       "ID": "1zzHtStW2ZPlullmz6L7DGnmk9V",
       "Name": "ometria-dev",