From 99b172c601cba9543b9062407cd0954b391be846 Mon Sep 17 00:00:00 2001
From: Denis Tereshkin <denis@kasan.ws>
Date: Tue, 24 Dec 2024 20:16:51 +0700
Subject: [PATCH] BrokerServer: debug

---
 src/ATrade/Broker/Backend.hs | 2 +-
 src/ATrade/Broker/Server.hs  | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/ATrade/Broker/Backend.hs b/src/ATrade/Broker/Backend.hs
index 98bf7e6..019bf38 100644
--- a/src/ATrade/Broker/Backend.hs
+++ b/src/ATrade/Broker/Backend.hs
@@ -21,7 +21,7 @@ backendNotificationOrderId (BackendTradeNotification trade) = tradeOrderId trade
 data BrokerBackend = BrokerBackend
   {
     accounts                :: [T.Text],
-    setNotificationCallback :: (Maybe (BrokerBackendNotification -> IO ())) -> IO (),
+    setNotificationCallback :: Maybe (BrokerBackendNotification -> IO ()) -> IO (),
     submitOrder             :: Order -> IO (),
     cancelOrder             :: OrderId -> IO (),
     stop                    :: IO ()
diff --git a/src/ATrade/Broker/Server.hs b/src/ATrade/Broker/Server.hs
index 436f71e..2c27588 100644
--- a/src/ATrade/Broker/Server.hs
+++ b/src/ATrade/Broker/Server.hs
@@ -66,7 +66,6 @@ import           System.ZMQ4                    (Context, Event (In),
                                                  setZapDomain, socket)
 import           System.ZMQ4.ZAP                (zapApplyCertificate)
 
-newtype OrderIdGenerator = IO OrderId
 type PeerId = B.ByteString
 
 data FullOrderId = FullOrderId ClientIdentity OrderId
@@ -276,6 +275,7 @@ brokerServerThread state logger = finally brokerServerThread' cleanup
               return ResponseOk
             _ -> return $ ResponseError "Unknown order"
         RequestNotifications sqnum clientIdentity initialSqnum -> do
+          log Debug "Broker.Server" $ "Request: notifications:" <> (T.pack . show) request
           maybeNs <- M.lookup clientIdentity . pendingNotifications <$> readIORef state
           case maybeNs of
             Just ns -> do
@@ -284,6 +284,7 @@ brokerServerThread state logger = finally brokerServerThread' cleanup
               return $ ResponseNotifications . L.reverse $ filtered
             Nothing -> return $ ResponseNotifications []
         RequestCurrentSqnum sqnum clientIdentity -> do
+          log Debug "Broker.Server" $ "Request: current sqnum:" <> (T.pack . show) request
           sqnumMap <- notificationSqnum <$> readIORef state
           notifMap <- pendingNotifications <$> readIORef state
           case M.lookup clientIdentity notifMap of