integration-0.1.0

Safe Haskell	None
Language	GHC2021

Test.Events

Synopsis

testConsumeEventsOneWebSocket :: HasCallStack => App ()
testWebSocketTimeout :: HasCallStack => App ()
testConsumeTempEvents :: HasCallStack => App ()
testTemporaryQueuesAreDeletedAfterUse :: HasCallStack => App ()
testSendMessageNoReturnToSenderWithConsumableNotificationsProteus :: HasCallStack => App ()
testEventsForSpecificClients :: HasCallStack => App ()
testConsumeEventsForDifferentUsers :: HasCallStack => App ()
testConsumeEventsWhileHavingLegacyClients :: HasCallStack => App ()
testConsumeEventsAcks :: HasCallStack => App ()
testConsumeEventsMultipleAcks :: HasCallStack => App ()
testConsumeEventsAckNewEventWithoutAckingOldOne :: HasCallStack => App ()
testEventsDeadLettered :: HasCallStack => App ()
testEventsDeadLetteredWithReconnect :: HasCallStack => App ()
testTransientEventsDoNotTriggerDeadLetters :: HasCallStack => App ()
testTransientEvents :: HasCallStack => App ()
testChannelLimit :: HasCallStack => App ()
testChannelKilled :: HasCallStack => App ()
testSingleConsumer :: HasCallStack => App ()
testPrefetchCount :: HasCallStack => App ()
testEndOfInitialSync :: HasCallStack => App ()
testEndOfInitialSyncMoreEventsAfterSyncMessage :: HasCallStack => App ()
testEndOfInitialSyncIgnoreExpired :: HasCallStack => App ()
testEndOfInitialSyncAckMultiple :: HasCallStack => App ()
mkEvent :: (ToJSON a1, ToJSON a2) => a1 -> a2 -> Bool -> Value
testTypingIndicatorIsNotSentToOwnClient :: HasCallStack => TaggedBool "federated" -> App ()
testBackendPusherRecoversFromQueueDeletion :: HasCallStack => App ()
mkUserPlusClientWithDomain :: (HasCallStack, MakesValue domain) => domain -> App (Value, String, String)
mkUserPlusClient :: HasCallStack => App (Value, String, String)
data EventWebSocket = EventWebSocket {
- events :: Chan (Either ConnectionException Value)
- ack :: MVar (Maybe Value)
- kill :: MVar ()
- done :: MVar ()
}
createEventWebSockets :: (HasCallStack, MakesValue user) => [(user, Maybe String)] -> Codensity App [EventWebSocket]
createEventsWebSocket :: (HasCallStack, MakesValue user) => user -> Maybe String -> Codensity App EventWebSocket
createEventsWebSocketWithSync :: (HasCallStack, MakesValue user) => user -> Maybe String -> Codensity App (String, EventWebSocket)
createEventsWebSocketEither :: (HasCallStack, MakesValue user) => user -> Maybe String -> Maybe String -> Codensity App (Either HandshakeException EventWebSocket)
ackFullSync :: HasCallStack => EventWebSocket -> App ()
ackEvent :: HasCallStack => EventWebSocket -> Value -> App ()
sendAck :: HasCallStack => EventWebSocket -> Value -> Bool -> App ()
killWebSocketClient :: EventWebSocket -> App ()
assertEvent :: HasCallStack => EventWebSocket -> (HasCallStack => Value -> App a) -> App a
assertFindsEvent :: HasCallStack => EventWebSocket -> (HasCallStack => Value -> App a) -> App a
assertFindsEventConfigurableAck :: HasCallStack => (HasCallStack => EventWebSocket -> Value -> App ()) -> EventWebSocket -> (HasCallStack => Value -> App a) -> App a
data NoEvent
- = NoEvent
- | WebSocketDied
assertNoEventHelper :: HasCallStack => EventWebSocket -> App NoEvent
assertNoEvent_ :: HasCallStack => EventWebSocket -> App ()
assertWebSocketDied :: HasCallStack => EventWebSocket -> App ()
consumeEventsUntilEndOfInitialSync :: HasCallStack => EventWebSocket -> String -> App [Value]
assertEndOfIniitalSync :: HasCallStack => EventWebSocket -> String -> App ()
consumeAllEvents_ :: EventWebSocket -> App ()
emptyQueue :: (HasCallStack, MakesValue user) => user -> String -> App ()
consumeAllEvents :: EventWebSocket -> App [Value]
consumeAllEventsNoAck :: EventWebSocket -> App [Value]
waitUntilNoRabbitMqConns :: HasCallStack => BackendResource -> App ()
killAllRabbitMqConns :: HasCallStack => BackendResource -> App [Connection]
getCannonConnections :: AdminAPI (AsClientT App) -> String -> App [Connection]
mkRabbitMqAdminClientForResource :: BackendResource -> App (AdminAPI (AsClientT App))

