From e6a3e8b65ac33bd50bac591ab9a0a3cbf667a821 Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Fri, 29 Jul 2022 12:52:56 -0400
Subject: [PATCH] Add warning msg for `openOrders.userref` always being 0

---
 piker/brokers/kraken/broker.py | 16 +++++++++++++---
 1 file changed, 13 insertions(+), 3 deletions(-)

diff --git a/piker/brokers/kraken/broker.py b/piker/brokers/kraken/broker.py
index 3d7e2d91..9cb3e9b3 100644
--- a/piker/brokers/kraken/broker.py
+++ b/piker/brokers/kraken/broker.py
@@ -188,6 +188,9 @@ async def handle_order_requests(
                     'event': ep,
                     'token': token,
 
+                    # XXX: this seems to always get an error response?
+                    # 'userref': f"'{reqid}'",
+
                     'reqid': reqid,  # remapped-to-int uid from ems
                     'pair': pair,
                     'price': str(order.price),
@@ -711,8 +714,7 @@ async def handle_order_updates(
                             continue
 
                         case {
-                            # XXX: lol, ws bug, this is always 0!
-                            'userref': _,
+                            'userref': reqid,
 
                             # during a fill this field is **not**
                             # provided! but, it is always avail on
@@ -764,7 +766,15 @@ async def handle_order_updates(
                             else:
                                 vlm = rest.get('vol_exec', 0)
 
-                            reqid = reqids2txids.inverse.get(txid)
+                            ourreqid = reqids2txids.inverse.get(txid)
+
+                            if ourreqid != reqid:
+                                log.warning(
+                                    'REQID MISMATCH due to kraken api bugs..\n'
+                                    f'msg:{reqid}, ours:{ourreqid}'
+                                )
+                                reqid = ourreqid
+
                             oid = ids.inverse.get(reqid)
 
                             if (