@fluidframework/sequence - npm Package Compare versions

Comparing version 0.26.3 to 0.26.4

dist/packageVersion.d.ts

@@ -8,3 +8,3 @@ /*!
 export declare const pkgName = "@fluidframework/sequence";
-export declare const pkgVersion = "0.26.3";
+export declare const pkgVersion = "0.26.4";
 //# sourceMappingURL=packageVersion.d.ts.map

dist/packageVersion.js

@@ -10,3 +10,3 @@ "use strict";
 exports.pkgName = "@fluidframework/sequence";
-exports.pkgVersion = "0.26.3";
+exports.pkgVersion = "0.26.4";
 //# sourceMappingURL=packageVersion.js.map

dist/sequence.js

@@ -387,3 +387,22 @@ "use strict";
                 .then((msgs) => {
-                msgs.forEach((m) => this.processMergeTreeMsg(m));
+                msgs.forEach((m) => {
+                    const collabWindow = this.client.getCollabWindow();
+                    if (m.minimumSequenceNumber < collabWindow.minSeq
+                        || m.referenceSequenceNumber < collabWindow.minSeq
+                        || m.sequenceNumber <= collabWindow.minSeq
+                        || m.sequenceNumber <= collabWindow.currentSeq) {
+                        assert_1.strict.fail(`Invalid catchup operations in snapshot: ${JSON.stringify({
+                            op: {
+                                seq: m.sequenceNumber,
+                                minSeq: m.minimumSequenceNumber,
+                                refSeq: m.referenceSequenceNumber,
+                            },
+                            collabWindow: {
+                                seq: collabWindow.currentSeq,
+                                minSeq: collabWindow.minSeq,
+                            },
+                        })}`);
+                    }
+                    this.processMergeTreeMsg(m);
+                });
                 this.loadFinished();
@@ -390,0 +409,0 @@ })

lib/packageVersion.d.ts

@@ -8,3 +8,3 @@ /*!
 export declare const pkgName = "@fluidframework/sequence";
-export declare const pkgVersion = "0.26.3";
+export declare const pkgVersion = "0.26.4";
 //# sourceMappingURL=packageVersion.d.ts.map

lib/packageVersion.js

@@ -8,3 +8,3 @@ /*!
 export const pkgName = "@fluidframework/sequence";
-export const pkgVersion = "0.26.3";
+export const pkgVersion = "0.26.4";
 //# sourceMappingURL=packageVersion.js.map

lib/sequence.js

@@ -375,3 +375,22 @@ /*!
                 .then((msgs) => {
-                msgs.forEach((m) => this.processMergeTreeMsg(m));
+                msgs.forEach((m) => {
+                    const collabWindow = this.client.getCollabWindow();
+                    if (m.minimumSequenceNumber < collabWindow.minSeq
+                        || m.referenceSequenceNumber < collabWindow.minSeq
+                        || m.sequenceNumber <= collabWindow.minSeq
+                        || m.sequenceNumber <= collabWindow.currentSeq) {
+                        assert.fail(`Invalid catchup operations in snapshot: ${JSON.stringify({
+                            op: {
+                                seq: m.sequenceNumber,
+                                minSeq: m.minimumSequenceNumber,
+                                refSeq: m.referenceSequenceNumber,
+                            },
+                            collabWindow: {
+                                seq: collabWindow.currentSeq,
+                                minSeq: collabWindow.minSeq,
+                            },
+                        })}`);
+                    }
+                    this.processMergeTreeMsg(m);
+                });
                 this.loadFinished();
@@ -378,0 +397,0 @@ })

package.json

 {
   "name": "@fluidframework/sequence",
-  "version": "0.26.3",
+  "version": "0.26.4",
   "description": "Distributed sequence",
@@ -59,10 +59,10 @@ "homepage": "https://fluidframework.com",
     "@fluidframework/common-utils": "^0.23.0",
-    "@fluidframework/core-interfaces": "^0.26.3",
-    "@fluidframework/datastore-definitions": "^0.26.3",
-    "@fluidframework/map": "^0.26.3",
-    "@fluidframework/merge-tree": "^0.26.3",
+    "@fluidframework/core-interfaces": "^0.26.4",
+    "@fluidframework/datastore-definitions": "^0.26.4",
+    "@fluidframework/map": "^0.26.4",
+    "@fluidframework/merge-tree": "^0.26.4",
     "@fluidframework/protocol-definitions": "^0.1012.0",
-    "@fluidframework/runtime-utils": "^0.26.3",
-    "@fluidframework/shared-object-base": "^0.26.3",
-    "@fluidframework/telemetry-utils": "^0.26.3",
+    "@fluidframework/runtime-utils": "^0.26.4",
+    "@fluidframework/shared-object-base": "^0.26.4",
+    "@fluidframework/telemetry-utils": "^0.26.4",
     "debug": "^4.1.1",
@@ -75,5 +75,5 @@ "lodash": "^4.17.19"
     "@fluidframework/gitresources": "^0.1012.0",
-    "@fluidframework/mocha-test-setup": "^0.26.3",
+    "@fluidframework/mocha-test-setup": "^0.26.4",
     "@fluidframework/server-services-client": "^0.1012.0",
-    "@fluidframework/test-runtime-utils": "^0.26.3",
+    "@fluidframework/test-runtime-utils": "^0.26.4",
     "@microsoft/api-extractor": "^7.7.2",
@@ -80,0 +80,0 @@ "@types/debug": "^4.1.5",

src/packageVersion.ts

@@ -9,2 +9,2 @@ /*!
 export const pkgName = "@fluidframework/sequence";
-export const pkgVersion = "0.26.3";
+export const pkgVersion = "0.26.4";

src/sequence.ts

@@ -510,3 +510,23 @@ /*!
                 .then((msgs) => {
-                    msgs.forEach((m) => this.processMergeTreeMsg(m));
+                    msgs.forEach((m) => {
+                        const collabWindow = this.client.getCollabWindow();
+                        if (m.minimumSequenceNumber < collabWindow.minSeq
+                            || m.referenceSequenceNumber < collabWindow.minSeq
+                            || m.sequenceNumber <= collabWindow.minSeq
+                            || m.sequenceNumber <= collabWindow.currentSeq) {
+                            assert.fail(`Invalid catchup operations in snapshot: ${
+                                JSON.stringify({
+                                    op:{
+                                        seq: m.sequenceNumber,
+                                        minSeq: m.minimumSequenceNumber,
+                                        refSeq:m.referenceSequenceNumber,
+                                    },
+                                    collabWindow:{
+                                        seq: collabWindow.currentSeq,
+                                        minSeq: collabWindow.minSeq,
+                                    },
+                                })}`);
+                        }
+                        this.processMergeTreeMsg(m);
+                    });
                     this.loadFinished();
@@ -513,0 +533,0 @@ })

No alert changes

Improved metrics

Total package byte prevSize

3723640

increased by0.18%

Lines of code

30234

increased by0.19%

Dependency changes

• Updated@fluidframework/core-interfaces@^0.26.4

• Updated@fluidframework/datastore-definitions@^0.26.4

• Updated@fluidframework/map@^0.26.4

• Updated@fluidframework/merge-tree@^0.26.4

• Updated@fluidframework/runtime-utils@^0.26.4

• Updated@fluidframework/shared-object-base@^0.26.4

• Updated@fluidframework/telemetry-utils@^0.26.4