asakul
/
mds
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

QHP: fix response structure

master
Denis Tereshkin 6 years ago
parent
b8fcee4c84
commit
7856ef7baa
1 changed files with 1 additions and 1 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 2
      src/ATrade/MDS/HistoryServer.hs

2
src/ATrade/MDS/HistoryServer.hs
Unescape View File

@ -58,7 +58,7 @@ serveQHP db sock = forever $ do
debugM "QHP" $ "Incoming command: " ++ show cmd debugM "QHP" $ "Incoming command: " ++ show cmd
qdata <- getData db (rqTicker rq) (TimeInterval (rqStartTime rq) (rqEndTime rq)) (Timeframe (periodSeconds $ rqPeriod rq)) qdata <- getData db (rqTicker rq) (TimeInterval (rqStartTime rq) (rqEndTime rq)) (Timeframe (periodSeconds $ rqPeriod rq))
let bytes = serializeBars $ V.concat $ fmap snd qdata let bytes = serializeBars $ V.concat $ fmap snd qdata
sendMulti sock $ peerId :| B.empty : [BL.toStrict bytes] sendMulti sock $ peerId :| [B.empty, "OK", BL.toStrict bytes]
serializeBars :: V.Vector Bar -> BL.ByteString serializeBars :: V.Vector Bar -> BL.ByteString
serializeBars bars = runPut $ V.forM_ bars serializeBar' serializeBars bars = runPut $ V.forM_ bars serializeBar'
serializeBar' bar = do serializeBar' bar = do

Write Preview
Loading…
Cancel
Save