Create Retrieve and Delete tested

Author: mswatosh

src/test/java/io/openliberty/sample/it/MongoIT.java

@@ -10,12 +10,10 @@
 *******************************************************************************/
 package io.openliberty.sample.it;
 
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.fail;
 
 import java.io.StringReader;
-import java.net.URI;
-import java.util.concurrent.TimeUnit;
 
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
@@ -25,6 +23,7 @@
 import jakarta.json.JsonArray;
 import jakarta.json.JsonObject;
 import jakarta.json.JsonReader;
+import jakarta.json.JsonValue;
 import jakarta.ws.rs.client.Client;
 import jakarta.ws.rs.client.ClientBuilder;
 import jakarta.ws.rs.client.Entity;
@@ -33,15 +32,13 @@
 public class MongoIT {
 
     private static Client restClient;
-
-
     private static String baseURL;
 
     @BeforeAll
     public static void setup() throws Exception {             
         String port = System.getProperty("http.port");
         baseURL = "http://localhost:" + port + "/db/crew/";
-
+        
         restClient = ClientBuilder.newClient();
     }
 
@@ -56,12 +53,32 @@ public static void teardown() throws Exception {
      */
     @Test
     public void CreateRetrieveDeleteTest() throws InterruptedException {
-        //{"name":"Test","rank":"Captain","crewID":"12345"}
         restClient.target(baseURL + "it").request().post(Entity.json("{\"name\":\"Test\",\"rank\":\"Captain\",\"crewID\":\"12345\"}"));
 
         Response response = restClient.target(baseURL).request().get();
         JsonReader reader = Json.createReader(new StringReader(response.readEntity(String.class)));
         JsonArray array = reader.readArray();
         System.out.println(array);
+        String id = null;
+        for (JsonValue value : array) {
+            JsonObject obj = value.asJsonObject();
+            if (obj.getString("Name").equals("Test") &&
+                obj.getString("Rank").equals("Captain") &&
+                obj.getString("CrewID").equals("12345"))
+                id = obj.getJsonObject("_id").getString("$oid");
+        }
+        assertNotNull(id, "CrewMember not found in returned value: " + array);
+
+        restClient.target(baseURL + id).request().delete();
+
+        response = restClient.target(baseURL).request().get();
+        reader = Json.createReader(new StringReader(response.readEntity(String.class)));
+        array = reader.readArray();
+
+        for (JsonValue value : array) {
+            System.out.println(value.asJsonObject().getJsonObject("_id").getString("$oid"));
+            if (id == value.asJsonObject().getJsonObject("_id").getString("$oid"))
+                fail("CrewMember should have been deleted, but id was found: " + id);
+        }
     }
 }