v0.1.39 Web3 now has a flag whether SubSquid is available on the chain. Used in eth.get_logs to only try SubSquid if it's generally available

Author: simone1999

IceCreamSwapWeb3/EthAdvanced.py

@@ -181,7 +181,7 @@ def get_logs(
             use_subsquid=use_subsquid,
         )
 
-        if use_subsquid and from_block < self.w3.latest_seen_block - self.w3.unstable_blocks:
+        if use_subsquid and self.w3.subsquid_available and from_block < self.w3.latest_seen_block - self.w3.unstable_blocks:
             kwargs["use_subsquid"] = False  # make sure we only try once with Subsquid
             try:
                 # trying to get logs from SubSquid

IceCreamSwapWeb3/Web3Advanced.py

@@ -10,6 +10,7 @@
 from .BatchRetryMiddleware import BatchRetryMiddleware
 from .EthAdvanced import EthAdvanced
 from .Multicall import MultiCall
+from .Subsquid import get_endpoints
 from .Web3ErrorHandlerPatch import patch_error_formatters
 from .FastChecksumAddress import to_checksum_address
 
@@ -77,6 +78,7 @@ def __init__(
         if not self.revert_reason_available:
             print(f"RPC {self.node_url} does not return revert reasons")
         self.overwrites_available: bool = self._check_overwrites_available()
+        self.subsquid_available: bool = self._check_subsquid_available()
 
         self.middleware_onion.inject(BatchRetryMiddleware, layer=0, name="batch_retry")  # split and retry batch requests
 
@@ -166,3 +168,17 @@ def _check_overwrites_available(self) -> bool:
             print(f"RPC does not support state overwrites, got: {repr(e)}")
             return False
         return response == test_value
+
+    def _check_subsquid_available(self) -> bool:
+        try:
+            endpoints = get_endpoints()
+        except Exception as e:
+            print(f"Could not get supported chains from SubSquid: {repr(e)}")
+            return False
+
+        chain_id = self.eth.chain_id
+        if chain_id not in endpoints:
+            print(f"SubSquid does not support chain {chain_id}")
+            return False
+
+        return True

setup.py

@@ -1,6 +1,6 @@
 from setuptools import setup, find_packages
 
-VERSION = '0.1.38'
+VERSION = '0.1.39'
 DESCRIPTION = 'IceCreamSwap Web3.py wrapper'
 LONG_DESCRIPTION = 'IceCreamSwap Web3.py wrapper with automatic retries, multicall and other advanced functionality'