* ============LICENSE_END=========================================================
*/
package org.onap.dmaap.dbcapi.resources;
-import org.onap.dmaap.dbcapi.model.*;
-import org.onap.dmaap.dbcapi.service.*;
-import static org.junit.Assert.*;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-import java.util.*;
-import java.sql.*;
+import static org.junit.Assert.assertTrue;
-import org.glassfish.jersey.test.JerseyTest;
-import org.glassfish.jersey.server.ResourceConfig;
import javax.ws.rs.client.Entity;
import javax.ws.rs.core.Application;
-import javax.ws.rs.core.Response;
import javax.ws.rs.core.MediaType;
-import javax.ws.rs.Path;
-import javax.ws.rs.GET;
+import javax.ws.rs.core.Response;
+
+import org.glassfish.jersey.server.ResourceConfig;
+import org.glassfish.jersey.test.JerseyTest;
+import org.junit.Test;
+import org.onap.dmaap.dbcapi.model.DcaeLocation;
+import org.onap.dmaap.dbcapi.model.MR_Cluster;
+import org.onap.dmaap.dbcapi.testframework.DmaapObjectFactory;
public class MR_ClusterResourceTest extends JerseyTest {
@Override
protected Application configure() {
- return new ResourceConfig( MR_ClusterResource.class );
+
+ return new ResourceConfig()
+ .register( MR_ClusterResource.class )
+ .register( DcaeLocationResource.class );
}
private static final String fmt = "%24s: %s%n";
Entity<MR_Cluster> reqEntity = Entity.entity( cluster, MediaType.APPLICATION_JSON );
Response resp = target( "mr_clusters").request().post( reqEntity, Response.class );
System.out.println( "POST MR_Cluster resp=" + resp.getStatus() + " " + resp.readEntity( String.class ) );
- assertTrue( resp.getStatus() == 201 );
+ if (resp.getStatus() != 409 ) {
+ assertTrue( resp.getStatus() == 201);
+ }
+ resp = target( "mr_clusters").
+ path( cluster.getDcaeLocationName()).request().get( Response.class );
+ System.out.println( "GET MR_Cluster resp=" + resp.getStatus() + " " + resp.readEntity( String.class ) );
+
+ assertTrue( resp.getStatus() >= 200 && resp.getStatus() < 300 );
+
}
@Test
public void PutTest() {
-/*
+
try {
DcaeLocation loc = factory.genDcaeLocation( "central" );
Entity<DcaeLocation> reqEntity = Entity.entity( loc, MediaType.APPLICATION_JSON );
Response resp = target( "dcaeLocations").request().post( reqEntity, Response.class );
System.out.println( "POST dcaeLocation resp=" + resp.getStatus() + " " + resp.readEntity( String.class ));
- assertTrue( resp.getStatus() == 201 );
+ if ( resp.getStatus() != 409 ) {
+ assertTrue( resp.getStatus() == 201 );
+ }
} catch (Exception e ) {
}
-*/
+
String h[] = {"host4", "host5", "host6" };
- MR_Cluster cluster = factory.genMR_Cluster( "edge" );
+ MR_Cluster cluster = factory.genMR_Cluster( "central" );
Entity<MR_Cluster> reqEntity = Entity.entity( cluster, MediaType.APPLICATION_JSON );
Response resp = target( "mr_clusters").request().post( reqEntity, Response.class );
// first, add it
System.out.println( "POST MR_Cluster resp=" + resp.getStatus() + " " + resp.readEntity( String.class ) );
- assertTrue( resp.getStatus() == 201 );
+ if( resp.getStatus() != 409 ) {
+ assertTrue( resp.getStatus() == 200 );
+ }
// now change a field
cluster.setHosts( h );
// update with incorrect key
resp = target( "mr_clusters")
- .path( cluster.getFqdn())
+ .path( cluster.getDcaeLocationName())
.request()
.put( reqEntity, Response.class );
System.out.println( "PUT MR_Cluster resp=" + resp.getStatus() + " " + resp.readEntity(String.class));
- assertTrue( resp.getStatus() == 404 );
+ assertTrue( resp.getStatus() == 200 );
// update with correct key
resp = target( "mr_clusters")
assertTrue( resp.getStatus() == 200 );
}
+ @Test
+ public void DelTest() {
+
+ try {
+ DcaeLocation loc = factory.genDcaeLocation( "edge" );
+ Entity<DcaeLocation> reqEntity = Entity.entity( loc, MediaType.APPLICATION_JSON );
+ Response resp = target( "dcaeLocations").request().post( reqEntity, Response.class );
+ System.out.println( "POST dcaeLocation resp=" + resp.getStatus() + " " + resp.readEntity( String.class ));
+ if ( resp.getStatus() != 409 ) {
+ assertTrue( resp.getStatus() == 201 );
+ }
+ } catch (Exception e ) {
+ }
+
+
+ MR_Cluster cluster = factory.genMR_Cluster( "edge" );
+
+ Response resp = target( "mr_clusters").
+ path( cluster.getDcaeLocationName()).
+ request().
+ delete( Response.class );
+
+ // confirm cluster is not there
+ System.out.println( "DELETE MR_Cluster resp=" + resp.getStatus() + " " + resp.readEntity( String.class ) );
+ assertTrue( resp.getStatus() == 404 );
+
+ // now, add it
+ Entity<MR_Cluster> reqEntity = Entity.entity( cluster, MediaType.APPLICATION_JSON );
+ resp = target( "mr_clusters").request().post( reqEntity, Response.class );
+
+
+ System.out.println( "POST MR_Cluster resp=" + resp.getStatus() + " " + resp.readEntity( String.class ) );
+ assertTrue( resp.getStatus() == 201 );
+
+ // now really delete it
+ resp = target( "mr_clusters").
+ path( cluster.getDcaeLocationName()).
+ request().
+ delete( Response.class );
+ System.out.println( "DELETE MR_Cluster resp=" + resp.getStatus() + " " + resp.readEntity( String.class ) );
+ assertTrue( resp.getStatus() == 204 );
+
+ }