@fluidframework/telemetry-utils - npm Package Compare versions

Comparing version 2.0.0-dev-rc.5.0.0.271262 to 2.0.0-dev-rc.5.0.0.271717

dist/config.js

@@ -149,7 +149,5 @@ "use strict";
 class CachedConfigProvider {
-    logger;
-    configCache = new Map();
-    orderedBaseProviders;
     constructor(logger, ...orderedBaseProviders) {
         this.logger = logger;
+        this.configCache = new Map();
         this.orderedBaseProviders = [];
@@ -156,0 +154,0 @@ const knownProviders = new Set();

dist/error.js

@@ -31,4 +31,2 @@ "use strict";
 class GenericError extends errorLogging_js_1.LoggingError {
-    error;
-    errorType = internal_1.FluidErrorTypes.genericError;
     /**
@@ -47,2 +45,3 @@ * Create a new GenericError
         this.error = error;
+        this.errorType = internal_1.FluidErrorTypes.genericError;
     }
@@ -57,5 +56,5 @@ }
 class UsageError extends errorLogging_js_1.LoggingError {
-    errorType = internal_1.FluidErrorTypes.usageError;
     constructor(message, props) {
         super(message, { ...props, usageError: true });
+        this.errorType = internal_1.FluidErrorTypes.usageError;
     }
@@ -71,6 +70,6 @@ }
 class DataCorruptionError extends errorLogging_js_1.LoggingError {
-    errorType = internal_1.FluidErrorTypes.dataCorruptionError;
-    canRetry = false;
     constructor(message, props) {
         super(message, { ...props, dataProcessingError: 1 });
+        this.errorType = internal_1.FluidErrorTypes.dataCorruptionError;
+        this.canRetry = false;
     }
@@ -91,9 +90,9 @@ }
 class DataProcessingError extends errorLogging_js_1.LoggingError {
-    /**
-     * {@inheritDoc IFluidErrorBase.errorType}
-     */
-    errorType = internal_1.FluidErrorTypes.dataProcessingError;
-    canRetry = false;
     constructor(errorMessage, props) {
         super(errorMessage, props);
+        /**
+         * {@inheritDoc IFluidErrorBase.errorType}
+         */
+        this.errorType = internal_1.FluidErrorTypes.dataProcessingError;
+        this.canRetry = false;
     }
@@ -100,0 +99,0 @@ /**

dist/errorLogging.js

@@ -97,7 +97,7 @@ "use strict";
         if ("canRetry" in error) {
-            retryProps ??= {};
+            retryProps ?? (retryProps = {});
             retryProps.canRetry = maybeHasRetry.canRetry;
         }
         if ("retryAfterSeconds" in error) {
-            retryProps ??= {};
+            retryProps ?? (retryProps = {});
             retryProps.retryAfterSeconds = maybeHasRetry.retryAfterSeconds;
@@ -297,4 +297,2 @@ }
 class LoggingError extends Error {
-    omitPropsFromLogging;
-    _errorInstanceId = (0, uuid_1.v4)();
     get errorInstanceId() {
@@ -315,2 +313,3 @@ return this._errorInstanceId;
         this.omitPropsFromLogging = omitPropsFromLogging;
+        this._errorInstanceId = (0, uuid_1.v4)();
         // Don't log this list itself, or the private _errorInstanceId
@@ -378,7 +377,7 @@ omitPropsFromLogging.add("omitPropsFromLogging");
 class NormalizedLoggingError extends LoggingError {
-    // errorType "genericError" is used as a default value throughout the code.
-    // Note that this matches ContainerErrorTypes/DriverErrorTypes' genericError
-    errorType = exports.NORMALIZED_ERROR_TYPE;
     constructor(errorProps) {
         super(errorProps.message);
+        // errorType "genericError" is used as a default value throughout the code.
+        // Note that this matches ContainerErrorTypes/DriverErrorTypes' genericError
+        this.errorType = exports.NORMALIZED_ERROR_TYPE;
         if (errorProps.stack !== undefined) {
@@ -385,0 +384,0 @@ overwriteStack(this, errorProps.stack);

dist/eventEmitterWithErrorHandling.js

@@ -21,3 +21,2 @@ "use strict";
 class EventEmitterWithErrorHandling extends client_utils_1.TypedEventEmitter {
-    errorHandler;
     constructor(
@@ -24,0 +23,0 @@ // TODO: use `unknown` instead (breaking API change)

dist/index.d.ts

@@ -17,2 +17,3 @@ /*!
 export { TelemetryEventPropertyTypeExt, ITelemetryEventExt, ITelemetryGenericEventExt, ITelemetryErrorEventExt, ITelemetryPerformanceEventExt, ITelemetryLoggerExt, ITaggedTelemetryPropertyTypeExt, ITelemetryPropertiesExt, TelemetryEventCategory, } from "./telemetryTypes.js";
+export { type IMeasuredCodeResult, TelemetryEventBatcher } from "./telemetryEventBatcher.js";
 //# sourceMappingURL=index.d.ts.map

dist/index.js

@@ -7,3 +7,3 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.createSampledLogger = exports.SampledTelemetryHelper = exports.ThresholdCounter = exports.MockLogger = exports.TelemetryDataTag = exports.tagCodeArtifacts = exports.tagData = exports.TaggedLoggerAdapter = exports.PerformanceEvent = exports.numberFromString = exports.formatTick = exports.createMultiSinkLogger = exports.createChildLogger = exports.eventNamespaceSeparator = exports.isFluidError = exports.hasErrorInstanceId = exports.safeRaiseEvent = exports.raiseConnectedEvent = exports.disconnectedEventName = exports.connectedEventName = exports.EventEmitterWithErrorHandling = exports.wrapErrorAndLog = exports.wrapError = exports.overwriteStack = exports.normalizeError = exports.NORMALIZED_ERROR_TYPE = exports.LoggingError = exports.isTaggedTelemetryPropertyValue = exports.isILoggingError = exports.isExternalError = exports.getCircularReplacer = exports.generateStack = exports.generateErrorWithStack = exports.extractLogSafeErrorProperties = exports.validatePrecondition = exports.UsageError = exports.GenericError = exports.extractSafePropertiesFromMessage = exports.DataProcessingError = exports.DataCorruptionError = exports.wrapConfigProviderWithDefaults = exports.loggerToMonitoringContext = exports.mixinMonitoringContext = exports.sessionStorageConfigProvider = exports.createChildMonitoringContext = void 0;
+exports.TelemetryEventBatcher = exports.createSampledLogger = exports.SampledTelemetryHelper = exports.ThresholdCounter = exports.MockLogger = exports.TelemetryDataTag = exports.tagCodeArtifacts = exports.tagData = exports.TaggedLoggerAdapter = exports.PerformanceEvent = exports.numberFromString = exports.formatTick = exports.createMultiSinkLogger = exports.createChildLogger = exports.eventNamespaceSeparator = exports.isFluidError = exports.hasErrorInstanceId = exports.safeRaiseEvent = exports.raiseConnectedEvent = exports.disconnectedEventName = exports.connectedEventName = exports.EventEmitterWithErrorHandling = exports.wrapErrorAndLog = exports.wrapError = exports.overwriteStack = exports.normalizeError = exports.NORMALIZED_ERROR_TYPE = exports.LoggingError = exports.isTaggedTelemetryPropertyValue = exports.isILoggingError = exports.isExternalError = exports.getCircularReplacer = exports.generateStack = exports.generateErrorWithStack = exports.extractLogSafeErrorProperties = exports.validatePrecondition = exports.UsageError = exports.GenericError = exports.extractSafePropertiesFromMessage = exports.DataProcessingError = exports.DataCorruptionError = exports.wrapConfigProviderWithDefaults = exports.loggerToMonitoringContext = exports.mixinMonitoringContext = exports.sessionStorageConfigProvider = exports.createChildMonitoringContext = void 0;
 var config_js_1 = require("./config.js");
@@ -65,2 +65,4 @@ Object.defineProperty(exports, "createChildMonitoringContext", { enumerable: true, get: function () { return config_js_1.createChildMonitoringContext; } });
 Object.defineProperty(exports, "createSampledLogger", { enumerable: true, get: function () { return utils_js_1.createSampledLogger; } });
+var telemetryEventBatcher_js_1 = require("./telemetryEventBatcher.js");
+Object.defineProperty(exports, "TelemetryEventBatcher", { enumerable: true, get: function () { return telemetryEventBatcher_js_1.TelemetryEventBatcher; } });
 //# sourceMappingURL=index.js.map

dist/logger.js

@@ -69,8 +69,2 @@ "use strict";
 class TelemetryLogger {
-    namespace;
-    properties;
-    /**
-     * {@inheritDoc eventNamespaceSeparator}
-     */
-    static eventNamespaceSeparator = exports.eventNamespaceSeparator;
     static sanitizePkgName(name) {
@@ -210,2 +204,6 @@ return name.replace("@", "").replace("/", "-");
 /**
+ * {@inheritDoc eventNamespaceSeparator}
+ */
+TelemetryLogger.eventNamespaceSeparator = exports.eventNamespaceSeparator;
+/**
  * @deprecated 0.56, remove TaggedLoggerAdapter once its usage is removed from
@@ -218,3 +216,2 @@ * container-runtime. Issue: #8191
 class TaggedLoggerAdapter {
-    logger;
     constructor(logger) {
@@ -287,3 +284,2 @@ this.logger = logger;
 class ChildLogger extends TelemetryLogger {
-    baseLogger;
     /**
@@ -374,5 +370,2 @@ * Create child logger
 class MultiSinkLogger extends TelemetryLogger {
-    loggers;
-    // This is minimum of minLlogLevel of all loggers.
-    _minLogLevelOfAllLoggers;
     /**
@@ -388,3 +381,3 @@ * Create multiple sink logger (i.e. logger that sends events to multiple sinks)
         if (tryInheritProperties === true) {
-            const merge = (realProperties ??= {});
+            const merge = (realProperties ?? (realProperties = {}));
             loggers
@@ -449,5 +442,2 @@ .filter((l) => l instanceof TelemetryLogger)
 class PerformanceEvent {
-    logger;
-    markers;
-    emitLogs;
     /**
@@ -524,5 +514,2 @@ * Creates an instance of {@link PerformanceEvent} and starts measurements
     }
-    event;
-    startTime = client_utils_1.performance.now();
-    startMark;
     constructor(logger, event, markers = { end: true, cancel: "generic" }, emitLogs = true) {
@@ -532,2 +519,3 @@ this.logger = logger;
         this.emitLogs = emitLogs;
+        this.startTime = client_utils_1.performance.now();
         this.event = { ...event };
@@ -592,3 +580,2 @@ if (this.markers.start) {
     }
-    static eventHits = new Map();
     static shouldReport(event, sampleThreshold) {
@@ -602,2 +589,3 @@ const eventKey = `.${event.category}.${event.eventName}`;
 exports.PerformanceEvent = PerformanceEvent;
+PerformanceEvent.eventHits = new Map();
 /**
@@ -604,0 +592,0 @@ * Takes in an event object, and converts all of its values to a basePropertyType.

dist/mockLogger.js

@@ -17,6 +17,5 @@ "use strict";
 class MockLogger {
-    minLogLevel;
-    events = [];
     constructor(minLogLevel) {
         this.minLogLevel = minLogLevel;
+        this.events = [];
     }
@@ -23,0 +22,0 @@ clear() {

dist/sampledTelemetryHelper.js

@@ -21,9 +21,2 @@ "use strict";
 class SampledTelemetryHelper {
-    eventBase;
-    logger;
-    sampleThreshold;
-    includeAggregateMetrics;
-    perBucketProperties;
-    disposed = false;
-    measurementsMap = new Map();
     /**
@@ -53,2 +46,4 @@ * @param eventBase -
         this.perBucketProperties = perBucketProperties;
+        this.disposed = false;
+        this.measurementsMap = new Map();
     }
@@ -55,0 +50,0 @@ /**

dist/thresholdCounter.js

@@ -14,5 +14,2 @@ "use strict";
 class ThresholdCounter {
-    threshold;
-    logger;
-    thresholdMultiple;
     constructor(threshold, logger, thresholdMultiple = threshold) {
@@ -19,0 +16,0 @@ this.threshold = threshold;

lib/config.js

@@ -144,7 +144,5 @@ /*!
 export class CachedConfigProvider {
-    logger;
-    configCache = new Map();
-    orderedBaseProviders;
     constructor(logger, ...orderedBaseProviders) {
         this.logger = logger;
+        this.configCache = new Map();
         this.orderedBaseProviders = [];
@@ -151,0 +149,0 @@ const knownProviders = new Set();

lib/error.js

@@ -27,4 +27,2 @@ /*!
 export class GenericError extends LoggingError {
-    error;
-    errorType = FluidErrorTypes.genericError;
     /**
@@ -43,2 +41,3 @@ * Create a new GenericError
         this.error = error;
+        this.errorType = FluidErrorTypes.genericError;
     }
@@ -52,5 +51,5 @@ }
 export class UsageError extends LoggingError {
-    errorType = FluidErrorTypes.usageError;
     constructor(message, props) {
         super(message, { ...props, usageError: true });
+        this.errorType = FluidErrorTypes.usageError;
     }
@@ -65,6 +64,6 @@ }
 export class DataCorruptionError extends LoggingError {
-    errorType = FluidErrorTypes.dataCorruptionError;
-    canRetry = false;
     constructor(message, props) {
         super(message, { ...props, dataProcessingError: 1 });
+        this.errorType = FluidErrorTypes.dataCorruptionError;
+        this.canRetry = false;
     }
@@ -84,9 +83,9 @@ }
 export class DataProcessingError extends LoggingError {
-    /**
-     * {@inheritDoc IFluidErrorBase.errorType}
-     */
-    errorType = FluidErrorTypes.dataProcessingError;
-    canRetry = false;
     constructor(errorMessage, props) {
         super(errorMessage, props);
+        /**
+         * {@inheritDoc IFluidErrorBase.errorType}
+         */
+        this.errorType = FluidErrorTypes.dataProcessingError;
+        this.canRetry = false;
     }
@@ -93,0 +92,0 @@ /**

lib/errorLogging.js

@@ -92,7 +92,7 @@ /*!
         if ("canRetry" in error) {
-            retryProps ??= {};
+            retryProps ?? (retryProps = {});
             retryProps.canRetry = maybeHasRetry.canRetry;
         }
         if ("retryAfterSeconds" in error) {
-            retryProps ??= {};
+            retryProps ?? (retryProps = {});
             retryProps.retryAfterSeconds = maybeHasRetry.retryAfterSeconds;
@@ -283,4 +283,2 @@ }
 export class LoggingError extends Error {
-    omitPropsFromLogging;
-    _errorInstanceId = uuid();
     get errorInstanceId() {
@@ -301,2 +299,3 @@ return this._errorInstanceId;
         this.omitPropsFromLogging = omitPropsFromLogging;
+        this._errorInstanceId = uuid();
         // Don't log this list itself, or the private _errorInstanceId
@@ -363,7 +362,7 @@ omitPropsFromLogging.add("omitPropsFromLogging");
 class NormalizedLoggingError extends LoggingError {
-    // errorType "genericError" is used as a default value throughout the code.
-    // Note that this matches ContainerErrorTypes/DriverErrorTypes' genericError
-    errorType = NORMALIZED_ERROR_TYPE;
     constructor(errorProps) {
         super(errorProps.message);
+        // errorType "genericError" is used as a default value throughout the code.
+        // Note that this matches ContainerErrorTypes/DriverErrorTypes' genericError
+        this.errorType = NORMALIZED_ERROR_TYPE;
         if (errorProps.stack !== undefined) {
@@ -370,0 +369,0 @@ overwriteStack(this, errorProps.stack);

lib/eventEmitterWithErrorHandling.js

@@ -18,3 +18,2 @@ /*!
 export class EventEmitterWithErrorHandling extends TypedEventEmitter {
-    errorHandler;
     constructor(
@@ -21,0 +20,0 @@ // TODO: use `unknown` instead (breaking API change)

lib/index.d.ts

@@ -17,2 +17,3 @@ /*!
 export { TelemetryEventPropertyTypeExt, ITelemetryEventExt, ITelemetryGenericEventExt, ITelemetryErrorEventExt, ITelemetryPerformanceEventExt, ITelemetryLoggerExt, ITaggedTelemetryPropertyTypeExt, ITelemetryPropertiesExt, TelemetryEventCategory, } from "./telemetryTypes.js";
+export { type IMeasuredCodeResult, TelemetryEventBatcher } from "./telemetryEventBatcher.js";
 //# sourceMappingURL=index.d.ts.map

lib/index.js

@@ -16,2 +16,3 @@ /*!
 export { createSampledLogger } from "./utils.js";
+export { TelemetryEventBatcher } from "./telemetryEventBatcher.js";
 //# sourceMappingURL=index.js.map

lib/logger.js

@@ -64,8 +64,2 @@ /*!
 export class TelemetryLogger {
-    namespace;
-    properties;
-    /**
-     * {@inheritDoc eventNamespaceSeparator}
-     */
-    static eventNamespaceSeparator = eventNamespaceSeparator;
     static sanitizePkgName(name) {
@@ -204,2 +198,6 @@ return name.replace("@", "").replace("/", "-");
 /**
+ * {@inheritDoc eventNamespaceSeparator}
+ */
+TelemetryLogger.eventNamespaceSeparator = eventNamespaceSeparator;
+/**
  * @deprecated 0.56, remove TaggedLoggerAdapter once its usage is removed from
@@ -212,3 +210,2 @@ * container-runtime. Issue: #8191
 export class TaggedLoggerAdapter {
-    logger;
     constructor(logger) {
@@ -279,3 +276,2 @@ this.logger = logger;
 export class ChildLogger extends TelemetryLogger {
-    baseLogger;
     /**
@@ -364,5 +360,2 @@ * Create child logger
 export class MultiSinkLogger extends TelemetryLogger {
-    loggers;
-    // This is minimum of minLlogLevel of all loggers.
-    _minLogLevelOfAllLoggers;
     /**
@@ -378,3 +371,3 @@ * Create multiple sink logger (i.e. logger that sends events to multiple sinks)
         if (tryInheritProperties === true) {
-            const merge = (realProperties ??= {});
+            const merge = (realProperties ?? (realProperties = {}));
             loggers
@@ -438,5 +431,2 @@ .filter((l) => l instanceof TelemetryLogger)
 export class PerformanceEvent {
-    logger;
-    markers;
-    emitLogs;
     /**
@@ -513,5 +503,2 @@ * Creates an instance of {@link PerformanceEvent} and starts measurements
     }
-    event;
-    startTime = performance.now();
-    startMark;
     constructor(logger, event, markers = { end: true, cancel: "generic" }, emitLogs = true) {
@@ -521,2 +508,3 @@ this.logger = logger;
         this.emitLogs = emitLogs;
+        this.startTime = performance.now();
         this.event = { ...event };
@@ -581,3 +569,2 @@ if (this.markers.start) {
     }
-    static eventHits = new Map();
     static shouldReport(event, sampleThreshold) {
@@ -590,2 +577,3 @@ const eventKey = `.${event.category}.${event.eventName}`;
 }
+PerformanceEvent.eventHits = new Map();
 /**
@@ -592,0 +580,0 @@ * Takes in an event object, and converts all of its values to a basePropertyType.

lib/mockLogger.js

@@ -14,6 +14,5 @@ /*!
 export class MockLogger {
-    minLogLevel;
-    events = [];
     constructor(minLogLevel) {
         this.minLogLevel = minLogLevel;
+        this.events = [];
     }
@@ -20,0 +19,0 @@ clear() {

lib/sampledTelemetryHelper.js

@@ -18,9 +18,2 @@ /*!
 export class SampledTelemetryHelper {
-    eventBase;
-    logger;
-    sampleThreshold;
-    includeAggregateMetrics;
-    perBucketProperties;
-    disposed = false;
-    measurementsMap = new Map();
     /**
@@ -50,2 +43,4 @@ * @param eventBase -
         this.perBucketProperties = perBucketProperties;
+        this.disposed = false;
+        this.measurementsMap = new Map();
     }
@@ -52,0 +47,0 @@ /**

lib/thresholdCounter.js

@@ -11,5 +11,2 @@ /*!
 export class ThresholdCounter {
-    threshold;
-    logger;
-    thresholdMultiple;
     constructor(threshold, logger, thresholdMultiple = threshold) {
@@ -16,0 +13,0 @@ this.threshold = threshold;

package.json

 {
   "name": "@fluidframework/telemetry-utils",
-  "version": "2.0.0-dev-rc.5.0.0.271262",
+  "version": "2.0.0-dev-rc.5.0.0.271717",
   "description": "Collection of telemetry relates utilities for Fluid",
@@ -70,6 +70,6 @@ "homepage": "https://fluidframework.com",
   "dependencies": {
-    "@fluid-internal/client-utils": "2.0.0-dev-rc.5.0.0.271262",
-    "@fluidframework/core-interfaces": "2.0.0-dev-rc.5.0.0.271262",
-    "@fluidframework/core-utils": "2.0.0-dev-rc.5.0.0.271262",
-    "@fluidframework/driver-definitions": "2.0.0-dev-rc.5.0.0.271262",
+    "@fluid-internal/client-utils": "2.0.0-dev-rc.5.0.0.271717",
+    "@fluidframework/core-interfaces": "2.0.0-dev-rc.5.0.0.271717",
+    "@fluidframework/core-utils": "2.0.0-dev-rc.5.0.0.271717",
+    "@fluidframework/driver-definitions": "2.0.0-dev-rc.5.0.0.271717",
     "debug": "^4.3.4",
@@ -81,3 +81,3 @@ "uuid": "^9.0.0"
     "@biomejs/biome": "^1.7.3",
-    "@fluid-internal/mocha-test-setup": "2.0.0-dev-rc.5.0.0.271262",
+    "@fluid-internal/mocha-test-setup": "2.0.0-dev-rc.5.0.0.271717",
     "@fluid-tools/build-cli": "^0.39.0",
@@ -84,0 +84,0 @@ "@fluidframework/build-common": "^2.0.3",

src/index.ts

@@ -79,1 +79,2 @@ /*!
 } from "./telemetryTypes.js";
+export { type IMeasuredCodeResult, TelemetryEventBatcher } from "./telemetryEventBatcher.js";

No alert changes

Improved metrics

Total package byte prevSize

796735

increased by5.59%

Number of package files

158

increased by12.86%

Lines of code

10073

increased by5.64%

Dependency changes

• + Added@fluid-internal/client-utils@2.0.0-dev-rc.5.0.0.271717(transitive)

• + Added@fluidframework/core-interfaces@2.0.0-dev-rc.5.0.0.271717(transitive)

• + Added@fluidframework/core-utils@2.0.0-dev-rc.5.0.0.271717(transitive)

• + Added@fluidframework/driver-definitions@2.0.0-dev-rc.5.0.0.271717(transitive)

• - Removed@fluid-internal/client-utils@2.0.0-dev-rc.5.0.0.271262(transitive)

• - Removed@fluidframework/core-interfaces@2.0.0-dev-rc.5.0.0.271262(transitive)

• - Removed@fluidframework/core-utils@2.0.0-dev-rc.5.0.0.271262(transitive)

• - Removed@fluidframework/driver-definitions@2.0.0-dev-rc.5.0.0.271262(transitive)

• Updated@fluid-internal/client-utils@2.0.0-dev-rc.5.0.0.271717

• Updated@fluidframework/core-interfaces@2.0.0-dev-rc.5.0.0.271717

• Updated@fluidframework/core-utils@2.0.0-dev-rc.5.0.0.271717

• Updated@fluidframework/driver-definitions@2.0.0-dev-rc.5.0.0.271717