module LaunchDarkly.Server.Client.Internal
( Client(..)
, ClientI(..)
, Status(..)
, clientVersion
, setStatus
, getStatusI
) where
import Data.Text (Text)
import Data.IORef (IORef, readIORef, atomicModifyIORef')
import GHC.Generics (Generic)
import Control.Concurrent (ThreadId)
import Control.Concurrent.MVar (MVar)
import Data.Generics.Product (getField)
import LaunchDarkly.Server.Config.Internal (ConfigI)
import LaunchDarkly.Server.Store.Internal (StoreHandle, getInitializedC)
import LaunchDarkly.Server.Events (EventState)
newtype Client = Client ClientI
clientVersion :: Text
clientVersion = "1.0.4"
data Status
= Uninitialized
| Unauthorized
| Initialized
| ShuttingDown
deriving (Eq)
setStatus :: ClientI -> Status -> IO ()
setStatus client status' = atomicModifyIORef' (getField @"status" client) $ \status ->
case status' of
Initialized -> (if status == Uninitialized then Initialized else status, ())
_ -> (if status == ShuttingDown then ShuttingDown else status', ())
getStatusI :: ClientI -> IO Status
getStatusI client = readIORef (getField @"status" client) >>= \case
Unauthorized -> pure Unauthorized
ShuttingDown -> pure ShuttingDown
_ -> getInitializedC (getField @"store" client) >>= \case
Right True -> pure Initialized
_ -> pure Uninitialized
data ClientI = ClientI
{ config :: !(ConfigI)
, store :: !(StoreHandle IO)
, status :: !(IORef Status)
, events :: !EventState
, downloadThreadPair :: !(Maybe (ThreadId, MVar ()))
, eventThreadPair :: !(Maybe (ThreadId, MVar ()))
} deriving (Generic)