From 6a5950b18bbd50414b4e674d76364c51cf71f63a Mon Sep 17 00:00:00 2001
From: Tim <tim@dexorder.trade>
Date: Tue, 19 Mar 2024 18:30:30 -0400
Subject: [PATCH] 'ohlc' pubsub message has period

---
 src/dexorder/ohlc.py | 7 ++-----
 1 file changed, 2 insertions(+), 5 deletions(-)

diff --git a/src/dexorder/ohlc.py b/src/dexorder/ohlc.py
index 7897035..9d3daa5 100644
--- a/src/dexorder/ohlc.py
+++ b/src/dexorder/ohlc.py
@@ -506,11 +506,8 @@ def pub_ohlc(_series:str, key: OHLCKey, bars: list[NativeOHLC]):
     pool_addr, period = key
     chain_id = current_chain.get().chain_id
     period = period_name(period)
-    return (
-        f'{chain_id}|{pool_addr}|{period}',  # channel name is like 0x...|1m
-        'ohlc',
-        (chain_id, pool_addr, period, [b.ohlc for b in bars])
-    )
+    key = f'{pool_addr}|{period}'
+    return f'{chain_id}|{key}', 'ohlc', (chain_id, key, [b.ohlc for b in bars])
 
 def ohlc_key_to_str(k):
     return f'{k[0]}|{period_name(k[1])}'