Add an e2e test

test/e2e/lib/framework/intakeRegistry.ts

@@ -121,6 +121,10 @@ export class IntakeRegistry {
   get replaySegments() {
     return this.replayRequests.map((request) => request.segment)
   }
+
+  get replayRecords() {
+    return this.replayRequests.flatMap((request) => request.segment.records)
+  }
 }
 
 function isLogsIntakeRequest(request: IntakeRequest): request is LogsIntakeRequest {

test/e2e/lib/framework/serverApps/intake.ts

@@ -58,7 +58,7 @@ function computeIntakeRequestInfos(req: express.Request): IntakeRequestInfos {
     return {
       isBridge: true,
       encoding,
-      intakeType: eventType === 'log' ? 'logs' : 'rum',
+      intakeType: eventType === 'log' ? 'logs' : eventType === 'record' ? 'replay' : 'rum',
     }
   }
 
@@ -104,6 +104,23 @@ function readReplayIntakeRequest(
   infos: IntakeRequestInfos & { intakeType: 'replay' }
 ): Promise<ReplayIntakeRequest> {
   return new Promise((resolve, reject) => {
+    if (infos.isBridge) {
+      readStream(req)
+        .then((rawBody) => {
+          resolve({
+            ...infos,
+            segment: {
+              records: rawBody
+                .toString('utf-8')
+                .split('\n')
+                .map((line): any => JSON.parse(line)),
+            },
+          } as ReplayIntakeRequest)
+        })
+        .catch(reject)
+      return
+    }
+
     let segmentPromise: Promise<{
       encoding: string
       filename: string

test/e2e/scenario/eventBridge.scenario.ts

@@ -91,4 +91,14 @@ describe('bridge present', () => {
       expect(intakeRegistry.logsEvents.length).toBe(1)
       expect(intakeRegistry.hasOnlyBridgeRequests).toBe(true)
     })
+
+  createTest('send records to the bridge')
+    .withRum()
+    .withEventBridge()
+    .run(async ({ intakeRegistry }) => {
+      await flushEvents()
+
+      expect(intakeRegistry.replayRecords.length).toBeGreaterThan(0)
+      expect(intakeRegistry.hasOnlyBridgeRequests).toBe(true)
+    })
 })