Add nodeCanSupportMultipleEtcdClusters test

Author: locallycompact

hydra-cluster/src/Hydra/Cluster/Scenarios.hs

@@ -1096,6 +1096,29 @@ threeNodesNoErrorsOnOpen tracer tmpDir node@RunningNode{nodeSocket} hydraScripts
       Right _headIsOpen ->
         pure ()
 
+-- | Hydra nodes ABC run and connect to each other.
+-- Hydra nodes ABC shut down.
+-- Hydra nodes AB run and connect to each other.
+-- Hydra nodes AB shut down.
+-- Hydra nodes ABC run and connect to each other.
+nodeCanSupportMultipleEtcdClusters :: Tracer IO EndToEndLog -> FilePath -> RunningNode -> [TxId] -> IO ()
+nodeCanSupportMultipleEtcdClusters tracer tmpDir RunningNode{nodeSocket} hydraScriptsTxId = do
+  aliceKeys <- generate genKeyPair
+  bobKeys <- generate genKeyPair
+  carolKeys <- generate genKeyPair
+
+  let cardanoKeysABC = [aliceKeys, bobKeys, carolKeys]
+      hydraKeysABC = [aliceSk, bobSk, carolSk]
+  let cardanoKeysAB = [aliceKeys, bobKeys]
+      hydraKeysAB = [aliceSk, bobSk]
+
+  let contestationPeriod = UnsafeContestationPeriod 2
+  let depositDeadline = UnsafeDepositDeadline 50
+  let hydraTracer = contramap FromHydraNode tracer
+  withHydraCluster hydraTracer tmpDir nodeSocket 1 cardanoKeysABC hydraKeysABC hydraScriptsTxId contestationPeriod depositDeadline $ \clients -> waitForNodesConnected hydraTracer 20 clients
+  withHydraCluster hydraTracer tmpDir nodeSocket 1 cardanoKeysAB hydraKeysAB hydraScriptsTxId contestationPeriod depositDeadline $ \clients -> waitForNodesConnected hydraTracer 20 clients
+  withHydraCluster hydraTracer tmpDir nodeSocket 1 cardanoKeysABC hydraKeysABC hydraScriptsTxId contestationPeriod depositDeadline $ \clients -> waitForNodesConnected hydraTracer 20 clients
+
 -- | Two hydra node setup where Alice is wrongly configured to use Carol's
 -- cardano keys instead of Bob's which will prevent him to be notified the
 -- `HeadIsInitializing` but he should still receive some notification.

hydra-cluster/test/Test/EndToEndSpec.hs

@@ -60,6 +60,7 @@ import Hydra.Cluster.Scenarios (
   checkFanout,
   headIsInitializingWith,
   initWithWrongKeys,
+  nodeCanSupportMultipleEtcdClusters,
   nodeReObservesOnChainTxs,
   oneOfThreeNodesStopsForAWhile,
   persistenceCanLoadWithEmptyCommit,
@@ -282,6 +283,13 @@ spec = around (showLogsOnFailure "EndToEndSpec") $ do
               publishHydraScriptsAs node Faucet
                 >>= threeNodesNoErrorsOnOpen tracer tmpDir node
 
+      it "node can support multiple etcd clusters" $ \tracer ->
+        failAfter 60 $
+          withClusterTempDir $ \tmpDir -> do
+            withCardanoNodeDevnet (contramap FromCardanoNode tracer) tmpDir $ \node -> do
+              publishHydraScriptsAs node Faucet
+                >>= nodeCanSupportMultipleEtcdClusters tracer tmpDir node
+
       it "inits a Head, processes a single Cardano transaction and closes it again" $ \tracer ->
         failAfter 60 $
           withClusterTempDir $ \tmpDir -> do