Drop uneeded count-sequencec verification

tractor_typed_msg_hackin
Tyler Goodlet 2022-07-05 11:25:40 -04:00
parent 204d3b7214
commit 9723d2737a
1 changed files with 1 additions and 7 deletions

View File

@ -329,8 +329,6 @@ async def trades_dialogue(
ids, ids,
) )
count: int = 0
# process and relay trades events to ems # process and relay trades events to ems
# https://docs.kraken.com/websockets/#message-ownTrades # https://docs.kraken.com/websockets/#message-ownTrades
async for msg in stream_messages(ws): async for msg in stream_messages(ws):
@ -340,11 +338,6 @@ async def trades_dialogue(
'ownTrades', 'ownTrades',
{'sequence': seq}, {'sequence': seq},
]: ]:
# XXX: do we actually need this orrr?
# ensure that we are only processing new trades?
assert seq > count
count += 1
# flatten msgs for processing # flatten msgs for processing
trades = { trades = {
tid: trade tid: trade
@ -472,6 +465,7 @@ async def trades_dialogue(
'userref': reqid, 'userref': reqid,
**rest, **rest,
# XXX: eg. of remaining msg schema:
# 'avg_price': _, # 'avg_price': _,
# 'cost': _, # 'cost': _,
# 'descr': { # 'descr': {