Ctl.Internal.Testnet.Utils

newtype EventSource b

Constructors

• EventSource { cancel :: Error -> Effect Unit, subscribe :: ({ event :: Either Error b, unsubscribe :: Effect Unit } -> Effect Unit) -> Effect (Either Error { unsubscribe :: Effect Unit }) }

type TestnetCleanupRef = Ref (Array (Aff Unit))

findNodeDirs :: { workdir :: FilePath } -> Effect (Array (Record (NodeLocation ())))

onLine :: forall a b. Readable a -> (String -> Maybe b) -> Effect (EventSource b)

makeEventSource :: forall a b c. ({ handle :: Either Error a -> Effect Unit } -> Effect { outcome :: c, unsubscribe :: Effect Unit }) -> (a -> Maybe b) -> Effect { eventSource :: EventSource b, outcome :: c }

findTestnetPaths :: { workdir :: FilePath } -> Effect (Either Error TestnetPaths)

getNodePort :: { nodeDir :: FilePath } -> Effect UInt

getRuntime :: TestnetPaths -> Effect (Record (TestnetRuntime ()))

scheduleCleanup :: forall a. TestnetCleanupRef -> Aff a -> (a -> Aff Unit) -> Aff a

addCleanup :: TestnetCleanupRef -> Aff Unit -> Effect Unit

tmpdir :: Effect String

tmpdirUnique :: forall m. MonadEffect m => String -> m FilePath

runCleanup :: Ref (Array (Aff Unit)) -> Aff Unit

tryAndLogErrors :: forall a m. MonadEffect m => MonadError Error m => String -> m a -> m (Either Error a)

suppressAndLogErrors :: forall m. MonadEffect m => MonadError Error m => String -> m Unit -> m Unit

after :: forall a. Aff a -> (a -> Aff Unit) -> Aff a

Just as a bracket but without the body.

onTestnetEvent :: EventSource String -> Effect (EventSource Event)

parseEvent :: String -> Maybe Event

readNodes :: forall r. { nodeDirs :: Array (Record (NodeLocation ())), testnetDirectory :: FilePath | r } -> Effect (Array (Record (Node ())))

read872GenesisKey :: forall r. Record (GenesisUtxoKeyLocation r) -> Effect PrivatePaymentKey

whenError :: forall (a :: Type). Aff Unit -> Aff a -> Aff a

waitFor :: forall a e. EventSource e -> (e -> Maybe a) -> Aff a

waitForClose :: ManagedProcess -> Aff Unit

Waits until processe's stdout closes.

waitForError :: ManagedProcess -> Aff Error

Waits until processe's stdout closes.

waitForEvent :: forall a. EventSource a -> Aff a

Waits for any event. Note, if the event source throws an async error, any joining process dies.

waitUntil :: forall a d. Duration d => d -> Aff (Maybe a) -> Aff a

cleanupOnExit :: Ref (Array (Aff Unit)) -> Aff { fiber :: Fiber Unit }

annotateError :: forall (a :: Type) m. MonadError Error m => String -> m a -> m a