dexorder/backend
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

rpc connections limited to 8

Browse Source
This commit is contained in:
tim
2025-02-24 19:46:42 -04:00
parent f2e7749c7b
commit 67ab504a40
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
conf/arb1/dexorder-arb1.toml
View File

@@ -1,6 +1,6 @@
rpc_url = 'arbitrum_dxod' rpc_url = 'arbitrum_dxod'
ws_url = 'arbitrum_dxod_ws' ws_url = 'arbitrum_dxod_ws'
archive_url = 'arbitrum_alchemy' archive_url = 'arbitrum_alchemy'
concurrent_rpc_connections=20 concurrent_rpc_connections=8
metrics_port=9001 metrics_port=9001
metadata = '' # this setting approves no tokens metadata = '' # this setting approves no tokens

2
src/dexorder/runner.py
View File

@@ -82,7 +82,7 @@ class BlockStateRunner(BlockProgressor):
log.debug('connecting to ws provider') log.debug('connecting to ws provider')
await w3ws.provider.connect() await w3ws.provider.connect()
subscription = await w3ws.eth.subscribe('newHeads') # the return value of this call is not consistent between anvil/hardhat/rpc. subscription = await w3ws.eth.subscribe('newHeads') # the return value of this call is not consistent between anvil/hardhat/rpc.
log.debug(f'subscribed to newHeads {subscription}') # log.debug(f'subscribed to newHeads {subscription}')
while self.running: while self.running:
async for message in w3ws.ws.process_subscriptions(): async for message in w3ws.ws.process_subscriptions():
block = Block(chain_id, message['result']) block = Block(chain_id, message['result'])