Make the set_subscribe_callback boolean an input paramater with defau…

…lt true
bitshares · Mar 22, 2018 · 943539b · 943539b
1 parent 1a27ff7
commit 943539b
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 10 deletions.
diff --git a/examples/chainStore.js b/examples/chainStore.js
@@ -1,16 +1,16 @@
 import {Apis} from "bitsharesjs-ws";
 import {ChainStore} from "../lib";
 
-Apis.instance("wss://bitshares.openledger.info/ws", true).init_promise.then((res) => {
+Apis.instance("wss://eu.nodes.bitshares.ws", true).init_promise.then(res => {
     console.log("connected to:", res[0].network);
-    ChainStore.init().then(() => {
+    ChainStore.init(false).then(() => {
         ChainStore.subscribe(updateState);
     });
 });
 
 let dynamicGlobal = null;
 function updateState(object) {
-    dynamicGlobal = ChainStore.getObject("2.1.0");
+    // dynamicGlobal = ChainStore.getObject("2.1.0");
 
-    console.log("ChainStore object update\n", dynamicGlobal ? dynamicGlobal.toJS() : dynamicGlobal);
+    console.log("ChainStore object update");
 }
diff --git a/lib/chain/src/ChainStore.js b/lib/chain/src/ChainStore.js
@@ -101,21 +101,21 @@ class ChainStore {
         this.dispatched = false;
     }
 
-    resetCache() {
+    resetCache(subscribe_to_new) {
         this.subscribed = false;
         this.subError = null;
         this.clearCache();
         this.head_block_time_string = null;
-        return this.init().catch(err => {
-            console.log("resetCache init error:", err);
+        return this.init(subscribe_to_new).catch(err => {
+            console.log("resetCache init error:", err());
         });
     }
 
     setDispatchFrequency(freq) {
         this.dispatchFrequency = freq;
     }
 
-    init() {
+    init(subscribe_to_new = true) {
         let reconnectCounter = 0;
         var _init = (resolve, reject) => {
             if (this.subscribed) return resolve();
@@ -163,7 +163,7 @@ class ChainStore {
                                     .db_api()
                                     .exec("set_subscribe_callback", [
                                         this.onUpdate.bind(this),
-                                        true
+                                        subscribe_to_new
                                     ])
                                     .then(() => {
                                         console.log(

diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
     "name": "bitsharesjs",
-    "version": "1.5.3",
+    "version": "1.5.4",
     "description":
         "Pure JavaScript Bitshares library for node.js and browsers.",
     "browser": {