Browse Source

Make starting sqnum equal to current posix time

master
Denis Tereshkin 2 years ago
parent
commit
44442e0033
  1. 4
      src/Main.hs
  2. 2
      src/TXMLConnector/Internal.hs

4
src/Main.hs

@ -29,6 +29,7 @@ import Control.Exception (bracket)
import Control.Monad (forever, void) import Control.Monad (forever, void)
import Control.Monad.IO.Class (MonadIO) import Control.Monad.IO.Class (MonadIO)
import qualified Data.Text as T import qualified Data.Text as T
import Data.Time.Clock.POSIX (getPOSIXTime)
import Data.Version (showVersion) import Data.Version (showVersion)
import Debug.EventCounters (emitEvent, import Debug.EventCounters (emitEvent,
initEventCounters) initEventCounters)
@ -108,12 +109,13 @@ main = do
tickTable <- newTickTable tickTable <- newTickTable
paper <- mkPaperBroker tickTable tisH qssCh2 (fromDouble 100000.0) ["demo"] (commissions cfg) logger paper <- mkPaperBroker tickTable tisH qssCh2 (fromDouble 100000.0) ["demo"] (commissions cfg) logger
txml <- Connector.start logger tickTable cfg qssChannel tisH txml <- Connector.start logger tickTable cfg qssChannel tisH
startTimestamp <- floor <$> getPOSIXTime
bracket (startBrokerServer bracket (startBrokerServer
[Connector.makeBrokerBackend txml (account cfg), paper] [Connector.makeBrokerBackend txml (account cfg), paper]
ctx ctx
(brokerEndpoint cfg) (brokerEndpoint cfg)
(brokerNotificationsEndpoint cfg) (brokerNotificationsEndpoint cfg)
(NotificationSqnum 1) (NotificationSqnum startTimestamp)
[tsDashboard, tsGotify] [tsDashboard, tsGotify]
defaultServerSecurityParams defaultServerSecurityParams
logger) (\x -> do logger) (\x -> do

2
src/TXMLConnector/Internal.hs

@ -559,7 +559,7 @@ handleGetInfo = do
tisH <- asks tisHandle tisH <- asks tisHandle
let tickerInfos = securityToTickerInfo <$> securities let tickerInfos = securityToTickerInfo <$> securities
log Info "TXMLConnector.WorkThread" $ "Incoming securities: " <> (T.pack . show . length) securities log Info "TXMLConnector.WorkThread" $ "Incoming securities: " <> (T.pack . show . length) securities
--forM_ tickerInfos (log Debug "TXMLConnector.WorkThread" . T.pack . show . tiTicker) forM_ tickerInfos (log Debug "TXMLConnector.WorkThread" . T.pack . show . tiTicker)
forM_ tickerInfos (liftIO . putTickerInfo tisH) forM_ tickerInfos (liftIO . putTickerInfo tisH)
pure Nothing pure Nothing
TransaqResponseSecInfo secInfo -> do TransaqResponseSecInfo secInfo -> do

Loading…
Cancel
Save