✨ Add betaEnableViewUpdates config option

Author: mormubis

packages/browser-core/src/tools/experimentalFeatures.ts

@@ -15,7 +15,6 @@ import { objectHasValue } from './utils/objectUtils'
 // eslint-disable-next-line no-restricted-syntax
 export enum ExperimentalFeature {
   TRACK_INTAKE_REQUESTS = 'track_intake_requests',
-  PARTIAL_VIEW_UPDATES = 'partial_view_updates',
 }
 
 const enabledExperimentalFeatures: Set<ExperimentalFeature> = new Set()

packages/browser-rum-core/src/domain/configuration/configuration.spec.ts

@@ -832,6 +832,7 @@ describe('serializeRumConfiguration', () => {
       profilingSampleRate: 42,
       propagateTraceBaggage: true,
       trackResourceHeaders: true,
+      betaEnableViewUpdates: true,
     }
 
     type MapRumInitConfigurationKey<Key extends string> = Key extends keyof InitConfiguration
@@ -887,6 +888,7 @@ describe('serializeRumConfiguration', () => {
       use_remote_configuration_proxy: true,
       profiling_sample_rate: 42,
       track_resource_headers: 'default_headers',
+      beta_enable_view_updates: true,
     })
   })
 })

packages/browser-rum-core/src/domain/configuration/configuration.ts

@@ -343,6 +343,14 @@ export interface RumInitConfiguration extends InitConfiguration {
    * @category Data Collection
    */
   allowedGraphQlUrls?: Array<MatchOption | GraphQlUrlOption> | undefined
+
+  /**
+   * Enable partial view updates, which reduces bandwidth by sending only changed
+   * fields instead of full view events on intermediate updates.
+   *
+   * @category Beta
+   */
+  betaEnableViewUpdates?: boolean | undefined
 }
 
 export type HybridInitConfiguration = Omit<RumInitConfiguration, 'applicationId' | 'clientToken'>
