ohlc's

pool.js

@@ -14,3 +14,21 @@ export function unsubPools( socket, chainId, addresses ) {
         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)
+    }
+}
+