wip

Author: mormubis

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

@@ -13,6 +13,7 @@ export function createStreamPlugin(): { plugin: RumPlugin; createStream: () => R
 
   const api: API = {
     get addEvent() {
+      console.log('>>>', 'getter addEvent', addEvent)
       return addEvent ?? store
     },
   }

packages/rum/src/entries/main.ts

@@ -9,7 +9,8 @@
 // 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 { makeRumPublicApi, startRum } 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 { makeRecorderApi } from '../boot/recorderApi'
 import { createDeflateEncoder, startDeflateWorker } from '../domain/deflate'
 import { lazyLoadRecorder } from '../boot/lazyLoadRecorder'
@@ -83,6 +84,8 @@ export const datadogRum = makeRumPublicApi(startRum, recorderApi, profilerApi, {
   createDeflateEncoder,
   sdkName: 'rum',
 })
+// @ts-expect-error TBF
+datadogRum.createStreamPlugin = createStreamPlugin
 
 interface BrowserWindow extends Window {
   DD_RUM?: RumPublicApi

sandbox/index.html

@@ -7,6 +7,9 @@
     <script src="http://localhost:8080/datadog-logs.js"></script>
     <script src="http://localhost:8080/datadog-flagging.js"></script>
     <script>
+      const plugin = DD_RUM.createStreamPlugin()
+      window.stream = plugin.createStream()
+
       DD_RUM.init({
         clientToken: 'xxx',
         applicationId: 'xxx',
@@ -17,6 +20,7 @@
         telemetryConfigurationSampleRate: 100,
         telemetryUsageSampleRate: 100,
         enableExperimentalFeatures: [],
+        plugins: [plugin.plugin]
       })
       DD_LOGS.init({
         clientToken: 'xxx',
@@ -26,6 +30,8 @@
         enableExperimentalFeatures: [],
       })
       DD_FLAGGING.init()
+
+
     </script>
   </head>