Implement executeLocalStateQueryExprWithVersion

Author: Jimbo4350

cardano-api/src/Cardano/Api/Network/IPC.hs

@@ -219,6 +219,7 @@ module Cardano.Api.Network.IPC
     -- **** Query monad
   , LocalStateQueryExpr
   , executeLocalStateQueryExpr
+  , executeLocalStateQueryExprWithVersion
   , queryExpr
 
     -- *** Local tx monitoring

cardano-api/src/Cardano/Api/Network/IPC/Internal/Monad.hs

@@ -5,6 +5,7 @@
 module Cardano.Api.Network.IPC.Internal.Monad
   ( LocalStateQueryExpr
   , executeLocalStateQueryExpr
+  , executeLocalStateQueryExprWithVersion
   , queryExpr
   )
 where
@@ -44,6 +45,31 @@ newtype LocalStateQueryExpr block point query r m a = LocalStateQueryExpr
   }
   deriving (Functor, Applicative, Monad, MonadReader NodeToClientVersion, MonadIO)
 
+-- | Execute a local state query expression.
+executeLocalStateQueryExprWithVersion
+  :: ()
+  => LocalNodeConnectInfo
+  -> Net.Query.Target ChainPoint
+  -> (NodeToClientVersion -> LocalStateQueryExpr BlockInMode ChainPoint QueryInMode () IO a)
+  -> IO (Either AcquiringFailure a)
+executeLocalStateQueryExprWithVersion connectInfo target f = do
+  tmvResultLocalState <- newEmptyTMVarIO
+  let waitResult = readTMVar tmvResultLocalState
+
+  connectToLocalNodeWithVersion
+    connectInfo
+    ( \ntcVersion ->
+        LocalNodeClientProtocols
+          { localChainSyncClient = NoLocalChainSyncClient
+          , localStateQueryClient =
+              Just $ setupLocalStateQueryExpr waitResult target tmvResultLocalState ntcVersion (f ntcVersion)
+          , localTxSubmissionClient = Nothing
+          , localTxMonitoringClient = Nothing
+          }
+    )
+
+  atomically waitResult
+
 -- | Execute a local state query expression.
 executeLocalStateQueryExpr
   :: ()