Drop uneeded count-sequencec verification
parent
df4cec930b
commit
84cab1327d
|
@ -328,8 +328,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):
|
||||||
|
@ -339,11 +337,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
|
||||||
|
@ -471,6 +464,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': {
|
||||||
|
|
Loading…
Reference in New Issue