diff --git a/main.js b/main.js
index c99fa92..1ed0d69 100644
--- a/main.js
+++ b/main.js
@@ -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 )
diff --git a/pool.js b/pool.js
index 910e814..f670996 100644
--- a/pool.js
+++ b/pool.js
@@ -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)
     }
 }