From a3e945edc66c3203befacba119138edd1867329f Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Thu, 24 Nov 2022 15:04:16 -0500
Subject: [PATCH] Adjust order mode to use `Flume.get_index()`

---
 piker/ui/order_mode.py | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/piker/ui/order_mode.py b/piker/ui/order_mode.py
index 7e4ae066..27c5adb4 100644
--- a/piker/ui/order_mode.py
+++ b/piker/ui/order_mode.py
@@ -930,7 +930,6 @@ async def process_trade_msg(
 
 ) -> tuple[Dialog, Status]:
 
-    get_index = mode.chart.get_index
     fmsg = pformat(msg)
     log.debug(f'Received order msg:\n{fmsg}')
     name = msg['name']
@@ -965,6 +964,9 @@ async def process_trade_msg(
     oid = msg.oid
     dialog: Dialog = mode.dialogs.get(oid)
 
+    fqsn = dialog.symbol.front_fqsn()
+    flume = mode.feed.flumes[fqsn]
+
     match msg:
         case Status(
             resp='dark_open' | 'open',
@@ -1037,7 +1039,7 @@ async def process_trade_msg(
             mode.on_fill(
                 oid,
                 price=req.price,
-                arrow_index=get_index(time.time()),
+                arrow_index=flume.get_index(time.time()),
             )
             mode.lines.remove_line(uuid=oid)
             msg.req = req
@@ -1072,7 +1074,7 @@ async def process_trade_msg(
                 pointing='up' if action == 'buy' else 'down',
 
                 # TODO: put the actual exchange timestamp
-                arrow_index=get_index(
+                arrow_index=flume.get_index(
                     # TODO: note currently the ``kraken`` openOrders sub
                     # doesn't deliver their engine timestamp as part of
                     # it's schema, so this value is **not** from them