Update onClusterStartup hook to return node config path

Author: errfrom

src/Internal/Contract/Hooks.purs

@@ -23,6 +23,7 @@ type Hooks =
 
 type ClusterParameters =
   { nodeSocketPath :: FilePath
+  , nodeConfigPath :: FilePath
   }
 
 emptyHooks :: Hooks

src/Internal/Testnet/Contract.purs

@@ -44,6 +44,7 @@ import Control.Monad.State (State, execState, modify_)
 import Control.Monad.Trans.Class (lift)
 import Control.Monad.Writer (censor, execWriterT, tell)
 import Control.Parallel (parTraverse)
+import Ctl.Internal.Contract.Hooks (ClusterParameters)
 import Ctl.Internal.Test.ContractTest
   ( ContractTest(ContractTest)
   , ContractTestPlan(ContractTestPlan)
@@ -62,7 +63,7 @@ import Ctl.Internal.Testnet.DistributeFunds
   )
 import Ctl.Internal.Testnet.DistributeFunds (Tx(Tx)) as DistrFunds
 import Ctl.Internal.Testnet.Server
-  ( StartedTestnetCluster
+  ( StartedTestnetCluster(StartedTestnetCluster)
   , makeClusterContractEnv
   , mkLogging
   , startTestnetCluster
@@ -243,14 +244,17 @@ startTestnetContractEnv
 startTestnetContractEnv cfg distr cleanupRef = do
   _ <- cleanupOnExit cleanupRef
   logging@{ logger } <- liftEffect $ mkLogging cfg
-  cluster <- startTestnetCluster cfg cleanupRef logger
+  cluster@(StartedTestnetCluster { paths: { nodeSocketPath, nodeConfigPath } }) <-
+    startTestnetCluster cfg cleanupRef logger
   { env, printLogs, clearLogs } <- makeClusterContractEnv cleanupRef logging
   wallets <- mkWallets env cluster
-  apathize $ liftEffect $
-    for_ env.hooks.onClusterStartup \onClusterStartup ->
-      onClusterStartup
-        { nodeSocketPath: (unwrap cluster).paths.nodeSocketPath
-        }
+  let
+    clusterParams :: ClusterParameters
+    clusterParams =
+      { nodeSocketPath
+      , nodeConfigPath
+      }
+  apathize $ liftEffect $ for_ env.hooks.onClusterStartup (_ $ clusterParams)
   pure
     { cluster
     , env

src/Internal/Testnet/Server.purs

@@ -1,6 +1,6 @@
 module Ctl.Internal.Testnet.Server
   ( Channels
-  , StartedTestnetCluster(MkStartedTestnetCluster)
+  , StartedTestnetCluster(StartedTestnetCluster)
   , startKupo
   , startOgmios
   , startTestnetCluster
@@ -103,7 +103,7 @@ type Channels a =
   , stdout :: EventSource a
   }
 
-newtype StartedTestnetCluster = MkStartedTestnetCluster
+newtype StartedTestnetCluster = StartedTestnetCluster
   { ogmios ::
       { process :: ManagedProcess
       , channels :: Channels String
@@ -224,7 +224,7 @@ startTestnetCluster cfg cleanupRef logger = do
   kupo <- annotateError "Could not start kupo"
     $ startKupo' { paths, workdir: workdirAbsolute }
 
-  pure $ MkStartedTestnetCluster
+  pure $ StartedTestnetCluster
     { paths
     , ogmios
     , kupo

test/Testnet/ClusterParameters.purs

@@ -16,13 +16,15 @@ import Effect.Class (liftEffect)
 import Effect.Ref (Ref)
 import Effect.Ref as Ref
 import Mote (group, test)
-import Test.Spec.Assertions (shouldNotEqual)
+import Node.FS.Sync (exists)
+import Test.Spec.Assertions (shouldNotEqual, shouldReturn)
 
 runTest :: TestPlanM (Aff Unit) Unit
 runTest = do
   clusterParamsRef <-
     liftEffect $ Ref.new
       { nodeSocketPath: mempty
+      , nodeConfigPath: mempty
       }
   testTestnetContracts
     defaultTestnetConfig
@@ -39,5 +41,8 @@ mkSuite ref = do
       withWallets unit \_ -> do
         clusterParams <- liftEffect $ Ref.read ref
         clusterParams.nodeSocketPath `shouldNotEqual` mempty
+        clusterParams.nodeConfigPath `shouldNotEqual` mempty
+        liftEffect (exists clusterParams.nodeSocketPath) `shouldReturn` true
+        liftEffect (exists clusterParams.nodeConfigPath) `shouldReturn` true
         logDebug' $ "ClusterParameters: " <> show clusterParams
         pure unit