package org.onap.dmaap.dbcapi.resources;
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import io.swagger.annotations.ApiResponse;
-import io.swagger.annotations.ApiResponses;
-
import java.util.ArrayList;
import java.util.List;
import org.onap.dmaap.dbcapi.service.DR_SubService;
import org.onap.dmaap.dbcapi.service.FeedService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import io.swagger.annotations.ApiResponse;
+import io.swagger.annotations.ApiResponses;
+
@Path("/dr_subs")
@Api( value= "dr_subs", description = "Endpoint for a Data Router client that implements a Subscriber" )
String resp = prov.doPostDr_Sub( sub, apiError );
if ( unit_test.equals( "Yes" ) ) {
resp = simulateResp( sub, "POST" );
+ apiError.setCode(200);
}
logger.debug( "addDr_Sub resp=" + resp );
DrProvConnection prov = new DrProvConnection();
prov.makeSubPutConnection( obj.getSubId() );
String resp = prov.doPutDr_Sub( obj, apiError );
+ if ( unit_test.equals( "Yes" ) ) {
+ resp = simulateResp( obj, "PUT" );
+ apiError.setCode(200);
+ }
logger.debug( "resp=" + resp );
DR_Sub snew = null;
String resp = prov.doDeleteDr_Sub( sub, apiError );
logger.debug( "resp=" + resp );
- if ( apiError.is2xx() ) {
+ if ( apiError.is2xx() || unit_test.equals( "Yes" ) ) {
dr_subs.remove(key);
}
}
} else {
subid = "99";
}
- String ret = String.format("{\"delivery\": {\"url\": \"https://%s/delivery/%s\", \"user\": \"joe\", \"password\": \"secret\", \"use100\": true}, \"metadataOnly\": false, \"groupid\": \"0\" , \"follow_redirect\": true }",
- server, subid );
+ String ret = String.format("{\"suspend\": false, \"delivery\": {\"url\": \"https://%s/delivery/%s\", \"user\": \"%s\", \"password\": \"%s\", \"use100\": true}, \"metadataOnly\": false, \"groupid\": \"0\" , \"follow_redirect\": true, ",
+ server, subid, sub.getUsername(), sub.getUserpwd());
+ String links = String.format( "\"links\": {\"feed\": \"https://dr-prov/feedlog/%s\", \"self\": \"https://dr-prov/sub/%s\", \"log\": \"https://dr-prov/sublog/%s\" }",
+ sub.getFeedId(),
+ sub.getSubId(),
+ sub.getSubId() );
+ ret += links + "}";
+ logger.info( "DR_SubService:simulateResp=" + ret);
return ret;
}
if ( unit_test.equals( "Yes" ) ) {
// assume resp is null, so need to simulate it
resp = simulateResp( req, "PUT" );
+ err.setCode(200);
}
logger.info( "resp=" + resp );
if ( resp == null ) {
feedid = "99";
}
String ret = String.format(
-"{\"suspend\":false,\"groupid\":0,\"description\":\"%s\",\"version\":\"1.0\",\"authorization\":{\"endpoint_addrs\":[],\"classification\":\"unclassified\",\"endpoint_ids\":[{\"password\":\"topSecret123\",\"id\":\"sim\"}]},\"name\":\"%s\",\"business_description\":\"\",\"publisher\":\"sim\",\"links\":{\"subscribe\":\"https://%s/subscribe/%s\",\"log\":\"https://%s/feedlog/%s\",\"publish\":\"https://%s/publish/%s\",\"self\":\"https://%s/feed/%s\"}}",
- f.getFeedDescription(),
- f.getFeedName(),
- server, feedid,
- server, feedid,
- server, feedid,
- server, feedid
+"{\"suspend\":false,\"groupid\":0,\"description\":\"%s\",\"version\":\"1.0\",\"authorization\":",
+ f.getFeedDescription() );
- );
+ String endpoints = "{\"endpoint_addrs\":[],\"classification\":\"unclassified\",\"endpoint_ids\":[";
+ String sep = "";
+ for( DR_Pub pub: f.getPubs()) {
+ endpoints += String.format( "%s{\"password\":\"%s\",\"id\":\"%s\"}",
+ sep, pub.getUserpwd(), pub.getUsername() );
+ sep = ",";
+
+ }
+ endpoints += "]},";
+ ret += endpoints;
+
+ ret += String.format(
+ "\"name\":\"%s\",\"business_description\":\"\",\"publisher\":\"sim\",\"links\":{\"subscribe\":\"https://%s/subscribe/%s\",\"log\":\"https://%s/feedlog/%s\",\"publish\":\"https://%s/publish/%s\",\"self\":\"https://%s/feed/%s\"}}",
+
+ f.getFeedName(),
+ server, feedid,
+ server, feedid,
+ server, feedid,
+ server, feedid
+ );
+ logger.info( "simulateResp ret=" + ret );
return ret;
}
private String simulateDelResp( Feed f ){
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * org.onap.dmaap
+ * ================================================================================
+ * Copyright (C) 2017 AT&T 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.authentication;
+
+import static org.junit.Assert.assertTrue;
+
+import javax.ws.rs.core.Application;
+
+import org.glassfish.jersey.server.ResourceConfig;
+import org.glassfish.jersey.test.JerseyTest;
+import org.junit.Test;
+
+import org.onap.dmaap.dbcapi.authentication.AafLurAndFish;
+
+public class AafLurAndFishTest extends JerseyTest {
+
+ @Override
+ protected Application configure() {
+ return new ResourceConfig()
+ .register( AafLurAndFish.class );
+ }
+
+ @Test
+ public void constructorTest() {
+ try {
+ AafLurAndFish p = new AafLurAndFish();
+ } catch ( AuthenticationErrorException err ) {
+
+ }
+
+ assertTrue( true );
+ }
+}
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * org.onap.dmaap
+ * ================================================================================
+ * Copyright (C) 2017 AT&T 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.authentication;
+
+import static org.junit.Assert.assertTrue;
+
+import javax.ws.rs.core.Application;
+import org.glassfish.jersey.server.ResourceConfig;
+import org.glassfish.jersey.test.JerseyTest;
+import org.junit.Test;
+
+import org.onap.dmaap.dbcapi.authentication.ApiPerms;
+
+
+public class ApiPermsTest extends JerseyTest {
+
+ @Override
+ protected Application configure() {
+ return new ResourceConfig()
+ .register( ApiPerms.class );
+ }
+
+ @Test
+ public void bootTest() {
+ ApiPerms p = new ApiPerms();
+
+ p.setBootMap();
+
+ p.setEnvMap();
+
+
+ assertTrue( true );
+ }
+}
--- /dev/null
+
+/*-
+ * ============LICENSE_START=======================================================
+ * org.onap.dmaap
+ * ================================================================================
+ * Copyright (C) 2018 AT&T 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 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 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;
+
+public class DR_PubResourceTest extends JerseyTest{
+
+ @Override
+ protected Application configure() {
+ return new ResourceConfig()
+ .register( DR_PubResource.class )
+ .register( FeedResource.class );
+ }
+
+ private static final String fmt = "%24s: %s%n";
+ String d, un, up, f, p;
+/*
+ @Before
+ public void setUp() throws Exception {
+ d = "central-onap";
+ un = "user1";
+ up = "secretW0rd";
+ f = "234";
+ p = "678";
+ }
+
+ @After
+ public void tearDown() throws Exception {
+ }
+*/
+
+
+
+/* may conflict with test framework!
+ @Before
+ public void setUp() throws Exception {
+ }
+
+ @After
+ public void tearDown() throws Exception {
+ }
+*/
+
+ private Feed addFeed( String name, String desc ) {
+ Feed feed = new Feed( name, "1.0", desc, "dgl", "unrestricted" );
+ Entity<Feed> reqEntity = Entity.entity( feed, MediaType.APPLICATION_JSON );
+ Response resp = target( "feeds").request().post( reqEntity, Response.class );
+ int rc = resp.getStatus();
+ System.out.println( "POST feed resp=" + rc );
+ assertTrue( rc == 200 || rc == 409 );
+ feed = resp.readEntity( Feed.class );
+ return feed;
+ }
+
+ private DR_Pub addPub( String d, String un, String up, String feedId ) {
+ DR_Pub dr_pub = new DR_Pub( d, un, up, feedId, "" );
+ Entity<DR_Pub> reqEntity2 = Entity.entity( dr_pub, MediaType.APPLICATION_JSON);
+ Response resp = target( "dr_pubs").request().post( reqEntity2, Response.class);
+ System.out.println( "POST dr_pubs resp=" + resp.getStatus() );
+ assertTrue( resp.getStatus() == 201 );
+ dr_pub = resp.readEntity( DR_Pub.class );
+
+ return dr_pub;
+ }
+
+ @Test
+ public void GetTest() {
+ Response resp = target( "dr_pubs").request().get( Response.class );
+ System.out.println( "GET dr_pubs resp=" + resp.getStatus() );
+
+ assertTrue( resp.getStatus() == 200 );
+ }
+
+ @Test
+ public void PostTest() {
+
+ Feed feed = addFeed( "pubPostTest", "post unit test" );
+ System.out.println( "fpubPostTest: feedId=" + feed.getFeedId());
+
+ String d, un, up;
+ d = "central-onap";
+ un = "user1";
+ up = "secretW0rd";
+
+ DR_Pub dr_pub = addPub( d, un, up, feed.getFeedId() );
+ }
+
+ @Test
+ public void PutTest() {
+
+ Feed feed = addFeed( "pubPutTest", "put unit test");
+ String d, un, up;
+ d = "central-onap";
+ un = "user1";
+ up = "secretW0rd";
+
+ DR_Pub dr_pub = addPub( d, un, up, feed.getFeedId() );
+
+ dr_pub.setUserpwd("newSecret");
+ Entity<DR_Pub> reqEntity2 = Entity.entity( dr_pub, MediaType.APPLICATION_JSON);
+ Response resp = target( "dr_pubs")
+ .path( dr_pub.getPubId() )
+ .request()
+ .put( reqEntity2, Response.class);
+ System.out.println( "PUT dr_pubs resp=" + resp.getStatus() );
+ assertTrue( resp.getStatus() == 200 );
+ }
+
+
+
+}
+
+
--- /dev/null
+
+/*-
+ * ============LICENSE_START=======================================================
+ * org.onap.dmaap
+ * ================================================================================
+ * Copyright (C) 2018 AT&T 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 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 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;
+
+public class DR_SubResourceTest extends JerseyTest{
+
+ @Override
+ protected Application configure() {
+ return new ResourceConfig()
+ .register( DR_SubResource.class )
+ .register( FeedResource.class );
+ }
+
+ private static final String fmt = "%24s: %s%n";
+ String d, un, up, f, p;
+/*
+ @Before
+ public void setUp() throws Exception {
+ d = "central-onap";
+ un = "user1";
+ up = "secretW0rd";
+ f = "234";
+ p = "678";
+ }
+
+ @After
+ public void tearDown() throws Exception {
+ }
+*/
+
+
+
+/* may conflict with test framework!
+ @Before
+ public void setUp() throws Exception {
+ }
+
+ @After
+ public void tearDown() throws Exception {
+ }
+*/
+
+ private Feed addFeed( String name, String desc ) {
+ Feed feed = new Feed( name, "1.0", desc, "dgl", "unrestricted" );
+ Entity<Feed> reqEntity = Entity.entity( feed, MediaType.APPLICATION_JSON );
+ Response resp = target( "feeds").request().post( reqEntity, Response.class );
+ int rc = resp.getStatus();
+ System.out.println( "POST feed resp=" + rc );
+ assertTrue( rc == 200 || rc == 409 );
+ feed = resp.readEntity( Feed.class );
+ return feed;
+ }
+
+ private DR_Sub addSub( String d, String un, String up, String feedId ) {
+ DR_Sub dr_sub = new DR_Sub( d, un, up, feedId,
+ "https://subscriber.onap.org/foo", "https://dr-prov/sublog", true );
+
+ Entity<DR_Sub> reqEntity2 = Entity.entity( dr_sub, MediaType.APPLICATION_JSON);
+ Response resp = target( "dr_subs").request().post( reqEntity2, Response.class);
+ System.out.println( "POST dr_subs resp=" + resp.getStatus() );
+ assertTrue( resp.getStatus() == 201 );
+ dr_sub = resp.readEntity( DR_Sub.class );
+
+ return dr_sub;
+ }
+
+ @Test
+ public void GetTest() {
+ Response resp = target( "dr_subs").request().get( Response.class );
+ System.out.println( "GET dr_subs resp=" + resp.getStatus() );
+
+ assertTrue( resp.getStatus() == 200 );
+ }
+
+ @Test
+ public void PostTest() {
+
+ Feed feed = addFeed( "subPostTest", "post unit test" );
+ System.out.println( "subPostTest: feedId=" + feed.getFeedId());
+
+ String d, un, up;
+ d = "central-onap";
+ un = "user1";
+ up = "secretW0rd";
+
+ DR_Sub dr_pub = addSub( d, un, up, feed.getFeedId() );
+ }
+
+ @Test
+ public void PutTest() {
+
+ Feed feed = addFeed( "subPutTest", "put unit test");
+ String d, un, up;
+ d = "central-onap";
+ un = "user1";
+ up = "secretW0rd";
+
+ DR_Sub dr_sub = addSub( d, un, up, feed.getFeedId() );
+
+ dr_sub.setUserpwd("newSecret");
+ Entity<DR_Sub> reqEntity2 = Entity.entity( dr_sub, MediaType.APPLICATION_JSON);
+ Response resp = target( "dr_subs")
+ .path( dr_sub.getSubId() )
+ .request()
+ .put( reqEntity2, Response.class);
+ System.out.println( "PUT dr_subs resp=" + resp.getStatus() );
+ assertTrue( resp.getStatus() == 200 );
+ }
+/*
+ * TODO: figure out how to check delete() response
+ @Test
+ public void DelTest() {
+
+ Feed feed = addFeed( "subDelTest", "del unit test");
+ String d, un, up;
+ d = "central-onap";
+ un = "user1";
+ up = "secretW0rd";
+
+ DR_Sub dr_sub = addSub( d, un, up, feed.getFeedId() );
+
+ Entity<DR_Sub> reqEntity2 = Entity.entity( dr_sub, MediaType.APPLICATION_JSON);
+ Response resp = target( "dr_subs")
+ .path( dr_sub.getSubId() )
+ .request()
+ .delete();
+ System.out.println( "DEL dr_subs resp=" + resp.getStatus() );
+ assertTrue( resp.getStatus() == 200 );
+ }
+*/
+
+}
+
+
ApiError err = new ApiError();
Feed f = new Feed( "aTest", "1.0", "a unit test", "dgl", "unrestricted" );
f = fs.addFeed( f, err );
-/*
-TODO: make this not be null...
+
assertTrue( f != null );
DR_Pub node = new DR_Pub( locname, "aUser", "aPwd", f.getFeedId(), "pubId01" );
DR_Pub n2 = ns.addDr_Pub( node );
}
n2 = ns.removeDr_Pub( n2.getPubId(), err );
-*/
-
+
}
Code Review / dmaap / dbcapi.git / commitdiff