Merge pull request #6240 from IntersectMBO/nb/interrupt_nodes

Interrupt cardano nodes when `cardano-testnet` gets interrupted

Author: nbacquey

cardano-testnet/cardano-testnet.cabal

@@ -28,8 +28,13 @@ common project-config
                         -Wredundant-constraints
                         -Wunused-packages
 
+common maybe-unix
+  if !os(windows)
+    build-depends:      unix
+
 library
-  import:               project-config
+  import:               maybe-unix
+                      , project-config
 
   build-depends:        aeson
                       , aeson-pretty
@@ -101,6 +106,7 @@ library
                         Testnet.Defaults
                         Testnet.EpochStateProcessing
                         Testnet.Filepath
+                        Testnet.Handlers
                         Testnet.Ping
                         Testnet.Process.Cli.DRep
                         Testnet.Process.Cli.Keys

cardano-testnet/src/Testnet/Handlers.hs

@@ -0,0 +1,30 @@
+{-# LANGUAGE CPP #-}
+{-# LANGUAGE NamedFieldPuns #-}
+
+#if !defined(mingw32_HOST_OS)
+#define UNIX
+#endif
+
+module Testnet.Handlers
+  ( interruptNodesOnSigINT
+  ) where
+
+#ifdef UNIX
+import           Control.Monad
+import           System.Posix.Signals (Handler (..), installHandler, sigINT, raiseSignal)
+import           System.Process (interruptProcessGroupOf)
+#endif
+
+import           Testnet.Types
+
+interruptNodesOnSigINT :: [TestnetNode] -> IO ()
+#ifdef UNIX
+interruptNodesOnSigINT testnetNodes =
+  -- Interrupt cardano nodes when the main process is interrupted
+  void $ flip (installHandler sigINT) Nothing $ CatchOnce $ do
+    forM_ testnetNodes $ \TestnetNode{nodeProcessHandle} ->
+      interruptProcessGroupOf nodeProcessHandle
+    raiseSignal sigINT
+#else
+interruptNodesOnSigINT _testnetNodes = pure ()
+#endif

cardano-testnet/src/Testnet/Start/Cardano.hs

@@ -52,6 +52,7 @@ import qualified System.Info as OS
 import           Testnet.Components.Configuration
 import qualified Testnet.Defaults as Defaults
 import           Testnet.Filepath
+import           Testnet.Handlers (interruptNodesOnSigINT)
 import           Testnet.Process.Run (execCli', execCli_, mkExecConfig)
 import           Testnet.Property.Assert (assertChainExtended, assertExpectedSposInLedgerState)
 import           Testnet.Runtime as TR
@@ -299,6 +300,8 @@ cardanoTestnet
     H.noteShow_ . vsep $ prettyError <$> failedNodes
     H.failure
 
+  -- Interrupt cardano nodes when the main process is interrupted
+  H.evalIO $ interruptNodesOnSigINT testnetNodes'
   H.annotateShow $ nodeSprocket <$> testnetNodes'
 
   -- FIXME: use foldEpochState waiting for chain extensions

cardano-testnet/test/cardano-testnet-test/Cardano/Testnet/Test/SubmitApi/Transaction.hs

@@ -51,7 +51,7 @@ import qualified Hedgehog.Extras.Test.Golden as H
 import qualified Hedgehog.Extras.Test.TestWatchdog as H
 
 -- | Execute me with:
--- @DISABLE_RETRIES=1 cabal test cardano-testnet-test --test-options '-p "/transaction/"'@
+-- @DISABLE_RETRIES=1 cabal test cardano-testnet-test --test-options '-p "/SubmitApi.transaction/"'@
 hprop_transaction :: Property
 hprop_transaction = integrationRetryWorkspace 2 "submit-api-transaction" $ \tempAbsBasePath' -> H.runWithDefaultWatchdog_ $ do
   H.note_ SYS.os