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/Client.hs | 24 +++++++++++++----------- 1 file changed, 13 insertions(+), 11 deletions(-) (limited to 'hsm-core/Hsm/Core/Zmq/Client.hs') diff --git a/hsm-core/Hsm/Core/Zmq/Client.hs b/hsm-core/Hsm/Core/Zmq/Client.hs index 97728f7..aa74ed3 100644 --- a/hsm-core/Hsm/Core/Zmq/Client.hs +++ b/hsm-core/Hsm/Core/Zmq/Client.hs @@ -75,14 +75,16 @@ runClient :: ) => Eff (Client : es) a -> Eff es a -runClient action = - withSocket Z.Sub >>= \sock -> - E.evalStaticRep (Client sock) $ do - localDomain domain $ do - logInfo_ "Initializing ZMQ client" - env <- ask @env - forM_ env.subEps $ E.unsafeEff_ . Z.connect sock . unpack - forM_ env.topics $ E.unsafeEff_ . Z.subscribe sock . encodeUtf8 - logTrace_ $ "Listening to " <> pack (show env.subEps) - logTrace_ $ "Subscribed to " <> pack (show env.topics) - action +runClient action = do + sock <- localDomain domain $ withSocket Z.Sub + E.evalStaticRep (Client sock) $ do + localDomain domain $ initialize sock + action + where + initialize sock = do + logInfo_ "Initializing ZMQ client" + env <- ask @env + forM_ env.subEps $ E.unsafeEff_ . Z.connect sock . unpack + forM_ env.topics $ E.unsafeEff_ . Z.subscribe sock . encodeUtf8 + logTrace_ $ "Listening to " <> pack (show env.subEps) + logTrace_ $ "Subscribed to " <> pack (show env.topics) -- cgit v1.2.1