Data.Morpheus.Types.Internal.Subscription

Documentation

connect :: MonadIO m => m (Input WS)

disconnect :: Scope WS e m -> Input WS -> m ()

connectionThread :: MonadUnliftIO m => (Input WS -> Stream WS e m) -> Scope WS e m -> m ()

toOutStream :: (Monad m, Eq (StreamChannel e), GQLChannel e, Functor m) => (GQLRequest -> ResponseStream e m (Value VALID)) -> Input api -> Stream api e m

runStreamWS :: Monad m => Scope WS e m -> Stream WS e m -> m ()

runStreamHTTP :: Monad m => Scope HTTP e m -> Stream HTTP e m -> m GQLResponse

data Stream (api :: API) e (m :: * -> *)

Instances

Interpreter e m (Input api) (Stream api e m)

Defined in Data.Morpheus.Server.Deriving.Interpreter

Methods

interpreter :: (Monad m, RootResCon m e query mut sub) => RootResolver m e query mut sub -> Input api -> Stream api e m

data Scope (api :: API) event (m :: * -> *) where

Constructors

ScopeHTTP

Fields

• :: { httpCallback :: event -> m ()
•    } -> Scope HTTP event m

ScopeWS

Fields

• :: { listener :: m ByteString
•    , callback :: ByteString -> m ()
•    , update :: (ClientConnectionStore event m -> ClientConnectionStore event m) -> m ()
•    } -> Scope WS event m

data Input (api :: API) where

Constructors

Init :: ID -> Input WS

Request :: GQLRequest -> Input HTTP

Instances

Interpreter e m (Input api) (Stream api e m)

Defined in Data.Morpheus.Server.Deriving.Interpreter

Methods

interpreter :: (Monad m, RootResCon m e query mut sub) => RootResolver m e query mut sub -> Input api -> Stream api e m

type WS = WS

type HTTP = HTTP

acceptApolloRequest :: MonadIO m => PendingConnection -> m Connection

publish :: (Eq (StreamChannel event), GQLChannel event, Monad m) => event -> ClientConnectionStore event m -> m ()

data Store e m

PubSubStore interface shared GraphQL state between websocket and http server, you can define your own store if you provide write and read methods to work properly Morpheus needs all entries of ClientConnectionStore (+ client Callbacks) that why it is recomended that you use many local ClientStores on evenry server node rathen then single centralized Store.

Constructors

Store

Fields

• readStore :: m (ClientConnectionStore e m)
• writeStore :: (ClientConnectionStore e m -> ClientConnectionStore e m) -> m ()

initDefaultStore :: (MonadIO m, MonadIO m2, Eq (StreamChannel event), GQLChannel event) => m2 (Store event m)

initializes empty GraphQL state

publishEventWith :: (MonadIO m, Eq (StreamChannel event), GQLChannel event) => Store event m -> event -> m ()

class GQLChannel a where

Associated Types

type StreamChannel a :: Type

Methods

streamChannels :: a -> [Channel a]

Instances

GQLChannel ()

Defined in Data.Morpheus.Types.Internal.Resolving.Core

Associated Types

type StreamChannel () :: Type

Methods

streamChannels :: () -> [Channel ()]

GQLChannel (Event channel content)

Defined in Data.Morpheus.Types.Internal.Resolving.Core

Associated Types

type StreamChannel (Event channel content) :: Type

Methods

streamChannels :: Event channel content -> [Channel (Event channel content)]

data ClientConnectionStore e (m :: * -> *)

Instances

Show (ClientConnectionStore e m)

Defined in Data.Morpheus.Types.Internal.Subscription.ClientConnectionStore

Methods

showsPrec :: Int -> ClientConnectionStore e m -> ShowS

show :: ClientConnectionStore e m -> String

showList :: [ClientConnectionStore e m] -> ShowS

empty :: Collection a coll => coll

toList :: ClientConnectionStore e m -> [(UUID, ClientConnection e m)]

connectionSessionIds :: ClientConnection e m -> [SessionID]

type SessionID = Text