♻️ remove plugin

Author: mormubis

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

@@ -34,17 +34,9 @@ import type {
 } from '../domain/vital/vitalCollection'
 import { startDurationVital, stopDurationVital } from '../domain/vital/vitalCollection'
 import { callPluginsMethod } from '../domain/plugins'
-import { createStreamPlugin } from '../domain/stream'
 import type { StartRumResult } from './startRum'
 import type { RumPublicApiOptions, Strategy } from './rumPublicApi'
 
-declare global {
-  interface Window {
-    DD_STREAM_PLUGIN: ReturnType<typeof createStreamPlugin>
-    DD_STREAM: ReturnType<ReturnType<typeof createStreamPlugin>['createStream']>
-  }
-}
-
 export function createPreStartStrategy(
   { ignoreInitIfSyntheticsWillInjectRum = true, startDeflateWorker }: RumPublicApiOptions,
   trackingConsentState: TrackingConsentState,
@@ -188,10 +180,6 @@ export function createPreStartStrategy(
       initFeatureFlags(initConfiguration.enableExperimentalFeatures)
 
       // Expose the initial configuration regardless of initialization success.
-      window.DD_STREAM_PLUGIN = createStreamPlugin()
-      window.DD_STREAM = window.DD_STREAM_PLUGIN.createStream()
-
-      initConfiguration.plugins = (initConfiguration.plugins ?? []).concat([window.DD_STREAM_PLUGIN.plugin])
       cachedInitConfiguration = initConfiguration
 
       // If we are in a Synthetics test configured to automatically inject a RUM instance, we want

packages/rum-core/src/domain/stream/index.ts

@@ -17,7 +17,7 @@ export type RumEventDomainContext<T extends RumEventType = any> = T extends type
           : T extends typeof RumEventType.VITAL
             ? RumVitalEventDomainContext
             : T extends typeof RumEventType.STREAM
-              ? { streamId: string }
+              ? RumStreamEventDomainContext
               : never
 
 export interface RumViewEventDomainContext {
@@ -62,4 +62,5 @@ export interface RumLongTaskEventDomainContext {
 // eslint-disable-next-line @typescript-eslint/no-empty-object-type
 export interface RumVitalEventDomainContext {}
 
+// eslint-disable-next-line @typescript-eslint/no-empty-object-type
 export interface RumStreamEventDomainContext {}

packages/rum-core/src/domain/stream/metric.ts

@@ -71,4 +71,3 @@ export type { Hooks, DefaultRumEventAttributes, DefaultTelemetryEventAttributes
 export { createHooks } from './domain/hooks'
 export { isSampled } from './domain/sampler/sampler'
 export type { TracingOption, PropagatorType } from './domain/tracing/tracer.types'
-export { createStreamPlugin } from './domain/stream'

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

@@ -119,6 +119,25 @@ export function createRawRumEvent(type: RumEventType, overrides?: Context): RawR
         },
         overrides
       )
+    case RumEventType.STREAM:
+      return combine(
+        {
+          type,
+          _dd: {
+            document_version: 0,
+          },
+          date: 0 as TimeStamp,
+          view: {
+            id: generateUUID(),
+            action: { count: 0 },
+            error: { count: 0 },
+            long_task: { count: 0 },
+            resource: { count: 0 },
+            time_spent: 0 as ServerDuration,
+          },
+        },
+        overrides
+      )
   }
 }
 

packages/rum-core/src/domain/stream/timer.ts

@@ -9,15 +9,12 @@
 // Keep the following in sync with packages/rum-slim/src/entries/main.ts
 import { defineGlobal, getGlobalObject } from '@datadog/browser-core'
 import type { RumPublicApi } from '@datadog/browser-rum-core'
-import { createStreamPlugin, makeRumPublicApi, startRum } from '@datadog/browser-rum-core'
-import { createStream } from '@datadog/browser-rum-core/src/domain/stream/stream'
+import { makeRumPublicApi, startRum } from '@datadog/browser-rum-core'
 import { makeRecorderApi } from '../boot/recorderApi'
 import { createDeflateEncoder, startDeflateWorker } from '../domain/deflate'
 import { lazyLoadRecorder } from '../boot/lazyLoadRecorder'
 import { makeProfilerApi } from '../boot/profilerApi'
 
-export { createStreamPlugin } from '@datadog/browser-rum-core'
-
 export type {
   User,
   Account,