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

handle_order_cancel_all

Browse Source
This commit is contained in:
7400
2023-11-30 11:43:37 -08:00
parent ecc9e2eb98
commit a96428b9e3
1 changed files with 16 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/dexorder/event_handler.py
View File

@@ -62,6 +62,7 @@ def setup_logevent_triggers(runner):
runner.add_event_trigger(handle_uniswap_swap, get_contract_event('IUniswapV3PoolEvents', 'Swap')) runner.add_event_trigger(handle_uniswap_swap, get_contract_event('IUniswapV3PoolEvents', 'Swap'))
runner.add_event_trigger(handle_swap_filled, get_contract_event('OrderLib', 'DexorderSwapFilled')) runner.add_event_trigger(handle_swap_filled, get_contract_event('OrderLib', 'DexorderSwapFilled'))
runner.add_event_trigger(handle_order_canceled, get_contract_event('OrderLib', 'DexorderSwapCanceled')) runner.add_event_trigger(handle_order_canceled, get_contract_event('OrderLib', 'DexorderSwapCanceled'))
runner.add_event_trigger(handle_order_cancel_all, get_contract_event('OrderLib', 'DexorderCancelAll'))
runner.add_event_trigger(handle_transaction_receipts) runner.add_event_trigger(handle_transaction_receipts)
runner.add_event_trigger(handle_dexorderexecutions, executions) runner.add_event_trigger(handle_dexorderexecutions, executions)
runner.add_event_trigger(activate_time_triggers) runner.add_event_trigger(activate_time_triggers)
@@ -148,6 +149,21 @@ async def handle_order_canceled(event: EventData):
log.warning(f'DexorderCanceled IGNORED due to missing order {vault} {order_index}') log.warning(f'DexorderCanceled IGNORED due to missing order {vault} {order_index}')
async def handle_order_cancel_all(event: EventData):
# event DexorderCancelAll (uint64 numSwapOrders);
log.debug(f'DexorderCancelAll {event}')
vault = event['address']
cancelAllIndex = event['args']['cancelAllIndex']
for orderIndex in Order.vault_open_orders[vault]:
if orderIndex < cancelAllIndex:
try:
order: Order = Order.of(vault, orderIndex)
order.complete(SwapOrderState.Canceled)
log.debug(f'Canceled order {OrderKey(vault,orderIndex)}')
except KeyError:
log.warning(f'DexorderCanceled IGNORED due to missing order {vault} {orderIndex}')
def balance_adjuster(vault, token_address, amount): def balance_adjuster(vault, token_address, amount):
async def _adjust(vaddr, taddr, amt, old_balances): async def _adjust(vaddr, taddr, amt, old_balances):
result = dict(old_balances) # copy result = dict(old_balances) # copy