add tests

fabric8io · Dec 17, 2020 · b931cc4 · b931cc4
1 parent b13aad5
commit b931cc4
Show file tree

Hide file tree

Showing 2 changed files with 83 additions and 0 deletions.
diff --git a/kubernetes-itests/src/test/java/io/fabric8/kubernetes/ResourceIT.java b/kubernetes-itests/src/test/java/io/fabric8/kubernetes/ResourceIT.java
@@ -30,6 +30,7 @@
 import io.fabric8.kubernetes.api.model.ServiceBuilder;
 import io.fabric8.kubernetes.api.model.apps.Deployment;
 import io.fabric8.kubernetes.api.model.apps.DeploymentBuilder;
+import io.fabric8.kubernetes.api.model.apps.ReplicaSetList;
 import io.fabric8.kubernetes.client.KubernetesClient;
 import org.arquillian.cube.kubernetes.api.Session;
 import org.arquillian.cube.kubernetes.impl.requirement.RequiresKubernetes;
@@ -49,6 +50,7 @@
 import static junit.framework.TestCase.assertNotNull;
 import static org.awaitility.Awaitility.await;
 import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotEquals;
 import static org.junit.Assert.assertTrue;
 
 @RunWith(ArquillianConditionalRunner.class)
@@ -159,6 +161,60 @@ public void delete() {
     assertTrue(client.resource(pod1).inNamespace(session.getNamespace()).delete());
   }
 
