Data.Morpheus.Subscriptions.Internal

Documentation

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

disconnect :: ApiContext SUB e m -> Input SUB -> m ()

connectionThread :: (MonadUnliftIO m, Eq ch, Hashable ch) => App (Event ch con) m -> ApiContext SUB (Event ch con) m -> m ()

runStreamWS :: Monad m => ApiContext SUB e m -> Output SUB e m -> m ()

runStreamHTTP :: Monad m => ApiContext PUB e m -> Output PUB e m -> m GQLResponse

data ApiContext (api :: API) event (m :: Type -> Type) where

Constructors

PubContext

Fields

• :: { eventPublisher :: event -> m ()
•    } -> ApiContext PUB event m

SubContext

Fields

• :: { listener :: m ByteString
•    , callback :: ByteString -> m ()
•    , updateStore :: (ClientConnectionStore event m -> ClientConnectionStore event m) -> m ()
•    } -> ApiContext SUB event m

data Input (api :: API) where

Constructors

InitConnection :: UUID -> Input SUB

Request :: GQLRequest -> Input PUB

type PUB = 'PUB

type SUB = 'SUB

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 recommended that you use many local ClientStores on every server node rather then single centralized Store.

Constructors

Store

Fields

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

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

Instances

Show e => Show (ClientConnectionStore (Event e c) m)

Defined in Data.Morpheus.Subscriptions.ClientConnectionStore

Methods

showsPrec :: Int -> ClientConnectionStore (Event e c) m -> ShowS

show :: ClientConnectionStore (Event e c) m -> String

showList :: [ClientConnectionStore (Event e c) m] -> ShowS

Empty (ClientConnectionStore (Event ch con) m)

Defined in Data.Morpheus.Subscriptions.ClientConnectionStore

Methods

empty :: ClientConnectionStore (Event ch con) m

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

data SessionID

Instances

Generic SessionID

Defined in Data.Morpheus.Subscriptions.ClientConnectionStore

Associated Types

type Rep SessionID :: Type -> Type

Methods

from :: SessionID -> Rep SessionID x

to :: Rep SessionID x -> SessionID

Show SessionID

Defined in Data.Morpheus.Subscriptions.ClientConnectionStore

Methods

showsPrec :: Int -> SessionID -> ShowS

show :: SessionID -> String

showList :: [SessionID] -> ShowS

Eq SessionID

Defined in Data.Morpheus.Subscriptions.ClientConnectionStore

Methods

(==) :: SessionID -> SessionID -> Bool

(/=) :: SessionID -> SessionID -> Bool

Hashable SessionID

Defined in Data.Morpheus.Subscriptions.ClientConnectionStore

Methods

hashWithSalt :: Int -> SessionID -> Int

hash :: SessionID -> Int

type Rep SessionID

Defined in Data.Morpheus.Subscriptions.ClientConnectionStore

type Rep SessionID = D1 ('MetaData "SessionID" "Data.Morpheus.Subscriptions.ClientConnectionStore" "morpheus-graphql-subscriptions-0.27.3-Jp3yrGVVM41CK0cJ4tH1CU" 'False) (C1 ('MetaCons "SessionID" 'PrefixI 'True) (S1 ('MetaSel ('Just "cid") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 UUID) :*: S1 ('MetaSel ('Just "sid") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Text)))

publish :: (Monad m, Eq channel, Hashable channel, Show channel) => Event channel content -> ClientConnectionStore (Event channel content) m -> m ()

initDefaultStore :: (MonadIO m, MonadIO m2) => m2 (Store (Event ch con) m)

initializes empty GraphQL state

publishEventWith :: (MonadIO m, Eq channel, Hashable channel, Show channel) => Store (Event channel cont) m -> Event channel cont -> m ()

empty :: Empty coll => coll

toList :: ClientConnectionStore (Event channel content) m -> [(UUID, ClientConnection m)]

connectionSessionIds :: ClientConnection m -> [Text]

storedSessions :: ClientConnectionStore (Event channel content) m -> [(SessionID, ClientSession (Event channel content) m)]

storedChannels :: ClientConnectionStore (Event channel content) m -> [(channel, [SessionID])]

streamApp :: (Eq ch, Monad m, Hashable ch) => App (Event ch con) m -> Input api -> Output api (Event ch con) m

data ApolloSubscription payload

Constructors

ApolloSubscription

Fields

• apolloId :: Maybe ID
• apolloType :: Text
• apolloPayload :: Maybe payload

Instances

FromJSON a => FromJSON (ApolloSubscription a)

Defined in Data.Morpheus.Subscriptions.Apollo

Methods

parseJSON :: Value -> Parser (ApolloSubscription a)

parseJSONList :: Value -> Parser [ApolloSubscription a]

ToJSON a => ToJSON (ApolloSubscription a)

Defined in Data.Morpheus.Subscriptions.Apollo

Methods

toJSON :: ApolloSubscription a -> Value

toEncoding :: ApolloSubscription a -> Encoding

toJSONList :: [ApolloSubscription a] -> Value

toEncodingList :: [ApolloSubscription a] -> Encoding

Generic (ApolloSubscription payload)

Defined in Data.Morpheus.Subscriptions.Apollo

Associated Types

type Rep (ApolloSubscription payload) :: Type -> Type

Methods

from :: ApolloSubscription payload -> Rep (ApolloSubscription payload) x

to :: Rep (ApolloSubscription payload) x -> ApolloSubscription payload

Show payload => Show (ApolloSubscription payload)

Defined in Data.Morpheus.Subscriptions.Apollo

Methods

showsPrec :: Int -> ApolloSubscription payload -> ShowS

show :: ApolloSubscription payload -> String

showList :: [ApolloSubscription payload] -> ShowS

type Rep (ApolloSubscription payload)

Defined in Data.Morpheus.Subscriptions.Apollo

type Rep (ApolloSubscription payload)

data ApolloAction

Constructors

SessionStop ID

SessionStart ID GQLRequest

ConnectionInit