Offline mode: allow for multi-party heads

This simulates the corresponding initTx and commitTx transactions
cardano-scaling · Sep 17, 2024 · 26bc95a · 26bc95a
1 parent af2e37b
commit 26bc95a
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 4 deletions.
diff --git a/hydra-node/src/Hydra/Chain/Offline.hs b/hydra-node/src/Hydra/Chain/Offline.hs
@@ -68,10 +68,11 @@ withOfflineChain ::
   NodeId ->
   OfflineChainConfig ->
   Party ->
+  [Party] ->
   -- | Last known chain state as loaded from persistence.
   ChainStateHistory Tx ->
   ChainComponent Tx IO a
-withOfflineChain nodeId OfflineChainConfig{ledgerGenesisFile, initialUTxOFile} party chainStateHistory callback action = do
+withOfflineChain nodeId OfflineChainConfig{ledgerGenesisFile, initialUTxOFile} party otherParties chainStateHistory callback action = do
   initializeOfflineHead
   genesis <- loadGenesisFile ledgerGenesisFile
   withAsync (tickForever genesis callback) $ \tickThread -> do
@@ -103,7 +104,7 @@ withOfflineChain nodeId OfflineChainConfig{ledgerGenesisFile, initialUTxOFile} p
                 , headSeed = offlineHeadSeed nodeId
                 , headParameters =
                     HeadParameters
-                      { parties = [party]
+                      { parties = sort (party : otherParties)
                       , -- NOTE: This is irrelevant in offline mode.
                         contestationPeriod = defaultContestationPeriod
                       }
@@ -120,6 +121,17 @@ withOfflineChain nodeId OfflineChainConfig{ledgerGenesisFile, initialUTxOFile} p
                 , headId
                 }
           }
+      forM_ otherParties $ \p ->
+        callback $
+          Observation
+            { newChainState = initialChainState
+            , observedTx =
+                OnCommitTx
+                  { party = p
+                  , committed = mempty
+                  , headId
+                  }
+            }
       callback $
         Observation
           { newChainState = initialChainState

diff --git a/hydra-node/src/Hydra/Node/Run.hs b/hydra-node/src/Hydra/Node/Run.hs
@@ -118,9 +118,9 @@ run opts = do
     let ledgerEnv = newLedgerEnv protocolParams
      in action (cardanoLedger globals ledgerEnv)
 
-  prepareChainComponent tracer Environment{party} = \case
+  prepareChainComponent tracer Environment{party, otherParties} = \case
     Offline cfg ->
-      pure $ withOfflineChain nodeId cfg party
+      pure $ withOfflineChain nodeId cfg party otherParties
     Direct cfg -> do
       ctx <- loadChainContext cfg party
       wallet <- mkTinyWallet (contramap DirectChain tracer) cfg