Merge pull request #44 from chainstacklabs/dev

Add block range for eth_getLogs

Author: smypmsa

config/defaults.py

@@ -33,12 +33,12 @@ class MetricsServiceConfig:
 
     # Block offset configuration (N blocks back from latest)
     BLOCK_OFFSET_RANGES = {  # noqa: RUF012
-        "ethereum": (7200, 14400),
-        "base": (7200, 14400),
+        "ethereum": (7200, 10000),
+        "base": (7200, 10000),
         "solana": (432000, 648000),
         "ton": (1555200, 1572480),
-        "arbitrum": (7200, 14400),
-        "bnb": (7200, 14400),
+        "arbitrum": (7200, 10000),
+        "bnb": (7200, 10000),
     }
 
 

metrics/arbitrum.py

@@ -109,12 +109,23 @@ class HTTPGetLogsLatencyMetric(HttpCallLatencyMetricBase):
     def method(self) -> str:
         return "eth_getLogs"
 
+    @staticmethod
+    def validate_state(state_data: dict) -> bool:
+        """Validates that required old block number exists in state data."""
+        return bool(state_data and state_data.get("block"))
+
     @staticmethod
     def get_params_from_state(state_data: dict) -> list:
-        """Get parameters for USDC transfer logs from latest block."""
+        """Get parameters for USDC transfer logs from recent block range."""
+        from_block_hex = state_data["old_block"]
+        from_block_int = int(from_block_hex, 16)
+        to_block_int: int = max(0, from_block_int + 100)
+        to_block_hex: str = hex(to_block_int)
+
         return [
             {
-                "fromBlock": "latest",
+                "fromBlock": from_block_hex,
+                "toBlock": to_block_hex,
                 "address": "0xaf88d065e77c8cC2239327C5EDb3A432268e5831",  # USDC on Arbitrum
                 "topics": [
                     "0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef"  # Transfer event

metrics/base.py

@@ -111,10 +111,16 @@ def method(self) -> str:
 
     @staticmethod
     def get_params_from_state(state_data: dict) -> list:
-        """Get parameters for USDC transfer logs from latest block."""
+        """Get parameters for USDC transfer logs from recent block range."""
+        from_block_hex = state_data["old_block"]
+        from_block_int = int(from_block_hex, 16)
+        to_block_int: int = max(0, from_block_int + 100)
+        to_block_hex: str = hex(to_block_int)
+
         return [
             {
-                "fromBlock": "latest",
+                "fromBlock": from_block_hex,
+                "toBlock": to_block_hex,
                 "address": "0x833589fcd6edb6e08f4c7c32d4f71b54bda02913",  # USDC on Base
                 "topics": [
                     "0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef"  # Transfer event

metrics/bnbsc.py

@@ -109,12 +109,23 @@ class HTTPGetLogsLatencyMetric(HttpCallLatencyMetricBase):
     def method(self) -> str:
         return "eth_getLogs"
 
+    @staticmethod
+    def validate_state(state_data: dict) -> bool:
+        """Validates that required old block number exists in state data."""
+        return bool(state_data and state_data.get("block"))
+
     @staticmethod
     def get_params_from_state(state_data: dict) -> list:
-        """Get parameters for Wrapped BNB transfer logs from latest block."""
+        """Get parameters for Wrapped BNB transfer logs from recent block range."""
+        from_block_hex = state_data["old_block"]
+        from_block_int = int(from_block_hex, 16)
+        to_block_int: int = max(0, from_block_int + 100)
+        to_block_hex: str = hex(to_block_int)
+
         return [
             {
-                "fromBlock": "latest",
+                "fromBlock": from_block_hex,
+                "toBlock": to_block_hex,
                 "address": "0xbb4CdB9CBd36B01bD1cBaEBF2De08d9173bc095c",  # Wrapped BNB on BSC
                 "topics": [
                     "0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef"  # Transfer event

metrics/ethereum.py

@@ -117,12 +117,23 @@ class HTTPGetLogsLatencyMetric(HttpCallLatencyMetricBase):
     def method(self) -> str:
         return "eth_getLogs"
 
+    @staticmethod
+    def validate_state(state_data: dict) -> bool:
+        """Validates that required block number exists in state data."""
+        return bool(state_data and state_data.get("old_block"))
+
     @staticmethod
     def get_params_from_state(state_data: dict) -> list:
-        """Get parameters for USDC transfer logs from latest block."""
+        """Get parameters for USDC transfer logs from recent block range."""
+        from_block_hex = state_data["old_block"]
+        from_block_int = int(from_block_hex, 16)
+        to_block_int: int = max(0, from_block_int + 100)
+        to_block_hex: str = hex(to_block_int)
+
         return [
             {
-                "fromBlock": "latest",
+                "fromBlock": from_block_hex,
+                "toBlock": to_block_hex,
                 "address": "0xA0b86991c6218b36c1d19D4a2e9Eb0cE3606eB48",  # USDC
                 "topics": [
                     "0xddf252ad1be2c89b69c2b068fc378daa952ba7f163c4a11628f55a4df523b3ef"  # Transfer event

vercel.json

@@ -1,11 +1,11 @@
 {
   "functions": {
     "api/read/ethereum.py": {
-      "memory": 300,
+      "memory": 400,
       "maxDuration": 59
     },
     "api/read/base.py": {
-      "memory": 320,
+      "memory": 400,
       "maxDuration": 59
     },
     "api/read/solana.py": {
@@ -17,11 +17,11 @@
       "maxDuration": 59
     },
     "api/read/arbitrum.py": {
-      "memory": 300,
+      "memory": 400,
       "maxDuration": 59
     },
     "api/read/bnbsc.py": {
-      "memory": 300,
+      "memory": 400,
       "maxDuration": 59
     },
     "api/read/test_blockchain.py": {
@@ -72,7 +72,7 @@
     },
     {
       "path": "/api/support/update_state",
-      "schedule": "*/30 * * * *"
+      "schedule": "*/15 * * * *"
     }
   ]
-}
+}