|
|
|
|
@ -61,9 +61,6 @@ serveQHP db sock = forever $ do
@@ -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 |
|
|
|
|
|