Skip to content

Commit 0d85a6c

Browse files
committed
fix: naming and cleanup (#74)
Signed-off-by: Attila Mészáros <[email protected]>
1 parent 6bb64bc commit 0d85a6c

File tree

6 files changed

+25
-29
lines changed

6 files changed

+25
-29
lines changed

src/test/java/io/csviri/operator/resourceglue/GlueOperatorTest.java

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
import io.fabric8.kubernetes.api.model.ObjectMetaBuilder;
1919
import io.quarkus.test.junit.QuarkusTest;
2020

21+
import static io.csviri.operator.resourceglue.TestUtils.GC_WAIT_TIMEOUT_SECOND;
2122
import static io.csviri.operator.resourceglue.customresource.TestCustomResource.CR_GROUP;
2223
import static org.assertj.core.api.Assertions.assertThat;
2324
import static org.awaitility.Awaitility.await;
@@ -139,12 +140,13 @@ void simpleConcurrencyForMultipleOperatorTest() {
139140
crs.forEach(this::delete);
140141
cr2s.forEach(this::delete);
141142

142-
await().untilAsserted(() -> IntStream.range(0, num).forEach(n -> {
143-
var cm = get(ConfigMap.class, TEST_RESOURCE_PREFIX + n);
144-
assertThat(cm).isNull();
145-
var cm2 = get(ConfigMap.class, TEST_RESOURCE2_PREFIX + n);
146-
assertThat(cm2).isNull();
147-
}));
143+
await().timeout(GC_WAIT_TIMEOUT_SECOND)
144+
.untilAsserted(() -> IntStream.range(0, num).forEach(n -> {
145+
var cm = get(ConfigMap.class, TEST_RESOURCE_PREFIX + n);
146+
assertThat(cm).isNull();
147+
var cm2 = get(ConfigMap.class, TEST_RESOURCE2_PREFIX + n);
148+
assertThat(cm2).isNull();
149+
}));
148150
}
149151

150152
TestCustomResource testCustomResource() {

src/test/java/io/csviri/operator/resourceglue/TestUtils.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
import java.io.*;
44
import java.net.URL;
55
import java.nio.charset.StandardCharsets;
6+
import java.time.Duration;
67
import java.util.Arrays;
78
import java.util.List;
89
import java.util.concurrent.TimeUnit;
@@ -25,6 +26,8 @@
2526

2627
public class TestUtils {
2728

29+
public static final Duration GC_WAIT_TIMEOUT_SECOND = Duration.ofSeconds(30);
30+
2831
public static final int CRD_READY_WAIT = 1000;
2932

3033
private static final Logger log = LoggerFactory.getLogger(TestUtils.class);

src/test/java/io/csviri/operator/resourceglue/sample/mutation/MutationWebhookDeploymentE2E.java

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
1717
import io.fabric8.kubernetes.client.dsl.NonDeletingOperation;
1818

19+
import static io.csviri.operator.resourceglue.TestUtils.GC_WAIT_TIMEOUT_SECOND;
1920
import static org.assertj.core.api.Assertions.assertThat;
2021
import static org.awaitility.Awaitility.await;
2122

@@ -37,7 +38,7 @@ void applyCRDs() throws MalformedURLException, URISyntaxException {
3738

3839
@Test
3940
void testMutationHookDeployment() {
40-
client.resource(TestUtils.load("/sample/mutation/mutation.glue.yaml"))
41+
var glue = client.resource(TestUtils.load("/sample/mutation/mutation.glue.yaml"))
4142
.createOr(NonDeletingOperation::update);
4243

4344
await().atMost(Duration.ofMinutes(5)).untilAsserted(() -> {
@@ -51,6 +52,13 @@ void testMutationHookDeployment() {
5152
var pod = client.resource(testPod()).create();
5253
assertThat(pod.getMetadata().getAnnotations()).containsEntry("sample.annotation.present",
5354
"true");
55+
56+
client.resource(glue).delete();
57+
58+
await().timeout(GC_WAIT_TIMEOUT_SECOND).untilAsserted(() -> {
59+
var deployment = client.apps().deployments().withName("pod-mutating-hook").get();
60+
assertThat(deployment).isNull();
61+
});
5462
}
5563

5664
Pod testPod() {

src/test/java/io/csviri/operator/resourceglue/sample/webpage/WebPageE2E.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,12 @@
1-
package io.csviri.operator.resourceglue;
1+
package io.csviri.operator.resourceglue.sample.webpage;
22

33

44
import org.junit.jupiter.api.BeforeEach;
55
import org.junit.jupiter.api.Test;
66

7+
import io.csviri.operator.resourceglue.TestUtils;
78
import io.csviri.operator.resourceglue.customresource.glue.Glue;
89
import io.csviri.operator.resourceglue.customresource.operator.GlueOperator;
9-
import io.csviri.operator.resourceglue.sample.webpage.WebPage;
1010
import io.fabric8.kubernetes.api.model.ConfigMap;
1111
import io.fabric8.kubernetes.api.model.Service;
1212
import io.fabric8.kubernetes.api.model.apps.Deployment;
@@ -15,6 +15,7 @@
1515
import io.fabric8.kubernetes.client.KubernetesClientBuilder;
1616
import io.fabric8.kubernetes.client.dsl.NonDeletingOperation;
1717

18+
import static io.csviri.operator.resourceglue.TestUtils.GC_WAIT_TIMEOUT_SECOND;
1819
import static org.assertj.core.api.Assertions.assertThat;
1920
import static org.awaitility.Awaitility.await;
2021

@@ -61,7 +62,7 @@ void testWebPageCRUDOperations() {
6162

6263
client.resource(createdWebPage).delete();
6364

64-
await().untilAsserted(() -> {
65+
await().timeout(GC_WAIT_TIMEOUT_SECOND).untilAsserted(() -> {
6566
var deployment =
6667
client.resources(Deployment.class).withName(webPage.getMetadata().getName()).get();
6768
var configMap =

src/test/resources/resourceglueoperator/Simple.yaml

Lines changed: 0 additions & 18 deletions
This file was deleted.

src/test/resources/resourceglueoperator/Templating.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
apiVersion: io.csviri.operator.resourceglue/v1beta1
22
kind: GlueOperator
33
metadata:
4-
name: rfo-templating-sample
4+
name: templating-sample
55
spec:
66
parent:
77
apiVersion: io.csviri.operator.resourceglue/v1

0 commit comments

Comments
 (0)