@@ -386,6 +394,7 @@ export interface RumConfiguration extends Configuration {
   sessionReplaySampleRate: number
   startSessionReplayRecordingManually: boolean
   trackUserInteractions: boolean
+  betaEnableViewUpdates: boolean
   trackViewsManually: boolean
   trackResources: boolean
   trackResourceHeaders: MatchHeader[]
@@ -458,6 +467,7 @@ export function validateAndBuildRumConfiguration(
     workerUrl: initConfiguration.workerUrl,
     compressIntakeRequests: !!initConfiguration.compressIntakeRequests,
     trackUserInteractions: !!(initConfiguration.trackUserInteractions ?? true),
+    betaEnableViewUpdates: !!initConfiguration.betaEnableViewUpdates,
     trackViewsManually: !!initConfiguration.trackViewsManually,
     trackResources: !!(initConfiguration.trackResources ?? true),
     trackResourceHeaders: validateAndBuildTrackResourceHeaders(initConfiguration),
@@ -687,6 +697,7 @@ export function serializeRumConfiguration(configuration: RumInitConfiguration) {
     profiling_sample_rate: configuration.profilingSampleRate,
     use_remote_configuration_proxy: !!configuration.remoteConfigurationProxy,
     track_resource_headers: getTrackResourceHeadersTelemetryValue(configuration.trackResourceHeaders),
+    beta_enable_view_updates: configuration.betaEnableViewUpdates,
     ...baseSerializedConfiguration,
   } satisfies RawTelemetryConfiguration
 }

packages/browser-rum-core/src/transport/startRumBatch.spec.ts

@@ -1,5 +1,4 @@
-import { ExperimentalFeature, Observable, addExperimentalFeatures } from '@datadog/browser-core'
-import { resetExperimentalFeatures } from '@datadog/browser-core/src/tools/experimentalFeatures'
+import { Observable } from '@datadog/browser-core'
 import type { FlushEvent } from '@datadog/browser-core/src/transport/flushController'
 import { registerCleanupTask } from '@datadog/browser-core/test'
 import type { AssembledRumEvent } from '../rawRumEvent.types'
@@ -215,11 +214,6 @@ describe('computeAssembledViewDiff', () => {
 })
 
 describe('startRumBatch partial_view_updates routing', () => {
-  beforeEach(() => {
-    addExperimentalFeatures([ExperimentalFeature.PARTIAL_VIEW_UPDATES])
-    registerCleanupTask(resetExperimentalFeatures)
-  })
-
   it('PARTIAL_VIEW_UPDATE_CHECKPOINT_INTERVAL should be 100', () => {
     expect(PARTIAL_VIEW_UPDATE_CHECKPOINT_INTERVAL).toBe(100)
   })
@@ -288,13 +282,10 @@ function makeView(viewId: string, docVersion: number, overrides: Record<string,
 // ---------------------------------------------------------------------------
 
 describe('createBatchDispatcher', () => {
-  describe('feature flag OFF', () => {
+  describe('feature disabled', () => {
     it('should upsert full VIEW events (legacy behaviour)', () => {
-      resetExperimentalFeatures()
-      registerCleanupTask(resetExperimentalFeatures)
-
       const { batch, upsertSpy } = createMockBatch()
-      const { dispatch } = createBatchDispatcher(batch)
+      const { dispatch } = createBatchDispatcher(batch, false)
 
       const v1 = makeView('view-1', 1)
       const v2 = makeView('view-1', 2)
@@ -308,14 +299,9 @@ describe('createBatchDispatcher', () => {
   })
 
   describe('non-view events', () => {
-    beforeEach(() => {
-      addExperimentalFeatures([ExperimentalFeature.PARTIAL_VIEW_UPDATES])
-      registerCleanupTask(resetExperimentalFeatures)
-    })
-
     it('should always append non-view events', () => {
       const { batch, addSpy, upsertSpy } = createMockBatch()
-      const { dispatch } = createBatchDispatcher(batch)
+      const { dispatch } = createBatchDispatcher(batch, true)
 
       const action = { type: RumEventType.ACTION } as unknown as AssembledRumEvent
       dispatch(action)
@@ -326,14 +312,9 @@ describe('createBatchDispatcher', () => {
   })
 
   describe('optimization 1 — VIEW already in batch', () => {
-    beforeEach(() => {
-      addExperimentalFeatures([ExperimentalFeature.PARTIAL_VIEW_UPDATES])
-      registerCleanupTask(resetExperimentalFeatures)
-    })
-
     it('should upsert the latest full VIEW for every intermediate update', () => {
       const { batch, upsertSpy } = createMockBatch()
-      const { dispatch } = createBatchDispatcher(batch)
+      const { dispatch } = createBatchDispatcher(batch, true)
 
       const v1 = makeView('view-1', 1)
       const v2 = makeView('view-1', 2, {
@@ -363,7 +344,7 @@ describe('createBatchDispatcher', () => {
 
     it('should not emit any view_update events while the VIEW is in the batch', () => {
       const { batch, upsertSpy } = createMockBatch()
-      const { dispatch } = createBatchDispatcher(batch)
+      const { dispatch } = createBatchDispatcher(batch, true)
 
       dispatch(makeView('view-1', 1))
       dispatch(makeView('view-1', 2))
@@ -375,14 +356,9 @@ describe('createBatchDispatcher', () => {
   })
 
   describe('optimization 2 — no VIEW in batch (post-flush)', () => {
-    beforeEach(() => {
-      addExperimentalFeatures([ExperimentalFeature.PARTIAL_VIEW_UPDATES])
-      registerCleanupTask(resetExperimentalFeatures)
-    })
-
     it('should upsert an aggregate view_update after a flush', () => {
       const { batch, upsertSpy, flush } = createMockBatch()
-      const { dispatch } = createBatchDispatcher(batch)
+      const { dispatch } = createBatchDispatcher(batch, true)
 
       dispatch(makeView('view-1', 1))
       flush() // batchHasFullView resets; batchBase = v1
@@ -412,7 +388,7 @@ describe('createBatchDispatcher', () => {
 
     it('should aggregate multiple updates into a single view_update per batch', () => {
       const { batch, upsertSpy, flush } = createMockBatch()
-      const { dispatch } = createBatchDispatcher(batch)
+      const { dispatch } = createBatchDispatcher(batch, true)
 
       dispatch(makeView('view-1', 1))
       flush()
@@ -449,7 +425,7 @@ describe('createBatchDispatcher', () => {
 
     it('should compute the diff from batchBase, not from the previous intermediate update', () => {
       const { batch, upsertSpy, flush } = createMockBatch()
-      const { dispatch } = createBatchDispatcher(batch)
+      const { dispatch } = createBatchDispatcher(batch, true)
 
       // Initial view with action.count = 0
       dispatch(makeView('view-1', 1))
@@ -496,7 +472,7 @@ describe('createBatchDispatcher', () => {
 
     it('should emit nothing if nothing changed since batchBase', () => {
       const { batch, upsertSpy, flush } = createMockBatch()
-      const { dispatch } = createBatchDispatcher(batch)
+      const { dispatch } = createBatchDispatcher(batch, true)
 
       const v1 = makeView('view-1', 1)
       dispatch(v1)
@@ -513,14 +489,9 @@ describe('createBatchDispatcher', () => {
   })
 
   describe('checkpoint', () => {
-    beforeEach(() => {
-      addExperimentalFeatures([ExperimentalFeature.PARTIAL_VIEW_UPDATES])
-      registerCleanupTask(resetExperimentalFeatures)
-    })
-
     it('should send a full VIEW after PARTIAL_VIEW_UPDATE_CHECKPOINT_INTERVAL intermediate updates', () => {
       const { batch, upsertSpy, flush } = createMockBatch()
-      const { dispatch } = createBatchDispatcher(batch)
+      const { dispatch } = createBatchDispatcher(batch, true)
 
       dispatch(makeView('view-1', 1))
       flush()
@@ -553,14 +524,9 @@ describe('createBatchDispatcher', () => {
   })
 
   describe('view lifecycle', () => {
-    beforeEach(() => {
-      addExperimentalFeatures([ExperimentalFeature.PARTIAL_VIEW_UPDATES])
-      registerCleanupTask(resetExperimentalFeatures)
-    })
-
     it('should send a full VIEW when a new view starts', () => {
       const { batch, upsertSpy } = createMockBatch()
-      const { dispatch } = createBatchDispatcher(batch)
+      const { dispatch } = createBatchDispatcher(batch, true)
 
       dispatch(makeView('view-1', 1))
       dispatch(makeView('view-2', 1)) // new view
@@ -574,7 +540,7 @@ describe('createBatchDispatcher', () => {
 
     it('should send a full VIEW when the view ends', () => {
       const { batch, upsertSpy, flush } = createMockBatch()
-      const { dispatch } = createBatchDispatcher(batch)
+      const { dispatch } = createBatchDispatcher(batch, true)
 
       dispatch(makeView('view-1', 1))
       flush()
@@ -603,7 +569,7 @@ describe('createBatchDispatcher', () => {
 
     it('should upsert a stale view-end without resetting state for the current view', () => {
       const { batch, upsertSpy, flush } = createMockBatch()
-      const { dispatch } = createBatchDispatcher(batch)
+      const { dispatch } = createBatchDispatcher(batch, true)
 
       // view-1 starts and flushes
       dispatch(makeView('view-1', 1))
@@ -655,7 +621,7 @@ describe('createBatchDispatcher', () => {
 
     it('should reset to opt-1 after a new view starts following a flush', () => {
       const { batch, upsertSpy, flush } = createMockBatch()
-      const { dispatch } = createBatchDispatcher(batch)
+      const { dispatch } = createBatchDispatcher(batch, true)
 
       dispatch(makeView('view-1', 1))
       flush()

packages/browser-rum-core/src/transport/startRumBatch.ts

@@ -2,8 +2,6 @@ import type { Observable, Encoder, Context } from '@datadog/browser-core'
 import {
   createBatch,
   DeflateEncoderStreamId,
-  isExperimentalFeatureEnabled,
-  ExperimentalFeature,
   sendToExtension,
 } from '@datadog/browser-core'
 import { combine } from '@datadog/js-core/util'
@@ -68,7 +66,8 @@ export function computeAssembledViewDiff(current: RumViewEvent, last: RumViewEve
  * aggregated into a single view_update diff against the last flushed state.
  */
 export function createBatchDispatcher(
-  batch: Pick<ReturnType<typeof createBatch>, 'flushObservable' | 'isEmpty' | 'add' | 'upsert'>
+  batch: Pick<ReturnType<typeof createBatch>, 'flushObservable' | 'isEmpty' | 'add' | 'upsert'>,
+  enableViewUpdates: boolean
 ): { dispatch: (event: AssembledRumEvent) => void; stop: () => void } {
   let lastSentView: RumViewEvent | undefined
   // Base used to compute the aggregate diff for the current batch's view_update.
@@ -96,7 +95,7 @@ export function createBatchDispatcher(
         return
       }
 
-      if (!isExperimentalFeatureEnabled(ExperimentalFeature.PARTIAL_VIEW_UPDATES)) {
+      if (!enableViewUpdates) {
         // Feature OFF: existing behavior — upsert full view
         batch.upsert(serverRumEvent, serverRumEvent.view.id)
         return
@@ -195,7 +194,7 @@ export function startRumBatch(
   })
   sessionExpireObservable.subscribe(() => batch.forceFlush('session_expire'))
 
-  const { dispatch, stop: stopDispatcher } = createBatchDispatcher(batch)
+  const { dispatch, stop: stopDispatcher } = createBatchDispatcher(batch, configuration.betaEnableViewUpdates)
   lifeCycle.subscribe(LifeCycleEventType.RUM_EVENT_COLLECTED, dispatch)
 
   const stopBatch = batch.stop.bind(batch)