{-|
Module: IHP.AutoRefresh.Types
Description: Types & Data Structures for IHP AutoRefresh
Copyright: (c) digitally induced GmbH, 2020
-}
module IHP.AutoRefresh.Types where

import IHP.Prelude
import Wai.Request.Params.Middleware (Respond)
import Control.Concurrent.MVar (MVar)
import qualified IHP.PGListener as PGListener
import Network.Wai (Request)

data AutoRefreshState = AutoRefreshEnabled { AutoRefreshState -> UUID
sessionId :: !UUID }
data AutoRefreshSession = AutoRefreshSession
        { AutoRefreshSession -> UUID
id :: !UUID
        -- | A callback to rerun an action within the given request and respond
        , AutoRefreshSession -> Request -> Respond -> IO ()
renderView :: !(Request -> Respond -> IO ())
        -- | MVar that is filled whenever some table changed
        , AutoRefreshSession -> MVar ()
event :: !(MVar ())
        -- | All tables this auto refresh session watches
        , AutoRefreshSession -> Set Text
tables :: !(Set Text)
        -- | The last rendered html of this action. Initially this is the result of the initial page rendering
        , AutoRefreshSession -> LByteString
lastResponse :: !LByteString
        -- | Keep track of the last ping to this session to close it after too much time has passed without anything happening
        , AutoRefreshSession -> UTCTime
lastPing :: !UTCTime
        }

data AutoRefreshServer = AutoRefreshServer
        { AutoRefreshServer -> [Subscription]
subscriptions :: [PGListener.Subscription]
        , AutoRefreshServer -> [AutoRefreshSession]
sessions :: ![AutoRefreshSession]
        , AutoRefreshServer -> Set Text
subscribedTables :: !(Set Text)
        , AutoRefreshServer -> PGListener
pgListener :: PGListener.PGListener
        }

newAutoRefreshServer :: PGListener.PGListener -> AutoRefreshServer
newAutoRefreshServer :: PGListener -> AutoRefreshServer
newAutoRefreshServer PGListener
pgListener = AutoRefreshServer { subscriptions :: [Subscription]
subscriptions = [], sessions :: [AutoRefreshSession]
sessions = [], subscribedTables :: Set Text
subscribedTables = Set Text
forall a. Monoid a => a
mempty, PGListener
pgListener :: PGListener
pgListener :: PGListener
pgListener }