From c8073ad89122983aff1233ea1ae89b3f052c2705 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Sat, 12 Dec 2020 17:14:47 -0500 Subject: [PATCH] Port kraken to declare "wap" field --- piker/brokers/kraken.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/piker/brokers/kraken.py b/piker/brokers/kraken.py index 4329a981..2289f743 100644 --- a/piker/brokers/kraken.py +++ b/piker/brokers/kraken.py @@ -57,13 +57,15 @@ _ohlc_dtype = [ ('close', float), ('volume', float), ('count', int), - ('vwap', float), + ('bar_wap', float), ] # UI components allow this to be declared such that additional # (historical) fields can be exposed. ohlc_dtype = np.dtype(_ohlc_dtype) +_show_wap_in_history = True + class Client: @@ -341,7 +343,7 @@ async def stream_quotes( while True: try: async with trio_websocket.open_websocket_url( - 'wss://ws.kraken.com', + 'wss://ws.kraken.com/', ) as ws: # XXX: setup subs @@ -433,7 +435,7 @@ async def stream_quotes( 'high', 'low', 'close', - 'vwap', + 'bar_wap', # in this case vwap of bar 'volume'] ][-1] = ( o,