Refactor code to support no AAF requests 23/42623/1
authordglFromAtt <dgl@research.att.com>
Tue, 10 Apr 2018 23:01:35 +0000 (19:01 -0400)
committerdglFromAtt <dgl@research.att.com>
Tue, 10 Apr 2018 23:09:21 +0000 (19:09 -0400)
Change-Id: Ib95ba2458eb9fab90013012718f708c15cbf9db3
Signed-off-by: dglFromAtt <dgl@research.att.com>
Issue-ID: DMAAP-320

46 files changed:
.classpath [new file with mode: 0644]
src/main/java/org/onap/dmaap/dbcapi/aaf/AafService.java
src/main/java/org/onap/dmaap/dbcapi/authentication/ApiPermissionInterface.java [moved from src/main/java/org/onap/dmaap/dbcapi/aaf/authentication/ApiPermissionInterface.java with 95% similarity]
src/main/java/org/onap/dmaap/dbcapi/authentication/ApiPerms.java [moved from src/main/java/org/onap/dmaap/dbcapi/aaf/authentication/ApiPerms.java with 99% similarity]
src/main/java/org/onap/dmaap/dbcapi/authentication/ApiPolicy.java [moved from src/main/java/org/onap/dmaap/dbcapi/aaf/authentication/ApiPolicy.java with 97% similarity]
src/main/java/org/onap/dmaap/dbcapi/authentication/AuthenticationErrorException.java [moved from src/main/java/org/onap/dmaap/dbcapi/aaf/authentication/AuthenticationErrorException.java with 95% similarity]
src/main/java/org/onap/dmaap/dbcapi/client/DrProvConnection.java [moved from src/main/java/org/onap/dmaap/dbcapi/aaf/client/DrProvConnection.java with 99% similarity]
src/main/java/org/onap/dmaap/dbcapi/client/MrProvConnection.java [moved from src/main/java/org/onap/dmaap/dbcapi/aaf/client/MrProvConnection.java with 99% similarity]
src/main/java/org/onap/dmaap/dbcapi/client/MrTopicConnection.java [moved from src/main/java/org/onap/dmaap/dbcapi/aaf/client/MrTopicConnection.java with 99% similarity]
src/main/java/org/onap/dmaap/dbcapi/database/ConnWrapper.java [moved from src/main/java/org/onap/dmaap/dbcapi/aaf/database/ConnWrapper.java with 97% similarity]
src/main/java/org/onap/dmaap/dbcapi/database/ConnectionFactory.java [moved from src/main/java/org/onap/dmaap/dbcapi/aaf/database/ConnectionFactory.java with 98% similarity]
src/main/java/org/onap/dmaap/dbcapi/database/DBException.java [moved from src/main/java/org/onap/dmaap/dbcapi/aaf/database/DBException.java with 96% similarity]
src/main/java/org/onap/dmaap/dbcapi/database/DBFieldHandler.java [moved from src/main/java/org/onap/dmaap/dbcapi/aaf/database/DBFieldHandler.java with 99% similarity]
src/main/java/org/onap/dmaap/dbcapi/database/DBMap.java [moved from src/main/java/org/onap/dmaap/dbcapi/aaf/database/DBMap.java with 99% similarity]
src/main/java/org/onap/dmaap/dbcapi/database/DBSingleton.java [moved from src/main/java/org/onap/dmaap/dbcapi/aaf/database/DBSingleton.java with 98% similarity]
src/main/java/org/onap/dmaap/dbcapi/database/DatabaseClass.java [moved from src/main/java/org/onap/dmaap/dbcapi/aaf/database/DatabaseClass.java with 99% similarity]
src/main/java/org/onap/dmaap/dbcapi/database/LoadSchema.java [moved from src/main/java/org/onap/dmaap/dbcapi/aaf/database/LoadSchema.java with 98% similarity]
src/main/java/org/onap/dmaap/dbcapi/database/TableHandler.java [moved from src/main/java/org/onap/dmaap/dbcapi/aaf/database/TableHandler.java with 99% similarity]
src/main/java/org/onap/dmaap/dbcapi/model/MR_Client.java
src/main/java/org/onap/dmaap/dbcapi/resources/AuthorizationFilter.java
src/main/java/org/onap/dmaap/dbcapi/resources/BridgeResource.java
src/main/java/org/onap/dmaap/dbcapi/resources/FeedResource.java
src/main/java/org/onap/dmaap/dbcapi/server/JettyServer.java
src/main/java/org/onap/dmaap/dbcapi/server/Main.java
src/main/java/org/onap/dmaap/dbcapi/service/ApiService.java
src/main/java/org/onap/dmaap/dbcapi/service/DR_NodeService.java
src/main/java/org/onap/dmaap/dbcapi/service/DR_PubService.java
src/main/java/org/onap/dmaap/dbcapi/service/DR_SubService.java
src/main/java/org/onap/dmaap/dbcapi/service/DcaeLocationService.java
src/main/java/org/onap/dmaap/dbcapi/service/DmaapService.java
src/main/java/org/onap/dmaap/dbcapi/service/FeedService.java
src/main/java/org/onap/dmaap/dbcapi/service/MR_ClientService.java
src/main/java/org/onap/dmaap/dbcapi/service/MR_ClusterService.java
src/main/java/org/onap/dmaap/dbcapi/service/MirrorMakerService.java
src/main/java/org/onap/dmaap/dbcapi/service/TopicService.java
src/main/java/org/onap/dmaap/dbcapi/util/Graph.java
src/test/java/org/onap/dmaap/dbcapi/client/DrProvConnectionTest.java [moved from src/test/java/org/onap/dmaap/dbcapi/aaf/client/DrProvConnectionTest.java with 97% similarity]
src/test/java/org/onap/dmaap/dbcapi/client/MrProvConnectionTest.java [moved from src/test/java/org/onap/dmaap/dbcapi/aaf/client/MrProvConnectionTest.java with 96% similarity]
src/test/java/org/onap/dmaap/dbcapi/client/MrTopicConnectionTest.java [moved from src/test/java/org/onap/dmaap/dbcapi/aaf/client/MrTopicConnectionTest.java with 96% similarity]
src/test/java/org/onap/dmaap/dbcapi/database/DBFieldHandlerTest.java [moved from src/test/java/org/onap/dmaap/dbcapi/aaf/database/DBFieldHandlerTest.java with 96% similarity]
src/test/java/org/onap/dmaap/dbcapi/database/DBMapTest.java [moved from src/test/java/org/onap/dmaap/dbcapi/aaf/database/DBMapTest.java with 94% similarity]
src/test/java/org/onap/dmaap/dbcapi/database/DBSingletonTest.java [moved from src/test/java/org/onap/dmaap/dbcapi/aaf/database/DBSingletonTest.java with 94% similarity]
src/test/java/org/onap/dmaap/dbcapi/database/LoadSchemaTest.java [moved from src/test/java/org/onap/dmaap/dbcapi/aaf/database/LoadSchemaTest.java with 95% similarity]
src/test/java/org/onap/dmaap/dbcapi/database/TableHandlerTest.java [moved from src/test/java/org/onap/dmaap/dbcapi/aaf/database/TableHandlerTest.java with 93% similarity]
src/test/java/org/onap/dmaap/dbcapi/service/ApiServiceTest.java
src/test/java/org/onap/dmaap/dbcapi/service/FeedServiceTest.java

