serum-vial - npm Package Compare versions

Comparing version 0.9.6 to 0.9.7

dist/data_mapper.d.ts

@@ -14,3 +14,3 @@ import { Market } from '@project-serum/serum';
     private _lastSeenSeqNum;
-    private _lastL3DiffWasInvalid;
+    private _invalidSubsequentL3DiffsCount;
     private _currentL2Snapshot;
@@ -17,0 +17,0 @@ private _currentQuote;

dist/data_mapper.js

@@ -20,3 +20,3 @@ "use strict";
         this._lastSeenSeqNum = undefined;
-        this._lastL3DiffWasInvalid = false;
+        this._invalidSubsequentL3DiffsCount = 0;
         this._currentL2Snapshot = undefined;
@@ -108,3 +108,3 @@ this._currentQuote = undefined;
             const diffIsValid = this._validateL3DiffCorrectness(l3Diff);
-            if (diffIsValid === false && this._lastL3DiffWasInvalid) {
+            if (diffIsValid === false && this._invalidSubsequentL3DiffsCount >= 2) {
                 logger_1.logger.log('warn', 'Resetting data mapper state due to invalid l3diff', {
@@ -120,3 +120,8 @@ market: this._options.symbol,
             }
-            this._lastL3DiffWasInvalid = diffIsValid === false;
+            if (diffIsValid == false) {
+                this._invalidSubsequentL3DiffsCount++;
+            }
+            else {
+                this._invalidSubsequentL3DiffsCount = 0;
+            }
         }
@@ -290,3 +295,3 @@ // initialize only when we have both asks and bids accounts data
         this._currentQuote = undefined;
-        this._lastL3DiffWasInvalid = false;
+        this._invalidSubsequentL3DiffsCount = 0;
     }
@@ -293,0 +298,0 @@ _validateL3DiffCorrectness(l3Diff) {

package.json

 {
   "name": "serum-vial",
-  "version": "0.9.6",
+  "version": "0.9.7",
   "engines": {
@@ -5,0 +5,0 @@ "node": ">=15"

src/data_mapper.ts

@@ -39,3 +39,3 @@ import { EVENT_QUEUE_LAYOUT, Market, Orderbook, getLayoutVersion } from '@project-serum/serum'
   private _lastSeenSeqNum: number | undefined = undefined
-  private _lastL3DiffWasInvalid = false
+  private _invalidSubsequentL3DiffsCount = 0
 
@@ -143,3 +143,3 @@ private _currentL2Snapshot:
 
-      if (diffIsValid === false && this._lastL3DiffWasInvalid) {
+      if (diffIsValid === false && this._invalidSubsequentL3DiffsCount >= 2) {
         logger.log('warn', 'Resetting data mapper state due to invalid l3diff', {
@@ -155,4 +155,7 @@ market: this._options.symbol,
       }
-
-      this._lastL3DiffWasInvalid = diffIsValid === false
+      if (diffIsValid == false) {
+        this._invalidSubsequentL3DiffsCount++
+      } else {
+        this._invalidSubsequentL3DiffsCount = 0
+      }
     }
@@ -375,3 +378,3 @@
     this._currentQuote = undefined
-    this._lastL3DiffWasInvalid = false
+    this._invalidSubsequentL3DiffsCount = 0
   }
@@ -378,0 +381,0 @@

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

268034

increased by0.14%

Lines of code

3958

increased by0.23%

No dependency changes