package biz.paluch.logging.gelf.log4j;
import biz.paluch.logging.gelf.DynamicMdcMessageField;
import biz.paluch.logging.gelf.GelfUtil;
import biz.paluch.logging.gelf.LogEvent;
import biz.paluch.logging.gelf.LogMessageField;
import biz.paluch.logging.gelf.MdcMessageField;
import biz.paluch.logging.gelf.MessageField;
import biz.paluch.logging.gelf.Values;
import org.apache.log4j.Level;
import org.apache.log4j.MDC;
import org.apache.log4j.NDC;
import org.apache.log4j.spi.LoggingEvent;
import org.apache.log4j.spi.ThrowableInformation;
import java.util.HashSet;
import java.util.Set;
/**
* @author <a href="mailto:mpaluch@paluch.biz">Mark Paluch</a>
* @since 26.09.13 15:37
*/
class Log4jLogEvent implements LogEvent {
private LoggingEvent loggingEvent;
public Log4jLogEvent(LoggingEvent loggingEvent) {
this.loggingEvent = loggingEvent;
}
@Override
public String getMessage() {
return loggingEvent.getRenderedMessage();
}
@Override
public Object[] getParameters() {
return new Object[0];
}
@Override
public Throwable getThrowable() {
ThrowableInformation ti = loggingEvent.getThrowableInformation();
if (ti != null) {
return ti.getThrowable();
}
return null;
}
@Override
public long getLogTimestamp() {
return Log4jVersionChecker.getTimeStamp(loggingEvent);
}
@Override
public String getSyslogLevel() {
return "" + levelToSyslogLevel(loggingEvent.getLevel());
}
private int levelToSyslogLevel(final Level level) {
final int syslogLevel;
switch (level.toInt()) {
case Level.FATAL_INT:
return 2;
case Level.ERROR_INT:
return 3;
case Level.WARN_INT:
return 4;
case Level.INFO_INT:
return 6;
default:
return 7;
}
}
@Override
public Values getValues(MessageField field) {
if (field instanceof LogMessageField) {
return new Values(field.getName(), getValue((LogMessageField) field));
}
if (field instanceof MdcMessageField) {
return new Values(field.getName(), getValue((MdcMessageField) field));
}
if (field instanceof DynamicMdcMessageField) {
return getMdcValues((DynamicMdcMessageField) field);
}
throw new UnsupportedOperationException("Cannot provide value for " + field);
}
public String getValue(LogMessageField field) {
switch (field.getNamedLogField()) {
case Severity:
return loggingEvent.getLevel().toString();
case ThreadName:
return loggingEvent.getThreadName();
case SourceClassName:
return loggingEvent.getLocationInformation().getClassName();
case SourceMethodName:
return loggingEvent.getLocationInformation().getMethodName();
case SourceSimpleClassName:
return GelfUtil.getSimpleClassName(loggingEvent.getLocationInformation().getClassName());
case LoggerName:
return loggingEvent.getLoggerName();
case NDC:
String ndc = NDC.get();
if (ndc != null && !"".equals(ndc)) {
return ndc;
}
return null;
}
throw new UnsupportedOperationException("Cannot provide value for " + field);
}
private String getValue(MdcMessageField field) {
return getMdcValue(field.getMdcName());
}
@Override
public String getMdcValue(String mdcName) {
Object value = MDC.get(mdcName);
if (value != null) {
return value.toString();
}
return null;
}
private Values getMdcValues(DynamicMdcMessageField field) {
Values result = new Values();
Set<String> mdcNames = getAllMdcNames();
Set<String> matchingMdcNames = getMatchingMdcNames(field, mdcNames);
for (String mdcName : matchingMdcNames) {
String mdcValue = getMdcValue(mdcName);
if (mdcName != null) {
result.setValue(mdcName, mdcValue);
}
}
return result;
}
private Set<String> getAllMdcNames() {
Set<String> mdcNames = new HashSet<String>();
mdcNames.addAll(MDC.getContext().keySet());
return mdcNames;
}
private Set<String> getMatchingMdcNames(DynamicMdcMessageField field, Set<String> mdcNames) {
Set<String> matchingMdcNames = new HashSet<String>();
for (String mdcName : mdcNames) {
if (field.getPattern().matcher(mdcName).matches()) {
matchingMdcNames.add(mdcName);
}
}
return matchingMdcNames;
}
@Override
public Set<String> getMdcNames() {
return getAllMdcNames();
}
}