add vitals e2e scenario

test/e2e/lib/framework/intakeRegistry.ts

@@ -1,5 +1,12 @@
 import type { LogsEvent } from '@datadog/browser-logs'
-import type { RumEvent, RumActionEvent, RumErrorEvent, RumResourceEvent, RumViewEvent } from '@datadog/browser-rum'
+import type {
+  RumEvent,
+  RumActionEvent,
+  RumErrorEvent,
+  RumResourceEvent,
+  RumViewEvent,
+  RumVitalEvent,
+} from '@datadog/browser-rum'
 import type { TelemetryEvent, TelemetryErrorEvent, TelemetryConfigurationEvent } from '@datadog/browser-core'
 import type { BrowserSegment } from '@datadog/browser-rum/src/types'
 import type { BrowserSegmentMetadataAndSegmentSizes } from '@datadog/browser-rum/src/domain/segmentCollection'
@@ -94,6 +101,10 @@ export class IntakeRegistry {
     return this.rumEvents.filter(isRumViewEvent)
   }
 
+  get rumVitalEvents() {
+    return this.rumEvents.filter(isRumVitalEvent)
+  }
+
   //
   // Telemetry
   //
@@ -155,6 +166,10 @@ function isRumErrorEvent(event: RumEvent): event is RumErrorEvent {
   return event.type === 'error'
 }
 
+function isRumVitalEvent(event: RumEvent): event is RumVitalEvent {
+  return event.type === 'vital'
+}
+
 function isTelemetryEvent(event: RumEvent | TelemetryEvent): event is TelemetryEvent {
   return event.type === 'telemetry'
 }

test/e2e/scenario/rum/vitals.scenario.ts

@@ -0,0 +1,26 @@
+import { createTest, flushEvents } from '../../lib/framework'
+import { browserExecuteAsync } from '../../lib/helpers/browser'
+
+describe('vital collection', () => {
+  createTest('send custom duration vital')
+    .withRum({
+      enableExperimentalFeatures: ['custom_vitals'],
+    })
+    .run(async ({ intakeRegistry }) => {
+      await browserExecuteAsync<void>((done) => {
+        // TODO remove cast and unsafe calls when removing the flag
+        const global = window.DD_RUM! as any
+        // eslint-disable-next-line @typescript-eslint/no-unsafe-call
+        global.startDurationVital('foo')
+        setTimeout(() => {
+          // eslint-disable-next-line @typescript-eslint/no-unsafe-call
+          global.stopDurationVital('foo')
+          done()
+        }, 5)
+      })
+      await flushEvents()
+
+      expect(intakeRegistry.rumVitalEvents.length).toBe(1)
+      expect(intakeRegistry.rumVitalEvents[0].vital.custom).toEqual({ foo: jasmine.any(Number) })
+    })
+})