midefos/basicswap
1
0
Fork 0
mirror of https://github.com/basicswap/basicswap.git synced 2025-11-06 02:38:11 +01:00
Code Issues Packages Projects Releases Wiki Activity

wow: reuse threadPollXMRChainstate & monerod_proxy_config

Browse Source
This commit is contained in:
nahuhh
2025-07-12 04:40:50 +00:00
parent 96faa26c5b
commit 90a162f0ea
2 changed files with 6 additions and 60 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
basicswap/basicswap.py
View File

@@ -259,32 +259,6 @@ def threadPollXMRChainState(swap_client, coin_type):
) # Random to stagger updates
def threadPollWOWChainState(swap_client, coin_type):
ci = swap_client.ci(coin_type)
cc = swap_client.coin_clients[coin_type]
while not swap_client.chainstate_delay_event.is_set():
try:
new_height: int = ci.getChainHeight()
if new_height != cc["chain_height"]:
swap_client.log.debug(
f"New {ci.ticker()} block at height: {new_height}"
)
with swap_client.mxDB:
cc["chain_height"] = new_height
checkAndNotifyBalanceChange(
swap_client, coin_type, ci, cc, new_height, "block"
)
except Exception as e:
swap_client.log.warning(
f"threadPollWOWChainState {ci.ticker()}, error: {e}"
)
swap_client.chainstate_delay_event.wait(
random.randrange(20, 30)
) # Random to stagger updates
def threadPollChainState(swap_client, coin_type):
ci = swap_client.ci(coin_type)
cc = swap_client.coin_clients[coin_type]
@@ -1150,7 +1124,7 @@ class BasicSwap(BaseApp, UIApp):
thread_func = {
Coins.XMR: threadPollXMRChainState,
Coins.WOW: threadPollWOWChainState,
Coins.WOW: threadPollXMRChainState,
}.get(
c, threadPollChainState
) # default case