cardano-testnet | Add gRPC evalTx test

Author: carbolymer

.gitignore

@@ -77,3 +77,5 @@ cardano-tracer/cardano-tracer-test
 .idea/
 
 .codex
+
+.serena/

cardano-node/src/Cardano/Node/Run.hs

@@ -57,6 +57,7 @@ import           Cardano.Node.Protocol.Types
 import           Cardano.Node.Queries
 import           Cardano.Rpc.Server
 import           Cardano.Rpc.Server.Config
+import           Data.IORef
 import           Cardano.Node.Startup
 import           Cardano.Node.TraceConstraints (TraceConstraints)
 import           Cardano.Node.Tracing.API
@@ -541,6 +542,7 @@ handleSimpleNode blockType runP tracers nc networkMagic onKernel = do
 #endif
     nForkPolicy <- getForkPolicy $ ncResponderCoreAffinityPolicy nc
     cForkPolicy <- getForkPolicy $ ncResponderCoreAffinityPolicy nc
+    nodeAccessRef <- newIORef Nothing
     void $
       let diffusionNodeArguments :: Cardano.Diffusion.CardanoNodeArguments IO
           diffusionNodeArguments = Cardano.Diffusion.CardanoNodeArguments {
@@ -573,7 +575,7 @@ handleSimpleNode blockType runP tracers nc networkMagic onKernel = do
               (readTVar ledgerPeerSnapshotVar)
               nc
       in
-      withAsync (rpcServerLoop (startupTracer tracers) (rpcTracer tracers) rpcConfigVar networkMagic) $ \_ ->
+      withAsync (rpcServerLoop (startupTracer tracers) (rpcTracer tracers) rpcConfigVar networkMagic nodeAccessRef) $ \_ ->
         Node.run
           nodeArgs {
               rnNodeKernelHook = \registry nodeKernel -> do
@@ -858,16 +860,17 @@ rpcServerLoop :: Tracer IO (StartupTrace blk)
               -> Tracer IO TraceRpc
               -> StrictTVar IO RpcConfig
               -> NetworkMagic
+              -> IORef (Maybe (NodeAccess IO))
               -> IO ()
-rpcServerLoop startupTracer rpcTracer rpcConfigVar networkMagic = go
+rpcServerLoop startupTracer rpcTracer rpcConfigVar networkMagic nodeAccessRef = go
   where
     go = do
       config@RpcConfig{isEnabled = Identity enabled} <- readTVarIO rpcConfigVar
       if enabled
         then
           race_
             (do
-              runRpcServer rpcTracer (config, networkMagic)
+              runRpcServer rpcTracer config networkMagic nodeAccessRef
               traceWith startupTracer RpcForceDisabled
               disableRpcServer)
             (waitForRpcConfigChange config)

cardano-node/src/Cardano/Node/Tracing/Tracers/Rpc.hs

@@ -46,6 +46,8 @@ instance LogFormatting TraceRpc where
                 TraceRpcSubmitTxDecodingError _ -> []
                 TraceRpcSubmitTxValidationError _ -> []
                 TraceRpcSubmitSpan s -> [spanToObject s]
+                TraceRpcEvalTxDecodingError _ -> []
+                TraceRpcEvalTxSpan s -> [spanToObject s]
 
   forHuman = docToText . pretty
 
@@ -56,6 +58,7 @@ instance LogFormatting TraceRpc where
     TraceRpcQuery (TraceRpcQueryReadUtxosSpan (SpanBegin _)) -> [CounterM "rpc.request.QueryService.ReadUtxos" Nothing]
     TraceRpcQuery (TraceRpcQuerySearchUtxosSpan (SpanBegin _)) -> [CounterM "rpc.request.QueryService.SearchUtxos" Nothing]
     TraceRpcSubmit (TraceRpcSubmitSpan (SpanBegin _)) -> [CounterM "rpc.request.SubmitService.SubmitTx" Nothing]
+    TraceRpcSubmit (TraceRpcEvalTxSpan (SpanBegin _)) -> [CounterM "rpc.request.SubmitService.EvalTx" Nothing]
     _ -> []
 
 instance MetaTrace TraceRpc where
@@ -76,6 +79,8 @@ instance MetaTrace TraceRpc where
             TraceRpcSubmitTxDecodingError _ -> ["TxDecodingError"]
             TraceRpcSubmitTxValidationError _ -> ["TxValidationError"]
             TraceRpcSubmitSpan _ -> ["SubmitTx", "Span"]
+            TraceRpcEvalTxDecodingError _ -> ["EvalTxDecodingError"]
+            TraceRpcEvalTxSpan _ -> ["EvalTx", "Span"]
 
   severityFor (Namespace _ nsInner) _ = case nsInner of
     ["FatalError"] -> Just Error -- RPC server startup errors
@@ -84,9 +89,11 @@ instance MetaTrace TraceRpc where
     ["QueryService", "ReadUtxos", "Span"] -> Just Debug
     ["QueryService", "SearchUtxos", "Span"] -> Just Debug
     ["SubmitService", "SubmitTx", "Span"] -> Just Debug
+    ["SubmitService", "EvalTx", "Span"] -> Just Debug
     ["SubmitService", "N2cConnectionError"] -> Just Warning -- this is a more serious error, this shouldn't happen
     ["SubmitService", "TxDecodingError"] -> Just Debug -- request error
     ["SubmitService", "TxValidationError"] -> Just Debug -- request error
+    ["SubmitService", "EvalTxDecodingError"] -> Just Debug -- request error
     _ -> Nothing
 
   documentFor (Namespace _ nsInner) = case nsInner of
@@ -96,11 +103,13 @@ instance MetaTrace TraceRpc where
     ["QueryService", "ReadUtxos", "Span"] -> Just "Span for the ReadUtxos UTXORPC method."
     ["QueryService", "SearchUtxos", "Span"] -> Just "Span for the SearchUtxos UTXORPC method."
     ["SubmitService", "SubmitTx", "Span"] -> Just "Span for the SubmitTx UTXORPC method."
+    ["SubmitService", "EvalTx", "Span"] -> Just "Span for the EvalTx UTXORPC method."
     ["SubmitService", "N2cConnectionError"] ->
       Just
         "Node connection error. This should not happen, as this means that there is an issue in cardano-rpc configuration."
     ["SubmitService", "TxDecodingError"] -> Just "A regular request error, when submitted transaction decoding fails."
     ["SubmitService", "TxValidationError"] -> Just "A regular request error, when submitted transaction is invalid."
+    ["SubmitService", "EvalTxDecodingError"] -> Just "A regular request error, when evalTx transaction decoding fails."
     _ -> Nothing
 
   metricsDocFor (Namespace _ nsInner) = case nsInner of
@@ -112,6 +121,8 @@ instance MetaTrace TraceRpc where
       [("rpc.request.QueryService.SearchUtxos", "Span for the SearchUtxos UTXORPC method.")]
     ["SubmitService", "SubmitTx", "Span"] ->
       [("rpc.request.SubmitService.SubmitTx", "Span for the SubmitTx UTXORPC method.")]
+    ["SubmitService", "EvalTx", "Span"] ->
+      [("rpc.request.SubmitService.EvalTx", "Span for the EvalTx UTXORPC method.")]
     _ -> []
 
   allNamespaces =
@@ -122,9 +133,11 @@ instance MetaTrace TraceRpc where
           , ["QueryService", "ReadUtxos", "Span"]
           , ["QueryService", "SearchUtxos", "Span"]
           , ["SubmitService", "SubmitTx", "Span"]
+          , ["SubmitService", "EvalTx", "Span"]
           , ["SubmitService", "N2cConnectionError"]
           , ["SubmitService", "TxDecodingError"]
           , ["SubmitService", "TxValidationError"]
+          , ["SubmitService", "EvalTxDecodingError"]
           ]
 
 -- helper functions

cardano-testnet/cardano-testnet.cabal

@@ -238,6 +238,7 @@ test-suite cardano-testnet-test
                         Cardano.Testnet.Test.Gov.TreasuryDonation
                         Cardano.Testnet.Test.Gov.TreasuryGrowth
                         Cardano.Testnet.Test.Gov.TreasuryWithdrawal
+                        Cardano.Testnet.Test.Rpc.Eval
                         Cardano.Testnet.Test.Rpc.Query
                         Cardano.Testnet.Test.Rpc.SearchUtxos
                         Cardano.Testnet.Test.Rpc.Transaction