diff --git a/.classpath b/.classpath
new file mode 100644 (file)
index 0000000..17efa84
--- /dev/null
@@ -0,0 +1,31 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+       <classpathentry including="**/*.java" kind="src" output="target/classes" path="src/main/java">
+               <attributes>
+                       <attribute name="optional" value="true"/>
+                       <attribute name="maven.pomderived" value="true"/>
+               </attributes>
+       </classpathentry>
+       <classpathentry excluding="**" kind="src" output="target/classes" path="src/main/resources">
+               <attributes>
+                       <attribute name="maven.pomderived" value="true"/>
+               </attributes>
+       </classpathentry>
+       <classpathentry kind="src" output="target/test-classes" path="src/test/java">
+               <attributes>
+                       <attribute name="optional" value="true"/>
+                       <attribute name="maven.pomderived" value="true"/>
+               </attributes>
+       </classpathentry>
+       <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8">
+               <attributes>
+                       <attribute name="maven.pomderived" value="true"/>
+               </attributes>
+       </classpathentry>
+       <classpathentry kind="con" path="org.eclipse.m2e.MAVEN2_CLASSPATH_CONTAINER">
+               <attributes>
+                       <attribute name="maven.pomderived" value="true"/>
+               </attributes>
+       </classpathentry>
+       <classpathentry kind="output" path="target/classes"/>
+</classpath>
index 727ec19..01506bf 100644 (file)
@@ -36,6 +36,13 @@ public class AafService extends BaseLoggingClass {
        private AafConnection aaf;
        private ServiceType ctype;
        private String aafURL ;
+       private boolean useAAF = false;
+       
+       public AafService() {
+               DmaapConfig p = (DmaapConfig)DmaapConfig.getConfig();
+               useAAF= "true".equalsIgnoreCase(p.getProperty("UseAAF", "false"));
+               
+       }
        
        private String getCred( boolean wPwd ) {
                String mechIdProperty = null;
@@ -54,21 +61,10 @@ public class AafService extends BaseLoggingClass {
                        return null;
                }
                String user = p.getProperty( mechIdProperty, "noMechId@domain.netset.com" );
-               //String dClass = p.getProperty( "AafDecryption.Class", "org.openecomp.dmaapbc.aaf.ClearDecrypt");
+
                String pwd = "";
                String encPwd = p.getProperty( pwdProperty, "notSet" );
-               //DecryptionInterface dec = null;
-               //try {
-               //      dec = (DecryptionInterface) (Class.forName(dClass).newInstance());      
-               //      dec.init( p.getProperty("CredentialCodecKeyfile", "LocalKey"));
-               //} catch (Exception ee ) {
-               //      errorLogger.error(DmaapbcLogMessageEnum.UNEXPECTED_CONDITION, "attempting to use " + dClass + " to decrypt " + encPwd );                
-               //}     
-               //try {         
-               //      pwd = dec.decrypt( encPwd );
-               //} catch( IOException io ) {
-               //      errorLogger.error(DmaapbcLogMessageEnum.DECRYPT_IO_ERROR, dClass, encPwd );
-               //} 
+
                
                pwd = decryptor.decrypt(encPwd);
                
@@ -101,7 +97,11 @@ public class AafService extends BaseLoggingClass {
                int rc = -1;
                logger.info( "entry: addPerm() "  );
                String pURL = aafURL + "authz/perm";
-               rc = aaf.postAaf( perm, pURL );
+               if ( useAAF ) {
+                       rc = aaf.postAaf( perm, pURL );
+               } else {
+                       rc = 201;
+               }
         switch( rc ) {
        case 401:
        case 403:
@@ -127,7 +127,12 @@ public class AafService extends BaseLoggingClass {
                logger.info( "entry: addGrant() "  );
 
                String pURL = aafURL + "authz/role/perm";
-               rc = aaf.postAaf( grant, pURL );
+               if ( useAAF ) {
+                       rc = aaf.postAaf( grant, pURL );
+               } else {
+                       rc = 201;
+               }
+               
         switch( rc ) {
        case 401:
        case 403:
@@ -155,7 +160,12 @@ public class AafService extends BaseLoggingClass {
                logger.info( "entry: delGrant() "  );
 
                String pURL = aafURL + "authz/role/:" + grant.getRole() + "/perm";
-               rc = aaf.delAaf( grant, pURL );
+               
+               if ( useAAF ) {
+                       rc = aaf.delAaf( grant, pURL );
+               } else {
+                       rc = 200;
+               }
         switch( rc ) {
        case 401:
                case 403:
@@ -18,7 +18,7 @@
  * ============LICENSE_END=========================================================
  */
 
-package org.onap.dmaap.dbcapi.aaf.authentication;
+package org.onap.dmaap.dbcapi.authentication;
 
 import org.onap.dmaap.dbcapi.aaf.DmaapPerm;
 
@@ -18,7 +18,7 @@
  * ============LICENSE_END=========================================================
  */
 
-package org.onap.dmaap.dbcapi.aaf.authentication;
+package org.onap.dmaap.dbcapi.authentication;
 
 import com.att.eelf.configuration.EELFLogger;
 import com.att.eelf.configuration.EELFManager;
@@ -17,7 +17,7 @@
  * limitations under the License.
  * ============LICENSE_END=========================================================
  */
-package org.onap.dmaap.dbcapi.aaf.authentication;
+package org.onap.dmaap.dbcapi.authentication;
 
 import org.onap.dmaap.dbcapi.aaf.DmaapPerm;
 import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;
@@ -18,7 +18,7 @@
  * ============LICENSE_END=========================================================
  */
 
-package org.onap.dmaap.dbcapi.aaf.authentication;
+package org.onap.dmaap.dbcapi.authentication;
 
 public class AuthenticationErrorException extends Exception {
        /**
@@ -18,7 +18,7 @@
  * ============LICENSE_END=========================================================
  */
 
-package org.onap.dmaap.dbcapi.aaf.client;
+package org.onap.dmaap.dbcapi.client;
 
 import java.io.BufferedReader;
 import java.io.IOException;
@@ -18,7 +18,7 @@
  * ============LICENSE_END=========================================================
  */
 
-package org.onap.dmaap.dbcapi.aaf.client;
+package org.onap.dmaap.dbcapi.client;
 
 import java.io.BufferedReader;
 import java.io.IOException;
@@ -18,7 +18,7 @@
  * ============LICENSE_END=========================================================
  */
 
-package org.onap.dmaap.dbcapi.aaf.client;
+package org.onap.dmaap.dbcapi.client;
 
 import java.io.BufferedReader;
 import java.io.IOException;
@@ -18,7 +18,7 @@
  * ============LICENSE_END=========================================================
  */
 
-package org.onap.dmaap.dbcapi.aaf.database;
+package org.onap.dmaap.dbcapi.database;
 
 import java.sql.*;
 
@@ -18,7 +18,7 @@
  * ============LICENSE_END=========================================================
  */
 
-package org.onap.dmaap.dbcapi.aaf.database;
+package org.onap.dmaap.dbcapi.database;
 
 import java.sql.*;
 import java.util.*;
@@ -18,7 +18,7 @@
  * ============LICENSE_END=========================================================
  */
 
-package org.onap.dmaap.dbcapi.aaf.database;
+package org.onap.dmaap.dbcapi.database;
 
 import com.att.eelf.configuration.EELFLogger;
 import com.att.eelf.configuration.EELFManager;
@@ -18,7 +18,7 @@
  * ============LICENSE_END=========================================================
  */
 
-package org.onap.dmaap.dbcapi.aaf.database;
+package org.onap.dmaap.dbcapi.database;
 
 import java.lang.reflect.*;
 import java.sql.*;
@@ -18,7 +18,7 @@
  * ============LICENSE_END=========================================================
  */
 
-package org.onap.dmaap.dbcapi.aaf.database;
+package org.onap.dmaap.dbcapi.database;
 
 import java.sql.*;
 import java.util.*;
@@ -18,7 +18,7 @@
  * ============LICENSE_END=========================================================
  */
 
-package org.onap.dmaap.dbcapi.aaf.database;
+package org.onap.dmaap.dbcapi.database;
 
 import java.sql.*;
 import java.util.*;
@@ -18,7 +18,7 @@
  * ============LICENSE_END=========================================================
  */
 
-package org.onap.dmaap.dbcapi.aaf.database;
+package org.onap.dmaap.dbcapi.database;
 
 import java.util.*;
 import java.sql.*;
@@ -18,7 +18,7 @@
  * ============LICENSE_END=========================================================
  */
 
-package org.onap.dmaap.dbcapi.aaf.database;
+package org.onap.dmaap.dbcapi.database;
 
 import java.io.*;
 import java.sql.*;
@@ -18,7 +18,7 @@
  * ============LICENSE_END=========================================================
  */
 
-package org.onap.dmaap.dbcapi.aaf.database;
+package org.onap.dmaap.dbcapi.database;
 
 import java.util.*;
 import java.lang.reflect.*;
index dc43cc0..580800c 100644 (file)
@@ -24,10 +24,7 @@ import java.util.Date;
 
 import javax.xml.bind.annotation.XmlRootElement;
 
-
-
-
-import org.onap.dmaap.dbcapi.aaf.database.DatabaseClass;
+import org.onap.dmaap.dbcapi.database.DatabaseClass;
 
 @XmlRootElement
 public class MR_Client extends DmaapObject {
index d990b09..ab0e262 100644 (file)
@@ -25,7 +25,7 @@ import java.io.IOException;
 import javax.ws.rs.container.ContainerRequestContext;
 import javax.ws.rs.container.ContainerRequestFilter;
 
-import org.onap.dmaap.dbcapi.aaf.authentication.AuthenticationErrorException;
+import org.onap.dmaap.dbcapi.authentication.AuthenticationErrorException;
 import org.onap.dmaap.dbcapi.service.ApiService;
 import org.onap.dmaap.dbcapi.util.DmaapConfig;
 
index 4796217..1a6310c 100644 (file)
@@ -40,7 +40,7 @@ import javax.ws.rs.core.Response;
 import javax.ws.rs.core.UriInfo;
 import javax.ws.rs.core.Response.Status;
 
-import org.onap.dmaap.dbcapi.aaf.authentication.AuthenticationErrorException;
+import org.onap.dmaap.dbcapi.authentication.AuthenticationErrorException;
 import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;
 import org.onap.dmaap.dbcapi.logging.DmaapbcLogMessageEnum;
 import org.onap.dmaap.dbcapi.model.ApiError;
index 417b18a..eead1de 100644 (file)
@@ -46,26 +46,7 @@ import javax.ws.rs.core.Response.Status;
 import javax.ws.rs.core.UriInfo;
 
 import org.apache.log4j.Logger;
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-import org.onap.dmaap.dbcapi.aaf.authentication.AuthenticationErrorException;
+import org.onap.dmaap.dbcapi.authentication.AuthenticationErrorException;
 import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;
 import org.onap.dmaap.dbcapi.logging.DmaapbcLogMessageEnum;
 import org.onap.dmaap.dbcapi.model.ApiError;
index c0699d5..519fa4a 100644 (file)
@@ -45,7 +45,7 @@ import org.eclipse.jetty.util.ssl.SslContextFactory;
 import com.att.eelf.configuration.EELFLogger;
 import com.att.eelf.configuration.EELFManager;
 
-import org.onap.dmaap.dbcapi.aaf.database.LoadSchema;
+import org.onap.dmaap.dbcapi.database.LoadSchema;
 import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;
 /**
  * A  Jetty server which supports:
index 1ada428..c3340e6 100644 (file)
@@ -23,8 +23,8 @@ import java.net.InetAddress;
 import java.util.Properties;
 import java.util.UUID;
 
-import org.onap.dmaap.dbcapi.aaf.authentication.ApiPerms;
-import org.onap.dmaap.dbcapi.aaf.database.DatabaseClass;
+import org.onap.dmaap.dbcapi.authentication.ApiPerms;
+import org.onap.dmaap.dbcapi.database.DatabaseClass;
 import org.onap.dmaap.dbcapi.logging.*;
 import org.onap.dmaap.dbcapi.model.Dmaap;
 import org.onap.dmaap.dbcapi.util.DmaapConfig;
index aab989d..e708043 100644 (file)
@@ -41,8 +41,8 @@ import javax.ws.rs.core.Response.Status;
 import javax.xml.bind.DatatypeConverter;
 
 import org.onap.dmaap.dbcapi.aaf.DmaapPerm;
-import org.onap.dmaap.dbcapi.aaf.authentication.ApiPolicy;
-import org.onap.dmaap.dbcapi.aaf.authentication.AuthenticationErrorException;
+import org.onap.dmaap.dbcapi.authentication.ApiPolicy;
+import org.onap.dmaap.dbcapi.authentication.AuthenticationErrorException;
 import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;
 import org.onap.dmaap.dbcapi.model.ApiError;
 import org.onap.dmaap.dbcapi.model.Dmaap;
index b6d62a2..cf8c7c1 100644 (file)
@@ -27,8 +27,8 @@ import java.util.Map;
 import javax.ws.rs.core.Response.Status;
 
 import org.apache.log4j.Logger;
-import org.onap.dmaap.dbcapi.aaf.client.DrProvConnection;
-import org.onap.dmaap.dbcapi.aaf.database.DatabaseClass;
+import org.onap.dmaap.dbcapi.client.DrProvConnection;
+import org.onap.dmaap.dbcapi.database.DatabaseClass;
 import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;
 import org.onap.dmaap.dbcapi.model.ApiError;
 import org.onap.dmaap.dbcapi.model.DR_Node;
index ca60b8a..13717da 100644 (file)
@@ -27,8 +27,8 @@ import java.util.Map;
 import javax.ws.rs.core.Response.Status;
 
 import org.apache.log4j.Logger;
-import org.onap.dmaap.dbcapi.aaf.client.DrProvConnection;
-import org.onap.dmaap.dbcapi.aaf.database.DatabaseClass;
+import org.onap.dmaap.dbcapi.client.DrProvConnection;
+import org.onap.dmaap.dbcapi.database.DatabaseClass;
 import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;
 import org.onap.dmaap.dbcapi.logging.DmaapbcLogMessageEnum;
 import org.onap.dmaap.dbcapi.model.ApiError;
index c3f8c9c..0fe1d9e 100644 (file)
@@ -26,8 +26,8 @@ import java.util.Map;
 
 import javax.ws.rs.core.Response.Status;
 
-import org.onap.dmaap.dbcapi.aaf.client.DrProvConnection;
-import org.onap.dmaap.dbcapi.aaf.database.DatabaseClass;
+import org.onap.dmaap.dbcapi.client.DrProvConnection;
+import org.onap.dmaap.dbcapi.database.DatabaseClass;
 import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;
 import org.onap.dmaap.dbcapi.logging.DmaapbcLogMessageEnum;
 import org.onap.dmaap.dbcapi.model.ApiError;
index 23d44d1..de72ade 100644 (file)
@@ -24,17 +24,7 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 
-
-
-
-
-
-
-
-
-
-
-import org.onap.dmaap.dbcapi.aaf.database.DatabaseClass;
+import org.onap.dmaap.dbcapi.database.DatabaseClass;
 import org.onap.dmaap.dbcapi.model.DcaeLocation;
 import org.onap.dmaap.dbcapi.model.DmaapObject.DmaapObject_Status;
 
index 6f1294a..03410f3 100644 (file)
@@ -35,8 +35,8 @@ import org.onap.dmaap.dbcapi.aaf.AafService;
 import org.onap.dmaap.dbcapi.aaf.DmaapGrant;
 import org.onap.dmaap.dbcapi.aaf.DmaapPerm;
 import org.onap.dmaap.dbcapi.aaf.AafService.ServiceType;
-import org.onap.dmaap.dbcapi.aaf.authentication.ApiPerms;
-import org.onap.dmaap.dbcapi.aaf.database.DatabaseClass;
+import org.onap.dmaap.dbcapi.authentication.ApiPerms;
+import org.onap.dmaap.dbcapi.database.DatabaseClass;
 import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;
 import org.onap.dmaap.dbcapi.logging.DmaapbcLogMessageEnum;
 import org.onap.dmaap.dbcapi.model.ApiError;
index 5f1cfb8..8332a35 100644 (file)
@@ -29,8 +29,8 @@ import java.util.Map;
 import javax.ws.rs.core.Response.Status;
 
 import org.apache.log4j.Logger;
-import org.onap.dmaap.dbcapi.aaf.client.DrProvConnection;
-import org.onap.dmaap.dbcapi.aaf.database.DatabaseClass;
+import org.onap.dmaap.dbcapi.client.DrProvConnection;
+import org.onap.dmaap.dbcapi.database.DatabaseClass;
 import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;
 import org.onap.dmaap.dbcapi.model.ApiError;
 import org.onap.dmaap.dbcapi.model.DR_Pub;
index 68b340f..40f86b6 100644 (file)
@@ -38,8 +38,8 @@ import org.onap.dmaap.dbcapi.aaf.AafService;
 import org.onap.dmaap.dbcapi.aaf.DmaapGrant;
 import org.onap.dmaap.dbcapi.aaf.DmaapPerm;
 import org.onap.dmaap.dbcapi.aaf.AafService.ServiceType;
-import org.onap.dmaap.dbcapi.aaf.client.MrProvConnection;
-import org.onap.dmaap.dbcapi.aaf.database.DatabaseClass;
+import org.onap.dmaap.dbcapi.client.MrProvConnection;
+import org.onap.dmaap.dbcapi.database.DatabaseClass;
 import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;
 import org.onap.dmaap.dbcapi.model.ApiError;
 import org.onap.dmaap.dbcapi.model.DcaeLocation;
index d8eb91d..529723e 100644 (file)
@@ -26,13 +26,7 @@ import java.util.Map;
 
 import javax.ws.rs.core.Response.Status;
 
-
-
-
-
-
-
-import org.onap.dmaap.dbcapi.aaf.database.DatabaseClass;
+import org.onap.dmaap.dbcapi.database.DatabaseClass;
 import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;
 import org.onap.dmaap.dbcapi.model.ApiError;
 import org.onap.dmaap.dbcapi.model.DcaeLocation;
index 6701328..29010b6 100644 (file)
@@ -34,8 +34,8 @@ import java.util.Map;
 
 //import org.openecomp.dmaapbc.aaf.AndrewDecryptor;
 import org.onap.dmaap.dbcapi.aaf.AafDecrypt;
-import org.onap.dmaap.dbcapi.aaf.client.MrTopicConnection;
-import org.onap.dmaap.dbcapi.aaf.database.DatabaseClass;
+import org.onap.dmaap.dbcapi.client.MrTopicConnection;
+import org.onap.dmaap.dbcapi.database.DatabaseClass;
 import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;
 import org.onap.dmaap.dbcapi.logging.DmaapbcLogMessageEnum;
 import org.onap.dmaap.dbcapi.model.ApiError;
index 7082b9b..d3c849c 100644 (file)
@@ -31,7 +31,7 @@ import javax.ws.rs.core.Response.Status;
 import org.onap.dmaap.dbcapi.aaf.AafService;
 import org.onap.dmaap.dbcapi.aaf.DmaapPerm;
 import org.onap.dmaap.dbcapi.aaf.AafService.ServiceType;
-import org.onap.dmaap.dbcapi.aaf.database.DatabaseClass;
+import org.onap.dmaap.dbcapi.database.DatabaseClass;
 import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;
 import org.onap.dmaap.dbcapi.logging.DmaapbcLogMessageEnum;
 import org.onap.dmaap.dbcapi.model.ApiError;
index 5c57ebc..f86569d 100644 (file)
@@ -26,7 +26,7 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
-import org.onap.dmaap.dbcapi.aaf.database.DatabaseClass;
+import org.onap.dmaap.dbcapi.database.DatabaseClass;
 import org.onap.dmaap.dbcapi.model.DcaeLocation;
 import org.onap.dmaap.dbcapi.model.MR_Client;
 
@@ -17,8 +17,9 @@
  * limitations under the License.
  * ============LICENSE_END=========================================================
  */
-package org.onap.dmaap.dbcapi.aaf.client;
+package org.onap.dmaap.dbcapi.client;
 
+import org.onap.dmaap.dbcapi.client.DrProvConnection;
 import org.onap.dmaap.dbcapi.model.*;
 import org.onap.dmaap.dbcapi.service.*;
 import org.onap.dmaap.dbcapi.testframework.DmaapObjectFactory;
@@ -17,8 +17,9 @@
  * limitations under the License.
  * ============LICENSE_END=========================================================
  */
-package org.onap.dmaap.dbcapi.aaf.client;
+package org.onap.dmaap.dbcapi.client;
 
+import org.onap.dmaap.dbcapi.client.MrProvConnection;
 import org.onap.dmaap.dbcapi.model.*;
 import org.onap.dmaap.dbcapi.service.*;
 import org.onap.dmaap.dbcapi.testframework.ReflectionHarness;
@@ -17,8 +17,9 @@
  * limitations under the License.
  * ============LICENSE_END=========================================================
  */
-package org.onap.dmaap.dbcapi.aaf.client;
+package org.onap.dmaap.dbcapi.client;
 
+import org.onap.dmaap.dbcapi.client.MrTopicConnection;
 import org.onap.dmaap.dbcapi.model.*;
 import org.onap.dmaap.dbcapi.service.*;
 import org.onap.dmaap.dbcapi.testframework.ReflectionHarness;
@@ -18,8 +18,9 @@
  * limitations under the License.
  * ============LICENSE_END=========================================================
  */
-package org.onap.dmaap.dbcapi.aaf.database;
+package org.onap.dmaap.dbcapi.database;
 
+import org.onap.dmaap.dbcapi.database.DBFieldHandler;
 import org.onap.dmaap.dbcapi.model.*;
 import org.onap.dmaap.dbcapi.testframework.ReflectionHarness;
 
  * limitations under the License.
  * ============LICENSE_END=========================================================
  */
-package org.onap.dmaap.dbcapi.aaf.database;
+package org.onap.dmaap.dbcapi.database;
 
+import org.onap.dmaap.dbcapi.database.DBMap;
+import org.onap.dmaap.dbcapi.database.DBSingleton;
 import org.onap.dmaap.dbcapi.model.*;
 import org.onap.dmaap.dbcapi.testframework.ReflectionHarness;
 import org.onap.dmaap.dbcapi.util.Singleton;
@@ -18,9 +18,9 @@
  * limitations under the License.
  * ============LICENSE_END=========================================================
  */
-package org.onap.dmaap.dbcapi.aaf.database;
+package org.onap.dmaap.dbcapi.database;
 
-import org.onap.dmaap.dbcapi.aaf.database.DBSingleton;
+import org.onap.dmaap.dbcapi.database.DBSingleton;
 import org.onap.dmaap.dbcapi.model.*;
 import org.onap.dmaap.dbcapi.testframework.ReflectionHarness;
 
@@ -17,8 +17,9 @@
  * limitations under the License.
  * ============LICENSE_END=========================================================
  */
-package org.onap.dmaap.dbcapi.aaf.database;
+package org.onap.dmaap.dbcapi.database;
 
+import org.onap.dmaap.dbcapi.database.LoadSchema;
 import org.onap.dmaap.dbcapi.model.*;
 import org.onap.dmaap.dbcapi.testframework.ReflectionHarness;
 
  * limitations under the License.
  * ============LICENSE_END=========================================================
  */
-package org.onap.dmaap.dbcapi.aaf.database;
+package org.onap.dmaap.dbcapi.database;
 
+import org.onap.dmaap.dbcapi.database.ConnectionFactory;
+import org.onap.dmaap.dbcapi.database.DBFieldHandler;
+import org.onap.dmaap.dbcapi.database.TableHandler;
 import org.onap.dmaap.dbcapi.model.*;
 import org.onap.dmaap.dbcapi.testframework.ReflectionHarness;
 
index f29d985..67489e1 100644 (file)
@@ -21,9 +21,9 @@ package org.onap.dmaap.dbcapi.service;
 
 import  org.onap.dmaap.dbcapi.model.*;
 import  org.onap.dmaap.dbcapi.aaf.*;
+import org.onap.dmaap.dbcapi.authentication.AuthenticationErrorException;
 import org.onap.dmaap.dbcapi.resources.*;
 import org.onap.dmaap.dbcapi.testframework.ReflectionHarness;
-import org.onap.dmaap.dbcapi.aaf.authentication.AuthenticationErrorException;
 
 import static org.junit.Assert.*;
 
index 1827594..d601bc4 100644 (file)
@@ -21,9 +21,9 @@ package org.onap.dmaap.dbcapi.service;
 
 import  org.onap.dmaap.dbcapi.model.*;
 import  org.onap.dmaap.dbcapi.aaf.*;
+import org.onap.dmaap.dbcapi.authentication.AuthenticationErrorException;
 import org.onap.dmaap.dbcapi.resources.*;
 import org.onap.dmaap.dbcapi.testframework.ReflectionHarness;
-import org.onap.dmaap.dbcapi.aaf.authentication.AuthenticationErrorException;
 
 import static org.junit.Assert.*;