pool fee selection; ohlc subs
This commit is contained in:
1
cache.js
1
cache.js
@@ -81,3 +81,4 @@ export const prices = new CacheDict('p')
|
|||||||
export const orderStatuses = new CacheDict('o')
|
export const orderStatuses = new CacheDict('o')
|
||||||
export const vaultOpenOrders = new CacheDict('voo')
|
export const vaultOpenOrders = new CacheDict('voo')
|
||||||
export const orderFilled = new CacheDict('of')
|
export const orderFilled = new CacheDict('of')
|
||||||
|
export const ohlcs = new CacheDict('ohlc')
|
||||||
|
|||||||
3
pool.js
3
pool.js
@@ -1,8 +1,10 @@
|
|||||||
|
import {ohlcs, prices} from "./cache.js";
|
||||||
|
|
||||||
export function subPools( socket, chainId, addresses) {
|
export function subPools( socket, chainId, addresses) {
|
||||||
for(const address of addresses) {
|
for(const address of addresses) {
|
||||||
const room = `${chainId}|${address}`;
|
const room = `${chainId}|${address}`;
|
||||||
socket.join(room)
|
socket.join(room)
|
||||||
|
socket.emit('p', chainId, address, prices[address])
|
||||||
console.log('joined room', room)
|
console.log('joined room', room)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -20,6 +22,7 @@ export function subOHLCs( socket, chainId, poolPeriods) {
|
|||||||
for(const key of poolPeriods) {
|
for(const key of poolPeriods) {
|
||||||
const room = `${chainId}|${key}`;
|
const room = `${chainId}|${key}`;
|
||||||
socket.join(room)
|
socket.join(room)
|
||||||
|
socket.emit('ohlc', chainId, key, ohlcs[key])
|
||||||
console.log('joined room', room)
|
console.log('joined room', room)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user