| Safe Haskell | Safe-Inferred |
|---|---|
| Language | GHC2021 |
Hydra.NodeSpec
Synopsis
- spec :: Spec
- primeWith :: Monad m => [Input tx] -> HydraNode tx m -> m (HydraNode tx m)
- notConnect :: MonadThrow m => DraftHydraNode tx m -> m (HydraNode tx m)
- mockServer :: Monad m => Server tx m
- mockNetwork :: Monad m => Network m (Message tx)
- mockChain :: MonadThrow m => Chain tx m
- mockSink :: Monad m => EventSink a m
- mockEventStore :: Monad m => [a] -> EventStore a m
- mockSource :: Monad m => [a] -> EventSource a m
- createRecordingSink :: IO (EventSink a IO, IO [a])
- createMockEventStore :: MonadLabelledSTM m => m (EventStore a m)
- inputsToOpenHead :: [Input SimpleTx]
- observationInput :: OnChainTx SimpleTx -> Input SimpleTx
- runToCompletion :: IsChainState tx => HydraNode tx IO -> IO ()
- testHydraNode :: (MonadDelay m, MonadAsync m, MonadLabelledSTM m, MonadThrow m, MonadUnliftIO m) => Tracer m (HydraNodeLog SimpleTx) -> SigningKey HydraKey -> [Party] -> ContestationPeriod -> [Input SimpleTx] -> m (HydraNode SimpleTx m)
- testTTL :: TTL
- recordNetwork :: HydraNode tx IO -> IO (HydraNode tx IO, IO [Message tx])
- recordServerOutputs :: IsChainState tx => HydraNode tx IO -> IO (HydraNode tx IO, IO [Either (ServerOutput tx) (ClientMessage tx)])
- messageRecorder :: IO (msg -> IO (), IO [msg])
- throwExceptionOnPostTx :: IsChainState tx => PostTxError tx -> HydraNode tx IO -> IO (HydraNode tx IO)
Documentation
primeWith :: Monad m => [Input tx] -> HydraNode tx m -> m (HydraNode tx m) Source #
Add given list of inputs to the InputQueue. This is returning the node to
allow for chaining with runToCompletion.
notConnect :: MonadThrow m => DraftHydraNode tx m -> m (HydraNode tx m) Source #
Convert a DraftHydraNode to a HydraNode by providing mock implementations.
mockServer :: Monad m => Server tx m Source #
mockNetwork :: Monad m => Network m (Message tx) Source #
mockEventStore :: Monad m => [a] -> EventStore a m Source #
mockSource :: Monad m => [a] -> EventSource a m Source #
createMockEventStore :: MonadLabelledSTM m => m (EventStore a m) Source #
inputsToOpenHead :: [Input SimpleTx] Source #
observationInput :: OnChainTx SimpleTx -> Input SimpleTx Source #
runToCompletion :: IsChainState tx => HydraNode tx IO -> IO () Source #
testHydraNode :: (MonadDelay m, MonadAsync m, MonadLabelledSTM m, MonadThrow m, MonadUnliftIO m) => Tracer m (HydraNodeLog SimpleTx) -> SigningKey HydraKey -> [Party] -> ContestationPeriod -> [Input SimpleTx] -> m (HydraNode SimpleTx m) Source #
Creates a full HydraNode with given parameters and primed Inputs. Note
that this node is notConnected to any components.
A lot shorter than the real world ttl which requires to be long to overcome some longer chain observation delays, but would just make tests longer.