timestamp

Author: carbolymer

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

@@ -50,6 +50,8 @@ import           Cardano.Node.Protocol.Types
 import           Cardano.Node.Queries
 import           Cardano.Rpc.Server
 import           Cardano.Rpc.Server.Config
+import           Cardano.Rpc.Server.Internal.Env (NodeKernelAccess)
+import           Cardano.Rpc.Server.NodeKernelAccess.Internal (mkNodeKernelAccess)
 import           Data.IORef
 import           Cardano.Node.Startup
 import           Cardano.Node.TraceConstraints (TraceConstraints)

cardano-testnet/test/cardano-testnet-test/Cardano/Testnet/Test/Rpc/FetchBlock.hs

@@ -19,15 +19,18 @@ import           Cardano.Testnet
 
 import           Prelude
 
+import           Control.Monad ((<=<))
 import qualified Data.ByteString as BS
 import qualified Data.ByteString.Short as SBS
 import           Data.Default.Class
+import           Data.Time.Clock.POSIX (utcTimeToPOSIXSeconds)
 import           Data.Word (Word64)
 import           Lens.Micro
 
 import           Testnet.Process.Run
 import           Testnet.Property.Util (integrationRetryWorkspace)
 import           Testnet.Start.Types
+import           Testnet.Types (nodeConnectionInfo)
 
 import qualified Hedgehog as H
 import qualified Hedgehog.Extras as H
@@ -46,7 +49,7 @@ hprop_rpc_fetch_block = integrationRetryWorkspace 2 "rpc-fetch-block" $ \tempAbs
         creationOptions = def{creationEra = AnyShelleyBasedEra sbe}
         runtimeOptions = def{runtimeEnableRpc = RpcEnabled}
 
-    TestnetRuntime
+    tr@TestnetRuntime
         { testnetMagic
         , testnetNodes = node0@TestnetNode{nodeSprocket} : _
         } <-
@@ -92,5 +95,17 @@ hprop_rpc_fetch_block = integrationRetryWorkspace 2 "rpc-fetch-block" $ \tempAbs
     -- height is the block number from ChainDB
     block ^. U5c.cardano . U5c.header . U5c.height H.=== blockNo
 
-    -- timestamp is not available without era history, defaults to 0
-    block ^. U5c.cardano . U5c.timestamp H.=== 0
+    -- Compute expected timestamp via N2C IPC
+    connectionInfo <- nodeConnectionInfo tr 0
+    (systemStart, eraHistory) <-
+        (H.leftFail <=< H.leftFailM) . H.evalIO $
+          executeLocalStateQueryExpr connectionInfo VolatileTip $ do
+            ss <- querySystemStart
+            eh <- queryEraHistory
+            pure $ (,) <$> ss <*> eh
+    expectedTimestampMs :: Word64 <- H.leftFail $ do
+        utcTime <- slotToUTCTime systemStart eraHistory (SlotNo slot)
+        pure . round $ utcTimeToPOSIXSeconds utcTime * 1000
+
+    -- Verify timestamp is within 1000ms of expected
+    H.assertWithinTolerance (block ^. U5c.cardano . U5c.timestamp) expectedTimestampMs 1000