Release alpha

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@idexio/idex-sdk",
-  "version": "4.0.0-beta.12",
+  "version": "4.0.0-alpha.14",
   "description": "IDEX SDK for Javascript in the browser and Node.js",
   "repository": "git@github.com:idexio/idex-sdk-js.git",
   "license": "MIT",
@@ -103,6 +103,8 @@
     "lint": "eslint --cache 'src/**/*.ts'",
     "lint:fix": "eslint --cache 'src/**/*.ts' --fix",
     "lint:fix:staged": "lint-staged",
+    "lint:fix:staged-and-modified": "eslint --cache --fix $(git diff --name-only HEAD | grep -E '\\.(ts|tsx)$' | xargs) && yarn lint:prettier:staged-and-modified",
+    "lint:prettier:staged-and-modified": "prettier --write $(git diff --name-only HEAD | grep -E '\\.(ts|tsx)$' | xargs)",
     "lint:types": "yarn exec tsc --noEmit",
     "on:commit": "npm-run-all build test --parallel lint:fix:staged lint:types --",
     "orderbook:demo": "yarn node dist/orderbook/demo.js",
@@ -162,7 +164,7 @@
     "eslint-config-airbnb-base": "^15.0.0",
     "eslint-config-prettier": "^9.1.0",
     "eslint-import-resolver-typescript": "^3.6.1",
-    "eslint-plugin-import": "npm:eslint-plugin-i@2.29.1",
+    "eslint-plugin-import": "npm:eslint-plugin-i@latest",
     "eslint-plugin-promise": "^6.1.1",
     "globals": "^15.2.0",
     "lint-staged": "^15.2.2",

src/client/orderBook/realTime.ts

@@ -202,7 +202,7 @@ export class OrderBookRealTimeClient extends EventEmitter<{
       this.unsubscribe();
       this.webSocketClient.disconnect();
     }
-    this.resetInternalState();
+    this.resetInternalState(true);
   }
 
   public async getMaximumTickSizeUnderSpread(market: string) {
@@ -287,9 +287,10 @@ export class OrderBookRealTimeClient extends EventEmitter<{
     }
 
     const beforeL1 = L2toL1OrderBook(book);
+
     for (const update of updates) {
       // outdated sequence, ignore
-      if (book.sequence > update.sequence) {
+      if (book.sequence >= update.sequence) {
         // eslint-disable-next-line no-continue
         continue;
       }
@@ -305,9 +306,9 @@ export class OrderBookRealTimeClient extends EventEmitter<{
             `Missing l2 update sequence, current book is ${book.sequence} message was ${update.sequence}`,
           ),
         );
-        this.unsubscribe();
+        // this.unsubscribe();
         this.resetInternalState();
-        this.subscribe();
+        // this.subscribe();
 
         // eslint-disable-next-line no-await-in-loop
         await this.synchronizeFromRestApi();
@@ -409,10 +410,13 @@ export class OrderBookRealTimeClient extends EventEmitter<{
     }
   }
 
-  private resetInternalState() {
+  private resetInternalState(includeUpdates = false) {
     this.l1OrderBooks.clear();
     this.l2OrderBooks.clear();
-    this.l2OrderBookUpdates.clear();
+    if (includeUpdates) {
+      this.l2OrderBookUpdates.clear();
+    }
+    //
   }
 
   /* Connection management */
@@ -456,7 +460,7 @@ export class OrderBookRealTimeClient extends EventEmitter<{
 
   private webSocketHandleDisconnect() {
     // Assume messages will be lost during disconnection and clear state. State will be re-synchronized again on reconnect
-    this.resetInternalState();
+    this.resetInternalState(true);
 
     this.emit(OrderBookRealTimeClientEvent.disconnected);
   }