diff --git a/pom.xml b/pom.xml index 58cd4c9..3aeaa40 100644 --- a/pom.xml +++ b/pom.xml @@ -60,6 +60,31 @@ ${spring-security.version} + + org.codehaus.plexus + plexus-utils + 3.3.0 + + + + com.github.jknack + handlebars + 4.3.1 + + + + org.sonatype.plexus + plexus-build-api + 0.0.7 + provided + + + org.codehaus.plexus + plexus-utils + + + + org.openapitools @@ -114,6 +139,11 @@ commons-lang3 3.11 + + org.apache.commons + commons-text + 1.10.0 + org.apache.commons diff --git a/src/test/java/de/caritas/cob/liveservice/LiveServiceApplicationIT.java b/src/test/java/de/caritas/cob/liveservice/LiveServiceApplicationIT.java index c718968..24cb2d9 100644 --- a/src/test/java/de/caritas/cob/liveservice/LiveServiceApplicationIT.java +++ b/src/test/java/de/caritas/cob/liveservice/LiveServiceApplicationIT.java @@ -98,10 +98,11 @@ void subscribe_Should_subscribeUser() throws Exception { var stompSession = performConnect(FIRST_VALID_USER); final Subscription subscription = performSubscribe(stompSession); + assertThat(this.socketUserRegistry.retrieveAllUsers(), hasSize(1)); WebSocketUserSession registeredUser = this.socketUserRegistry.retrieveAllUsers().get(0); await() - .atMost(MESSAGE_TIMEOUT, SECONDS) + .atMost(15, SECONDS) .until(registeredUser::getSubscriptionId, notNullValue()); assertThat(registeredUser, notNullValue()); @@ -110,11 +111,11 @@ void subscribe_Should_subscribeUser() throws Exception { assertThat(registeredUser.getSubscriptionId(), notNullValue()); assertThat(subscription.getSubscriptionHeaders().get("destination"), contains(SUBSCRIPTION_ENDPOINT)); - performDisconnect(stompSession); } @Test void disconnect_Should_removeUserFromRegistry() throws Exception { + var stompSession = performConnect(FIRST_VALID_USER); assertThat(this.socketUserRegistry.retrieveAllUsers(), hasSize(1)); @@ -187,7 +188,7 @@ void sendLiveEvent_Should_sendVideoDenyRequestMessageEventToUser_When_userIsSubs .andExpect(status().isOk()); await() - .atMost(MESSAGE_TIMEOUT, SECONDS) + .atMost(15, SECONDS) .until(receivedMessages::size, is(1)); var resultMessage = receivedMessages.iterator().next(); assertThat(resultMessage, notNullValue());