X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=auth%2Fauth-cass%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Faaf%2Fauth%2Fdao%2FCassAccess.java;h=6fe9bde56a0fffc9d2457dc5017109dddfc06ff5;hb=12414fe43077e12d7ef711951b1633ad31d73573;hp=e70bffb703b9a9a3c5038674855197320a964f45;hpb=71037c39a37d3549dcfe31926832a657744fbe05;p=aaf%2Fauthz.git

diff --git a/auth/auth-cass/src/main/java/org/onap/aaf/auth/dao/CassAccess.java b/auth/auth-cass/src/main/java/org/onap/aaf/auth/dao/CassAccess.java
index e70bffb7..6fe9bde5 100644
--- a/auth/auth-cass/src/main/java/org/onap/aaf/auth/dao/CassAccess.java
+++ b/auth/auth-cass/src/main/java/org/onap/aaf/auth/dao/CassAccess.java
@@ -38,186 +38,186 @@ import com.datastax.driver.core.policies.DCAwareRoundRobinPolicy;
 import com.datastax.driver.core.policies.TokenAwarePolicy;
 
 public class CassAccess {
-	public static final String KEYSPACE = "authz";
-	public static final String CASSANDRA_CLUSTERS = "cassandra.clusters";
-	public static final String CASSANDRA_CLUSTERS_PORT = "cassandra.clusters.port";
-	public static final String CASSANDRA_CLUSTERS_USER_NAME = "cassandra.clusters.user";
-	public static final String CASSANDRA_CLUSTERS_PASSWORD = "cassandra.clusters.password";
-	public static final String CASSANDRA_RESET_EXCEPTIONS = "cassandra.reset.exceptions";
-	private static final List<Resettable> resetExceptions = new ArrayList<Resettable>();
-	public static final String ERR_ACCESS_MSG = "Accessing Backend";
-	private static Builder cb = null;
+    public static final String KEYSPACE = "authz";
+    public static final String CASSANDRA_CLUSTERS = "cassandra.clusters";
+    public static final String CASSANDRA_CLUSTERS_PORT = "cassandra.clusters.port";
+    public static final String CASSANDRA_CLUSTERS_USER_NAME = "cassandra.clusters.user";
+    public static final String CASSANDRA_CLUSTERS_PASSWORD = "cassandra.clusters.password";
+    public static final String CASSANDRA_RESET_EXCEPTIONS = "cassandra.reset.exceptions";
+    private static final List<Resettable> resetExceptions = new ArrayList<>();
+    public static final String ERR_ACCESS_MSG = "Accessing Backend";
+    private static Builder cb = null;
 
-	/**
-	 * To create DCAwareRoundRobing Policy:
-	 * 	 Need Properties
-	 * 		LATITUDE (or AFT_LATITUDE)
-	 * 		LONGITUDE (or AFT_LONGITUDE)
-	 * 		CASSANDRA CLUSTERS with additional information:
-	 * 			machine:DC:lat:long,machine:DC:lat:long
-	 * @param env
-	 * @param prefix
-	 * @return
-	 * @throws APIException
-	 * @throws IOException
-	 */
+    /**
+     * To create DCAwareRoundRobing Policy:
+     *      Need Properties
+     *         LATITUDE (or AFT_LATITUDE)
+     *         LONGITUDE (or AFT_LONGITUDE)
+     *         CASSANDRA CLUSTERS with additional information:
+     *             machine:DC:lat:long,machine:DC:lat:long
+     * @param env
+     * @param prefix
+     * @return
+     * @throws APIException
+     * @throws IOException
+     */
 
-//	@SuppressWarnings("deprecation")
-	public static synchronized Cluster cluster(Env env, String prefix) throws APIException, IOException {
-		if(cb == null) {
-			String pre;
-			if(prefix==null) {
-				pre="";
-			} else {
-				env.info().log("Cassandra Connection for ",prefix);
-				pre = prefix+'.';
-			}
-			cb = Cluster.builder();
-			String str = env.getProperty(pre+CASSANDRA_CLUSTERS_PORT,env.getProperty(CASSANDRA_CLUSTERS_PORT,"9042"));
-			if(str!=null) {
-				env.init().log("Cass Port = ",str );
-				cb.withPort(Integer.parseInt(str));
-			}
-			str = env.getProperty(pre+CASSANDRA_CLUSTERS_USER_NAME,env.getProperty(CASSANDRA_CLUSTERS_USER_NAME,null));
-			if(str!=null) {
-				env.init().log("Cass User = ",str );
-				String epass = env.getProperty(pre + CASSANDRA_CLUSTERS_PASSWORD,env.getProperty(CASSANDRA_CLUSTERS_PASSWORD,null));
-				if(epass==null) {
-					throw new APIException("No Password configured for " + str);
-				}
-				//TODO Figure out way to ensure Decryptor setting in AuthzEnv
-				if(env instanceof AuthzEnv) {
-					cb.withCredentials(str,((AuthzEnv)env).decrypt(epass,true));
-				} else {
-					cb.withCredentials(str, env.decryptor().decrypt(epass));
-				}
-			}
-	
-			str = env.getProperty(pre+CASSANDRA_RESET_EXCEPTIONS,env.getProperty(CASSANDRA_RESET_EXCEPTIONS,null));
-			if(str!=null) {
-				env.init().log("Cass ResetExceptions = ",str );
-				for(String ex : Split.split(',', str)) {
-					resetExceptions.add(new Resettable(env,ex));
-				}
-			}
-	
-			str = env.getProperty(Config.CADI_LATITUDE);
-			Double lat = str!=null?Double.parseDouble(str):null;
-			str = env.getProperty(Config.CADI_LONGITUDE);
-			Double lon = str!=null?Double.parseDouble(str):null;
-			if(lat == null || lon == null) {
-				throw new APIException(Config.CADI_LATITUDE + " and/or " + Config.CADI_LONGITUDE + " are not set");
-			}
-			
-			env.init().printf("Service Latitude,Longitude = %f,%f",lat,lon);
-			
-			str = env.getProperty(pre+CASSANDRA_CLUSTERS,env.getProperty(CASSANDRA_CLUSTERS,"localhost"));
-			env.init().log("Cass Clusters = ",str );
-			String[] machs = Split.split(',', str);
-			String[] cpoints = new String[machs.length];
-			String bestDC = null;
-			int numInBestDC = 1;
-			double mlat, mlon,temp,distance = Double.MAX_VALUE;
-			for(int i=0;i<machs.length;++i) {
-				String[] minfo = Split.split(':',machs[i]);
-				if(minfo.length>0) {
-					cpoints[i]=minfo[0];
-				}
-				
-				if(minfo.length>3) {
-					if(minfo[1].equals(bestDC)) {
-						++numInBestDC;
-					} else {
-						// Calc closest DC with Great Circle
-						mlat = Double.parseDouble(minfo[2]);
-						mlon = Double.parseDouble(minfo[3]);
-						// Note: GreatCircle Distance is always >= 0.0 (not negative)
-						if((temp=GreatCircle.calc(lat, lon, mlat, mlon)) < distance) {
-							distance = temp;
-							if(bestDC==null || !bestDC.equals(minfo[1])) {
-								bestDC = minfo[1];
-								numInBestDC = 1;
-							}
-						}
-					}
-				}
-			}
-			
-			cb.addContactPoints(cpoints);
-			
-			if(bestDC!=null) {
-				// 8/26/2016 Management has determined that Accuracy is preferred over speed in bad situations
-				// Local DC Aware Load Balancing appears to have the highest normal performance, with the best
-				// Degraded Accuracy
-				DCAwareRoundRobinPolicy dcrrPolicy = DCAwareRoundRobinPolicy.builder()
-					.withLocalDc(bestDC)
-					.withUsedHostsPerRemoteDc(numInBestDC)
-					.build();
-//				cb.withLoadBalancingPolicy(new DCAwareRoundRobinPolicy(
-//						bestDC, numInBestDC, true /*allow LocalDC to look at other DCs for LOCAL_QUORUM */));
-				cb.withLoadBalancingPolicy(new TokenAwarePolicy(dcrrPolicy));
-				env.init().printf("Cassandra configured for DCAwareRoundRobinPolicy with best DC at %s with emergency remote of up to %d node(s)"
-					,bestDC, numInBestDC);
-			} else {
-				env.init().printf("Cassandra is using Default Policy, which is not DC aware");
-			}
-		}
-		return cb.build();
-	}
-	
-	private static class Resettable {
-		private Class<? extends Exception> cls;
-		private List<String> messages;
-		
-		@SuppressWarnings("unchecked")
-		public Resettable(Env env, String propData) throws APIException {
-			if(propData!=null && propData.length()>1) {
-				String[] split = Split.split(':', propData);
-				if(split.length>0) {
-					try {
-						cls = (Class<? extends Exception>)Class.forName(split[0]);
-					} catch (ClassNotFoundException e) {
-						throw new APIException("Declared Cassandra Reset Exception, " + propData + ", cannot be ClassLoaded");
-					}
-				}
-				if(split.length>1) {
-					messages=new ArrayList<String>();
-					for(int i=1;i<split.length;++i) {
-						String str = split[i];
-						int start = str.startsWith("\"")?1:0;
-						int end = str.length()-(str.endsWith("\"")?1:0);
-						messages.add(split[i].substring(start, end));
-					}
-				} else {
-					messages = null;
-				}
-			}
-		}
-		
-		public boolean matches(Exception ex) {
-			if(ex.getClass().equals(cls)) {
-				if(messages!=null) {
-					String msg = ex.getMessage();
-					for(String m : messages) {
-						if(msg.contains(m)) {
-							return true;
-						}
-					}
-				}
-			}
-			return false;
-		}
-	}
-	
-	public static final boolean isResetException(Exception e) {
-		if(e==null) {
-			return true;
-		}
-		for(Resettable re : resetExceptions) {
-			if(re.matches(e)) {
-				return true;
-			}
-		}
-		return false;
-	}
+//    @SuppressWarnings("deprecation")
+    public static synchronized Cluster cluster(Env env, String prefix) throws APIException, IOException {
+        if (cb == null) {
+            String pre;
+            if (prefix==null) {
+                pre="";
+            } else {
+                env.info().log("Cassandra Connection for ",prefix);
+                pre = prefix+'.';
+            }
+            cb = Cluster.builder();
+            String str = env.getProperty(pre+CASSANDRA_CLUSTERS_PORT,env.getProperty(CASSANDRA_CLUSTERS_PORT,"9042"));
+            if (str!=null) {
+                env.init().log("Cass Port = ",str );
+                cb.withPort(Integer.parseInt(str));
+            }
+            str = env.getProperty(pre+CASSANDRA_CLUSTERS_USER_NAME,env.getProperty(CASSANDRA_CLUSTERS_USER_NAME,null));
+            if (str!=null) {
+                env.init().log("Cass User = ",str );
+                String epass = env.getProperty(pre + CASSANDRA_CLUSTERS_PASSWORD,env.getProperty(CASSANDRA_CLUSTERS_PASSWORD,null));
+                if (epass==null) {
+                    throw new APIException("No Password configured for " + str);
+                }
+                //TODO Figure out way to ensure Decryptor setting in AuthzEnv
+                if (env instanceof AuthzEnv) {
+                    cb.withCredentials(str,((AuthzEnv)env).decrypt(epass,true));
+                } else {
+                    cb.withCredentials(str, env.decryptor().decrypt(epass));
+                }
+            }
+    
+            str = env.getProperty(pre+CASSANDRA_RESET_EXCEPTIONS,env.getProperty(CASSANDRA_RESET_EXCEPTIONS,null));
+            if (str!=null) {
+                env.init().log("Cass ResetExceptions = ",str );
+                for (String ex : Split.split(',', str)) {
+                    resetExceptions.add(new Resettable(env,ex));
+                }
+            }
+    
+            str = env.getProperty(Config.CADI_LATITUDE);
+            Double lat = str!=null && !str.isEmpty()?Double.parseDouble(str):null;
+            str = env.getProperty(Config.CADI_LONGITUDE);
+            Double lon = str!=null && !str.isEmpty()?Double.parseDouble(str):null;
+            if (lat == null || lon == null) {
+                throw new APIException(Config.CADI_LATITUDE + " and/or " + Config.CADI_LONGITUDE + " are not set");
+            }
+            
+            env.init().printf("Service Latitude,Longitude = %f,%f",lat,lon);
+            
+            str = env.getProperty(pre+CASSANDRA_CLUSTERS,env.getProperty(CASSANDRA_CLUSTERS,"localhost"));
+            env.init().log("Cass Clusters = ",str );
+            String[] machs = Split.split(',', str);
+            String[] cpoints = new String[machs.length];
+            String bestDC = null;
+            int numInBestDC = 1;
+            double mlat, mlon,temp,distance = Double.MAX_VALUE;
+            for (int i=0;i<machs.length;++i) {
+                String[] minfo = Split.split(':',machs[i]);
+                if (minfo.length>0) {
+                    cpoints[i]=minfo[0];
+                }
+                
+                if (minfo.length>3) {
+                    if (minfo[1].equals(bestDC)) {
+                        ++numInBestDC;
+                    } else {
+                        // Calc closest DC with Great Circle
+                        mlat = Double.parseDouble(minfo[2]);
+                        mlon = Double.parseDouble(minfo[3]);
+                        // Note: GreatCircle Distance is always >= 0.0 (not negative)
+                        if ((temp=GreatCircle.calc(lat, lon, mlat, mlon)) < distance) {
+                            distance = temp;
+                            if (bestDC==null || !bestDC.equals(minfo[1])) {
+                                bestDC = minfo[1];
+                                numInBestDC = 1;
+                            }
+                        }
+                    }
+                }
+            }
+            
+            cb.addContactPoints(cpoints);
+            
+            if (bestDC!=null) {
+                // 8/26/2016 Management has determined that Accuracy is preferred over speed in bad situations
+                // Local DC Aware Load Balancing appears to have the highest normal performance, with the best
+                // Degraded Accuracy
+                DCAwareRoundRobinPolicy dcrrPolicy = DCAwareRoundRobinPolicy.builder()
+                    .withLocalDc(bestDC)
+                    .withUsedHostsPerRemoteDc(numInBestDC)
+                    .build();
+//                cb.withLoadBalancingPolicy(new DCAwareRoundRobinPolicy(
+//                        bestDC, numInBestDC, true /*allow LocalDC to look at other DCs for LOCAL_QUORUM */));
+                cb.withLoadBalancingPolicy(new TokenAwarePolicy(dcrrPolicy));
+                env.init().printf("Cassandra configured for DCAwareRoundRobinPolicy with best DC at %s with emergency remote of up to %d node(s)"
+                    ,bestDC, numInBestDC);
+            } else {
+                env.init().printf("Cassandra is using Default Policy, which is not DC aware");
+            }
+        }
+        return cb.build();
+    }
+    
+    private static class Resettable {
+        private Class<? extends Exception> cls;
+        private List<String> messages;
+        
+        @SuppressWarnings("unchecked")
+        public Resettable(Env env, String propData) throws APIException {
+            if (propData!=null && propData.length()>1) {
+                String[] split = Split.split(':', propData);
+                if (split.length>0) {
+                    try {
+                        cls = (Class<? extends Exception>)Class.forName(split[0]);
+                    } catch (ClassNotFoundException e) {
+                        throw new APIException("Declared Cassandra Reset Exception, " + propData + ", cannot be ClassLoaded");
+                    }
+                }
+                if (split.length>1) {
+                    messages=new ArrayList<>();
+                    for (int i=1;i<split.length;++i) {
+                        String str = split[i];
+                        int start = str.startsWith("\"")?1:0;
+                        int end = str.length()-(str.endsWith("\"")?1:0);
+                        messages.add(split[i].substring(start, end));
+                    }
+                } else {
+                    messages = null;
+                }
+            }
+        }
+        
+        public boolean matches(Exception ex) {
+            if (ex.getClass().equals(cls)) {
+                if (messages!=null) {
+                    String msg = ex.getMessage();
+                    for (String m : messages) {
+                        if (msg.contains(m)) {
+                            return true;
+                        }
+                    }
+                }
+            }
+            return false;
+        }
+    }
+    
+    public static final boolean isResetException(Exception e) {
+        if (e==null) {
+            return true;
+        }
+        for (Resettable re : resetExceptions) {
+            if (re.matches(e)) {
+                return false;
+            }
+        }
+        return true;
+    }
 }