integration-0.1.0

Safe Haskell	Safe-Inferred
Language	GHC2021

Test.Events

Synopsis

testConsumeEventsOneWebSocket :: HasCallStack => App ()
testConsumeTempEvents :: HasCallStack => App ()
testConsumeTempEventsWithoutOwnClient :: HasCallStack => App ()
testTemporaryQueuesAreDeletedAfterUse :: HasCallStack => App ()
testMLSTempEvents :: HasCallStack => App ()
testConsumeEventsForDifferentUsers :: HasCallStack => App ()
testConsumeEventsWhileHavingLegacyClients :: HasCallStack => App ()
testConsumeEventsAcks :: HasCallStack => App ()
testConsumeEventsMultipleAcks :: HasCallStack => App ()
testConsumeEventsAckNewEventWithoutAckingOldOne :: HasCallStack => App ()
testEventsDeadLettered :: HasCallStack => App ()
testTransientEventsDoNotTriggerDeadLetters :: HasCallStack => App ()
testTransientEvents :: HasCallStack => App ()
testChannelLimit :: HasCallStack => App ()
testChannelKilled :: HasCallStack => App ()
data EventWebSocket = EventWebSocket {
- events :: Chan (Either ConnectionException Value)
- ack :: MVar (Maybe Value)
}
createEventsWebSocket :: (HasCallStack, MakesValue uid) => uid -> Maybe String -> Codensity App EventWebSocket
ackFullSync :: HasCallStack => EventWebSocket -> App ()
ackEvent :: HasCallStack => EventWebSocket -> Value -> App ()
sendAck :: HasCallStack => EventWebSocket -> Value -> Bool -> App ()
assertEvent :: HasCallStack => EventWebSocket -> (HasCallStack => Value -> App a) -> App a
assertFindsEvent :: forall a. HasCallStack => EventWebSocket -> (HasCallStack => Value -> App a) -> App a
data NoEvent
- = NoEvent
- | WebSocketDied
assertNoEvent :: HasCallStack => EventWebSocket -> App NoEvent
assertNoEvent_ :: HasCallStack => EventWebSocket -> App ()
consumeAllEvents :: EventWebSocket -> App ()
killConnection :: HasCallStack => BackendResource -> App ()
mkRabbitMqAdminClientForResource :: BackendResource -> App (AdminAPI (AsClientT App))

Documentation

testConsumeEventsOneWebSocket :: HasCallStack => App () Source #

testConsumeTempEvents :: HasCallStack => App () Source #

testConsumeTempEventsWithoutOwnClient :: HasCallStack => App () Source #

testTemporaryQueuesAreDeletedAfterUse :: HasCallStack => App () Source #

testMLSTempEvents :: HasCallStack => App () Source #

testConsumeEventsForDifferentUsers :: HasCallStack => App () Source #

testConsumeEventsWhileHavingLegacyClients :: HasCallStack => App () Source #

testConsumeEventsAcks :: HasCallStack => App () Source #

testConsumeEventsMultipleAcks :: HasCallStack => App () Source #

testConsumeEventsAckNewEventWithoutAckingOldOne :: HasCallStack => App () Source #

testEventsDeadLettered :: HasCallStack => App () Source #

testTransientEventsDoNotTriggerDeadLetters :: HasCallStack => App () Source #

testTransientEvents :: HasCallStack => App () Source #

testChannelLimit :: HasCallStack => App () Source #

testChannelKilled :: HasCallStack => App () Source #

data EventWebSocket Source #

Constructors

EventWebSocket
Fields events :: Chan (Either ConnectionException Value) ack :: MVar (Maybe Value)

createEventsWebSocket :: (HasCallStack, MakesValue uid) => uid -> Maybe String -> Codensity App EventWebSocket Source #

ackFullSync :: HasCallStack => EventWebSocket -> App () Source #

ackEvent :: HasCallStack => EventWebSocket -> Value -> App () Source #

sendAck :: HasCallStack => EventWebSocket -> Value -> Bool -> App () Source #

assertEvent :: HasCallStack => EventWebSocket -> (HasCallStack => Value -> App a) -> App a Source #

assertFindsEvent :: forall a. HasCallStack => EventWebSocket -> (HasCallStack => Value -> App a) -> App a Source #

Tolerates and consumes other events before expected event

data NoEvent Source #

Constructors

NoEvent
WebSocketDied

Instances

Instances details

ToJSON NoEvent Source #
Instance details Defined in Test.Events Methods toJSON :: NoEvent -> Value Source # toEncoding :: NoEvent -> Encoding Source # toJSONList :: [NoEvent] -> Value Source # toEncodingList :: [NoEvent] -> Encoding Source #

assertNoEvent :: HasCallStack => EventWebSocket -> App NoEvent Source #

assertNoEvent_ :: HasCallStack => EventWebSocket -> App () Source #

consumeAllEvents :: EventWebSocket -> App () Source #

killConnection :: HasCallStack => BackendResource -> App () Source #

mkRabbitMqAdminClientForResource :: BackendResource -> App (AdminAPI (AsClientT App)) Source #