@fluidframework/runtime-utils - npm Package Compare versions

Comparing version 0.27.2 to 0.27.3

dist/packageVersion.d.ts

@@ -8,3 +8,3 @@ /*!
 export declare const pkgName = "@fluidframework/runtime-utils";
-export declare const pkgVersion = "0.27.2";
+export declare const pkgVersion = "0.27.3";
 //# sourceMappingURL=packageVersion.d.ts.map

dist/packageVersion.js

@@ -10,3 +10,3 @@ "use strict";
 exports.pkgName = "@fluidframework/runtime-utils";
-exports.pkgVersion = "0.27.2";
+exports.pkgVersion = "0.27.3";
 //# sourceMappingURL=packageVersion.js.map

dist/summarizerNode.js

@@ -118,3 +118,14 @@ "use strict";
                             const newEarliestSeq = newOutstandingOps[0].sequenceNumber;
-                            assert_1.strict(latestSeq < newEarliestSeq, `latestSeq exceeds newEarliestSeq in decodeSummary: ${latestSeq} >= ${newEarliestSeq}`);
+                            if (newEarliestSeq <= latestSeq) {
+                                logger.sendTelemetryEvent({
+                                    eventName: "DuplicateOutstandingOps",
+                                    category: "generic",
+                                    // eslint-disable-next-line max-len
+                                    message: `newEarliestSeq <= latestSeq in decodeSummary: ${newEarliestSeq} <= ${latestSeq}`,
+                                });
+                                while (newOutstandingOps.length > 0
+                                    && newOutstandingOps[0].sequenceNumber <= latestSeq) {
+                                    newOutstandingOps.shift();
+                                }
+                            }
                         }
@@ -266,2 +277,6 @@ outstandingOps = outstandingOps.concat(newOutstandingOps);
             }
+            this.logger.logException({
+                eventName: "SummarizingWithBasePlusOps",
+                category: "error",
+            }, error);
             const summary = encodeSummary(encodeParam, this.outstandingOps);
@@ -268,0 +283,0 @@ this.wipLocalPaths = {

lib/packageVersion.d.ts

@@ -8,3 +8,3 @@ /*!
 export declare const pkgName = "@fluidframework/runtime-utils";
-export declare const pkgVersion = "0.27.2";
+export declare const pkgVersion = "0.27.3";
 //# sourceMappingURL=packageVersion.d.ts.map

lib/packageVersion.js

@@ -8,3 +8,3 @@ /*!
 export const pkgName = "@fluidframework/runtime-utils";
-export const pkgVersion = "0.27.2";
+export const pkgVersion = "0.27.3";
 //# sourceMappingURL=packageVersion.js.map

lib/summarizerNode.js

@@ -116,3 +116,14 @@ /*!
                             const newEarliestSeq = newOutstandingOps[0].sequenceNumber;
-                            assert(latestSeq < newEarliestSeq, `latestSeq exceeds newEarliestSeq in decodeSummary: ${latestSeq} >= ${newEarliestSeq}`);
+                            if (newEarliestSeq <= latestSeq) {
+                                logger.sendTelemetryEvent({
+                                    eventName: "DuplicateOutstandingOps",
+                                    category: "generic",
+                                    // eslint-disable-next-line max-len
+                                    message: `newEarliestSeq <= latestSeq in decodeSummary: ${newEarliestSeq} <= ${latestSeq}`,
+                                });
+                                while (newOutstandingOps.length > 0
+                                    && newOutstandingOps[0].sequenceNumber <= latestSeq) {
+                                    newOutstandingOps.shift();
+                                }
+                            }
                         }
@@ -264,2 +275,6 @@ outstandingOps = outstandingOps.concat(newOutstandingOps);
             }
+            this.logger.logException({
+                eventName: "SummarizingWithBasePlusOps",
+                category: "error",
+            }, error);
             const summary = encodeSummary(encodeParam, this.outstandingOps);
@@ -266,0 +281,0 @@ this.wipLocalPaths = {

package.json

 {
   "name": "@fluidframework/runtime-utils",
-  "version": "0.27.2",
+  "version": "0.27.3",
   "description": "Collection of utility functions for Fluid Runtime",
@@ -58,7 +58,7 @@ "homepage": "https://fluidframework.com",
     "@fluidframework/common-utils": "^0.24.0",
-    "@fluidframework/core-interfaces": "^0.27.2",
-    "@fluidframework/datastore-definitions": "^0.27.2",
+    "@fluidframework/core-interfaces": "^0.27.3",
+    "@fluidframework/datastore-definitions": "^0.27.3",
     "@fluidframework/protocol-base": "^0.1013.0",
     "@fluidframework/protocol-definitions": "^0.1013.0",
-    "@fluidframework/runtime-definitions": "^0.27.2"
+    "@fluidframework/runtime-definitions": "^0.27.3"
   },
@@ -68,3 +68,3 @@ "devDependencies": {
     "@fluidframework/eslint-config-fluid": "^0.19.1",
-    "@fluidframework/mocha-test-setup": "^0.27.2",
+    "@fluidframework/mocha-test-setup": "^0.27.3",
     "@microsoft/api-extractor": "^7.7.2",
@@ -71,0 +71,0 @@ "@types/benchmark": "^1.0.31",

src/packageVersion.ts

@@ -9,2 +9,2 @@ /*!
 export const pkgName = "@fluidframework/runtime-utils";
-export const pkgVersion = "0.27.2";
+export const pkgVersion = "0.27.3";

src/summarizerNode.ts

@@ -152,6 +152,14 @@ /*!
                             const newEarliestSeq = newOutstandingOps[0].sequenceNumber;
-                            assert(
-                                latestSeq < newEarliestSeq,
-                                `latestSeq exceeds newEarliestSeq in decodeSummary: ${latestSeq} >= ${newEarliestSeq}`,
-                            );
+                            if (newEarliestSeq <= latestSeq) {
+                                logger.sendTelemetryEvent({
+                                    eventName:"DuplicateOutstandingOps",
+                                    category: "generic",
+                                    // eslint-disable-next-line max-len
+                                    message: `newEarliestSeq <= latestSeq in decodeSummary: ${newEarliestSeq} <= ${latestSeq}`,
+                                });
+                                while (newOutstandingOps.length > 0
+                                    && newOutstandingOps[0].sequenceNumber <= latestSeq) {
+                                    newOutstandingOps.shift();
+                                }
+                            }
                         }
@@ -328,2 +336,7 @@ outstandingOps = outstandingOps.concat(newOutstandingOps);
             }
+            this.logger.logException({
+                eventName: "SummarizingWithBasePlusOps",
+                category: "error",
+            },
+            error);
             const summary = encodeSummary(encodeParam, this.outstandingOps);
@@ -330,0 +343,0 @@ this.wipLocalPaths = {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

475624

increased by0.93%

Lines of code

5245

increased by0.83%

Dependency changes

• Updated@fluidframework/core-interfaces@^0.27.3

• Updated@fluidframework/datastore-definitions@^0.27.3

• Updated@fluidframework/runtime-definitions@^0.27.3