Documentation

testConsumeEventsOneWebSocket :: HasCallStack => App () Source #

testWebSocketTimeout :: HasCallStack => App () Source #

testConsumeTempEvents :: HasCallStack => App () Source #

testTemporaryQueuesAreDeletedAfterUse :: HasCallStack => App () Source #

testSendMessageNoReturnToSenderWithConsumableNotificationsProteus :: HasCallStack => App () Source #

testEventsForSpecificClients :: 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 #

testEventsDeadLetteredWithReconnect :: HasCallStack => App () Source #

testTransientEventsDoNotTriggerDeadLetters :: HasCallStack => App () Source #

testTransientEvents :: HasCallStack => App () Source #

testChannelLimit :: HasCallStack => App () Source #

testChannelKilled :: HasCallStack => App () Source #

testSingleConsumer :: HasCallStack => App () Source #

testPrefetchCount :: HasCallStack => App () Source #

testEndOfInitialSync :: HasCallStack => App () Source #

testEndOfInitialSyncMoreEventsAfterSyncMessage :: HasCallStack => App () Source #

testEndOfInitialSyncIgnoreExpired :: HasCallStack => App () Source #

testEndOfInitialSyncAckMultiple :: HasCallStack => App () Source #

mkEvent :: (ToJSON a1, ToJSON a2) => a1 -> a2 -> Bool -> Value Source #

testTypingIndicatorIsNotSentToOwnClient :: HasCallStack => TaggedBool "federated" -> App () Source #

testBackendPusherRecoversFromQueueDeletion :: HasCallStack => App () Source #

mkUserPlusClientWithDomain :: (HasCallStack, MakesValue domain) => domain -> App (Value, String, String) Source #

mkUserPlusClient :: HasCallStack => App (Value, String, String) Source #

data EventWebSocket Source #

Constructors

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

createEventWebSockets :: (HasCallStack, MakesValue user) => [(user, Maybe String)] -> Codensity App [EventWebSocket] Source #

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

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

createEventsWebSocketEither :: (HasCallStack, MakesValue user) => user -> Maybe String -> Maybe String -> Codensity App (Either HandshakeException EventWebSocket) Source #

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

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

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

killWebSocketClient :: EventWebSocket -> App () Source #

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

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

Tolerates and consumes other events before expected event

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

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 # omitField :: NoEvent -> Bool Source #

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

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

Similar to assertNoEvent from Testlib, but with rabbitMQ typing (`/event` end-point, not `/await`).

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

consumeEventsUntilEndOfInitialSync :: HasCallStack => EventWebSocket -> String -> App [Value] Source #

assertEndOfIniitalSync :: HasCallStack => EventWebSocket -> String -> App () Source #

consumeAllEvents_ :: EventWebSocket -> App () Source #

emptyQueue :: (HasCallStack, MakesValue user) => user -> String -> App () Source #

consumeAllEvents :: EventWebSocket -> App [Value] Source #

consumeAllEventsNoAck :: EventWebSocket -> App [Value] Source #

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

Only considers connections from cannon

killAllRabbitMqConns :: HasCallStack => BackendResource -> App [Connection] Source #

Only kills connections from cannon and returns them

getCannonConnections :: AdminAPI (AsClientT App) -> String -> App [Connection] Source #

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