1 files changed, 366 insertions, 0 deletions
diff --git a/common-logging/src/main/java/org/openecomp/policy/common/logging/flexlogger/FlexLogger.java b/common-logging/src/main/java/org/openecomp/policy/common/logging/flexlogger/FlexLogger.java
new file mode 100644
index 00000000..4748e34f
--- /dev/null
+++ b/common-logging/src/main/java/org/openecomp/policy/common/logging/flexlogger/FlexLogger.java
@@ -0,0 +1,366 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ECOMP-Logging
+ * ================================================================================
+ * 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.openecomp.policy.common.logging.flexlogger;
+
+import java.io.IOException;
+import java.text.SimpleDateFormat;
+import java.time.Instant;
+import java.util.Date;
+import java.util.Properties;
+import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
+
+import org.openecomp.policy.common.logging.eelf.PolicyLogger;
+import org.openecomp.policy.common.logging.flexlogger.PropertyUtil;
+import org.openecomp.policy.common.logging.flexlogger.PropertyUtil.Listener;
+
+/**
+ * 
+ * FlexLogger acts as factory to generate instances of Logger based on logger type
+ *
+ */
+public class FlexLogger extends SecurityManager{
+
+	private static LoggerType loggerType = LoggerType.EELF;
+	private static boolean initLoggerCalled = false;
+    private static ConcurrentHashMap<String, Logger4J> logger4JMap = new ConcurrentHashMap<String, Logger4J>();
+    private static ConcurrentHashMap<String, EelfLogger> eelfLoggerMap = new ConcurrentHashMap<String, EelfLogger>();
+    private static ConcurrentHashMap<String, SystemOutLogger> systemOutMap = new ConcurrentHashMap<String, SystemOutLogger>();
+    //--- init logger first
+	static {
+		loggerType = initlogger();
+	}
+    
+	/**
+	 * Returns an instance of Logger
+	 * @param clazz
+	 */
+	static public Logger getLogger(Class clazz) {
+		
+		if (initLoggerCalled == false) {
+			loggerType = initlogger();
+		}
+		Logger logger = null;
+		System.out.println("FlexLogger:getLogger : loggerType = " + loggerType);
+		switch (loggerType) {
+
+		case EELF:
+			logger = getEelfLogger(clazz, false);			
+			break;
+		case LOG4J:			
+			logger = getLog4JLogger(clazz);			
+			break;
+		case SYSTEMOUT:
+			logger = getSystemOutLogger(null);
+			break;
+		}
+
+		return logger;
+
+	}
+
+	/**
+	 * Returns an instance of Logger
+	 * @param s
+	 */
+	static public Logger getLogger(String s) {
+
+		if (initLoggerCalled == false) {
+			loggerType = initlogger();
+		}		
+		Logger logger = null;
+		System.out.println("FlexLogger:getLogger : loggerType = " + loggerType);
+		switch (loggerType) {
+
+		case EELF:
+			logger = getEelfLogger(null,false);
+			break;
+		case LOG4J:			
+			logger = getLog4JLogger(s);
+			break;			
+		case SYSTEMOUT:
+			logger = getSystemOutLogger(null);
+			break;
+		}
+
+		return logger;
+
+	}
+	
+	/**
+	 * Returns an instance of Logger
+	 * @param clazz
+	 * @param isNewTransaction
+	 */
+	static public Logger getLogger(Class clazz, boolean isNewTransaction) {
+
+		if (initLoggerCalled == false) {
+			loggerType = initlogger();
+		}
+		Logger logger = null;
+		System.out.println("FlexLogger:getLogger : loggerType = " + loggerType);
+		switch (loggerType) {
+
+		case EELF:
+			logger = getEelfLogger(clazz, isNewTransaction);
+			break;
+		case LOG4J:
+			logger = getLog4JLogger(clazz);
+			break;
+		case SYSTEMOUT:
+			logger = getSystemOutLogger(null);
+			break;
+		}
+
+		return logger;
+
+	}
+
+	/**
+	 * Returns an instance of Logger
+	 * @param s
+	 * @param isNewTransaction
+	 */
+	static public Logger getLogger(String s, boolean isNewTransaction) {
+
+		if (initLoggerCalled == false) {
+			loggerType = initlogger();
+		}
+		Logger logger = null;
+		System.out.println("FlexLogger:getLogger : loggerType = " + loggerType);
+		switch (loggerType) {
+
+		case EELF:
+			logger = getEelfLogger(null, isNewTransaction);
+			break;
+		case LOG4J:
+			logger = getLog4JLogger(s);
+			break;
+		case SYSTEMOUT:
+			logger = getSystemOutLogger(null);
+			break;
+		}
+
+		return logger;
+	}
+   
+	/**
+	 * Returns the calling class name
+	 */
+   public String getClassName(){	
+	    System.out.println("getClassContext()[3].getName() " + getClassContext()[3].getName());
+  	    return getClassContext()[3].getName();
+	}
+   
+	/**
+	 * Returns an instance of Logger4J
+	 * @param clazz
+	 */
+   private static Logger4J getLog4JLogger(Class clazz){
+		 String className = new FlexLogger().getClassName();
+
+		if(!logger4JMap.containsKey(className)){
+			//for 1610 release use the default debug.log for log4j
+			Logger4J logger = new Logger4J("debugLogger", className);	
+			logger4JMap.put(className, logger);
+		}
+		
+		return logger4JMap.get(className);
+   }
+   
+	/**
+	 * Returns an instance of Logger4J
+	 * @param s
+	 */
+   private static Logger4J getLog4JLogger(String s){
+		 String className = new FlexLogger().getClassName();
+
+		if(!logger4JMap.containsKey(className)){
+			Logger4J logger = new Logger4J(s, className);	
+			logger4JMap.put(className, logger);
+		}
+		
+		return logger4JMap.get(className);
+   }
+   
+	/**
+	 * Returns an instance of EelfLogger
+	 * @param clazz
+	 * @param isNewTransaction
+	 */
+   private static EelfLogger getEelfLogger(Class clazz, boolean isNewTransaction){
+
+		String className = "";
+		EelfLogger logger = null;
+		if(clazz != null){
+			className = clazz.getName();
+		}else{
+			className = new FlexLogger().getClassName();
+		}
+		
+		if(!eelfLoggerMap.containsKey(className)){
+			logger = new EelfLogger(clazz, isNewTransaction);
+			eelfLoggerMap.put(className, logger);
+		}else{ 
+        	logger = eelfLoggerMap.get(className);
+        	if(logger == null){
+        		logger = new EelfLogger(clazz, isNewTransaction);
+        		eelfLoggerMap.put(className, logger);
+        	}
+			//installl already created but it is new transaction
+	        if(isNewTransaction){	        	
+	        	String transId = PolicyLogger.postMDCInfoForEvent(null);
+	        	logger.setTransId(transId);
+	        }
+		}
+		System.out.println("eelfLoggerMap size : " + eelfLoggerMap.size() + " class name: " + className);
+		return logger;
+   }
+   
+	/**
+	 * Returns an instance of SystemOutLogger
+	 * @param clazz
+	 */
+   private static SystemOutLogger getSystemOutLogger(Class clazz){
+
+		 String className = new FlexLogger().getClassName();
+		
+		if(!systemOutMap.containsKey(className)){
+			SystemOutLogger logger = new SystemOutLogger(className);
+			systemOutMap.put(className, logger);
+		}
+		
+		return systemOutMap.get(className);
+   }
+   
+	/**
+	 * loads the logger properties
+	 */
+	private static LoggerType initlogger() {
+		LoggerType loggerType = LoggerType.EELF;
+		String overrideLogbackLevel = "FALSE";
+		String logger_Type = "";
+		try {
+
+			 Properties properties = null;
+		     properties = PropertyUtil.getProperties(
+				 "config/policyLogger.properties");
+		     System.out.println("FlexLogger:properties => " + properties); 
+		     
+		    if(properties != null) {
+		    	overrideLogbackLevel = properties.getProperty("override.logback.level.setup");	
+		    	System.out.println("FlexLogger:overrideLogbackLevel => " + overrideLogbackLevel);
+		    	logger_Type = properties.getProperty("logger.type");
+				if (logger_Type != null){
+					
+					if (logger_Type.equalsIgnoreCase("EELF")){
+						
+						loggerType = LoggerType.EELF;
+						
+					}else if (logger_Type.equalsIgnoreCase("LOG4J")){
+						
+						loggerType = LoggerType.LOG4J;
+						
+					}else if (logger_Type.equalsIgnoreCase("SYSTEMOUT")){
+						
+						loggerType = LoggerType.SYSTEMOUT;
+						
+					}
+					
+				    System.out.println("FlexLogger.logger_Type value: " + logger_Type);
+				}
+		    }
+			//--- only use reload policyLogger.properties file listener for logger type EEFL and overrideLogbackLevel flag is true
+			if(logger_Type.equalsIgnoreCase("EELF") && overrideLogbackLevel != null && overrideLogbackLevel.equalsIgnoreCase("TRUE")){
+				
+				 System.out.println("FlexLogger: start listener.");
+			     properties = PropertyUtil.getProperties(
+					 "config/policyLogger.properties", new PropertiesCallBack(
+							"FlexLogger-CallBack"));
+			}else{
+				System.out.println("FlexLogger: no listener needed.");
+			}
+			
+			try {
+
+				loggerType = PolicyLogger.init(properties);
+				initLoggerCalled = true;
+
+			} catch (Exception e) {
+				System.out.println("initlogger" + e);
+			}
+			
+		} catch (IOException e1) {
+			System.out.println("initlogger" + e1);
+		}
+
+		return loggerType;
+	}
+	
+	/**
+	 * PropertiesCallBack is listening any updates on the policyLogger.properties
+	 */
+	static public class PropertiesCallBack implements Listener {
+		String name;
+
+		public PropertiesCallBack(String name) {
+			this.name = name;
+		}
+        
+		/**
+		 * This method will be called automatically if he policyLogger.properties got updated
+		 */
+		public void propertiesChanged(Properties properties,
+				Set<String> changedKeys) {
+			
+			String debugLevel = properties.getProperty("debugLogger.level");
+			String metricsLevel = properties.getProperty("metricsLogger.level");
+			String auditLevel = properties.getProperty("audit.level");
+			String errorLevel = properties.getProperty("error.level");
+			
+			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS+00:00");
+			Instant startTime = Instant.now();
+			String formatedTime = sdf.format(Date.from(startTime));
+			System.out.println("FlexLogger.propertiesChanged : called at time : " + formatedTime);
+			System.out.println("FlexLogger.propertiesChanged : debugLevel : " + debugLevel);
+			
+			if (changedKeys != null) {
+
+				if (changedKeys.contains("debugLogger.level")) {
+					PolicyLogger.setDebugLevel(debugLevel);
+				}
+
+				if (changedKeys.contains("metricsLogger.level")) {
+					PolicyLogger.setMetricsLevel(metricsLevel);
+				}
+
+				if (changedKeys.contains("error.level")) {
+					PolicyLogger.setErrorLevel(errorLevel);
+				}
+
+				if (changedKeys.contains("audit.level")) {
+					PolicyLogger.setAuditLevel(auditLevel);
+				}
+			}				
+		  }
+	  }
+	
+}