@datadog/browser-core - npm Package Compare versions

Comparing version 4.48.2 to 4.49.0

cjs/boot/init.js

@@ -9,3 +9,3 @@ "use strict";
     var publicApi = (0, polyfills_1.assign)({
-        version: "4.48.2",
+        version: "4.49.0",
         // This API method is intentionally not monitored, since the only thing executed is the
@@ -12,0 +12,0 @@ // user-provided 'callback'.  All SDK usages executed in the callback should be monitored, and

cjs/browser/addEventListener.d.ts

@@ -36,3 +36,4 @@ import type { Configuration } from '../domain/configuration';
     SECURITY_POLICY_VIOLATION = "securitypolicyviolation",
-    SELECTION_CHANGE = "selectionchange"
+    SELECTION_CHANGE = "selectionchange",
+    STORAGE = "storage"
 }
@@ -59,3 +60,5 @@ interface AddEventListenerOptions {
  */
-export declare function addEventListener<Target extends EventTarget, EventName extends keyof EventMapFor<Target> & string>(configuration: Configuration, eventTarget: Target, eventName: EventName, listener: (event: EventMapFor<Target>[EventName]) => void, options?: AddEventListenerOptions): {
+export declare function addEventListener<Target extends EventTarget, EventName extends keyof EventMapFor<Target> & string>(configuration: Configuration, eventTarget: Target, eventName: EventName, listener: (event: EventMapFor<Target>[EventName] & {
+    type: EventName;
+}) => void, options?: AddEventListenerOptions): {
     stop: () => void;
@@ -75,5 +78,7 @@ };
  */
-export declare function addEventListeners<Target extends EventTarget, EventName extends keyof EventMapFor<Target> & string>(_: Configuration, eventTarget: Target, eventNames: EventName[], listener: (event: EventMapFor<Target>[EventName]) => void, { once, capture, passive }?: AddEventListenerOptions): {
+export declare function addEventListeners<Target extends EventTarget, EventName extends keyof EventMapFor<Target> & string>(_: Configuration, eventTarget: Target, eventNames: EventName[], listener: (event: EventMapFor<Target>[EventName] & {
+    type: EventName;
+}) => void, { once, capture, passive }?: AddEventListenerOptions): {
     stop: () => void;
 };
 export {};

cjs/browser/addEventListener.js

@@ -34,3 +34,3 @@ "use strict";
     var _b = _a === void 0 ? {} : _a, once = _b.once, capture = _b.capture, passive = _b.passive;
-    var wrappedListener = (0, monitor_1.monitor)(once
+    var listenerWithMonitor = (0, monitor_1.monitor)(once
         ? function (event) {
@@ -43,6 +43,6 @@ stop();
     var add = (0, getZoneJsOriginalValue_1.getZoneJsOriginalValue)(eventTarget, 'addEventListener');
-    eventNames.forEach(function (eventName) { return add.call(eventTarget, eventName, wrappedListener, options); });
+    eventNames.forEach(function (eventName) { return add.call(eventTarget, eventName, listenerWithMonitor, options); });
     function stop() {
         var remove = (0, getZoneJsOriginalValue_1.getZoneJsOriginalValue)(eventTarget, 'removeEventListener');
-        eventNames.forEach(function (eventName) { return remove.call(eventTarget, eventName, wrappedListener, options); });
+        eventNames.forEach(function (eventName) { return remove.call(eventTarget, eventName, listenerWithMonitor, options); });
     }
@@ -49,0 +49,0 @@ return {

cjs/domain/configuration/configuration.d.ts

@@ -23,2 +23,3 @@ import type { RawTelemetryConfiguration } from '../telemetry';
     trackLongTasks?: boolean | undefined;
+    storeContextsAcrossPages?: boolean | undefined;
     proxy?: string | undefined;
@@ -25,0 +26,0 @@ /**

cjs/domain/configuration/configuration.js

@@ -89,2 +89,3 @@ "use strict";
         allow_fallback_to_local_storage: !!initConfiguration.allowFallbackToLocalStorage,
+        store_contexts_across_pages: !!initConfiguration.storeContextsAcrossPages,
     };
@@ -91,0 +92,0 @@ }

cjs/domain/configuration/endpointBuilder.js

@@ -69,3 +69,3 @@ "use strict";
     var clientToken = _a.clientToken, internalAnalyticsSubdomain = _a.internalAnalyticsSubdomain;
-    var tags = ["sdk_version:".concat("4.48.2"), "api:".concat(api)].concat(configurationTags);
+    var tags = ["sdk_version:".concat("4.49.0"), "api:".concat(api)].concat(configurationTags);
     if (flushReason && (0, experimentalFeatures_1.isExperimentalFeatureEnabled)(experimentalFeatures_1.ExperimentalFeature.COLLECT_FLUSH_REASON)) {
@@ -81,3 +81,3 @@ tags.push("flush_reason:".concat(flushReason));
         "dd-api-key=".concat(clientToken),
-        "dd-evp-origin-version=".concat(encodeURIComponent("4.48.2")),
+        "dd-evp-origin-version=".concat(encodeURIComponent("4.49.0")),
         'dd-evp-origin=browser',
@@ -84,0 +84,0 @@ "dd-request-id=".concat((0, stringUtils_1.generateUUID)()),

cjs/domain/telemetry/rawTelemetryEvent.types.d.ts

@@ -10,3 +10,7 @@ import type { TelemetryEvent, TelemetryConfigurationEvent } from './telemetryEvent.types';
 }
+export interface RuntimeEnvInfo {
+    is_local_file: boolean;
+    is_worker: boolean;
+}
 export type RawTelemetryEvent = TelemetryEvent['telemetry'];
 export type RawTelemetryConfiguration = TelemetryConfigurationEvent['telemetry']['configuration'];

cjs/domain/telemetry/telemetry.d.ts

@@ -54,2 +54,3 @@ import type { Context } from '../../tools/serialisation/context';
         allow_fallback_to_local_storage?: boolean | undefined;
+        store_contexts_across_pages?: boolean | undefined;
         allow_untrusted_events?: boolean | undefined;
@@ -56,0 +57,0 @@ action_name_attribute?: string | undefined;

cjs/domain/telemetry/telemetry.js

@@ -36,5 +36,6 @@ "use strict";
         telemetryConfiguration.telemetryEnabled && (0, numberUtils_1.performDraw)(configuration.telemetryConfigurationSampleRate);
+    var runtimeEnvInfo = getRuntimeEnvInfo();
     onRawTelemetryEventCollected = function (rawEvent) {
         if (telemetryConfiguration.telemetryEnabled) {
-            var event_1 = toTelemetryEvent(telemetryService, rawEvent);
+            var event_1 = toTelemetryEvent(telemetryService, rawEvent, runtimeEnvInfo);
             observable.notify(event_1);
@@ -49,3 +50,3 @@ (0, sendToExtension_1.sendToExtension)('telemetry', event_1);
     });
-    function toTelemetryEvent(telemetryService, event) {
+    function toTelemetryEvent(telemetryService, event, runtimeEnvInfo) {
         return (0, mergeInto_1.combine)({
@@ -55,3 +56,3 @@ type: 'telemetry',
             service: telemetryService,
-            version: "4.48.2",
+            version: "4.49.0",
             source: 'browser',
@@ -61,3 +62,5 @@ _dd: {
             },
-            telemetry: event,
+            telemetry: (0, mergeInto_1.combine)(event, {
+                runtime_env: runtimeEnvInfo,
+            }),
             experimental_features: (0, polyfills_1.arrayFrom)((0, experimentalFeatures_1.getExperimentalFeatures)()),
@@ -75,2 +78,8 @@ }, contextProvider !== undefined ? contextProvider() : {});
 exports.startTelemetry = startTelemetry;
+function getRuntimeEnvInfo() {
+    return {
+        is_local_file: window.location.protocol === 'file:',
+        is_worker: 'WorkerGlobalScope' in self,
+    };
+}
 function startFakeTelemetry() {
@@ -77,0 +86,0 @@ var events = [];

cjs/domain/telemetry/telemetryEvent.types.d.ts

@@ -155,2 +155,6 @@ /**
             /**
+             * Whether contexts are stored in local storage
+             */
+            store_contexts_across_pages?: boolean;
+            /**
              * Whether untrusted events are allowed
@@ -157,0 +161,0 @@ */

cjs/index.d.ts

@@ -38,4 +38,6 @@ export { Configuration, InitConfiguration, validateAndBuildConfiguration, DefaultPrivacyLevel, EndpointBuilder, serializeConfiguration, INTAKE_SITE_AP1, INTAKE_SITE_STAGING, INTAKE_SITE_US1, INTAKE_SITE_US1_FED, INTAKE_SITE_EU1, } from './domain/configuration';
 export { catchUserErrors } from './tools/catchUserErrors';
-export { createContextManager, ContextManager } from './tools/serialisation/contextManager';
-export { warnIfCustomerDataLimitReached, CustomerDataType, CUSTOMER_DATA_BYTES_LIMIT, } from './tools/serialisation/heavyCustomerDataWarning';
+export { createContextManager, ContextManager } from './domain/context/contextManager';
+export { createStoredContextManager, removeStorageListeners } from './domain/context/storedContextManager';
+export { warnIfCustomerDataLimitReached, CUSTOMER_DATA_BYTES_LIMIT } from './domain/context/heavyCustomerDataWarning';
+export { CustomerDataType } from './domain/context/contextConstants';
 export { ValueHistory, ValueHistoryEntry, CLEAR_OLD_VALUES_INTERVAL } from './tools/valueHistory';
@@ -42,0 +44,0 @@ export { readBytesFromStream } from './tools/readBytesFromStream';

cjs/index.js

@@ -18,3 +18,3 @@ "use strict";
 exports.getFileFromStackTraceString = exports.toStackTraceString = exports.createHandlingStack = exports.computeRawError = exports.instrumentSetter = exports.instrumentMethodAndCallOriginal = exports.instrumentMethod = exports.getZoneJsOriginalValue = exports.runOnReadyState = exports.sendToExtension = exports.AbstractLifeCycle = exports.createFlushController = exports.startBatchWithReplica = exports.getEventBridge = exports.canUseEventBridge = exports.createHttpRequest = exports.SESSION_TIME_OUT_DELAY = exports.stopSessionManager = exports.startSessionManager = exports.Observable = exports.setDebugMode = exports.callMonitored = exports.monitor = exports.monitored = exports.addTelemetryConfiguration = exports.isTelemetryReplicationAllowed = exports.resetTelemetry = exports.startFakeTelemetry = exports.addTelemetryError = exports.addTelemetryDebug = exports.startTelemetry = exports.RawReportType = exports.initReportObservable = exports.makePublicApi = exports.defineGlobal = exports.computeStackTrace = exports.trackRuntimeError = exports.ExperimentalFeature = exports.getExperimentalFeatures = exports.resetExperimentalFeatures = exports.addExperimentalFeatures = exports.isExperimentalFeatureEnabled = exports.INTAKE_SITE_EU1 = exports.INTAKE_SITE_US1_FED = exports.INTAKE_SITE_US1 = exports.INTAKE_SITE_STAGING = exports.INTAKE_SITE_AP1 = exports.serializeConfiguration = exports.DefaultPrivacyLevel = exports.validateAndBuildConfiguration = void 0;
-exports.ErrorSource = exports.sanitizeUser = exports.checkUser = exports.getSyntheticsResultId = exports.getSyntheticsTestId = exports.willSyntheticsInjectRum = exports.SESSION_STORE_KEY = exports.STORAGE_POLL_DELAY = exports.readBytesFromStream = exports.CLEAR_OLD_VALUES_INTERVAL = exports.ValueHistory = exports.CUSTOMER_DATA_BYTES_LIMIT = exports.warnIfCustomerDataLimitReached = exports.createContextManager = exports.catchUserErrors = exports.BoundedBuffer = exports.resetConsoleObservable = exports.initConsoleObservable = exports.isPageExitReason = exports.PageExitReason = exports.createPageExitObservable = exports.initFetchObservable = exports.initXhrObservable = exports.deleteCookie = exports.setCookie = exports.getCookie = exports.areCookiesAuthorized = exports.NO_ERROR_STACK_PRESENT_MESSAGE = void 0;
+exports.ErrorSource = exports.sanitizeUser = exports.checkUser = exports.getSyntheticsResultId = exports.getSyntheticsTestId = exports.willSyntheticsInjectRum = exports.SESSION_STORE_KEY = exports.STORAGE_POLL_DELAY = exports.readBytesFromStream = exports.CLEAR_OLD_VALUES_INTERVAL = exports.ValueHistory = exports.CUSTOMER_DATA_BYTES_LIMIT = exports.warnIfCustomerDataLimitReached = exports.removeStorageListeners = exports.createStoredContextManager = exports.createContextManager = exports.catchUserErrors = exports.BoundedBuffer = exports.resetConsoleObservable = exports.initConsoleObservable = exports.isPageExitReason = exports.PageExitReason = exports.createPageExitObservable = exports.initFetchObservable = exports.initXhrObservable = exports.deleteCookie = exports.setCookie = exports.getCookie = exports.areCookiesAuthorized = exports.NO_ERROR_STACK_PRESENT_MESSAGE = void 0;
 var configuration_1 = require("./domain/configuration");
@@ -120,5 +120,8 @@ Object.defineProperty(exports, "validateAndBuildConfiguration", { enumerable: true, get: function () { return configuration_1.validateAndBuildConfiguration; } });
 Object.defineProperty(exports, "catchUserErrors", { enumerable: true, get: function () { return catchUserErrors_1.catchUserErrors; } });
-var contextManager_1 = require("./tools/serialisation/contextManager");
+var contextManager_1 = require("./domain/context/contextManager");
 Object.defineProperty(exports, "createContextManager", { enumerable: true, get: function () { return contextManager_1.createContextManager; } });
-var heavyCustomerDataWarning_1 = require("./tools/serialisation/heavyCustomerDataWarning");
+var storedContextManager_1 = require("./domain/context/storedContextManager");
+Object.defineProperty(exports, "createStoredContextManager", { enumerable: true, get: function () { return storedContextManager_1.createStoredContextManager; } });
+Object.defineProperty(exports, "removeStorageListeners", { enumerable: true, get: function () { return storedContextManager_1.removeStorageListeners; } });
+var heavyCustomerDataWarning_1 = require("./domain/context/heavyCustomerDataWarning");
 Object.defineProperty(exports, "warnIfCustomerDataLimitReached", { enumerable: true, get: function () { return heavyCustomerDataWarning_1.warnIfCustomerDataLimitReached; } });
@@ -125,0 +128,0 @@ Object.defineProperty(exports, "CUSTOMER_DATA_BYTES_LIMIT", { enumerable: true, get: function () { return heavyCustomerDataWarning_1.CUSTOMER_DATA_BYTES_LIMIT; } });

cjs/transport/batch.d.ts

@@ -10,5 +10,7 @@ import type { Context } from '../tools/serialisation/context';
     private upsertBuffer;
+    private flushSubscription;
     constructor(request: HttpRequest, flushController: FlushController, messageBytesLimit: number);
     add(message: Context): void;
     upsert(message: Context, key: string): void;
+    stop(): void;
     private flush;
@@ -15,0 +17,0 @@ private addOrUpdate;

cjs/transport/batch.js

@@ -17,3 +17,3 @@ "use strict";
         this.upsertBuffer = {};
-        this.flushController.flushObservable.subscribe(function (event) { return _this.flush(event); });
+        this.flushSubscription = this.flushController.flushObservable.subscribe(function (event) { return _this.flush(event); });
     }
@@ -26,2 +26,5 @@ Batch.prototype.add = function (message) {
     };
+    Batch.prototype.stop = function () {
+        this.flushSubscription.unsubscribe();
+    };
     Batch.prototype.flush = function (event) {
@@ -28,0 +31,0 @@ var messages = this.pushOnlyBuffer.concat((0, polyfills_1.objectValues)(this.upsertBuffer));

cjs/transport/flushController.js

@@ -13,5 +13,8 @@ "use strict";
     var messagesLimit = _a.messagesLimit, bytesLimit = _a.bytesLimit, durationLimit = _a.durationLimit, pageExitObservable = _a.pageExitObservable, sessionExpireObservable = _a.sessionExpireObservable;
-    var flushObservable = new observable_1.Observable();
-    pageExitObservable.subscribe(function (event) { return flush(event.reason); });
-    sessionExpireObservable.subscribe(function () { return flush('session_expire'); });
+    var pageExitSubscription = pageExitObservable.subscribe(function (event) { return flush(event.reason); });
+    var sessionExpireSubscription = sessionExpireObservable.subscribe(function () { return flush('session_expire'); });
+    var flushObservable = new observable_1.Observable(function () { return function () {
+        pageExitSubscription.unsubscribe();
+        sessionExpireSubscription.unsubscribe();
+    }; });
     var currentBytesCount = 0;
@@ -18,0 +21,0 @@ var currentMessagesCount = 0;

cjs/transport/startBatchWithReplica.d.ts

@@ -15,2 +15,3 @@ import type { Configuration, EndpointBuilder } from '../domain/configuration';
     upsert: (message: T, key: string) => void;
+    stop: () => void;
 };

cjs/transport/startBatchWithReplica.js

@@ -34,2 +34,6 @@ "use strict";
         },
+        stop: function () {
+            primaryBatch.stop();
+            replicaBatch === null || replicaBatch === void 0 ? void 0 : replicaBatch.stop();
+        },
     };
@@ -36,0 +40,0 @@ }

esm/boot/init.js

@@ -6,3 +6,3 @@ import { catchUserErrors } from '../tools/catchUserErrors';
     var publicApi = assign({
-        version: "4.48.2",
+        version: "4.49.0",
         // This API method is intentionally not monitored, since the only thing executed is the
@@ -9,0 +9,0 @@ // user-provided 'callback'.  All SDK usages executed in the callback should be monitored, and

esm/browser/addEventListener.d.ts

@@ -36,3 +36,4 @@ import type { Configuration } from '../domain/configuration';
     SECURITY_POLICY_VIOLATION = "securitypolicyviolation",
-    SELECTION_CHANGE = "selectionchange"
+    SELECTION_CHANGE = "selectionchange",
+    STORAGE = "storage"
 }
@@ -59,3 +60,5 @@ interface AddEventListenerOptions {
  */
-export declare function addEventListener<Target extends EventTarget, EventName extends keyof EventMapFor<Target> & string>(configuration: Configuration, eventTarget: Target, eventName: EventName, listener: (event: EventMapFor<Target>[EventName]) => void, options?: AddEventListenerOptions): {
+export declare function addEventListener<Target extends EventTarget, EventName extends keyof EventMapFor<Target> & string>(configuration: Configuration, eventTarget: Target, eventName: EventName, listener: (event: EventMapFor<Target>[EventName] & {
+    type: EventName;
+}) => void, options?: AddEventListenerOptions): {
     stop: () => void;
@@ -75,5 +78,7 @@ };
  */
-export declare function addEventListeners<Target extends EventTarget, EventName extends keyof EventMapFor<Target> & string>(_: Configuration, eventTarget: Target, eventNames: EventName[], listener: (event: EventMapFor<Target>[EventName]) => void, { once, capture, passive }?: AddEventListenerOptions): {
+export declare function addEventListeners<Target extends EventTarget, EventName extends keyof EventMapFor<Target> & string>(_: Configuration, eventTarget: Target, eventNames: EventName[], listener: (event: EventMapFor<Target>[EventName] & {
+    type: EventName;
+}) => void, { once, capture, passive }?: AddEventListenerOptions): {
     stop: () => void;
 };
 export {};

esm/browser/addEventListener.js

@@ -30,3 +30,3 @@ import { monitor } from '../tools/monitor';
     var _b = _a === void 0 ? {} : _a, once = _b.once, capture = _b.capture, passive = _b.passive;
-    var wrappedListener = monitor(once
+    var listenerWithMonitor = monitor(once
         ? function (event) {
@@ -39,6 +39,6 @@ stop();
     var add = getZoneJsOriginalValue(eventTarget, 'addEventListener');
-    eventNames.forEach(function (eventName) { return add.call(eventTarget, eventName, wrappedListener, options); });
+    eventNames.forEach(function (eventName) { return add.call(eventTarget, eventName, listenerWithMonitor, options); });
     function stop() {
         var remove = getZoneJsOriginalValue(eventTarget, 'removeEventListener');
-        eventNames.forEach(function (eventName) { return remove.call(eventTarget, eventName, wrappedListener, options); });
+        eventNames.forEach(function (eventName) { return remove.call(eventTarget, eventName, listenerWithMonitor, options); });
     }
@@ -45,0 +45,0 @@ return {

esm/domain/configuration/configuration.d.ts

@@ -23,2 +23,3 @@ import type { RawTelemetryConfiguration } from '../telemetry';
     trackLongTasks?: boolean | undefined;
+    storeContextsAcrossPages?: boolean | undefined;
     proxy?: string | undefined;
@@ -25,0 +26,0 @@ /**

esm/domain/configuration/configuration.js

@@ -85,4 +85,5 @@ import { catchUserErrors } from '../../tools/catchUserErrors';
         allow_fallback_to_local_storage: !!initConfiguration.allowFallbackToLocalStorage,
+        store_contexts_across_pages: !!initConfiguration.storeContextsAcrossPages,
     };
 }
 //# sourceMappingURL=configuration.js.map

esm/domain/configuration/endpointBuilder.js

@@ -65,3 +65,3 @@ import { timeStampNow } from '../../tools/utils/timeUtils';
     var clientToken = _a.clientToken, internalAnalyticsSubdomain = _a.internalAnalyticsSubdomain;
-    var tags = ["sdk_version:".concat("4.48.2"), "api:".concat(api)].concat(configurationTags);
+    var tags = ["sdk_version:".concat("4.49.0"), "api:".concat(api)].concat(configurationTags);
     if (flushReason && isExperimentalFeatureEnabled(ExperimentalFeature.COLLECT_FLUSH_REASON)) {
@@ -77,3 +77,3 @@ tags.push("flush_reason:".concat(flushReason));
         "dd-api-key=".concat(clientToken),
-        "dd-evp-origin-version=".concat(encodeURIComponent("4.48.2")),
+        "dd-evp-origin-version=".concat(encodeURIComponent("4.49.0")),
         'dd-evp-origin=browser',
@@ -80,0 +80,0 @@ "dd-request-id=".concat(generateUUID()),

esm/domain/telemetry/rawTelemetryEvent.types.d.ts

@@ -10,3 +10,7 @@ import type { TelemetryEvent, TelemetryConfigurationEvent } from './telemetryEvent.types';
 }
+export interface RuntimeEnvInfo {
+    is_local_file: boolean;
+    is_worker: boolean;
+}
 export type RawTelemetryEvent = TelemetryEvent['telemetry'];
 export type RawTelemetryConfiguration = TelemetryConfigurationEvent['telemetry']['configuration'];

esm/domain/telemetry/telemetry.d.ts

@@ -54,2 +54,3 @@ import type { Context } from '../../tools/serialisation/context';
         allow_fallback_to_local_storage?: boolean | undefined;
+        store_contexts_across_pages?: boolean | undefined;
         allow_untrusted_events?: boolean | undefined;
@@ -56,0 +57,0 @@ action_name_attribute?: string | undefined;

esm/domain/telemetry/telemetry.js

@@ -33,5 +33,6 @@ import { ConsoleApiName } from '../../tools/display';
         telemetryConfiguration.telemetryEnabled && performDraw(configuration.telemetryConfigurationSampleRate);
+    var runtimeEnvInfo = getRuntimeEnvInfo();
     onRawTelemetryEventCollected = function (rawEvent) {
         if (telemetryConfiguration.telemetryEnabled) {
-            var event_1 = toTelemetryEvent(telemetryService, rawEvent);
+            var event_1 = toTelemetryEvent(telemetryService, rawEvent, runtimeEnvInfo);
             observable.notify(event_1);
@@ -46,3 +47,3 @@ sendToExtension('telemetry', event_1);
     });
-    function toTelemetryEvent(telemetryService, event) {
+    function toTelemetryEvent(telemetryService, event, runtimeEnvInfo) {
         return combine({
@@ -52,3 +53,3 @@ type: 'telemetry',
             service: telemetryService,
-            version: "4.48.2",
+            version: "4.49.0",
             source: 'browser',
@@ -58,3 +59,5 @@ _dd: {
             },
-            telemetry: event,
+            telemetry: combine(event, {
+                runtime_env: runtimeEnvInfo,
+            }),
             experimental_features: arrayFrom(getExperimentalFeatures()),
@@ -71,2 +74,8 @@ }, contextProvider !== undefined ? contextProvider() : {});
 }
+function getRuntimeEnvInfo() {
+    return {
+        is_local_file: window.location.protocol === 'file:',
+        is_worker: 'WorkerGlobalScope' in self,
+    };
+}
 export function startFakeTelemetry() {
@@ -73,0 +82,0 @@ var events = [];

esm/domain/telemetry/telemetryEvent.types.d.ts

@@ -155,2 +155,6 @@ /**
             /**
+             * Whether contexts are stored in local storage
+             */
+            store_contexts_across_pages?: boolean;
+            /**
              * Whether untrusted events are allowed
@@ -157,0 +161,0 @@ */

esm/index.d.ts

@@ -38,4 +38,6 @@ export { Configuration, InitConfiguration, validateAndBuildConfiguration, DefaultPrivacyLevel, EndpointBuilder, serializeConfiguration, INTAKE_SITE_AP1, INTAKE_SITE_STAGING, INTAKE_SITE_US1, INTAKE_SITE_US1_FED, INTAKE_SITE_EU1, } from './domain/configuration';
 export { catchUserErrors } from './tools/catchUserErrors';
-export { createContextManager, ContextManager } from './tools/serialisation/contextManager';
-export { warnIfCustomerDataLimitReached, CustomerDataType, CUSTOMER_DATA_BYTES_LIMIT, } from './tools/serialisation/heavyCustomerDataWarning';
+export { createContextManager, ContextManager } from './domain/context/contextManager';
+export { createStoredContextManager, removeStorageListeners } from './domain/context/storedContextManager';
+export { warnIfCustomerDataLimitReached, CUSTOMER_DATA_BYTES_LIMIT } from './domain/context/heavyCustomerDataWarning';
+export { CustomerDataType } from './domain/context/contextConstants';
 export { ValueHistory, ValueHistoryEntry, CLEAR_OLD_VALUES_INTERVAL } from './tools/valueHistory';
@@ -42,0 +44,0 @@ export { readBytesFromStream } from './tools/readBytesFromStream';

esm/index.js

@@ -39,4 +39,5 @@ export { validateAndBuildConfiguration, DefaultPrivacyLevel, serializeConfiguration, INTAKE_SITE_AP1, INTAKE_SITE_STAGING, INTAKE_SITE_US1, INTAKE_SITE_US1_FED, INTAKE_SITE_EU1, } from './domain/configuration';
 export { catchUserErrors } from './tools/catchUserErrors';
-export { createContextManager } from './tools/serialisation/contextManager';
-export { warnIfCustomerDataLimitReached, CUSTOMER_DATA_BYTES_LIMIT, } from './tools/serialisation/heavyCustomerDataWarning';
+export { createContextManager } from './domain/context/contextManager';
+export { createStoredContextManager, removeStorageListeners } from './domain/context/storedContextManager';
+export { warnIfCustomerDataLimitReached, CUSTOMER_DATA_BYTES_LIMIT } from './domain/context/heavyCustomerDataWarning';
 export { ValueHistory, CLEAR_OLD_VALUES_INTERVAL } from './tools/valueHistory';
@@ -43,0 +44,0 @@ export { readBytesFromStream } from './tools/readBytesFromStream';

esm/transport/batch.d.ts

@@ -10,5 +10,7 @@ import type { Context } from '../tools/serialisation/context';
     private upsertBuffer;
+    private flushSubscription;
     constructor(request: HttpRequest, flushController: FlushController, messageBytesLimit: number);
     add(message: Context): void;
     upsert(message: Context, key: string): void;
+    stop(): void;
     private flush;
@@ -15,0 +17,0 @@ private addOrUpdate;

esm/transport/batch.js

@@ -14,3 +14,3 @@ import { display } from '../tools/display';
         this.upsertBuffer = {};
-        this.flushController.flushObservable.subscribe(function (event) { return _this.flush(event); });
+        this.flushSubscription = this.flushController.flushObservable.subscribe(function (event) { return _this.flush(event); });
     }
@@ -23,2 +23,5 @@ Batch.prototype.add = function (message) {
     };
+    Batch.prototype.stop = function () {
+        this.flushSubscription.unsubscribe();
+    };
     Batch.prototype.flush = function (event) {
@@ -25,0 +28,0 @@ var messages = this.pushOnlyBuffer.concat(objectValues(this.upsertBuffer));

esm/transport/flushController.js

@@ -10,5 +10,8 @@ import { Observable } from '../tools/observable';
     var messagesLimit = _a.messagesLimit, bytesLimit = _a.bytesLimit, durationLimit = _a.durationLimit, pageExitObservable = _a.pageExitObservable, sessionExpireObservable = _a.sessionExpireObservable;
-    var flushObservable = new Observable();
-    pageExitObservable.subscribe(function (event) { return flush(event.reason); });
-    sessionExpireObservable.subscribe(function () { return flush('session_expire'); });
+    var pageExitSubscription = pageExitObservable.subscribe(function (event) { return flush(event.reason); });
+    var sessionExpireSubscription = sessionExpireObservable.subscribe(function () { return flush('session_expire'); });
+    var flushObservable = new Observable(function () { return function () {
+        pageExitSubscription.unsubscribe();
+        sessionExpireSubscription.unsubscribe();
+    }; });
     var currentBytesCount = 0;
@@ -15,0 +18,0 @@ var currentMessagesCount = 0;

esm/transport/startBatchWithReplica.d.ts

@@ -15,2 +15,3 @@ import type { Configuration, EndpointBuilder } from '../domain/configuration';
     upsert: (message: T, key: string) => void;
+    stop: () => void;
 };

esm/transport/startBatchWithReplica.js

@@ -31,4 +31,8 @@ import { Batch } from './batch';
         },
+        stop: function () {
+            primaryBatch.stop();
+            replicaBatch === null || replicaBatch === void 0 ? void 0 : replicaBatch.stop();
+        },
     };
 }
 //# sourceMappingURL=startBatchWithReplica.js.map

package.json

 {
   "name": "@datadog/browser-core",
-  "version": "4.48.2",
+  "version": "4.49.0",
   "license": "Apache-2.0",
@@ -26,3 +26,3 @@ "main": "cjs/index.js",
   },
-  "gitHead": "da0c864639fd36358540f38342787b9967638ed4"
+  "gitHead": "4aa09a00c7457f4d4f302b15bc1c1bb645072016"
 }

src/browser/addEventListener.ts

@@ -40,2 +40,3 @@ import { monitor } from '../tools/monitor'
   SELECTION_CHANGE = 'selectionchange',
+  STORAGE = 'storage',
 }
@@ -90,3 +91,3 @@
   eventName: EventName,
-  listener: (event: EventMapFor<Target>[EventName]) => void,
+  listener: (event: EventMapFor<Target>[EventName] & { type: EventName }) => void,
   options?: AddEventListenerOptions
@@ -113,12 +114,12 @@ ) {
   eventNames: EventName[],
-  listener: (event: EventMapFor<Target>[EventName]) => void,
+  listener: (event: EventMapFor<Target>[EventName] & { type: EventName }) => void,
   { once, capture, passive }: AddEventListenerOptions = {}
 ) {
-  const wrappedListener = monitor(
+  const listenerWithMonitor = monitor(
     once
       ? (event: Event) => {
           stop()
-          listener(event as EventMapFor<Target>[EventName])
+          listener(event as unknown as EventMapFor<Target>[EventName] & { type: EventName })
         }
-      : (listener as (event: Event) => void)
+      : (listener as unknown as (event: Event) => void)
   )
@@ -129,7 +130,7 @@
   const add = getZoneJsOriginalValue(eventTarget, 'addEventListener')
-  eventNames.forEach((eventName) => add.call(eventTarget, eventName, wrappedListener, options))
+  eventNames.forEach((eventName) => add.call(eventTarget, eventName, listenerWithMonitor, options))
 
   function stop() {
     const remove = getZoneJsOriginalValue(eventTarget, 'removeEventListener')
-    eventNames.forEach((eventName) => remove.call(eventTarget, eventName, wrappedListener, options))
+    eventNames.forEach((eventName) => remove.call(eventTarget, eventName, listenerWithMonitor, options))
   }
@@ -136,0 +137,0 @@

src/domain/configuration/configuration.ts

@@ -36,2 +36,3 @@ import { catchUserErrors } from '../../tools/catchUserErrors'
   trackLongTasks?: boolean | undefined
+  storeContextsAcrossPages?: boolean | undefined
 
@@ -183,3 +184,4 @@ // transport options
     allow_fallback_to_local_storage: !!initConfiguration.allowFallbackToLocalStorage,
+    store_contexts_across_pages: !!initConfiguration.storeContextsAcrossPages,
   }
 }

src/domain/telemetry/rawTelemetryEvent.types.ts

@@ -13,3 +13,8 @@ import type { TelemetryEvent, TelemetryConfigurationEvent } from './telemetryEvent.types'
 
+export interface RuntimeEnvInfo {
+  is_local_file: boolean
+  is_worker: boolean
+}
+
 export type RawTelemetryEvent = TelemetryEvent['telemetry']
 export type RawTelemetryConfiguration = TelemetryConfigurationEvent['telemetry']['configuration']

src/domain/telemetry/telemetry.ts

@@ -19,3 +19,3 @@ import type { Context } from '../../tools/serialisation/context'
 import type { TelemetryEvent } from './telemetryEvent.types'
-import type { RawTelemetryConfiguration, RawTelemetryEvent } from './rawTelemetryEvent.types'
+import type { RawTelemetryConfiguration, RawTelemetryEvent, RuntimeEnvInfo } from './rawTelemetryEvent.types'
 import { StatusType, TelemetryType } from './rawTelemetryEvent.types'
@@ -66,5 +66,6 @@
 
+  const runtimeEnvInfo = getRuntimeEnvInfo()
   onRawTelemetryEventCollected = (rawEvent: RawTelemetryEvent) => {
     if (telemetryConfiguration.telemetryEnabled) {
-      const event = toTelemetryEvent(telemetryService, rawEvent)
+      const event = toTelemetryEvent(telemetryService, rawEvent, runtimeEnvInfo)
       observable.notify(event)
@@ -81,3 +82,7 @@ sendToExtension('telemetry', event)
 
-  function toTelemetryEvent(telemetryService: TelemetryService, event: RawTelemetryEvent): TelemetryEvent & Context {
+  function toTelemetryEvent(
+    telemetryService: TelemetryService,
+    event: RawTelemetryEvent,
+    runtimeEnvInfo: RuntimeEnvInfo
+  ): TelemetryEvent & Context {
     return combine(
@@ -93,7 +98,9 @@ {
         },
-        telemetry: event as any, // https://github.com/microsoft/TypeScript/issues/48457
+        telemetry: combine(event, {
+          runtime_env: runtimeEnvInfo,
+        }),
         experimental_features: arrayFrom(getExperimentalFeatures()),
       },
       contextProvider !== undefined ? contextProvider() : {}
-    )
+    ) as TelemetryEvent & Context
   }
@@ -109,2 +116,8 @@
 }
+function getRuntimeEnvInfo(): RuntimeEnvInfo {
+  return {
+    is_local_file: window.location.protocol === 'file:',
+    is_worker: 'WorkerGlobalScope' in self,
+  }
+}
 
@@ -111,0 +124,0 @@ export function startFakeTelemetry() {

src/domain/telemetry/telemetryEvent.types.ts

@@ -157,2 +157,6 @@ /* eslint-disable */
       /**
+       * Whether contexts are stored in local storage
+       */
+      store_contexts_across_pages?: boolean
+      /**
        * Whether untrusted events are allowed
@@ -159,0 +163,0 @@ */

src/index.ts

@@ -95,8 +95,6 @@ export {
 export { catchUserErrors } from './tools/catchUserErrors'
-export { createContextManager, ContextManager } from './tools/serialisation/contextManager'
-export {
-  warnIfCustomerDataLimitReached,
-  CustomerDataType,
-  CUSTOMER_DATA_BYTES_LIMIT,
-} from './tools/serialisation/heavyCustomerDataWarning'
+export { createContextManager, ContextManager } from './domain/context/contextManager'
+export { createStoredContextManager, removeStorageListeners } from './domain/context/storedContextManager'
+export { warnIfCustomerDataLimitReached, CUSTOMER_DATA_BYTES_LIMIT } from './domain/context/heavyCustomerDataWarning'
+export { CustomerDataType } from './domain/context/contextConstants'
 export { ValueHistory, ValueHistoryEntry, CLEAR_OLD_VALUES_INTERVAL } from './tools/valueHistory'
@@ -103,0 +101,0 @@ export { readBytesFromStream } from './tools/readBytesFromStream'

src/tools/utils/polyfills.ts

@@ -30,6 +30,3 @@ export function includes(candidate: string, search: string): boolean
 export function find<T>(array: ArrayLike<T>, predicate: (item: T, index: number) => boolean): T | undefined
-export function find(
-  array: ArrayLike<unknown>,
-  predicate: (item: unknown, index: number) => boolean
-): unknown | undefined {
+export function find(array: ArrayLike<unknown>, predicate: (item: unknown, index: number) => boolean): unknown {
   for (let i = 0; i < array.length; i += 1) {
@@ -36,0 +33,0 @@ const item = array[i]

src/transport/batch.ts

@@ -7,2 +7,3 @@ import { display } from '../tools/display'
 import { jsonStringify } from '../tools/serialisation/jsonStringify'
+import type { Subscription } from '../tools/observable'
 import type { HttpRequest } from './httpRequest'
@@ -14,2 +15,3 @@ import type { FlushController, FlushEvent } from './flushController'
   private upsertBuffer: { [key: string]: string } = {}
+  private flushSubscription: Subscription
 
@@ -21,3 +23,3 @@ constructor(
   ) {
-    this.flushController.flushObservable.subscribe((event) => this.flush(event))
+    this.flushSubscription = this.flushController.flushObservable.subscribe((event) => this.flush(event))
   }
@@ -33,2 +35,6 @@
 
+  stop() {
+    this.flushSubscription.unsubscribe()
+  }
+
   private flush(event: FlushEvent) {
@@ -35,0 +41,0 @@ const messages = this.pushOnlyBuffer.concat(objectValues(this.upsertBuffer))

src/transport/flushController.ts

@@ -36,6 +36,9 @@ import type { PageExitEvent, PageExitReason } from '../browser/pageExitObservable'
 }: FlushControllerOptions) {
-  const flushObservable = new Observable<FlushEvent>()
+  const pageExitSubscription = pageExitObservable.subscribe((event) => flush(event.reason))
+  const sessionExpireSubscription = sessionExpireObservable.subscribe(() => flush('session_expire'))
 
-  pageExitObservable.subscribe((event) => flush(event.reason))
-  sessionExpireObservable.subscribe(() => flush('session_expire'))
+  const flushObservable = new Observable<FlushEvent>(() => () => {
+    pageExitSubscription.unsubscribe()
+    sessionExpireSubscription.unsubscribe()
+  })
 
@@ -42,0 +45,0 @@ let currentBytesCount = 0

src/transport/startBatchWithReplica.ts

@@ -51,3 +51,8 @@ import type { Configuration, EndpointBuilder } from '../domain/configuration'
     },
+
+    stop: () => {
+      primaryBatch.stop()
+      replicaBatch?.stop()
+    },
   }
 }

No alert changes

Improved metrics

Total package byte prevSize

980622

increased by2.06%

Number of package files

619

increased by2.31%

Lines of code

17275

increased by1.77%

No dependency changes