1 files changed, 284 insertions, 0 deletions
diff --git a/dmaap-bc/src/test/java/org/onap/dmaap/dbcapi/resources/MR_ClusterResourceTest.java b/dmaap-bc/src/test/java/org/onap/dmaap/dbcapi/resources/MR_ClusterResourceTest.java
new file mode 100644
index 0000000..9027f13
--- /dev/null
+++ b/dmaap-bc/src/test/java/org/onap/dmaap/dbcapi/resources/MR_ClusterResourceTest.java
@@ -0,0 +1,284 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * org.onap.dmaap
+ * ================================================================================
+ * Copyright (C) 2019 Nokia Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+package org.onap.dmaap.dbcapi.resources;
+
+import static javax.ws.rs.client.Entity.entity;
+import static javax.ws.rs.core.MediaType.APPLICATION_JSON;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertFalse;
+import static org.junit.Assert.assertTrue;
+
+import java.util.List;
+import javax.ws.rs.client.Entity;
+import javax.ws.rs.core.GenericType;
+import javax.ws.rs.core.Response;
+import org.eclipse.jetty.http.HttpStatus;
+import org.glassfish.jersey.server.ResourceConfig;
+import org.junit.AfterClass;
+import org.junit.Before;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.onap.dmaap.dbcapi.database.DatabaseClass;
+import org.onap.dmaap.dbcapi.model.ApiError;
+import org.onap.dmaap.dbcapi.model.DcaeLocation;
+import org.onap.dmaap.dbcapi.model.DmaapObject.DmaapObject_Status;
+import org.onap.dmaap.dbcapi.model.MR_Cluster;
+import org.onap.dmaap.dbcapi.testframework.DmaapObjectFactory;
+
+public class MR_ClusterResourceTest {
+
+	private static final DmaapObjectFactory DMAAP_OBJECT_FACTORY = new DmaapObjectFactory();
+	private static FastJerseyTestContainer testContainer;
+	private static final String MR_CLUSTERS_TARGET = "mr_clusters";
+
+	@BeforeClass
+	public static void setUpClass() throws Exception {
+		DatabaseClass.getDmaap().init(DMAAP_OBJECT_FACTORY.genDmaap());
+
+		testContainer = new FastJerseyTestContainer(new ResourceConfig()
+			.register(MR_ClusterResource.class).register(DcaeLocationResource.class));
+		testContainer.init();
+	}
+
+	@AfterClass
+	public static void tearDownClass() throws Exception {
+		testContainer.destroy();
+        /*TODO: Cannot cleanup yet until still other Resources tests depends on the static DB content
+
+        DatabaseClass.getDmaap().remove();
+        DatabaseClass.clearDatabase();*/
+	}
+
+	@Before
+	public void setUpClusterAndLocation() {
+		DatabaseClass.clearDatabase();
+	}
+
+	@Test
+	public void getMrClusters_shouldReturnEmptyList_whenNoMrClustersInDataBase() {
+		//when
+		Response resp = testContainer.target(MR_CLUSTERS_TARGET).request().get(Response.class);
+
+		//then
+		assertEquals(HttpStatus.OK_200, resp.getStatus());
+		assertTrue(resp.hasEntity());
+
+		List<MR_Cluster> mrClusters = resp.readEntity(new GenericType<List<MR_Cluster>>() {
+		});
+		assertTrue(mrClusters.isEmpty());
+	}
+
+	@Test
+	public void addMrCluster_shouldReturnValidationError_whenDcaeLocationNameNotProvided() {
+		//given
+		Entity<MR_Cluster> requestEntity = entity(new MR_Cluster(), APPLICATION_JSON);
+
+		//when
+		Response resp = testContainer.target(MR_CLUSTERS_TARGET).request().post(requestEntity, Response.class);
+
+		//then
+		assertEquals(HttpStatus.BAD_REQUEST_400, resp.getStatus());
+		assertTrue(resp.hasEntity());
+		ApiError errorObj = resp.readEntity(ApiError.class);
+		assertEquals("dcaeLocationName", errorObj.getFields());
+	}
+
+	@Test
+	public void addMrCluster_shouldReturnValidationError_whenFqdnNotProvided() {
+		//given
+		MR_Cluster mr_cluster = new MR_Cluster();
+		mr_cluster.setDcaeLocationName("central-cloud");
+		Entity<MR_Cluster> requestEntity = entity(mr_cluster, APPLICATION_JSON);
+
+		//when
+		Response resp = testContainer.target(MR_CLUSTERS_TARGET).request().post(requestEntity, Response.class);
+
+		//then
+		assertEquals(HttpStatus.BAD_REQUEST_400, resp.getStatus());
+		assertTrue(resp.hasEntity());
+		ApiError errorObj = resp.readEntity(ApiError.class);
+		assertEquals("fqdn", errorObj.getFields());
+	}
+
+	@Test
+	public void addMrCluster_shouldAddMrClusterToDatabase() {
+		//given
+		MR_Cluster mrCluster = DMAAP_OBJECT_FACTORY.genMR_Cluster("edge");
+		Entity<MR_Cluster> requestEntity = entity(mrCluster, APPLICATION_JSON);
+
+		//when
+		Response resp = testContainer.target(MR_CLUSTERS_TARGET).request().post(requestEntity, Response.class);
+
+		//then
+		assertEquals(HttpStatus.CREATED_201, resp.getStatus());
+		assertTrue(resp.hasEntity());
+		MR_Cluster respEntity = resp.readEntity(MR_Cluster.class);
+		assertTrue(respEntity.isStatusValid());
+	}
+
+	@Test
+	public void addMrCluster_shouldReturnInvalidMrCluster_whenClusterCannotBeAddedToDatabase() {
+		//given
+		MR_Cluster mrCluster = DMAAP_OBJECT_FACTORY.genMR_Cluster("central");
+		Entity<MR_Cluster> requestEntity = entity(mrCluster, APPLICATION_JSON);
+		prepareDcaeLocationForCentralCluster();
+
+		//when
+		Response resp = testContainer.target(MR_CLUSTERS_TARGET).request().post(requestEntity, Response.class);
+
+		//then
+		assertEquals(HttpStatus.OK_200, resp.getStatus());
+		assertTrue(resp.hasEntity());
+		MR_Cluster respEntity = resp.readEntity(MR_Cluster.class);
+		assertFalse(respEntity.isStatusValid());
+	}
+
+	private void prepareDcaeLocationForCentralCluster() {
+		DcaeLocation centralDcaeLoc = DMAAP_OBJECT_FACTORY.genDcaeLocation("central");
+		centralDcaeLoc.setStatus(DmaapObject_Status.VALID);
+		DatabaseClass.getDcaeLocations().put(centralDcaeLoc.getDcaeLocationName(), centralDcaeLoc);
+	}
+
+	@Test
+	public void updateMrCluster_shouldReturnValidationError_whenDcaeLocationNameNotProvided() {
+		//given
+		Entity<MR_Cluster> requestEntity = entity(new MR_Cluster(), APPLICATION_JSON);
+
+		//when
+		Response resp = testContainer.target(MR_CLUSTERS_TARGET).path("clusterId")
+			.request().put(requestEntity, Response.class);
+
+		//then
+		assertEquals(HttpStatus.BAD_REQUEST_400, resp.getStatus());
+		assertTrue(resp.hasEntity());
+		ApiError errorObj = resp.readEntity(ApiError.class);
+		assertEquals("dcaeLocationName", errorObj.getFields());
+	}
+
+	@Test
+	public void updateMrCluster_shouldReturnApiError_whenMrClusterWithGivenIdNotFound() {
+		//given
+		MR_Cluster mr_cluster = new MR_Cluster();
+		mr_cluster.setDcaeLocationName("central-cloud");
+		Entity<MR_Cluster> requestEntity = entity(mr_cluster, APPLICATION_JSON);
+
+		//when
+		Response resp = testContainer.target(MR_CLUSTERS_TARGET).path("notExistingMrCluster")
+			.request().put(requestEntity, Response.class);
+
+		//then
+		assertEquals(HttpStatus.NOT_FOUND_404, resp.getStatus());
+		assertTrue(resp.hasEntity());
+		ApiError errorObj = resp.readEntity(ApiError.class);
+		assertEquals("dcaeLocationName", errorObj.getFields());
+	}
+
+	@Test
+	public void updateMrCluster_shouldUpdateClusterInDatabase() {
+		//given
+		String newReplicationGroup = "someNewReplicationGroup";
+		prepareDcaeLocationForEdgeCluster();
+		String clusterId = provideExistingEdgeMRClusterId();
+		MR_Cluster changedMrCluster = DMAAP_OBJECT_FACTORY.genMR_Cluster("edge");
+		changedMrCluster.setReplicationGroup(newReplicationGroup);
+		Entity<MR_Cluster> requestEntity = entity(changedMrCluster, APPLICATION_JSON);
+
+		//when
+		Response resp = testContainer.target(MR_CLUSTERS_TARGET).path(clusterId)
+			.request().put(requestEntity, Response.class);
+
+		//then
+		assertEquals(HttpStatus.CREATED_201, resp.getStatus());
+		assertTrue(resp.hasEntity());
+		MR_Cluster respEntity = resp.readEntity(MR_Cluster.class);
+		assertTrue(respEntity.isStatusValid());
+		assertEquals(newReplicationGroup, respEntity.getReplicationGroup());
+	}
+
+	private void prepareDcaeLocationForEdgeCluster() {
+		DcaeLocation edgeDcaeLoc = DMAAP_OBJECT_FACTORY.genDcaeLocation("edge");
+		edgeDcaeLoc.setStatus(DmaapObject_Status.VALID);
+		DatabaseClass.getDcaeLocations().put(edgeDcaeLoc.getDcaeLocationName(), edgeDcaeLoc);
+	}
+
+	private String provideExistingEdgeMRClusterId() {
+		MR_Cluster cluster = DMAAP_OBJECT_FACTORY.genMR_Cluster("edge");
+		cluster.setStatus(DmaapObject_Status.VALID);
+		DatabaseClass.getMr_clusters().put(cluster.getDcaeLocationName(), cluster);
+		return cluster.getDcaeLocationName();
+	}
+
+	@Test
+	public void deleteMr_Cluster_shouldReturnApiError_whenTryingToDeleteNotExistingMrCluster() {
+		//when
+		Response resp = testContainer.target(MR_CLUSTERS_TARGET).path("notExistingClusterId")
+			.request().delete(Response.class);
+
+		//then
+		assertEquals(HttpStatus.NOT_FOUND_404, resp.getStatus());
+		assertTrue(resp.hasEntity());
+		ApiError errorObj = resp.readEntity(ApiError.class);
+		assertEquals("dcaeLocationName", errorObj.getFields());
+	}
+
+	@Test
+	public void deleteMr_Cluster_shouldRemoveMrClusterFromDatabase() {
+		//given
+		String clusterId = provideExistingEdgeMRClusterId();
+
+		//when
+		Response resp = testContainer.target(MR_CLUSTERS_TARGET).path(clusterId)
+			.request().delete(Response.class);
+
+		//then
+		assertEquals(HttpStatus.NO_CONTENT_204, resp.getStatus());
+		assertFalse(resp.hasEntity());
+	}
+
+	@Test
+	public void getMr_Cluster_shouldReturnApiError_whenTryingToGetNotExistingMrCluster() {
+		//when
+		Response resp = testContainer.target(MR_CLUSTERS_TARGET).path("notExistingClusterId")
+			.request().get(Response.class);
+
+		//then
+		assertEquals(HttpStatus.OK_200, resp.getStatus());
+		assertTrue(resp.hasEntity());
+		ApiError errorObj = resp.readEntity(ApiError.class);
+		assertEquals("dcaeLocationName", errorObj.getFields());
+	}
+
+	@Test
+	public void getMr_Cluster_shouldReturnExistingMrCluster() {
+		//given
+		String clusterId = provideExistingEdgeMRClusterId();
+
+		//when
+		Response resp = testContainer.target(MR_CLUSTERS_TARGET).path(clusterId)
+			.request().get(Response.class);
+
+		//then
+		assertEquals(HttpStatus.CREATED_201, resp.getStatus());
+		assertTrue(resp.hasEntity());
+		MR_Cluster mrCluster = resp.readEntity(MR_Cluster.class);
+		assertEquals(clusterId, mrCluster.getDcaeLocationName());
+	}
+
+}