+  @Test
+  public void testDeleteExistingWithOrphanDeletion() {
+    // Create Deployment
+    client.resource(deployment).inNamespace(session.getNamespace()).createOrReplace();
+    await().atMost(30, TimeUnit.SECONDS).until(resourceIsReady(deployment));
+
+    // get creationTimestamp of underlying replicaset. we expect this NOT to match later, meaning the orphan WAS deleted.
+    ReplicaSetList replicaSetList = client.apps().replicaSets().inNamespace(session.getNamespace()).withLabel("run", "deploy1").list();
+    assertEquals(1, replicaSetList.getItems().size());
+    String replicaSetCreationTimestamp = replicaSetList.getItems().get(0).getMetadata().getCreationTimestamp();
+
+    // Recreate deployment with deleteExisting
+    client.resource(deployment).inNamespace(session.getNamespace()).withPropagationPolicy(DeletionPropagation.BACKGROUND).deletingExisting().createOrReplace();
+    await().atMost(30, TimeUnit.SECONDS).until(resourceIsReady(deployment));
+
+    // check that creationTimestamp DOES NOT MATCH original, meaning the orphan WAS deleted
+    replicaSetList = client.apps().replicaSets().inNamespace(session.getNamespace()).withLabel("run", "deploy1").list();
+    assertEquals(1, replicaSetList.getItems().size());
+    assertNotEquals(replicaSetCreationTimestamp, replicaSetList.getItems().get(0).getMetadata().getCreationTimestamp());
+
+    // cleanup
+    assertEquals(true, client.resource(deployment).inNamespace(session.getNamespace()).delete());
+    // Check whether child resources are also deleted
+    await().atMost(30, TimeUnit.SECONDS)
+      .until(() -> client.apps().replicaSets().inNamespace(session.getNamespace()).withLabel("run", "deploy1").list().getItems().size() == 0);
+  }
+
+  @Test
+  public void testDeleteExistingWithoutOrphanDeletion() {
+    // Create Deployment
+    client.resource(deployment).inNamespace(session.getNamespace()).createOrReplace();
+    await().atMost(30, TimeUnit.SECONDS).until(resourceIsReady(deployment));
+
+    // get creationTimestamp of underlying replicaset. we expect this to match later, meaning the orphan was not deleted.
+    ReplicaSetList replicaSetList = client.apps().replicaSets().inNamespace(session.getNamespace()).withLabel("run", "deploy1").list();
+    assertEquals(1, replicaSetList.getItems().size());
+    String replicaSetCreationTimestamp = replicaSetList.getItems().get(0).getMetadata().getCreationTimestamp();
+
+    // Recreate deployment with deleteExisting
+    client.resource(deployment).inNamespace(session.getNamespace()).withPropagationPolicy(DeletionPropagation.ORPHAN).deletingExisting().createOrReplace();
+    await().atMost(30, TimeUnit.SECONDS).until(resourceIsReady(deployment));
+
+    // check that creationTimestamp matches original, meaning the orphan was not deleted
+    replicaSetList = client.apps().replicaSets().inNamespace(session.getNamespace()).withLabel("run", "deploy1").list();
+    assertEquals(1, replicaSetList.getItems().size());
+    assertEquals(replicaSetCreationTimestamp, replicaSetList.getItems().get(0).getMetadata().getCreationTimestamp());
+
+    // cleanup
+    assertEquals(true, client.resource(deployment).inNamespace(session.getNamespace()).delete());
+    // Check whether child resources are also deleted
+    await().atMost(30, TimeUnit.SECONDS)
+      .until(() -> client.apps().replicaSets().inNamespace(session.getNamespace()).withLabel("run", "deploy1").list().getItems().size() == 0);
+  }
+
   @Test
   public void testDeletionWithOrphanDeletion() {
     // Create Deployment

diff --git a/kubernetes-tests/src/test/java/io/fabric8/kubernetes/client/mock/ResourceTest.java b/kubernetes-tests/src/test/java/io/fabric8/kubernetes/client/mock/ResourceTest.java
@@ -16,6 +16,8 @@
 
 package io.fabric8.kubernetes.client.mock;
 
+import io.fabric8.kubernetes.api.model.DeleteOptions;
+import io.fabric8.kubernetes.api.model.DeletionPropagation;
 import io.fabric8.kubernetes.api.model.HasMetadata;
 import io.fabric8.kubernetes.api.model.Pod;
 import io.fabric8.kubernetes.api.model.PodBuilder;
@@ -33,6 +35,7 @@
 import io.fabric8.kubernetes.client.dsl.PodResource;
 import io.fabric8.kubernetes.client.internal.readiness.Readiness;
 import io.fabric8.kubernetes.client.server.mock.KubernetesServer;
+import io.fabric8.kubernetes.client.utils.Serialization;
 import okhttp3.mockwebserver.RecordedRequest;
 import org.assertj.core.api.InstanceOfAssertFactories;
 import org.junit.Assert;
@@ -118,6 +121,30 @@ void testCreateOrReplaceWithDeleteExisting() throws Exception {
       assertEquals("POST", request.getMethod());
     }
 
+  @Test
+  void itPassesPropagationPolicyWithDeleteExisting() throws InterruptedException {
+    Pod pod1 = new PodBuilder().withNewMetadata().withName("pod1").withNamespace("test").and().build();
+
+    server.expect().delete().withPath("/api/v1/namespaces/ns1/pods/pod1").andReturn(HttpURLConnection.HTTP_OK, pod1).once();
+    server.expect().post().withPath("/api/v1/namespaces/ns1/pods").andReturn(HttpURLConnection.HTTP_CREATED, pod1).once();
+
+    KubernetesClient client = server.getClient();
+    HasMetadata response = client.resource(pod1).inNamespace("ns1").withPropagationPolicy(DeletionPropagation.FOREGROUND).deletingExisting().createOrReplace();
+    assertEquals(pod1, response);
+
+    assertEquals(2, server.getMockServer().getRequestCount());
+
+    RecordedRequest deleteRequest = server.getMockServer().takeRequest();
+    assertEquals("/api/v1/namespaces/ns1/pods/pod1", deleteRequest.getPath());
+    assertEquals("DELETE", deleteRequest.getMethod());
+    DeleteOptions deleteOptions = Serialization.unmarshal(deleteRequest.getBody().readUtf8(), DeleteOptions.class);
+    assertEquals("Foreground", deleteOptions.getPropagationPolicy());
+
+    RecordedRequest postRequest = server.getLastRequest();
+    assertEquals("/api/v1/namespaces/ns1/pods", postRequest.getPath());
+    assertEquals("POST", postRequest.getMethod());
+  }
+
   @Test
   void testCreateOrReplaceWithDeleteExistingWithCreateFailed() {
     // Given