mirror of
https://github.com/ilyakooo0/urbit.git
synced 2024-12-21 05:41:43 +03:00
73 lines
2.0 KiB
Haskell
73 lines
2.0 KiB
Haskell
{-|
|
|
Convenient Re-Exports
|
|
-}
|
|
|
|
module Urbit.Prelude
|
|
( module ClassyPrelude
|
|
, module Control.Arrow
|
|
, module Control.Lens
|
|
, module Data.Acquire
|
|
, module Data.RAcquire
|
|
, module Data.Void
|
|
, module Urbit.Noun
|
|
, module Text.Show.Pretty
|
|
, module Text.Printf
|
|
, module RIO
|
|
, io, rio
|
|
, logTrace
|
|
, acquireWorker, acquireWorkerBound
|
|
, hark
|
|
) where
|
|
|
|
import ClassyPrelude
|
|
import Urbit.Noun
|
|
|
|
import Control.Arrow ((<<<), (>>>))
|
|
import Control.Lens hiding (Each, Index, cons, index, snoc, uncons, unsnoc,
|
|
(<.>), (<|))
|
|
import Data.Acquire (Acquire, mkAcquire, with)
|
|
import Data.RAcquire (RAcquire, mkRAcquire, rwith)
|
|
import Data.RAcquire (MonadAcquire(..), MonadRIO(..))
|
|
import Data.Void (Void, absurd)
|
|
import Text.Printf (printf)
|
|
import Text.Show.Pretty (pPrint, ppShow)
|
|
|
|
import RIO (RIO, runRIO)
|
|
import RIO (Utf8Builder, display, displayShow)
|
|
import RIO (threadDelay)
|
|
import RIO (HasLogFunc, LogFunc, LogLevel(..), logDebug, logError, logFuncL,
|
|
logInfo, logOptionsHandle, logOther, logWarn, mkLogFunc,
|
|
setLogMinLevel, setLogUseLoc, setLogUseTime, withLogFunc)
|
|
|
|
import qualified RIO
|
|
|
|
io :: MonadIO m => IO a -> m a
|
|
io = liftIO
|
|
|
|
rio :: MonadRIO m => RIO e a -> m e a
|
|
rio = liftRIO
|
|
|
|
logTrace :: HasLogFunc e => Utf8Builder -> RIO e ()
|
|
logTrace = logOther "trace"
|
|
|
|
-- | Composes a log message out of textual components.
|
|
hark :: [Text] -> Utf8Builder
|
|
hark = RIO.displayBytesUtf8 . foldMap encodeUtf8
|
|
|
|
-- Utils for Spawning Worker Threads -------------------------------------------
|
|
|
|
acquireWorker :: HasLogFunc e => Text -> RIO e () -> RAcquire e (Async ())
|
|
acquireWorker nam act = mkRAcquire (async act) kill
|
|
where
|
|
kill tid = do
|
|
logInfo ("Killing worker thread: " <> display nam)
|
|
cancel tid
|
|
|
|
acquireWorkerBound :: HasLogFunc e => Text -> RIO e () -> RAcquire e (Async ())
|
|
acquireWorkerBound nam act = mkRAcquire (asyncBound act) kill
|
|
where
|
|
kill tid = do
|
|
logInfo ("Killing worker thread: " <> display nam)
|
|
cancel tid
|
|
|