100 lines
3.1 KiB
JavaScript
100 lines
3.1 KiB
JavaScript
import {socket} from "@/socket.js";
|
|
|
|
const ohlcSubCounts = {} // key is route and value is a subscription counter
|
|
export const WIDE_PRICE_FORMAT = {decimals:38, width:512, signed:false}; // 38 decimals is 127 bits
|
|
|
|
|
|
export function subOHLC( chainId, pool, period ) {
|
|
const key = `${pool}|${period}`
|
|
const ckey = `${chainId}|${key}`
|
|
// console.log('subOHLC', chainId, pool, period, ckey, ohlcSubCounts[ckey])
|
|
if (!(ckey in ohlcSubCounts) || ohlcSubCounts[ckey] === 0) {
|
|
ohlcSubCounts[ckey] = 1
|
|
console.log('subscribing OHLCs', chainId, key)
|
|
socket.emit('subOHLCs', chainId, [key])
|
|
} else
|
|
ohlcSubCounts[ckey]++
|
|
}
|
|
|
|
|
|
export function refreshOHLCSubs() {
|
|
const keys = []
|
|
let chainId = null
|
|
for (const key of Object.keys(ohlcSubCounts)) {
|
|
const [curChainId, pool, period] = key.split('|')
|
|
if (chainId === null)
|
|
chainId = curChainId
|
|
else if (chainId !== curChainId) {
|
|
console.error('refreshOHLCSubs: mixed chainIds')
|
|
continue
|
|
}
|
|
keys.push(`${pool}|${period}`)
|
|
}
|
|
console.log('refreshing OHLC subs', keys)
|
|
socket.emit('subOHLCs', chainId, keys)
|
|
}
|
|
|
|
|
|
export function unsubOHLC( chainId, pool, period ) {
|
|
const key = `${pool}|${period}`
|
|
const ckey = `${chainId}|${key}`
|
|
// console.log('unsubOHLC', chainId, pool, period, ckey, ohlcSubCounts[ckey])
|
|
if (!(ckey in ohlcSubCounts) || ohlcSubCounts[ckey] === 0) {
|
|
console.error('overdecremented ohlc', pool, period)
|
|
ohlcSubCounts[ckey] = 1
|
|
} else {
|
|
ohlcSubCounts[ckey]--
|
|
if (ohlcSubCounts[ckey] === 0) {
|
|
console.log('unsubscribing OHLCs', chainId, key)
|
|
// noinspection JSCheckFunctionSignatures
|
|
socket.emit('unsubOHLCs', chainId, [key])
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
export function unsubAllOHLCs( chainId ) {
|
|
const chainStr = chainId.toString() + '|'
|
|
const toUnsub = []
|
|
for( const k of Object.keys(ohlcSubCounts) ) {
|
|
if (k.startsWith(chainStr))
|
|
toUnsub.push(k.slice(chainStr.length))
|
|
}
|
|
if( toUnsub.length )
|
|
socket.emit('unsubOHLCs', chainId, toUnsub )
|
|
}
|
|
|
|
|
|
export function subOHLCs( chainId, poolPeriods ) {
|
|
if( !poolPeriods.length )
|
|
return
|
|
const toSub = []
|
|
for( const [pool,period] of poolPeriods ) {
|
|
const key = `${pool}|${period}`
|
|
if (!(key in ohlcSubCounts) || ohlcSubCounts[key] === 0) {
|
|
ohlcSubCounts[key] = 1
|
|
toSub.push(key)
|
|
} else
|
|
ohlcSubCounts[key]++
|
|
}
|
|
if( toSub.length )
|
|
socket.emit('subOHLCs', chainId, toSub)
|
|
}
|
|
|
|
export function unsubOHLCs( chainId, poolPeriods ) {
|
|
const toUnsub = []
|
|
for( const [pool,period] of poolPeriods ) {
|
|
const key = `${pool}|${period}`
|
|
if (!(key in ohlcSubCounts) || ohlcSubCounts[key] === 0) {
|
|
console.error('overdecremented',pool,period)
|
|
ohlcSubCounts[key] = 1
|
|
} else {
|
|
ohlcSubCounts[key]--
|
|
if( ohlcSubCounts[key] === 0 )
|
|
toUnsub.push(key)
|
|
}
|
|
}
|
|
if( toUnsub.length )
|
|
socket.emit('unsubOHLCs', chainId, toUnsub )
|
|
}
|