module LaunchDarkly.Server.Client.Internal
( Client (..)
, Status (..)
, clientVersion
, setStatus
, getStatusI
) where
import Control.Concurrent (ThreadId)
import Control.Concurrent.MVar (MVar)
import Data.Generics.Product (getField)
import Data.IORef (IORef, atomicModifyIORef', readIORef)
import Data.Text (Text)
import GHC.Generics (Generic)
import LaunchDarkly.Server.Client.Status (Status (..), transitionStatus)
import LaunchDarkly.Server.Config.Internal (Config)
import LaunchDarkly.Server.DataSource.Internal (DataSource)
import LaunchDarkly.Server.Events (EventState)
import LaunchDarkly.Server.Store.Internal (StoreHandle, getInitializedC)
clientVersion :: Text
clientVersion :: Text
clientVersion = Text
"4.1.0"
data Client = Client
{ Client -> Config
config :: !(Config)
, Client -> StoreHandle IO
store :: !(StoreHandle IO)
, Client -> IORef Status
status :: !(IORef Status)
, Client -> EventState
events :: !EventState
, Client -> Maybe (ThreadId, MVar ())
eventThreadPair :: !(Maybe (ThreadId, MVar ()))
, Client -> DataSource
dataSource :: !DataSource
}
deriving ((forall x. Client -> Rep Client x)
-> (forall x. Rep Client x -> Client) -> Generic Client
forall x. Rep Client x -> Client
forall x. Client -> Rep Client x
forall a.
(forall x. a -> Rep a x) -> (forall x. Rep a x -> a) -> Generic a
$cfrom :: forall x. Client -> Rep Client x
from :: forall x. Client -> Rep Client x
$cto :: forall x. Rep Client x -> Client
to :: forall x. Rep Client x -> Client
Generic)
setStatus :: Client -> Status -> IO ()
setStatus :: Client -> Status -> IO ()
setStatus Client
client Status
status' =
IORef Status -> (Status -> (Status, ())) -> IO ()
forall a b. IORef a -> (a -> (a, b)) -> IO b
atomicModifyIORef' (forall (f :: Symbol) a s. HasField' f s a => s -> a
getField @"status" Client
client) ((Status -> (Status, ()))
-> (Status -> Status) -> Status -> (Status, ())
forall a b. (a -> b) -> (Status -> a) -> Status -> b
forall (f :: * -> *) a b. Functor f => (a -> b) -> f a -> f b
fmap (,()) (Status -> Status -> Status
transitionStatus Status
status'))
getStatusI :: Client -> IO Status
getStatusI :: Client -> IO Status
getStatusI Client
client =
IORef Status -> IO Status
forall a. IORef a -> IO a
readIORef (forall (f :: Symbol) a s. HasField' f s a => s -> a
getField @"status" Client
client) IO Status -> (Status -> IO Status) -> IO Status
forall a b. IO a -> (a -> IO b) -> IO b
forall (m :: * -> *) a b. Monad m => m a -> (a -> m b) -> m b
>>= \case
Status
Unauthorized -> Status -> IO Status
forall a. a -> IO a
forall (f :: * -> *) a. Applicative f => a -> f a
pure Status
Unauthorized
Status
ShuttingDown -> Status -> IO Status
forall a. a -> IO a
forall (f :: * -> *) a. Applicative f => a -> f a
pure Status
ShuttingDown
Status
_ ->
StoreHandle IO -> StoreResultM IO Bool
forall store (m :: * -> *).
LaunchDarklyStoreRead store m =>
store -> StoreResultM m Bool
getInitializedC (forall (f :: Symbol) a s. HasField' f s a => s -> a
getField @"store" Client
client) StoreResultM IO Bool
-> (Either Text Bool -> IO Status) -> IO Status
forall a b. IO a -> (a -> IO b) -> IO b
forall (m :: * -> *) a b. Monad m => m a -> (a -> m b) -> m b
>>= \case
Right Bool
True -> Status -> IO Status
forall a. a -> IO a
forall (f :: * -> *) a. Applicative f => a -> f a
pure Status
Initialized
Either Text Bool
_ -> Status -> IO Status
forall a. a -> IO a
forall (f :: * -> *) a. Applicative f => a -> f a
pure Status
Uninitialized