{-# LANGUAGE FlexibleInstances #-}
{-# LANGUAGE MultiParamTypeClasses #-}
{-# LANGUAGE TypeFamilies #-}

{- | This modules provides concurrency abstractions for hedgehog tests. Using "lifted-base" one can execute
expensive test actions concurrently.

For example, the actions invoked inside 'mapConcurrently_' are invoked in the same 'MonadTest' as the outer
monad of 'mapConcurrently_'.

@
import qualified Hedgehog.Extras.Test.Concurrent as H

setUpEnvironment = H.mapConcurrently_ id
  [ H.threadDelay 100 >> pure 1
  , H.threadDelay 200 >> pure 2
  , H.threadDelay 300 >> pure 3
  ]
@


__Warning: Do not use this module for running concurrent checks!__ The 'MonadBaseControl' instance does not
aggregate effects for 'PropertyT'. Consider the following code:

@
  LA.mapConcurrently_ id
    [ do
      H.note_ \"FAIL1\"
      success
    , do
      IO.threadDelay 1_000_000
      H.note_ \"FAIL2\"
      failure
    , do
      H.note_ \"FAIL3\"
      failure
    ]
@

Executing this code will give you the following output in the test report:

@
66 ┃   LA.mapConcurrently_ id
67 ┃     [ do
68 ┃       H.note_ \"FAIL1\"
   ┃       │ FAIL1
69 ┃       success
70 ┃     , do
71 ┃       IO.threadDelay 1_000_000
72 ┃       H.note_ \"FAIL2\"
   ┃       │ FAIL2
73 ┃       failure
   ┃       ^^^^^^^
74 ┃     , do
75 ┃       H.note_ \"FAIL3\"
76 ┃       failure
77 ┃     ]
@
Please note that only @FAIL1@ and @FAIL2@ annotations were reported - @FAIL3@ annotation and the failure
below was swallowed without any information.

__Don't use concurrency abstractions from this module, when you need to aggregate and report failures!__

-}
module Hedgehog.Extras.Test.Concurrent
  ( threadDelay
  , asyncRegister_
  -- * Re-exports of concurrency abstractions from @lifted-base@
  , module Control.Concurrent.Async.Lifted
  , module Control.Concurrent.MVar.Lifted
  , module System.Timeout.Lifted
  ) where

import           Control.Concurrent.Async.Lifted
import qualified Control.Concurrent.Lifted as IO
import           Control.Concurrent.MVar.Lifted
import           Control.Monad.IO.Class
import           Control.Monad.Trans.Resource
import           Data.Function
import           Data.Int
import qualified GHC.Stack as GHC
import           System.IO (IO)
import           System.Timeout.Lifted
import           Hedgehog.Extras.Internal.Orphans ()

import           Control.Monad
import           Control.Monad.Catch (MonadCatch)
import           GHC.Stack
import           Hedgehog
import qualified Hedgehog as H

-- | Delay the thread by 'n' microseconds.
threadDelay :: (HasCallStack, MonadTest m, MonadIO m) => Int -> m ()
threadDelay :: forall (m :: * -> *).
(HasCallStack, MonadTest m, MonadIO m) =>
Int -> m ()
threadDelay Int
n = m () -> m ()
(HasCallStack => m ()) -> m ()
forall a. HasCallStack => (HasCallStack => a) -> a
GHC.withFrozenCallStack (m () -> m ()) -> (IO () -> m ()) -> IO () -> m ()
forall b c a. (b -> c) -> (a -> b) -> a -> c
. IO () -> m ()
forall (m :: * -> *) a.
(MonadTest m, MonadIO m, HasCallStack) =>
IO a -> m a
H.evalIO (IO () -> m ()) -> IO () -> m ()
forall a b. (a -> b) -> a -> b
$ Int -> IO ()
forall (m :: * -> *). MonadBase IO m => Int -> m ()
IO.threadDelay Int
n

-- | Runs an action in background, and registers its cancellation to 'MonadResource'.
asyncRegister_ :: HasCallStack
               => MonadTest m
               => MonadResource m
               => MonadCatch m
               => IO a -- ^ Action to run in background
               -> m ()
asyncRegister_ :: forall (m :: * -> *) a.
(HasCallStack, MonadTest m, MonadResource m, MonadCatch m) =>
IO a -> m ()
asyncRegister_ IO a
act = (HasCallStack => m ()) -> m ()
forall a. HasCallStack => (HasCallStack => a) -> a
GHC.withFrozenCallStack ((HasCallStack => m ()) -> m ()) -> (HasCallStack => m ()) -> m ()
forall a b. (a -> b) -> a -> b
$ m (ReleaseKey, Async a) -> m ()
forall (f :: * -> *) a. Functor f => f a -> f ()
void (m (ReleaseKey, Async a) -> m ())
-> (m (ReleaseKey, Async a) -> m (ReleaseKey, Async a))
-> m (ReleaseKey, Async a)
-> m ()
forall b c a. (b -> c) -> (a -> b) -> a -> c
. m (ReleaseKey, Async a) -> m (ReleaseKey, Async a)
forall (m :: * -> *) a.
(MonadTest m, MonadCatch m, HasCallStack) =>
m a -> m a
H.evalM (m (ReleaseKey, Async a) -> m ())
-> m (ReleaseKey, Async a) -> m ()
forall a b. (a -> b) -> a -> b
$ IO (Async a) -> (Async a -> IO ()) -> m (ReleaseKey, Async a)
forall (m :: * -> *) a.
MonadResource m =>
IO a -> (a -> IO ()) -> m (ReleaseKey, a)
allocate (IO a -> IO (Async (StM IO a))
forall (m :: * -> *) a.
MonadBaseControl IO m =>
m a -> m (Async (StM m a))
async IO a
act) Async a -> IO ()
forall a. Async a -> IO ()
cleanUp
  where
    cleanUp :: Async a -> IO ()
    cleanUp :: forall a. Async a -> IO ()
cleanUp Async a
a = Async a -> IO ()
forall (m :: * -> *) a. MonadBase IO m => Async a -> m ()
cancel Async a
a IO () -> IO () -> IO ()
forall a b. IO a -> IO b -> IO b
forall (m :: * -> *) a b. Monad m => m a -> m b -> m b
>> IO () -> IO ()
forall (f :: * -> *) a. Functor f => f a -> f ()
void (Async a -> IO ()
forall (m :: * -> *) a. MonadBase IO m => Async a -> m ()
link Async a
a)