Merge pull request #105 from vsys-host/104-add-option-to-disable-invoice-creation-for-lagging-or-unsynced-crypto-nodes

Add option to disable invoice creation for lagging or unsynced crypto

Author: yukonet

shkeeper/__init__.py

@@ -68,6 +68,7 @@ def create_app(test_config=None):
         DEV_MODE_ENC_PW=os.environ.get("DEV_MODE_ENC_PW"),
         NOTIFICATION_TASK_DELAY=int(os.environ.get("NOTIFICATION_TASK_DELAY", 60)),
         TEMPLATES_AUTO_RELOAD=True,
+        DISABLE_CRYPTO_WHEN_LAGS=bool(os.environ.get("DISABLE_CRYPTO_WHEN_LAGS", False)),
     )
 
     if test_config is None:

shkeeper/api_v1.py

@@ -46,10 +46,12 @@ def list_crypto():
     crypto_list = []
     for crypto in Crypto.instances.values():
         if crypto.wallet.enabled and (crypto.getstatus() != "Offline"):
-            filtered_list.append(crypto.crypto)
-            crypto_list.append(
-                {"name": crypto.crypto, "display_name": crypto.display_name}
-            )
+            if (not app.config.get("DISABLE_CRYPTO_WHEN_LAGS") or 
+                    (app.config.get("DISABLE_CRYPTO_WHEN_LAGS") and crypto.getstatus() == "Synced")):
+                filtered_list.append(crypto.crypto)
+                crypto_list.append(
+                    {"name": crypto.crypto, "display_name": crypto.display_name}
+                )
     return {
         "status": "success",
         "crypto": filtered_list,
@@ -81,6 +83,11 @@ def payment_request(crypto_name):
                 "status": "error",
                 "message": f"{crypto_name} payment gateway is unavailable",
             }
+        if app.config.get("DISABLE_CRYPTO_WHEN_LAGS") and crypto.getstatus() != "Synced":
+            return {
+                "status": "error",
+                "message": f"{crypto_name} payment gateway is unavailable because of lagging",
+            }
 
         req = request.get_json(force=True)
         invoice = Invoice.add(crypto=crypto, request=req)
@@ -116,6 +123,11 @@ def get_crypto_quote(crypto_name):
                 "status": "error",
                 "message": f"{crypto_name} payment gateway is unavailable",
             }
+        if app.config.get("DISABLE_CRYPTO_WHEN_LAGS") and crypto.getstatus() != "Synced":
+            return {
+                "status": "error",
+                "message": f"{crypto_name} payment gateway is unavailable because of lagging",
+            }
 
         req = request.get_json(force=True)
         fiat = req.get("fiat")