You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by bt...@apache.org on 2023/01/06 03:02:44 UTC
[james-project] 05/12: JAMES-3771 DockerElasticSearchExtension should cleanup its data after each test
This is an automated email from the ASF dual-hosted git repository.
btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 1fe4f82507da7c2611232c425c411b85addeb4c4
Author: Rene Cordier <rc...@linagora.com>
AuthorDate: Fri Jun 24 16:58:09 2022 +0700
JAMES-3771 DockerElasticSearchExtension should cleanup its data after each test
---
.../java/org/apache/james/DockerOpenSearchExtension.java | 13 +++++++------
.../apache/james/JamesServerWithRetryConnectionTest.java | 4 ++--
.../java/org/apache/james/DockerOpenSearchExtension.java | 13 +++++++------
.../RabbitMQReindexingWithEventDeadLettersTest.java | 4 ++--
4 files changed, 18 insertions(+), 16 deletions(-)
diff --git a/server/apps/cassandra-app/src/test/java/org/apache/james/DockerOpenSearchExtension.java b/server/apps/cassandra-app/src/test/java/org/apache/james/DockerOpenSearchExtension.java
index c9114ef5c3..3dceac582b 100644
--- a/server/apps/cassandra-app/src/test/java/org/apache/james/DockerOpenSearchExtension.java
+++ b/server/apps/cassandra-app/src/test/java/org/apache/james/DockerOpenSearchExtension.java
@@ -50,19 +50,20 @@ public class DockerOpenSearchExtension implements GuiceModuleTestExtension {
@Override
public void beforeAll(ExtensionContext extensionContext) {
- getDockerES().start();
+ getDockerOS().start();
}
@Override
public void beforeEach(ExtensionContext extensionContext) {
- if (!getDockerES().isRunning()) {
- getDockerES().unpause();
+ if (!getDockerOS().isRunning()) {
+ getDockerOS().unpause();
}
await();
}
@Override
public void afterEach(ExtensionContext extensionContext) {
+ getDockerOS().cleanUpData();
}
@Override
@@ -73,17 +74,17 @@ public class DockerOpenSearchExtension implements GuiceModuleTestExtension {
@Override
public void await() {
- getDockerES().flushIndices();
+ getDockerOS().flushIndices();
}
private OpenSearchConfiguration getOpenSearchConfigurationForDocker() {
return OpenSearchConfiguration.builder()
- .addHost(getDockerES().getHttpHost())
+ .addHost(getDockerOS().getHttpHost())
.requestTimeout(requestTimeout)
.build();
}
- public DockerOpenSearch getDockerES() {
+ public DockerOpenSearch getDockerOS() {
return dockerOpenSearch;
}
}
diff --git a/server/apps/cassandra-app/src/test/java/org/apache/james/JamesServerWithRetryConnectionTest.java b/server/apps/cassandra-app/src/test/java/org/apache/james/JamesServerWithRetryConnectionTest.java
index bcea7a3b67..f5afa48acb 100644
--- a/server/apps/cassandra-app/src/test/java/org/apache/james/JamesServerWithRetryConnectionTest.java
+++ b/server/apps/cassandra-app/src/test/java/org/apache/james/JamesServerWithRetryConnectionTest.java
@@ -86,9 +86,9 @@ class JamesServerWithRetryConnectionTest {
@Test
void serverShouldRetryToConnectToOpenSearchWhenStartService(GuiceJamesServer server) throws Exception {
- dockerOpenSearch.getDockerES().pause();
+ dockerOpenSearch.getDockerOS().pause();
- waitToStartContainer(WAITING_TIME, dockerOpenSearch.getDockerES()::unpause);
+ waitToStartContainer(WAITING_TIME, dockerOpenSearch.getDockerOS()::unpause);
assertThatServerStartCorrectly(server);
}
diff --git a/server/apps/scaling-pulsar-smtp/src/test/java/org/apache/james/DockerOpenSearchExtension.java b/server/apps/scaling-pulsar-smtp/src/test/java/org/apache/james/DockerOpenSearchExtension.java
index c9114ef5c3..3dceac582b 100644
--- a/server/apps/scaling-pulsar-smtp/src/test/java/org/apache/james/DockerOpenSearchExtension.java
+++ b/server/apps/scaling-pulsar-smtp/src/test/java/org/apache/james/DockerOpenSearchExtension.java
@@ -50,19 +50,20 @@ public class DockerOpenSearchExtension implements GuiceModuleTestExtension {
@Override
public void beforeAll(ExtensionContext extensionContext) {
- getDockerES().start();
+ getDockerOS().start();
}
@Override
public void beforeEach(ExtensionContext extensionContext) {
- if (!getDockerES().isRunning()) {
- getDockerES().unpause();
+ if (!getDockerOS().isRunning()) {
+ getDockerOS().unpause();
}
await();
}
@Override
public void afterEach(ExtensionContext extensionContext) {
+ getDockerOS().cleanUpData();
}
@Override
@@ -73,17 +74,17 @@ public class DockerOpenSearchExtension implements GuiceModuleTestExtension {
@Override
public void await() {
- getDockerES().flushIndices();
+ getDockerOS().flushIndices();
}
private OpenSearchConfiguration getOpenSearchConfigurationForDocker() {
return OpenSearchConfiguration.builder()
- .addHost(getDockerES().getHttpHost())
+ .addHost(getDockerOS().getHttpHost())
.requestTimeout(requestTimeout)
.build();
}
- public DockerOpenSearch getDockerES() {
+ public DockerOpenSearch getDockerOS() {
return dockerOpenSearch;
}
}
diff --git a/server/protocols/webadmin-integration-test/distributed-webadmin-integration-test/src/test/java/org/apache/james/webadmin/integration/rabbitmq/RabbitMQReindexingWithEventDeadLettersTest.java b/server/protocols/webadmin-integration-test/distributed-webadmin-integration-test/src/test/java/org/apache/james/webadmin/integration/rabbitmq/RabbitMQReindexingWithEventDeadLettersTest.java
index 7be41f7073..360c40128b 100644
--- a/server/protocols/webadmin-integration-test/distributed-webadmin-integration-test/src/test/java/org/apache/james/webadmin/integration/rabbitmq/RabbitMQReindexingWithEventDeadLettersTest.java
+++ b/server/protocols/webadmin-integration-test/distributed-webadmin-integration-test/src/test/java/org/apache/james/webadmin/integration/rabbitmq/RabbitMQReindexingWithEventDeadLettersTest.java
@@ -125,7 +125,7 @@ class RabbitMQReindexingWithEventDeadLettersTest {
aliceAccessToken = authenticateJamesUser(LocalHostURIBuilder.baseUri(jmapPort), ALICE, ALICE_PASSWORD);
- dockerOpenSearch.getDockerES().pause();
+ dockerOpenSearch.getDockerOS().pause();
Thread.sleep(Duration.ofSeconds(2).toMillis()); // Docker pause is asynchronous and we found no way to poll for it
}
@@ -153,7 +153,7 @@ class RabbitMQReindexingWithEventDeadLettersTest {
}
private void unpauseOpenSearch() throws Exception {
- dockerOpenSearch.getDockerES().unpause();
+ dockerOpenSearch.getDockerOS().unpause();
Thread.sleep(Duration.ofSeconds(2).toMillis()); // Docker unpause is asynchronous and we found no way to poll for it
}
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org