diff --git a/src/ATrade/MDS/HistoryServer.hs b/src/ATrade/MDS/HistoryServer.hs index c452944..bb5ae5b 100644 --- a/src/ATrade/MDS/HistoryServer.hs +++ b/src/ATrade/MDS/HistoryServer.hs @@ -61,9 +61,6 @@ serveQHP db sock = forever $ do debugM "QHP" $ "Incoming command: " ++ show cmd let dataC = getDataConduit db (replaceWildcards $ rqTicker rq) (TimeInterval (rqStartTime rq) (rqEndTime rq)) (Timeframe (periodSeconds $ rqPeriod rq)) runConduit $ dataC .| (conduitVector chunkSize) .| (sendChunks peerId) - --qdata <- getData db (rqTicker rq) (TimeInterval (rqStartTime rq) (rqEndTime rq)) (Timeframe (periodSeconds $ rqPeriod rq)) - --let bytes = serializeBars $ V.concat $ fmap snd qdata - --sendMulti sock $ peerId :| [B.empty, "OK", BL.toStrict bytes] sendChunks :: (MonadIO m) => B.ByteString -> ConduitT (V.Vector Bar) Void m () sendChunks peerId = do liftIO $ send sock [SendMore] peerId