Nucypher
/
nucypher
mirror of https://github.com/nucypher/nucypher.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Fix domain bug and move rpc endpoint shuffling

pull/3569/head
James Campbell 2024-12-12 13:51:06 +01:00
parent 25eec7314c
commit d3c7be4db7
No known key found for this signature in database
2 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
nucypher/blockchain/eth/actors.py
View File

@ -278,10 +278,10 @@ class Operator(BaseActor):
duplicated_endpoint_check = defaultdict(set)
# User-defined endpoints for chains
for chain_id, endpoints in endpoints.items():
for chain_id, endpoint_list in endpoints.items():
# connect to each endpoint and check that they are on the correct chain
for uri in endpoints:
for uri in endpoint_list:
if uri in duplicated_endpoint_check[chain_id]:
self.log.warn(
f"Duplicated user-supplied blockchain uri, {uri}, for condition evaluation on chain {chain_id}; skipping"
@ -303,9 +303,11 @@ class Operator(BaseActor):
# Ingest default/fallback RPC providers for each chain
# for chain_id in self.domain.condition_chain_ids:
default_endpoints = get_healthy_default_rpc_endpoints(self.domain.name)
for chain_id in default_endpoints:
for uri in default_endpoints[chain_id]:
default_endpoints = get_healthy_default_rpc_endpoints(self.domain)
for chain_id, chain_endpoints in default_endpoints.items():
# randomize list so that the same fallback RPC endpoints aren't always used by all nodes
random.shuffle(chain_endpoints)
for uri in chain_endpoints:
if uri in duplicated_endpoint_check[chain_id]:
self.log.warn(
f"Duplicated fallback blockchain uri, {uri}, for condition evaluation on chain {chain_id}; skipping"

3
nucypher/blockchain/eth/utils.py
View File

@ -1,4 +1,3 @@
import random
import time
from decimal import Decimal
from typing import Dict, List, Union
@ -169,8 +168,6 @@ def get_healthy_default_rpc_endpoints(domain: TACoDomain) -> Dict[int, List[str]
if not domain.is_testnet:
# iterate over all chains and filter out unhealthy endpoints
for chain_endpoints in endpoints.values():
random.shuffle(chain_endpoints)
healthy = {
chain_id: [
endpoint