AafService - interface was introduced

[dmaap/dbcapi.git] / src / main / java / org / onap / dmaap / dbcapi / aaf / AafService.java

diff --git a/src/main/java/org/onap/dmaap/dbcapi/aaf/AafService.java b/src/main/java/org/onap/dmaap/dbcapi/aaf/AafService.java
index 9d8776a..30efbf2 100644 (file)
--- a/src/main/java/org/onap/dmaap/dbcapi/aaf/AafService.java
+++ b/src/main/java/org/onap/dmaap/dbcapi/aaf/AafService.java
@@ -7,9 +7,9 @@
  * 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.
@@ -20,179 +20,27 @@
 
 package org.onap.dmaap.dbcapi.aaf;
 
-import org.onap.dmaap.dbcapi.logging.BaseLoggingClass;
-import org.onap.dmaap.dbcapi.logging.DmaapbcLogMessageEnum;
-import org.onap.dmaap.dbcapi.util.DmaapConfig;
-
 /*
  * this service uses the AAF REST API endpoints to provision values in AAF
  */
-public class AafService extends BaseLoggingClass {
-       public enum ServiceType {
-               AAF_Admin,
-               AAF_TopicMgr
-       }
-       
-       private AafConnection aaf;
-       private ServiceType ctype;
-       private String aafURL ;
-       private String identity;
-       private boolean useAAF = false;
-       
-       
-       
-       public String getIdentity() {
-               return identity;
-       }
-
-
-       public void setIdentity(String identity) {
-               this.identity = identity;
-       }
-
-
-       private String getCred( boolean wPwd ) {
-               String mechIdProperty = null;
-               String pwdProperty = null;
-               DmaapConfig p = (DmaapConfig)DmaapConfig.getConfig();
-               AafDecrypt decryptor = new AafDecrypt();
-
-               if ( ctype == ServiceType.AAF_Admin ) {
-                        mechIdProperty = "aaf.AdminUser";
-                        pwdProperty = "aaf.AdminPassword";
-               } else if ( ctype == ServiceType.AAF_TopicMgr ){        
-                        mechIdProperty = "aaf.TopicMgrUser";
-                        pwdProperty = "aaf.TopicMgrPassword";
-               } else {
-                       logger.error( "Unexpected case for AAF credential type: " + ctype );
-                       return null;
-               }
-               identity = p.getProperty( mechIdProperty, "noMechId@domain.netset.com" );
+public interface AafService {
+    enum ServiceType {
+        AAF_Admin,
+        AAF_TopicMgr
+    }
 
-               String pwd = "";
-               String encPwd = p.getProperty( pwdProperty, "notSet" );
+    String getIdentity();
 
-               
-               pwd = decryptor.decrypt(encPwd);
-               
-               if ( wPwd ) {
-                       return identity + ":" + pwd;
-               } else {
-                       return identity;
-               }
-               
-               
-       }
-       
-       
-       public AafService(ServiceType t ) {
-               DmaapConfig p = (DmaapConfig)DmaapConfig.getConfig();
-               aafURL = p.getProperty( "aaf.URL", "https://authentication.domain.netset.com:8100/proxy/");
-               initAafService( t );
-       }
-       public AafService( ServiceType t, String url ) {
-               aafURL = url;
-               initAafService( t );
-       }
-               
-       private void initAafService( ServiceType t ) {
-               DmaapConfig p = (DmaapConfig)DmaapConfig.getConfig();
-               useAAF= "true".equalsIgnoreCase(p.getProperty("UseAAF", "false"));
-               logger.info( "AafService initAafService: useAAF=" + useAAF);
-               
-               ctype = t;
-               aaf = new AafConnection( getCred( true ) );
-       }
-       
-       public int addPerm(DmaapPerm perm) {
-               logger.info( "entry: addPerm() "  );
-               return doPost( perm, "authz/perm", 201);
-       }
-       public int addGrant(DmaapGrant grant ) {
-               logger.info( "entry: addGrant() "  );
-               return doPost( grant, "authz/role/perm", 201 );
-       }
-       public int addUserRole( AafUserRole ur ) {
-               logger.info( "entry: addUserRole() "  );
-               return doPost( ur, "authz/userRole", 201 );
-       }
+    int addPerm(DmaapPerm perm);
 
-       public int delGrant( DmaapGrant grant ) {
-               int rc = -1;
-               logger.info( "entry: delGrant() "  );
+    int addGrant(DmaapGrant grant);
 
-               String pURL = aafURL + "authz/role/:" + grant.getRole() + "/perm";
-               
-               if ( useAAF ) {
-                       rc = aaf.delAaf( grant, pURL );
-               } else {
-                       rc = 200;
-               }
-        switch( rc ) {
-       case 401:
-               case 403:
-               errorLogger.error(DmaapbcLogMessageEnum.AAF_CREDENTIAL_ERROR,  getCred( false ) );
-               System.exit(1);
-               break;
- 
-       case 404:
-               logger.warn( "Perm not found...ignore");
-               break;
-               
-       case 200:
-               logger.info( "expected response" );
-               break;
-               default :
-               logger.error( "Unexpected response: " + rc );
-               break;
-        }
-               
-               return rc;
-       }
+    int addUserRole(AafUserRole ur);
 
-       public int addRole(AafRole role) {
-               logger.info( "entry: addRole() "  );
-               return doPost( role, "authz/role", 201 );
-       }
+    int delGrant(DmaapGrant grant);
 
-       
-       
-       public int addNamespace(AafNamespace ns) {
-               logger.info( "entry: addNamespace() "  );
-               return doPost( ns, "authz/ns", 201 );
-       }
+    int addRole(AafRole role);
 
-       
-       private int doPost( AafObject obj, String uri, int expect ) {
-               int rc = -1;
-               logger.info( "entry: doPost() "  );
-               String pURL = aafURL + uri;
-               logger.info( "doPost: useAAF=" + useAAF );
-               if ( useAAF ) {
-                       logger.info( "doPost: " + obj.toJSON());
-                       rc = aaf.postAaf( obj, pURL );
-               } else {
-                       rc = expect;
-               }
-        switch( rc ) {
-       case 401:
-       case 403:
-                       errorLogger.error(DmaapbcLogMessageEnum.AAF_CREDENTIAL_ERROR,  getCred( false ) );
-               System.exit(1);
-       case 409:
-               logger.warn( "Object for " + uri + " already exists. Possible conflict.");
-               break;
-               
 
-               default :
-                       if ( rc == expect ) {
-                               logger.info( "expected response: " + rc);
-                       } else {
-                               logger.error( "Unexpected response: " + rc );
-                       }
-               break;
-        }
-        
-        return rc;
-       }
+    int addNamespace(AafNamespace ns);
 }