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

ohlc pubsub bugfixes

Browse Source
This commit is contained in:
Tim
2024-03-14 22:27:55 -04:00
parent 5388611e94
commit e65651ae8a
2 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
main.js
View File

@@ -17,7 +17,7 @@ io.on("connection", (socket) => {
socket.on('address', (chainId, address) => loginAddress(socket, chainId, address) )
socket.on('subPools', (chainId, addresses) => subPools(socket, chainId, addresses) )
socket.on('unsubPools', (chainId, addresses) => unsubPools(socket, chainId, addresses) )
socket.on('subOHLCs', (chainId, poolPeriods) => subOHLCs(socket, chainId, poolPeriods) )
socket.on('subOHLCs', async (chainId, poolPeriods) => await subOHLCs(socket, chainId, poolPeriods) )
socket.on('unsubOHLCs', (chainId, poolPeriods) => unsubOHLCs(socket, chainId, poolPeriods) )
socket.on('ensureVault', (chainId,owner,num) => ensureVault(socket, chainId, owner, num) )
if( 31337 in chainInfo && chainInfo[31337]?.mockenv || 1337 in chainInfo && chainInfo[1337]?.mockenv )

7
pool.js
View File

@@ -18,11 +18,14 @@ export function unsubPools( socket, chainId, addresses ) {
}
export function subOHLCs( socket, chainId, poolPeriods) {
export async function subOHLCs( socket, chainId, poolPeriods) {
console.log('subOHLCs', chainId, poolPeriods)
for(const key of poolPeriods) {
const room = `${chainId}|${key}`;
socket.join(room)
socket.emit('ohlc', chainId, key, ohlcs[key])
const ohlc = await ohlcs.get(chainId,key);
console.log('got ohlc', ohlc)
socket.emit('ohlc', chainId, key, ohlc)
console.log('joined room', room)
}
}