35 lines
862 B
JavaScript
35 lines
862 B
JavaScript
|
|
export function subPools( socket, chainId, addresses) {
|
|
for(const address of addresses) {
|
|
const room = `${chainId}|${address}`;
|
|
socket.join(room)
|
|
console.log('joined room', room)
|
|
}
|
|
}
|
|
|
|
export function unsubPools( socket, chainId, addresses ) {
|
|
for(const address of addresses) {
|
|
const room = `${chainId}|${address}`;
|
|
socket.leave(room)
|
|
console.log('left room', room)
|
|
}
|
|
}
|
|
|
|
|
|
export function subOHLCs( socket, chainId, poolPeriods) {
|
|
for(const key of poolPeriods) {
|
|
const room = `${chainId}|${key}`;
|
|
socket.join(room)
|
|
console.log('joined room', room)
|
|
}
|
|
}
|
|
|
|
export function unsubOHLCs( socket, chainId, poolPeriods ) {
|
|
for(const key of poolPeriods) {
|
|
const room = `${chainId}|${key}`;
|
|
socket.leave(room)
|
|
console.log('left room', room)
|
|
}
|
|
}
|
|
|