dexorder/web
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

WIP subscription bars sanity checks

Browse Source
This commit is contained in:
7400
2024-03-20 08:59:18 -07:00
parent 532d44476a
commit 753e294c4a
1 changed files with 12 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/charts/datafeed.js
View File

@@ -375,23 +375,28 @@ export const DataFeed = {
bar = maybeInvertBar(pool, bar) bar = maybeInvertBar(pool, bar)
checkBar(bar, "poolCallback, after inversion:") checkBar(bar, "poolCallback, after inversion:")
console.log('DataFeed.poolCallback', date.toGMTString(), ohlcs, bar) console.log('DataFeed.poolCallback', date.toGMTString(), ohlcs, bar)
let lastBar = DataFeed.poolCallbackState.lastBar
// No last bar then initialize bar // 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 DataFeed.poolCallbackState.lastBar = bar
} }
// bar time is less than last bar then ignore // 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 // bar time equal to last bar then replace last bar
else if (bar.time==DataFeed.poolCallbackState.lastBar.time ) { else if (bar.time == lastBar.time ) {
console.log('DataFeed.poolCallback', new Date(DataFeed.poolCallbackState.lastBar.time).toGMTString(), 'lastBar=', DataFeed.poolCallbackState.lastBar) console.log('DataFeed.poolCallback', new Date(bar.time).toGMTString(), 'lastBar=', bar)
DataFeed.subscribeBarsOnRealtimeCallback(DataFeed.poolCallbackState.lastBar) 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 DataFeed.poolCallbackState.lastBar = bar
} }
// new bar, then render last and replace last bar // new bar, then render last and replace last bar
else { else {
console.log('DataFeed.poolCallback', new Date(DataFeed.poolCallbackState.lastBar.time).toGMTString(), 'lastBar=', DataFeed.poolCallbackState.lastBar) console.log('DataFeed.poolCallback', new Date(bar.time).toGMTString(), 'lastBar=', bar)
DataFeed.subscribeBarsOnRealtimeCallback(DataFeed.poolCallbackState.lastBar) DataFeed.subscribeBarsOnRealtimeCallback(bar)
DataFeed.poolCallbackState.lastBar = bar DataFeed.poolCallbackState.lastBar = bar
} }
// } // }