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

addrmeta can repair pools

Browse Source
This commit is contained in:
tim
2024-10-07 14:42:44 -04:00
parent 0ea0a0728c
commit 2298b37bc4
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/dexorder/pools.py
View File

@@ -29,15 +29,15 @@ async def get_pool(address: str) -> OldPoolDict:
else: else:
if result['base'] == ADDRESS_0 or result['quote'] == ADDRESS_0: if result['base'] == ADDRESS_0 or result['quote'] == ADDRESS_0:
log.warning(f'Repairing bad pool {address}') log.warning(f'Repairing bad pool {address}')
result = address_metadata[address] = await load_pool(address) result = address_metadata[address] = await load_pool(address, use_db=False)
return result return result
async def load_pool(address: str) -> OldPoolDict: async def load_pool(address: str, *, use_db=True) -> OldPoolDict:
found = None found = None
chain_id = current_chain.get().id chain_id = current_chain.get().id
# todo other exchanges # todo other exchanges
if db: if use_db and db:
pool = db.session.get(Pool, (chain_id, address)) pool = db.session.get(Pool, (chain_id, address))
if pool is not None: if pool is not None:
return OldPoolDict(type='Pool', chain=chain_id, address=address, exchange=pool.exchange.value, return OldPoolDict(type='Pool', chain=chain_id, address=address, exchange=pool.exchange.value,