♻️ move long task contexts to profiler (#4046)

Author: BenoitZugmeyer

packages/rum-core/src/boot/rumPublicApi.spec.ts

@@ -37,7 +37,6 @@ const noopStartRum = (): ReturnType<StartRum> => ({
   getInternalContext: () => undefined,
   lifeCycle: {} as any,
   viewHistory: {} as any,
-  longTaskContexts: {} as any,
   session: {} as any,
   stopSession: () => undefined,
   startDurationVital: () => ({}) as DurationVitalReference,

packages/rum-core/src/boot/rumPublicApi.ts

@@ -56,7 +56,6 @@ import { createCustomVitalsState } from '../domain/vital/vitalCollection'
 import { callPluginsMethod } from '../domain/plugins'
 import type { Hooks } from '../domain/hooks'
 import type { SdkName } from '../domain/contexts/defaultContext'
-import type { LongTaskContexts } from '../domain/longTask/longTaskCollection'
 import type { ActionOptions } from '../domain/action/trackManualActions'
 import type { ResourceOptions, ResourceStopOptions } from '../domain/resource/trackManualResources'
 import { createPreStartStrategy } from './preStartRum'
@@ -528,7 +527,6 @@ export interface ProfilerApi {
     configuration: RumConfiguration,
     sessionManager: RumSessionManager,
     viewHistory: ViewHistory,
-    longTaskContexts: LongTaskContexts,
     createEncoder: (streamId: DeflateEncoderStreamId) => Encoder
   ) => void
 }
@@ -626,7 +624,6 @@ export function makeRumPublicApi(
         configuration,
         startRumResult.session,
         startRumResult.viewHistory,
-        startRumResult.longTaskContexts,
         createEncoder
       )
 

packages/rum-core/src/boot/startRum.ts

@@ -227,7 +227,7 @@ export function startRumEventCollection(
   const resourceCollection = startResourceCollection(lifeCycle, configuration, pageStateHistory)
   cleanupTasks.push(resourceCollection.stop)
 
-  const { stop: stopLongTaskCollection, longTaskContexts } = startLongTaskCollection(lifeCycle, configuration)
+  const { stop: stopLongTaskCollection } = startLongTaskCollection(lifeCycle, configuration)
   cleanupTasks.push(stopLongTaskCollection)
 
   const { addError } = startErrorCollection(lifeCycle, configuration, bufferedDataObservable)
@@ -268,7 +268,6 @@ export function startRumEventCollection(
     globalContext,
     userContext,
     accountContext,
-    longTaskContexts,
     stop: () => cleanupTasks.forEach((task) => task()),
   }
 }

packages/rum-core/src/domain/action/actionCollection.spec.ts

@@ -64,7 +64,7 @@ describe('actionCollection', () => {
       events: [event],
     })
 
-    expect(rawRumEvents[0].startTime).toBe(1234 as RelativeTime)
+    expect(rawRumEvents[0].startClocks.relative).toBe(1234 as RelativeTime)
     expect(rawRumEvents[0].rawRumEvent).toEqual({
       action: {
         error: {
@@ -116,7 +116,7 @@ describe('actionCollection', () => {
       context: { foo: 'bar' },
     })
 
-    expect(rawRumEvents[0].startTime).toBe(1234 as RelativeTime)
+    expect(rawRumEvents[0].startClocks.relative).toBe(1234 as RelativeTime)
     expect(rawRumEvents[0].rawRumEvent).toEqual({
       action: {
         id: jasmine.any(String),

packages/rum-core/src/domain/action/actionCollection.ts

@@ -138,7 +138,7 @@ function processAction(action: AutoAction | ManualAction): RawRumEventCollectedD
         : { context: action.context }),
     },
     duration: action.duration,
-    startTime: action.startClocks.relative,
+    startClocks: action.startClocks,
     domainContext: isAuto ? { events: action.events } : { handlingStack: action.handlingStack },
   }
 }

packages/rum-core/src/domain/assembly.spec.ts

@@ -1,5 +1,12 @@
 import type { ClocksState, RelativeTime, TimeStamp } from '@datadog/browser-core'
-import { ErrorSource, HookNames, ONE_MINUTE, display, startGlobalContext } from '@datadog/browser-core'
+import {
+  ErrorSource,
+  HookNames,
+  ONE_MINUTE,
+  display,
+  relativeToClocks,
+  startGlobalContext,
+} from '@datadog/browser-core'
 import type { Clock } from '@datadog/browser-core/test'
 import { registerCleanupTask, mockClock } from '@datadog/browser-core/test'
 import {
@@ -461,7 +468,7 @@ describe('rum assembly', () => {
 
       notifyRawRumEvent(lifeCycle, {
         rawRumEvent: createRawRumEvent(RumEventType.ACTION),
-        startTime: 123 as RelativeTime,
+        startClocks: relativeToClocks(123 as RelativeTime),
       })
 
       expect(sessionManager.findTrackedSession).toHaveBeenCalledWith(123 as RelativeTime)
@@ -567,11 +574,11 @@ describe('rum assembly', () => {
 
 function notifyRawRumEvent<E extends RawRumEvent>(
   lifeCycle: LifeCycle,
-  partialData: Omit<RawRumEventCollectedData<E>, 'startTime' | 'domainContext'> &
-    Partial<Pick<RawRumEventCollectedData<E>, 'startTime' | 'domainContext'>>
+  partialData: Omit<RawRumEventCollectedData<E>, 'startClocks' | 'domainContext'> &
+    Partial<Pick<RawRumEventCollectedData<E>, 'startClocks' | 'domainContext'>>
 ) {
   const fullData = {
-    startTime: 0 as RelativeTime,
+    startClocks: relativeToClocks(0 as RelativeTime),
     domainContext: {} as RumEventDomainContext,
     ...partialData,
   }

packages/rum-core/src/domain/assembly.ts

@@ -92,12 +92,12 @@ export function startRumAssembly(
 
   lifeCycle.subscribe(
     LifeCycleEventType.RAW_RUM_EVENT_COLLECTED,
-    ({ startTime, duration, rawRumEvent, domainContext }) => {
+    ({ startClocks, duration, rawRumEvent, domainContext }) => {
       const defaultRumEventAttributes = hooks.triggerHook(HookNames.Assemble, {
         eventType: rawRumEvent.type,
         rawRumEvent,
         domainContext,
-        startTime,
+        startTime: startClocks.relative,
         duration,
       } as AssembleHookParams)!
 

packages/rum-core/src/domain/error/errorCollection.spec.ts

@@ -65,10 +65,11 @@ describe('error collection', () => {
       it(`notifies a raw rum error event from ${testCase}`, () => {
         setupErrorCollection()
 
+        const startClocks = { relative: 1234 as RelativeTime, timeStamp: 123456789 as TimeStamp }
         addError({
           error,
           handlingStack: 'Error: handling foo',
-          startClocks: { relative: 1234 as RelativeTime, timeStamp: 123456789 as TimeStamp },
+          startClocks,
         })
 
         expect(rawRumEvents.length).toBe(1)
@@ -92,7 +93,7 @@ describe('error collection', () => {
             type: RumEventType.ERROR,
             context: undefined,
           },
-          startTime: 1234 as RelativeTime,
+          startClocks,
           domainContext: {
             error,
             handlingStack: 'Error: handling foo',
@@ -239,7 +240,7 @@ describe('error collection', () => {
         },
       })
 
-      expect(rawRumEvents[0].startTime).toBe(1234 as RelativeTime)
+      expect(rawRumEvents[0].startClocks.relative).toBe(1234 as RelativeTime)
       expect(rawRumEvents[0].rawRumEvent).toEqual({
         date: jasmine.any(Number),
         error: {

packages/rum-core/src/domain/error/errorCollection.ts

@@ -98,7 +98,7 @@ function processError(error: RawError): RawRumEventCollectedData<RawRumErrorEven
 
   return {
     rawRumEvent,
-    startTime: error.startClocks.relative,
+    startClocks: error.startClocks,
     domainContext,
   }
 }

packages/rum-core/src/domain/event/eventCollection.spec.ts

@@ -33,7 +33,7 @@ describe('eventCollection', () => {
     eventCollection.addEvent(startTime, event, domainContext, duration)
 
     expect(notifySpy).toHaveBeenCalledWith(LifeCycleEventType.RAW_RUM_EVENT_COLLECTED, {
-      startTime,
+      startClocks: { relative: startTime, timeStamp: jasmine.any(Number) },
       rawRumEvent: event,
       domainContext,
       duration,