From 194800033037f25f4c9fdae365f63f6abe0e110c Mon Sep 17 00:00:00 2001 From: Paul Oliver Date: Tue, 28 Jan 2025 21:59:21 +0000 Subject: Adds logging domain to ZMQ resource operations --- hsm-core/Hsm/Core/Zmq/Server.hs | 20 +++++++++++--------- 1 file changed, 11 insertions(+), 9 deletions(-) (limited to 'hsm-core/Hsm/Core/Zmq/Server.hs') diff --git a/hsm-core/Hsm/Core/Zmq/Server.hs b/hsm-core/Hsm/Core/Zmq/Server.hs index 6ea8aeb..fd2f159 100644 --- a/hsm-core/Hsm/Core/Zmq/Server.hs +++ b/hsm-core/Hsm/Core/Zmq/Server.hs @@ -54,12 +54,14 @@ runServer :: ) => Eff (Server : es) a -> Eff es a -runServer action = - withSocket Z.Pub >>= \sock -> - E.evalStaticRep (Server sock) $ do - localDomain domain $ do - logInfo_ "Initializing ZMQ server" - env <- ask @env - E.unsafeEff_ $ Z.bind sock $ unpack env.pubEp - logTrace_ $ "Publishing to " <> env.pubEp - action +runServer action = do + sock <- localDomain domain $ withSocket Z.Pub + E.evalStaticRep (Server sock) $ do + localDomain domain $ initialize sock + action + where + initialize sock = do + logInfo_ "Initializing ZMQ server" + env <- ask @env + E.unsafeEff_ $ Z.bind sock $ unpack env.pubEp + logTrace_ $ "Publishing to " <> env.pubEp -- cgit v1.2.1