From 753e294c4a39447d4590ba00354fb362281542e1 Mon Sep 17 00:00:00 2001
From: 7400 <7400>
Date: Wed, 20 Mar 2024 08:59:18 -0700
Subject: [PATCH] WIP subscription bars sanity checks

---
 src/charts/datafeed.js | 19 ++++++++++++-------
 1 file changed, 12 insertions(+), 7 deletions(-)

diff --git a/src/charts/datafeed.js b/src/charts/datafeed.js
index d8d104a..c9b5dfb 100644
--- a/src/charts/datafeed.js
+++ b/src/charts/datafeed.js
@@ -375,23 +375,28 @@ export const DataFeed = {
 			bar = maybeInvertBar(pool, bar)
 			checkBar(bar, "poolCallback, after inversion:")
 			console.log('DataFeed.poolCallback', date.toGMTString(), ohlcs, bar)
+			let lastBar = DataFeed.poolCallbackState.lastBar
 			// No last bar then initialize bar
-			if ( DataFeed.poolCallbackState.lastBar===null) {
+			if (lastBar===null) {
+				console.log('DataFeed.poolCallback', new Date(bar.time).toGMTString(), 'lastBar=', bar)
+				DataFeed.subscribeBarsOnRealtimeCallback(bar)
 				DataFeed.poolCallbackState.lastBar = bar
 			}
 			// bar time is less than last bar then ignore
-			else if (bar.time<DataFeed.poolCallbackState.lastBar.time ) {
+			else if (bar.time < lastBar.time ) {
 			}
 			// bar time equal to last bar then replace last bar
-			else if (bar.time==DataFeed.poolCallbackState.lastBar.time ) {
-				console.log('DataFeed.poolCallback', new Date(DataFeed.poolCallbackState.lastBar.time).toGMTString(), 'lastBar=', DataFeed.poolCallbackState.lastBar)
-				DataFeed.subscribeBarsOnRealtimeCallback(DataFeed.poolCallbackState.lastBar)
+			else if (bar.time == lastBar.time ) {
+				console.log('DataFeed.poolCallback', new Date(bar.time).toGMTString(), 'lastBar=', bar)
+				if (bar.high < lastBar.high) console.log("bar.high < lastBar.high (lastbar=)")
+				if (bar.low  > lastBar.low)  console.log("bar.low  > lastBar.low  (lastbar=)")
+				DataFeed.subscribeBarsOnRealtimeCallback(bar)
 				DataFeed.poolCallbackState.lastBar = bar
 			}
 			// new bar, then render last and replace last bar
 			else {
-				console.log('DataFeed.poolCallback', new Date(DataFeed.poolCallbackState.lastBar.time).toGMTString(), 'lastBar=', DataFeed.poolCallbackState.lastBar)
-				DataFeed.subscribeBarsOnRealtimeCallback(DataFeed.poolCallbackState.lastBar)
+				console.log('DataFeed.poolCallback', new Date(bar.time).toGMTString(), 'lastBar=', bar)
+				DataFeed.subscribeBarsOnRealtimeCallback(bar)
 				DataFeed.poolCallbackState.lastBar = bar
 			}
 		// }