feat(persistence): add persistence policy with max retry && final callback

feat(persistence): add persistence policy with max retry && final callback

Author: 7kharov

lib/electrum_client.js

@@ -9,7 +9,8 @@ class ElectrumClient extends Client {
         this.timeLastCall = 0;
     }
 
-    initElectrum(electrumConfig) {
+    initElectrum(electrumConfig, persistencePolicy = { maxRetry: 1000, callback: null }) {
+        this.persistencePolicy = persistencePolicy;
         this.electrumConfig = electrumConfig;
         this.timeLastCall = 0;
         return this
@@ -20,18 +21,13 @@ class ElectrumClient extends Client {
 
     // Override parent
     request(method, params) {
-        console.log(`Call ${method} with ${JSON.stringify(params)}`);
         this.timeLastCall = new Date().getTime();
          const parentPromise = super.request(method, params);
          return parentPromise
             .then((response) => {
                 this.keepAlive();
                 return response;
             })
-            .catch((error) => {
-                console.log("Electrum_client catch:", error);
-                return Promise.reject(error);
-            })
         ;
     }
 
@@ -45,7 +41,14 @@ class ElectrumClient extends Client {
         ];
         list.forEach(event => this.subscribe.removeAllListeners(event));
         setTimeout(() => {
-            this.reconnect();
+            if (this.persistencePolicy != null && this.persistencePolicy.maxRetry > 0) {
+                this.reconnect();
+                this.persistencePolicy.maxRetry -= 1;
+            } else if (this.persistencePolicy != null && this.persistencePolicy.callback != null) {
+                this.persistencePolicy.callback();
+            } else if (this.persistencePolicy == null) {
+                this.reconnect();
+            }
         }, 10000);
     }