Indexers v2

indexers-v2/main.py

@@ -1,18 +1,20 @@
 import json
-import sys
 import os
 import argparse
 import yaml
+import logging
 from synthetix import Synthetix
 
+logging.basicConfig(level=logging.INFO)
+
 
 def save_abi(abi, contract_name):
     os.makedirs("abi", exist_ok=True)
     with open(f"abi/{contract_name}.json", "w") as file:
         json.dump(abi, file, indent=2)
 
 
-def create_squidgen_config(rpc_url, archive_url, contracts_info):
+def create_squidgen_config(rpc_url, archive_url, contracts_info, block_range):
     config = {
         "archive": archive_url,
         "finalityConfirmation": 1,
@@ -27,6 +29,7 @@ def create_squidgen_config(rpc_url, archive_url, contracts_info):
         contract_config = {
             "name": name,
             "address": address,
+            "range": block_range,
             "abi": f"./abi/{name}.json",
             "events": True,
             "functions": False,
@@ -99,21 +102,29 @@ def load_network_config(path):
 
     contracts = []
 
+    if "cannon_config" in network_config:
+        snx = Synthetix(
+            provider_rpc=rpc_endpoint,
+            network_id=network_config["network_id"],
+            cannon_config=network_config["cannon_config"],
+        )
+    else:
+        snx = Synthetix(
+            provider_rpc=rpc_endpoint,
+            network_id=network_config["network_id"],
+        )
+
+    block_range = {}
+    block_range["from"] = network_config["range"].get("from", 0)
+    if "to" in network_config["range"]:
+        if network_config["range"]["to"] == "latest":
+            block_range["to"] = snx.web3.eth.block_number
+        else:
+            block_range["to"] = network_config["range"]["to"]
+
     if "contracts_from_sdk" in network_config:
         contracts_from_sdk = network_config["contracts_from_sdk"]
 
-        if "cannon_config" in network_config:
-            snx = Synthetix(
-                provider_rpc=rpc_endpoint,
-                network_id=network_config["network_id"],
-                cannon_config=network_config["cannon_config"],
-            )
-        else:
-            snx = Synthetix(
-                provider_rpc=rpc_endpoint,
-                network_id=network_config["network_id"],
-            )
-
         for contract in contracts_from_sdk:
             name = contract["name"]
             package = contract["package"]
@@ -133,12 +144,14 @@ def load_network_config(path):
             save_abi(contract_data["abi"], name)
             contracts.append({"name": name, "address": contract_data["address"]})
 
-    squidgen_config = create_squidgen_config(rpc_endpoint, archive_url, contracts)
+    squidgen_config = create_squidgen_config(
+        rpc_endpoint, archive_url, contracts, block_range
+    )
     write_yaml(squidgen_config, "squidgen.yaml")
 
     squid_config = create_squid_config(args.network_name)
     write_yaml(squid_config, "squid.yaml")
 
-    print(
+    logging.info(
         f"squidgen.yaml, squid.yaml, and ABI files have been generated for {args.network_name}"
     )

indexers-v2/networks/arbitrum_mainnet/network_config.yaml

@@ -1,5 +1,7 @@
 arbitrum_mainnet:
   archive_url: "https://v2.archive.subsquid.io/network/arbitrum-one"
+  range:
+    from: 218000000
   contracts_from_sdk:
     - name: CoreProxy
       package: system

indexers-v2/networks/base_mainnet/network_config.yaml

@@ -1,5 +1,7 @@
 base_mainnet:
   archive_url: "https://v2.archive.subsquid.io/network/base-mainnet"
+  range:
+    from: 7500000
   contracts_from_sdk:
     - name: CoreProxy
       package: system