Update gas price

Author: Bojan131

dkg/providers/blockchain/async_blockchain.py

@@ -184,11 +184,19 @@ async def fetch_gas_price(oracle_url: str) -> Wei | None:
                         data: dict = await response.json()
 
                         if "result" in data:
-                            return int(data["result"], 16)
+                            gas_price = int(data["result"], 16)
                         elif "fast" in data:
-                            return self.w3.to_wei(data["fast"], "gwei")
+                            gas_price = self.w3.to_wei(data["fast"], "gwei")
                         else:
                             return None
+                        
+                        # Ensure minimum gas price (1 gwei = 1,000,000,000 wei)
+                        min_gas_price = self.w3.to_wei(1, "gwei")  # 1 gwei minimum
+                        if gas_price < min_gas_price:
+                            print(f"⚠️ Gas price from oracle too low ({gas_price} wei), using minimum ({min_gas_price} wei)")
+                            return min_gas_price
+                        
+                        return gas_price
             except Exception:
                 return None
 
@@ -202,7 +210,17 @@ async def fetch_gas_price(oracle_url: str) -> Wei | None:
                 if gas_price is not None:
                     return gas_price
 
-        return None
+        # Fallback: use network gas price with minimum
+        try:
+            network_gas_price = await self.w3.eth.gas_price
+            min_gas_price = self.w3.to_wei(1, "gwei")  # 1 gwei minimum
+            if network_gas_price < min_gas_price:
+                print(f"⚠️ Network gas price too low ({network_gas_price} wei), using minimum ({min_gas_price} wei)")
+                return min_gas_price
+            return network_gas_price
+        except Exception:
+            # Final fallback: return minimum gas price
+            return self.w3.to_wei(1, "gwei")
 
     async def _init_contracts(self):
         init_tasks = []

dkg/providers/blockchain/blockchain.py

@@ -169,11 +169,19 @@ def fetch_gas_price(oracle_url: str) -> Wei | None:
                 data: dict = response.json()
 
                 if "result" in data:
-                    return int(data["result"], 16)
+                    gas_price = int(data["result"], 16)
                 elif "fast" in data:
-                    return self.w3.to_wei(data["fast"], "gwei")
+                    gas_price = self.w3.to_wei(data["fast"], "gwei")
                 else:
                     return None
+                
+                # Ensure minimum gas price (1 gwei = 1,000,000,000 wei)
+                min_gas_price = self.w3.to_wei(1, "gwei")  # 1 gwei minimum
+                if gas_price < min_gas_price:
+                    print(f"⚠️ Gas price from oracle too low ({gas_price} wei), using minimum ({min_gas_price} wei)")
+                    return min_gas_price
+                
+                return gas_price
             except Exception:
                 return None
 
@@ -187,7 +195,17 @@ def fetch_gas_price(oracle_url: str) -> Wei | None:
                 if gas_price is not None:
                     return gas_price
 
-        return None
+        # Fallback: use network gas price with minimum
+        try:
+            network_gas_price = self.w3.eth.gas_price
+            min_gas_price = self.w3.to_wei(1, "gwei")  # 1 gwei minimum
+            if network_gas_price < min_gas_price:
+                print(f"⚠️ Network gas price too low ({network_gas_price} wei), using minimum ({min_gas_price} wei)")
+                return min_gas_price
+            return network_gas_price
+        except Exception:
+            # Final fallback: return minimum gas price
+            return self.w3.to_wei(1, "gwei")
 
     def _init_contracts(self):
         for contract in self.abi.keys():

tests/patched_blockchain_provider.py

@@ -14,6 +14,13 @@
     'otp:20430':       ("NEUROWEB_TESTNET_RPC", ["testnet", "otp:20430"]),
 }
 
+# Gas price oracles for mainnet networks
+GAS_PRICE_ORACLES = {
+    'base:8453': "https://api.basescan.org/api?module=gastracker&action=gasoracle",
+    'gnosis:100': "https://api.gnosisscan.io/api?module=gastracker&action=gasoracle", 
+    'otp:2043': "https://api.origintrail.io/api?module=gastracker&action=gasoracle",
+}
+
 class BlockchainProvider(OriginalBlockchainProvider):
     def __init__(self, blockchain_id):
         config = BLOCKCHAIN_RPC_CONFIG.get(blockchain_id)
@@ -27,6 +34,11 @@ def __init__(self, blockchain_id):
             for key in path[:-1]:
                 d = d[key]
             d[path[-1]]["rpc"] = rpc_url
+            
+            # Add gas price oracle for mainnet networks
+            if blockchain_id in GAS_PRICE_ORACLES:
+                d[path[-1]]["gas_price_oracle"] = GAS_PRICE_ORACLES[blockchain_id]
+                
         super().__init__(blockchain_id)
         self.environment = path[0] if config else None
         self.name = blockchain_id