[Lada-commits] [PATCH 1 of 3] Added tests for ort services
Wald Commits
scm-commit at wald.intevation.org
Wed Feb 18 13:25:27 CET 2015
# HG changeset patch
# User Raimund Renkert <raimund.renkert at intevation.de>
# Date 1424262345 -3600
# Node ID 4fab79ec8a939d0c20045dbfc09095030a04090e
# Parent ac5c5f581d59f883e39475136edd9732957c324e
Added tests for ort services.
diff -r ac5c5f581d59 -r 4fab79ec8a93 src/test/java/de/intevation/lada/LadaTest.java
--- a/src/test/java/de/intevation/lada/LadaTest.java Wed Feb 18 11:47:19 2015 +0100
+++ b/src/test/java/de/intevation/lada/LadaTest.java Wed Feb 18 13:25:45 2015 +0100
@@ -30,6 +30,7 @@
import de.intevation.lada.test.KommentarP;
import de.intevation.lada.test.Messung;
import de.intevation.lada.test.Messwert;
+import de.intevation.lada.test.Ort;
import de.intevation.lada.test.Probe;
import de.intevation.lada.test.Query;
@@ -47,7 +48,7 @@
private static Logger logger = Logger.getLogger(LadaTest.class);
- private static boolean verboseLogging = false;
+ private static boolean verboseLogging = true;
private Probe probeTest;
private Query queryTest;
@@ -55,6 +56,7 @@
private KommentarP kommentarPTest;
private KommentarM kommentarMTest;
private Messwert messwertTest;
+ private Ort ortTest;
private static List<Protocol> testProtocol;
@@ -65,6 +67,7 @@
kommentarPTest = new KommentarP();
kommentarMTest = new KommentarM();
messwertTest = new Messwert();
+ ortTest = new Ort();
testProtocol = new ArrayList<Protocol>();
}
@@ -253,6 +256,35 @@
}
/**
+ * Testing GET Services.
+ */
+ @Test
+ @RunAsClient
+ public final void testA_OrtGetAllServices(@ArquillianResource URL baseUrl)
+ throws Exception {
+ this.ortTest.getAllService(baseUrl, testProtocol);
+ }
+
+ /**
+ * Testing GET Services.
+ */
+ @Test
+ @RunAsClient
+ public final void testA_OrtGetByIdServices(@ArquillianResource URL baseUrl)
+ throws Exception {
+ this.ortTest.getByIdService(baseUrl, testProtocol);
+ }
+
+ /**
+ * Testing GET Services.
+ */
+ @Test
+ @RunAsClient
+ public final void testA_OrtGetFilterServices(@ArquillianResource URL baseUrl)
+ throws Exception {
+ this.ortTest.filterService(baseUrl, testProtocol);
+ }
+ /**
* Testing CREATE services.
*/
@Test
@@ -269,6 +301,10 @@
baseUrl,
testProtocol,
this.probeTest.getCreatedProbeId());
+ this.ortTest.createService(
+ baseUrl,
+ testProtocol,
+ this.probeTest.getCreatedProbeId());
Assert.assertNotNull(this.messungTest.getCreatedMessungId());
this.kommentarMTest.createService(
baseUrl,
@@ -336,12 +372,25 @@
}
/**
+ * Testing UPDATE services.
+ */
+ @Test
+ @RunAsClient
+ public final void testC_ortUpdateService(@ArquillianResource URL baseUrl)
+ throws Exception {
+ Assert.assertNotNull(this.ortTest.getCreatedId());
+ this.ortTest.updateService(baseUrl, testProtocol);
+ }
+
+ /**
* Testing DELETE services.
*/
@Test
@RunAsClient
public final void testD_DeleteServices(@ArquillianResource URL baseUrl)
throws Exception {
+ Assert.assertNotNull(this.ortTest.getCreatedId());
+ this.ortTest.deleteService(baseUrl, testProtocol);
Assert.assertNotNull(this.messwertTest.getCreatedMesswertId());
this.messwertTest.deleteService(baseUrl, testProtocol);
Assert.assertNotNull(this.kommentarMTest.getCreatedKommentarId());
diff -r ac5c5f581d59 -r 4fab79ec8a93 src/test/java/de/intevation/lada/test/Ort.java
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/src/test/java/de/intevation/lada/test/Ort.java Wed Feb 18 13:25:45 2015 +0100
@@ -0,0 +1,317 @@
+/* Copyright (C) 2013 by Bundesamt fuer Strahlenschutz
+ * Software engineering by Intevation GmbH
+ *
+ * This file is Free Software under the GNU GPL (v>=3)
+ * and comes with ABSOLUTELY NO WARRANTY! Check out
+ * the documentation coming with IMIS-Labordaten-Application for details.
+ */
+package de.intevation.lada.test;
+
+import java.io.StringReader;
+import java.net.URL;
+import java.util.List;
+
+import javax.json.Json;
+import javax.json.JsonException;
+import javax.json.JsonObject;
+import javax.json.JsonReader;
+import javax.ws.rs.client.Client;
+import javax.ws.rs.client.ClientBuilder;
+import javax.ws.rs.client.Entity;
+import javax.ws.rs.client.WebTarget;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.Response;
+
+import org.junit.Assert;
+
+import de.intevation.lada.Protocol;
+
+/**
+ * Class containing test cases for ort objects.
+ *
+ * @author <a href="mailto:rrenkert at intevation.de">Raimund Renkert</a>
+ */
+public class Ort {
+
+ private static final String COMPARE =
+ "{\"id\":1,\"letzteAenderung\":1376287046510,\"ortsTyp\":\"Z\"," +
+ "\"ortszusatztext\":null,\"probeId\":96,\"ort\":213}";
+
+ private static final String CREATE =
+ "{\"letzteAenderung\":1376287046510,\"ortsTyp\":\"Z\"," +
+ "\"ortszusatztext\":\"textzusatz\",\"probeId\":PID,\"ort\":213}";
+
+ private List<Protocol> protocol;
+
+ private static Integer createdId;
+
+ public Integer getCreatedId() {
+ return createdId;
+ }
+
+ /**
+ * @return The test protocol
+ */
+ public List<Protocol> getProtocol() {
+ return protocol;
+ }
+
+ /**
+ * Test the GET Service by requesting all objects.
+ *
+ * @param baseUrl The url pointing to the test deployment.
+ */
+ public final void getAllService(URL baseUrl, List<Protocol> protocol)
+ throws Exception {
+ System.out.print(".");
+ Protocol prot = new Protocol();
+ prot.setName("OrtService");
+ prot.setType("get all");
+ prot.setPassed(false);
+ protocol.add(prot);
+ /* Create a client*/
+ Client client = ClientBuilder.newClient();
+ WebTarget target = client.target(baseUrl + "ort");
+ /* Request all objects*/
+ Response response = target.request().get();
+ String entity = response.readEntity(String.class);
+ try{
+ /* Try to parse the response*/
+ JsonReader reader = Json.createReader(new StringReader(entity));
+ JsonObject content = reader.readObject();
+ /* Verify the response*/
+ Assert.assertTrue(content.getBoolean("success"));
+ prot.addInfo("success", content.getBoolean("success"));
+ Assert.assertEquals("200", content.getString("message"));
+ prot.addInfo("message", content.getString("message"));
+ Assert.assertNotNull(content.getJsonArray("data"));
+ prot.addInfo("objects", content.getJsonArray("data").size());
+ }
+ catch(JsonException je) {
+ prot.addInfo("exception", je.getMessage());
+ Assert.fail(je.getMessage());
+ }
+ prot.setPassed(true);
+ }
+
+ /**
+ * Test the GET Service by requesting a single object by id.
+ *
+ * @param baseUrl The url pointing to the test deployment.
+ */
+ public final void getByIdService(URL baseUrl, List<Protocol> protocol)
+ throws Exception {
+ System.out.print(".");
+ Protocol prot = new Protocol();
+ prot.setName("OrtService");
+ prot.setType("get by Id");
+ prot.setPassed(false);
+ protocol.add(prot);
+ try {
+ /* Create a json object from static messwert string*/
+ JsonReader fromStringRreader =
+ Json.createReader(new StringReader(COMPARE));
+ JsonObject staticMessung = fromStringRreader.readObject();
+ /* Create a client*/
+ Client client = ClientBuilder.newClient();
+ WebTarget target = client.target(baseUrl + "ort/1");
+ prot.addInfo("ortId", 1);
+ /* Request a object by id*/
+ Response response = target.request().get();
+ String entity = response.readEntity(String.class);
+ /* Try to parse the response*/
+ JsonReader fromServiceReader =
+ Json.createReader(new StringReader(entity));
+ JsonObject content = fromServiceReader.readObject();
+ /* Verify the response*/
+ Assert.assertTrue(content.getBoolean("success"));
+ prot.addInfo("success", content.getBoolean("success"));
+ Assert.assertEquals("200", content.getString("message"));
+ prot.addInfo("message", content.getString("message"));
+ Assert.assertEquals(staticMessung,
+ content.getJsonObject("data"));
+ prot.addInfo("object", "equals");
+ }
+ catch(JsonException je) {
+ prot.addInfo("exception", je.getMessage());
+ Assert.fail(je.getMessage());
+ }
+ prot.setPassed(true);
+ }
+
+ /**
+ * Test the GET service using filters.
+ *
+ * @param baseUrl The url poining to the test deployment.
+ */
+ public final void filterService(URL baseUrl, List<Protocol> protocol) {
+ System.out.print(".");
+ Protocol prot = new Protocol();
+ prot.setName("OrtService");
+ prot.setType("get by filter");
+ prot.setPassed(false);
+ protocol.add(prot);
+ try {
+ /* Create a client*/
+ Client client = ClientBuilder.newClient();
+ WebTarget target =
+ client.target(baseUrl + "ort?probeId=1");
+ prot.addInfo("filter", "probeId=1");
+ /* Request the objects using the filter*/
+ Response response = target.request().get();
+ String entity = response.readEntity(String.class);
+ /* Try to parse the response*/
+ JsonReader reader = Json.createReader(new StringReader(entity));
+ JsonObject respObj = reader.readObject();
+ /* Verify the response*/
+ Assert.assertTrue(respObj.getBoolean("success"));
+ prot.addInfo("success", respObj.getBoolean("success"));
+ Assert.assertEquals("200", respObj.getString("message"));
+ prot.addInfo("message", respObj.getString("message"));
+ Assert.assertNotNull(respObj.getJsonArray("data"));
+ prot.addInfo("objects", respObj.getJsonArray("data").size());
+ }
+ catch(JsonException je) {
+ prot.addInfo("exception", je.getMessage());
+ Assert.fail(je.getMessage());
+ }
+ prot.setPassed(true);
+ }
+
+ /**
+ * Test the CREATE Service.
+ *
+ * @param baseUrl The url pointing to the test deployment.
+ */
+ public final void createService(
+ URL baseUrl,
+ List<Protocol> protocol,
+ Integer probeId)
+ throws Exception {
+ System.out.print(".");
+ Protocol prot = new Protocol();
+ prot.setName("OrtService");
+ prot.setType("create");
+ prot.setPassed(false);
+ protocol.add(prot);
+ try {
+ /* Create a client*/
+ Client client = ClientBuilder.newClient();
+ WebTarget target = client.target(baseUrl + "ort");
+ /* Send a post request containing a new object*/
+ String mess = CREATE.replace("PID", probeId.toString());
+ Response response = target.request().post(
+ Entity.entity(mess, MediaType.APPLICATION_JSON));
+ String entity = response.readEntity(String.class);
+ /* Try to parse the response*/
+ JsonReader fromServiceReader =
+ Json.createReader(new StringReader(entity));
+ JsonObject content = fromServiceReader.readObject();
+ /* Save the id*/
+ createdId =
+ content.getJsonObject("data").getJsonNumber("id").intValue();
+ prot.addInfo("ortId", createdId);
+ /* Verify the response*/
+ Assert.assertTrue(content.getBoolean("success"));
+ prot.addInfo("success", content.getBoolean("success"));
+ Assert.assertEquals("200", content.getString("message"));
+ prot.addInfo("message", content.getString("message"));
+ }
+ catch(JsonException je) {
+ prot.addInfo("exception", je.getMessage());
+ Assert.fail(je.getMessage());
+ }
+ prot.setPassed(true);
+ }
+
+ /**
+ * Test the UPDATE Service.
+ *
+ * @param baseUrl The url pointing to the test deployment.
+ */
+ public final void updateService(URL baseUrl, List<Protocol> protocol)
+ throws Exception {
+ System.out.print(".");
+ Protocol prot = new Protocol();
+ prot.setName("OrtService");
+ prot.setType("update");
+ prot.setPassed(false);
+ protocol.add(prot);
+ try {
+ /* Create a client*/
+ Client client = ClientBuilder.newClient();
+ WebTarget target =
+ client.target(baseUrl + "ort/" + createdId);
+ prot.addInfo("ortId", createdId);
+ /* Request an object with the saved id*/
+ Response response = target.request().get();
+ String entity = response.readEntity(String.class);
+ /* Try to parse the response*/
+ JsonReader reader = Json.createReader(new StringReader(entity));
+ JsonObject old = reader.readObject().getJsonObject("data");
+ /* Change the mmtId*/
+ String updatedEntity =
+ old.toString().replace("textzusatz", "changedzusatz");
+ prot.addInfo("updated field", "ortszusatztext");
+ prot.addInfo("updated value", "text");
+ prot.addInfo("updated to", "zusatz");
+ /* Send the updated messwert via put request*/
+ WebTarget putTarget = client.target(baseUrl + "ort");
+ Response updated = putTarget.request().put(
+ Entity.entity(updatedEntity, MediaType.APPLICATION_JSON));
+ /* Try to parse the response*/
+ JsonReader updatedReader = Json.createReader(
+ new StringReader(updated.readEntity(String.class)));
+ JsonObject updatedObj = updatedReader.readObject();
+ /* Verify the response*/
+ Assert.assertTrue(updatedObj.getBoolean("success"));
+ prot.addInfo("success", updatedObj.getBoolean("success"));
+ Assert.assertEquals("200", updatedObj.getString("message"));
+ prot.addInfo("message", updatedObj.getString("message"));
+ Assert.assertEquals("changedzusatz",
+ updatedObj.getJsonObject("data").getString("ortszusatztext"));
+ }
+ catch(JsonException je) {
+ prot.addInfo("exception", je.getMessage());
+ Assert.fail(je.getMessage());
+ }
+ prot.setPassed(true);
+ }
+
+ /**
+ * Test the DELETE Service.
+ *
+ * @param baseUrl The url pointing to the test deployment.
+ */
+ public final void deleteService(URL baseUrl, List<Protocol> protocol) {
+ System.out.print(".");
+ Protocol prot = new Protocol();
+ prot.setName("OrtService");
+ prot.setType("delete");
+ prot.setPassed(false);
+ protocol.add(prot);
+ try {
+ /* Create a client*/
+ Client client = ClientBuilder.newClient();
+ WebTarget target =
+ client.target(baseUrl + "ort/" + createdId);
+ prot.addInfo("ortId", createdId);
+ /* Delete the object with the saved id*/
+ Response response = target.request().delete();
+ String entity = response.readEntity(String.class);
+ /* Try to parse the response*/
+ JsonReader reader = Json.createReader(new StringReader(entity));
+ JsonObject respObj = reader.readObject();
+ /* Verify the response*/
+ Assert.assertTrue(respObj.getBoolean("success"));
+ prot.addInfo("success", respObj.getBoolean("success"));
+ Assert.assertEquals("200", respObj.getString("message"));
+ prot.addInfo("message", respObj.getString("message"));
+ }
+ catch(JsonException je) {
+ prot.addInfo("exception", je.getMessage());
+ Assert.fail(je.getMessage());
+ }
+ prot.setPassed(true);
+ }
+}
More information about the Lada-commits
mailing list