diff options
Diffstat (limited to 'src/test')
5 files changed, 423 insertions, 4 deletions
diff --git a/src/test/java/org/onap/dmaap/dbcapi/authentication/AafLurAndFishTest.java b/src/test/java/org/onap/dmaap/dbcapi/authentication/AafLurAndFishTest.java new file mode 100644 index 0000000..34f779b --- /dev/null +++ b/src/test/java/org/onap/dmaap/dbcapi/authentication/AafLurAndFishTest.java @@ -0,0 +1,51 @@ +/*- + * ============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 ); + } +} diff --git a/src/test/java/org/onap/dmaap/dbcapi/authentication/ApiPermsTest.java b/src/test/java/org/onap/dmaap/dbcapi/authentication/ApiPermsTest.java new file mode 100644 index 0000000..ea749ce --- /dev/null +++ b/src/test/java/org/onap/dmaap/dbcapi/authentication/ApiPermsTest.java @@ -0,0 +1,52 @@ +/*- + * ============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 ); + } +} diff --git a/src/test/java/org/onap/dmaap/dbcapi/resources/DR_PubResourceTest.java b/src/test/java/org/onap/dmaap/dbcapi/resources/DR_PubResourceTest.java new file mode 100644 index 0000000..42c8014 --- /dev/null +++ b/src/test/java/org/onap/dmaap/dbcapi/resources/DR_PubResourceTest.java @@ -0,0 +1,148 @@ + +/*- + * ============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 ); + } + + + +} + + diff --git a/src/test/java/org/onap/dmaap/dbcapi/resources/DR_SubResourceTest.java b/src/test/java/org/onap/dmaap/dbcapi/resources/DR_SubResourceTest.java new file mode 100644 index 0000000..48d1016 --- /dev/null +++ b/src/test/java/org/onap/dmaap/dbcapi/resources/DR_SubResourceTest.java @@ -0,0 +1,170 @@ + +/*- + * ============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 ); + } +*/ + +} + + diff --git a/src/test/java/org/onap/dmaap/dbcapi/service/Dr_PubServiceTest.java b/src/test/java/org/onap/dmaap/dbcapi/service/Dr_PubServiceTest.java index 451cfff..2cfe475 100644 --- a/src/test/java/org/onap/dmaap/dbcapi/service/Dr_PubServiceTest.java +++ b/src/test/java/org/onap/dmaap/dbcapi/service/Dr_PubServiceTest.java @@ -76,8 +76,7 @@ public class Dr_PubServiceTest { 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 ); @@ -94,8 +93,7 @@ TODO: make this not be null... } n2 = ns.removeDr_Pub( n2.getPubId(), err ); -*/ - + } |