AllowAll api policy added
[dmaap/dbcapi.git] / src / main / java / org / onap / dmaap / dbcapi / authentication / AafLurAndFish.java
index 9defe34..d286df2 100644 (file)
@@ -8,9 +8,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.
 package org.onap.dmaap.dbcapi.authentication;
 
 
-import java.io.FileInputStream;
-import java.io.IOException;
-import java.util.Properties;
-
 import org.apache.log4j.Logger;
 import org.onap.aaf.cadi.CadiException;
 import org.onap.aaf.cadi.LocatorException;
@@ -34,17 +30,21 @@ import org.onap.dmaap.dbcapi.aaf.AafLurService;
 import org.onap.dmaap.dbcapi.aaf.DmaapPerm;
 import org.onap.dmaap.dbcapi.util.DmaapConfig;
 
+import java.io.FileInputStream;
+import java.io.IOException;
+import java.util.Properties;
+
+
 
-       
 
 public class AafLurAndFish implements ApiAuthorizationCheckInterface {
        private AafLurService svc;
        private static String apiNamespace;
        private static final String ERROR="Error";
        static final Logger logger = Logger.getLogger(AafLurAndFish.class);
-       
+
        AafLurAndFish()  throws AuthenticationErrorException  {
-       
+
                DmaapConfig p = (DmaapConfig)DmaapConfig.getConfig();
                apiNamespace = p.getProperty( "ApiNamespace", "org.onap.dmaap-bc.api");
 
@@ -65,36 +65,38 @@ public class AafLurAndFish implements ApiAuthorizationCheckInterface {
                }
                try {
                        PropAccess myAccess = new PropAccess( props );
-               
+
                        svc =  AafLurService.getInstance(myAccess);
                } catch (APIException | CadiException | LocatorException e ) {
                        logger.error(ERROR, e);
                        logger.error( e.toString() );
                        throw new AuthenticationErrorException();
                }
-       
+
        }
-       
+
        public void check( String mechid, String pwd, DmaapPerm p ) throws AuthenticationErrorException {
-       
+
                try {
-                       boolean resp = svc.checkPerm( apiNamespace, mechid, pwd, p );
-                       boolean flag = false;
-                       if ( resp == flag ) {
+                   if (mechid.isEmpty() || pwd.isEmpty()) {
+                throw new AuthenticationErrorException("No basic authorization value provided");
+            }
+
+                       if (!svc.checkPerm( apiNamespace, mechid, pwd, p )) {
                                throw new AuthenticationErrorException();
                        }
-               } catch ( IOException | CadiException  e ) { 
+               } catch ( IOException | CadiException  e ) {
                        logger.error(ERROR, e);
                        logger.error( e.toString() );
                        throw new AuthenticationErrorException();
                }
-               
+
        }
-       
+
         public static void main(String[] args) throws Exception {
                AafLurAndFish alaf = new AafLurAndFish();
                DmaapPerm p = new DmaapPerm( "org.onap.dmaap-bc.api.dmaap", "boot", "GET");
-               
+
                try {
                        alaf.check("mmanager@people.osaaf.org", "demo123456!", p);
                } catch (AuthenticationErrorException aee ) {