diff options
Diffstat (limited to 'common-app-logging')
24 files changed, 801 insertions, 963 deletions
diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/api/ILogConfiguration.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/api/ILogConfiguration.java index 6862fdddc3..024dcc1aa4 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/api/ILogConfiguration.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/api/ILogConfiguration.java @@ -2,28 +2,28 @@ package org.openecomp.sdc.common.log.api; public interface ILogConfiguration { - String MDC_SERVICE_INSTANCE_ID = "ServiceInstanceID"; - String MDC_SERVER_IP_ADDRESS = "ServerIPAddress"; - String MDC_REMOTE_HOST = "RemoteHost"; - String MDC_AUDIT_MESSAGE = "AuditMessage"; - String MDC_END_TIMESTAMP = "EndTimestamp"; - String MDC_ELAPSED_TIME = "ElapsedTime"; - String MDC_PROCESS_KEY = "ProcessKey"; - String MDC_TARGET_VIRTUAL_ENTITY = "TargetVirtualEntity"; - String MDC_ERROR_CATEGORY = "ErrorCategory"; - String MDC_ERROR_CODE = "ErrorCode"; - String MDC_ERROR_DESC = "ErrorDescription"; - String MDC_CLASS_NAME = "ClassName"; - String MDC_OPT_FIELD1 = "CustomField1"; - String MDC_OPT_FIELD2 = "CustomField2"; - String MDC_OPT_FIELD3 = "CustomField3"; - String MDC_OPT_FIELD4 = "CustomField4"; - String MDC_OUTGOING_INVOCATION_ID = "OutgoingInvocationId"; - String MDC_SUPPORTABLITY_ACTION = "SupportablityAction"; - String MDC_SUPPORTABLITY_CSAR_UUID="SupportablityCsarUUID"; - String MDC_SUPPORTABLITY_CSAR_VERSION="SupportablityCsarVersion"; - String MDC_SUPPORTABLITY_COMPONENT_NAME = "SupportablityComponentName"; - String MDC_SUPPORTABLITY_COMPONENT_UUID = "SupportablityComponentUUID"; - String MDC_SUPPORTABLITY_COMPONENT_VERSION="SupportablityComponentVersion"; - String MDC_SUPPORTABLITY_STATUS_CODE = "SupportablityStatus"; -}
\ No newline at end of file + String MDC_SERVICE_INSTANCE_ID = "ServiceInstanceID"; + String MDC_SERVER_IP_ADDRESS = "ServerIPAddress"; + String MDC_REMOTE_HOST = "RemoteHost"; + String MDC_AUDIT_MESSAGE = "AuditMessage"; + String MDC_END_TIMESTAMP = "EndTimestamp"; + String MDC_ELAPSED_TIME = "ElapsedTime"; + String MDC_PROCESS_KEY = "ProcessKey"; + String MDC_TARGET_VIRTUAL_ENTITY = "TargetVirtualEntity"; + String MDC_ERROR_CATEGORY = "ErrorCategory"; + String MDC_ERROR_CODE = "ErrorCode"; + String MDC_ERROR_DESC = "ErrorDescription"; + String MDC_CLASS_NAME = "ClassName"; + String MDC_OPT_FIELD1 = "CustomField1"; + String MDC_OPT_FIELD2 = "CustomField2"; + String MDC_OPT_FIELD3 = "CustomField3"; + String MDC_OPT_FIELD4 = "CustomField4"; + String MDC_OUTGOING_INVOCATION_ID = "OutgoingInvocationId"; + String MDC_SUPPORTABLITY_ACTION = "SupportablityAction"; + String MDC_SUPPORTABLITY_CSAR_UUID = "SupportablityCsarUUID"; + String MDC_SUPPORTABLITY_CSAR_VERSION = "SupportablityCsarVersion"; + String MDC_SUPPORTABLITY_COMPONENT_NAME = "SupportablityComponentName"; + String MDC_SUPPORTABLITY_COMPONENT_UUID = "SupportablityComponentUUID"; + String MDC_SUPPORTABLITY_COMPONENT_VERSION = "SupportablityComponentVersion"; + String MDC_SUPPORTABLITY_STATUS_CODE = "SupportablityStatus"; +} diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/api/ILogFieldsHandler.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/api/ILogFieldsHandler.java index ed1a19d76d..00e0c09aee 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/api/ILogFieldsHandler.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/api/ILogFieldsHandler.java @@ -6,6 +6,7 @@ import org.openecomp.sdc.common.log.enums.Severity; * Created by dd4296 on 12/25/2017. */ public interface ILogFieldsHandler { + void startAuditTimer(); void startMetricTimer(); @@ -36,42 +37,36 @@ public interface ILogFieldsHandler { void setOutgoingInvocationId(String outgoingInvocationId); - void setKeyRequestId(String keyRequestId); - - void setRemoteHost(String remoteHost); - - void setServiceName(String serviceName); - void setStatusCode(String statusCode); - void setPartnerName(String partnerName); - void setResponseCode(int responseCode); void setResponseDesc(String responseDesc); void setServiceInstanceId(String serviceInstanceId); - void setTargetEntity(String targetEntity); - - void setTargetServiceName(String targetServiceName); - void setTargetVirtualEntity(String targetVirtualEntity); - void setErrorCode(int errorCode); - - void setErrorCategory(String errorCategory); - String getErrorCode(); + void setErrorCode(int errorCode); + String getServiceName(); + void setServiceName(String serviceName); + String getTargetEntity(); + void setTargetEntity(String targetEntity); + String getTargetServiceName(); + void setTargetServiceName(String targetServiceName); + String getErrorCategory(); + void setErrorCategory(String errorCategory); + void clear(); boolean isMDCParamEmpty(String mdcKeyName); @@ -82,6 +77,8 @@ public interface ILogFieldsHandler { String getKeyRequestId(); + void setKeyRequestId(String keyRequestId); + void removeStatusCode(); void removePartnerName(); @@ -104,38 +101,37 @@ public interface ILogFieldsHandler { void removeErrorDescription(); - void setAuditMessage(String message); - String getAuditMessage(); - //service supportability [US 496441] + void setAuditMessage(String message); + //service supportability [US 496441] String getSupportablityAction(); - String getSupportablityCsarUUID(); - - String getSupportablityCsarVersion(); - - String getSupportablityComponentName(); - - String getSupportablityComponentUUID(); - - String getSupportablityComponentVersion(); - - String getSupportablityStatusCode(); - void setSupportablityAction(String action); + String getSupportablityCsarUUID(); + void setSupportablityCsarUUID(String uuid); + String getSupportablityCsarVersion(); + void setSupportablityCsarVersion(String version); + String getSupportablityComponentName(); + void setSupportablityComponentName(String name); + String getSupportablityComponentUUID(); + void setSupportablityComponentUUID(String UUID); + String getSupportablityComponentVersion(); + void setSupportablityComponentVersion(String version); + String getSupportablityStatusCode(); + void setSupportablityStatusCode(String statusCode); void removeSupportablityAction(); @@ -154,11 +150,15 @@ public interface ILogFieldsHandler { String getPartnerName(); + void setPartnerName(String partnerName); + String getRemoteHost(); - String getServerIpAddress(); + void setRemoteHost(String remoteHost); - void setKeyInvocationId(String invocationId); + String getServerIpAddress(); CharSequence getKeyInvocationId(); + + void setKeyInvocationId(String invocationId); } diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/api/ILogger.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/api/ILogger.java index 9a2ad6960a..1a3a8c5e90 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/api/ILogger.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/api/ILogger.java @@ -1,22 +1,30 @@ package org.openecomp.sdc.common.log.api; +import java.util.List; import org.openecomp.sdc.common.log.enums.LogLevel; import org.slf4j.Marker; -import java.util.List; - /** * Created by dd4296 on 12/24/2017. */ public interface ILogger { + void log(LogLevel logLevel, String message); + void log(Marker marker, LogLevel logLevel, String message); + void log(LogLevel logLevel, String message, Object... params); + void log(Marker marker, LogLevel logLevel, String message, Object... params); + void log(LogLevel logLevel, String message, Throwable throwable); + List<String> getMandatoryFields(); + ILogger clear(); + ILogger startTimer(); + ILogger setKeyRequestId(String keyRequestId); ILogger setKeyInvocationId(String keyInvocationId); diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/ErrorLogOptionalData.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/ErrorLogOptionalData.java index fce1143ad1..c0dee08fa7 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/ErrorLogOptionalData.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/ErrorLogOptionalData.java @@ -1,12 +1,17 @@ package org.openecomp.sdc.common.log.elements; public class ErrorLogOptionalData { + private String targetEntity; private String targetServiceName; public ErrorLogOptionalData() { } + public static Builder newBuilder() { + return new Builder(); + } + String getTargetEntity() { return targetEntity; } @@ -23,11 +28,8 @@ public class ErrorLogOptionalData { this.targetServiceName = targetServiceName; } - public static Builder newBuilder() { - return new Builder(); - } - public static class Builder { + private final ErrorLogOptionalData instance; private Builder() { diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LogFieldsMdcHandler.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LogFieldsMdcHandler.java index 3deb115f4b..8aba0cb209 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LogFieldsMdcHandler.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LogFieldsMdcHandler.java @@ -1,497 +1,482 @@ package org.openecomp.sdc.common.log.elements; +import static java.lang.Integer.valueOf; + +import java.net.InetAddress; +import java.time.Duration; +import java.time.Instant; +import java.time.LocalDateTime; +import java.time.ZoneOffset; +import java.time.format.DateTimeFormatter; +import javax.servlet.http.HttpServletRequest; import org.apache.commons.lang3.StringUtils; import org.onap.logging.ref.slf4j.ONAPLogConstants; -import org.openecomp.sdc.common.log.enums.ConstantsLogging; import org.openecomp.sdc.common.log.api.ILogConfiguration; import org.openecomp.sdc.common.log.api.ILogFieldsHandler; +import org.openecomp.sdc.common.log.enums.ConstantsLogging; import org.openecomp.sdc.common.log.enums.Severity; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.slf4j.MDC; -import javax.servlet.http.HttpServletRequest; -import java.net.InetAddress; -import java.time.Duration; -import java.time.Instant; -import java.time.LocalDateTime; -import java.time.ZoneOffset; -import java.time.format.DateTimeFormatter; - -import static java.lang.Integer.valueOf; public class LogFieldsMdcHandler implements ILogFieldsHandler { - private static LogFieldsMdcHandler instanceMdcWrapper = new LogFieldsMdcHandler(); - - public static LogFieldsMdcHandler getInstance() { - return instanceMdcWrapper; - } - - private final static String dateFormatPattern = "yyyy-MM-dd'T'HH:mm:ss.SSSz"; - private final DateTimeFormatter dateTimeFormatter = DateTimeFormatter - .ofPattern(dateFormatPattern); - protected static Logger log = LoggerFactory.getLogger(LogFieldsMdcHandler.class.getName()); - protected static String hostAddress; - protected static String fqdn; - - static { - try { - hostAddress = InetAddress.getLocalHost().getHostAddress(); - fqdn = InetAddress.getByName(hostAddress).getCanonicalHostName(); - } catch (Exception ex) { - log.error("failed to get machine parameters", ex); - } - } - - @Override - public void startAuditTimer() { - if (StringUtils.isEmpty(MDC.get(ONAPLogConstants.MDCs.ENTRY_TIMESTAMP))) { - MDC.put(ONAPLogConstants.MDCs.ENTRY_TIMESTAMP, generatedTimeNow()); - } - } - - @Override - public void startMetricTimer() { - if (StringUtils.isEmpty(MDC.get(ONAPLogConstants.MDCs.INVOKE_TIMESTAMP))) { - MDC.put(ONAPLogConstants.MDCs.INVOKE_TIMESTAMP, generatedTimeNow()); - } - } - - @Override - public void stopAuditTimer() { - //set start time if it is not set yet - startAuditTimer(); - MDC.put(ILogConfiguration.MDC_END_TIMESTAMP, generatedTimeNow()); - setElapsedTime(MDC.get(ONAPLogConstants.MDCs.ENTRY_TIMESTAMP)); - } - - @Override - public void stopMetricTimer() { - //set start time if it is not set yet - startMetricTimer(); - MDC.put(ILogConfiguration.MDC_END_TIMESTAMP, generatedTimeNow()); - setElapsedTime(MDC.get(ONAPLogConstants.MDCs.INVOKE_TIMESTAMP)); - } - - @Override - public void setClassName(String className) { - MDC.put(ILogConfiguration.MDC_CLASS_NAME, className); - } - - @Override - public void setServerFQDN(String serverFQDN) { - MDC.put(ONAPLogConstants.MDCs.SERVER_FQDN, serverFQDN); - } - - @Override - public void setServerIPAddress(String serverIPAddress) { - MDC.put(ILogConfiguration.MDC_SERVER_IP_ADDRESS, serverIPAddress); - } - - @Override - public void setServerFQDNInternally() { - setServerFQDN(fqdn); - } - - @Override - public void setServerIPAddressInternally() { - setServerIPAddress(hostAddress); - } - - @Override - public void setInstanceUUID(String instanceUUID) { - MDC.put(ONAPLogConstants.MDCs.INSTANCE_UUID, instanceUUID); - } - - @Override - public void setProcessKey(String processKey) { - MDC.put(ILogConfiguration.MDC_PROCESS_KEY, processKey); - } - - @Override - public void setAlertSeverity(Severity alertSeverity) { - MDC.put(ONAPLogConstants.MDCs.RESPONSE_SEVERITY, String.valueOf(alertSeverity.getSeverityType())); - } - - @Override - public void setOptCustomField1(String customField1) { - MDC.put(ILogConfiguration.MDC_OPT_FIELD1, customField1); - } - - @Override - public void setOutgoingInvocationId(String outgoingInvocationId) { - MDC.put(ILogConfiguration.MDC_OUTGOING_INVOCATION_ID, outgoingInvocationId); - } - - @Override - public void setKeyRequestId(String keyRequestId) { - MDC.put(ONAPLogConstants.MDCs.REQUEST_ID, - keyRequestId); // eg. servletRequest.getSession().getId() - } - - @Override - public void setKeyInvocationId(String invocationId ) { - MDC.put(ONAPLogConstants.MDCs.INVOCATION_ID, - invocationId); - } - - @Override - public void setRemoteHost(String remoteHost) { - MDC.put(ILogConfiguration.MDC_REMOTE_HOST, remoteHost); - } - - @Override - public void setServiceName(String serviceName) { - MDC.put(ONAPLogConstants.MDCs.SERVICE_NAME, serviceName); - } - - @Override - public void setStatusCode(String statusCode) { - MDC.put(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE, statusCode); - } - - @Override - public void setPartnerName(String partnerName) { - MDC.put(ONAPLogConstants.MDCs.PARTNER_NAME, partnerName); - } - - @Override - public void setResponseCode(int responseCode) { - MDC.put(ONAPLogConstants.MDCs.RESPONSE_CODE, Integer.toString(responseCode)); - } - - @Override - public void setResponseDesc(String responseDesc) { - MDC.put(ONAPLogConstants.MDCs.RESPONSE_DESCRIPTION, responseDesc); - } - - @Override - public void setServiceInstanceId(String serviceInstanceId) { - MDC.put(ILogConfiguration.MDC_SERVICE_INSTANCE_ID, serviceInstanceId); - } - - @Override - public void setTargetEntity(String targetEntity) { - MDC.put(ONAPLogConstants.MDCs.TARGET_ENTITY, targetEntity); - } - - @Override - public void setTargetServiceName(String targetServiceName) { - MDC.put(ONAPLogConstants.MDCs.TARGET_SERVICE_NAME, targetServiceName); - } - - @Override - public void setTargetVirtualEntity(String targetVirtualEntity) { - MDC.put(ILogConfiguration.MDC_TARGET_VIRTUAL_ENTITY, targetVirtualEntity); - } - - @Override - public void setErrorCode(int errorCode) { - MDC.put(ILogConfiguration.MDC_ERROR_CODE, valueOf(errorCode).toString()); - } - - @Override - public void setErrorCategory(String errorCategory) { - MDC.put(ILogConfiguration.MDC_ERROR_CATEGORY, errorCategory); - } - - @Override - public String getErrorCode() { - return MDC.get(ILogConfiguration.MDC_ERROR_CODE); - } - - @Override - public String getServiceName() { - return MDC.get(ONAPLogConstants.MDCs.SERVICE_NAME); - } - - @Override - public String getErrorCategory() { - return MDC.get(ILogConfiguration.MDC_ERROR_CATEGORY); - } - - @Override - public void clear() { - MDC.clear(); - } - - @Override - public boolean isMDCParamEmpty(String mdcKeyName) { - return StringUtils.isEmpty(MDC.get(mdcKeyName)); - } - - @Override - public String getFqdn() { - return fqdn; - } - - @Override - public String getHostAddress() { - return hostAddress; - } - - @Override - public String getKeyRequestId() { - return MDC.get(ONAPLogConstants.MDCs.REQUEST_ID); - } - - @Override - public String getTargetEntity() { - return MDC.get(ONAPLogConstants.MDCs.TARGET_ENTITY); - } - - @Override - public String getTargetServiceName() { - return MDC.get(ONAPLogConstants.MDCs.TARGET_SERVICE_NAME); - } - - @Override - public void removeStatusCode() { - MDC.remove(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE); - } - - @Override - public void removePartnerName() { - MDC.remove(ONAPLogConstants.MDCs.PARTNER_NAME); - } - - @Override - public void removeResponseCode() { - MDC.remove(ONAPLogConstants.MDCs.RESPONSE_CODE); - } - - @Override - public void removeResponseDesc() { - MDC.remove(ONAPLogConstants.MDCs.RESPONSE_DESCRIPTION); - } - - @Override - public void removeServiceInstanceId() { - MDC.remove(ILogConfiguration.MDC_SERVICE_INSTANCE_ID); - } - - @Override - public void removeTargetEntity() { - MDC.remove(ONAPLogConstants.MDCs.TARGET_ENTITY); - } - - @Override - public void removeTargetServiceName() { - MDC.remove(ONAPLogConstants.MDCs.TARGET_SERVICE_NAME); - } - - @Override - public void removeTargetVirtualEntity() { - MDC.remove(ILogConfiguration.MDC_TARGET_VIRTUAL_ENTITY); - } - - @Override - public void removeErrorCode() { - MDC.remove(ILogConfiguration.MDC_ERROR_CODE); - } - - @Override - public void removeErrorCategory() { - MDC.remove(ILogConfiguration.MDC_ERROR_CATEGORY); - } - - @Override - public void removeErrorDescription() { - MDC.remove(ILogConfiguration.MDC_ERROR_DESC); - } - - @Override - public void setAuditMessage(String message) { - MDC.put(ILogConfiguration.MDC_AUDIT_MESSAGE, message); - } - - @Override - public String getAuditMessage() { - return MDC.get(ILogConfiguration.MDC_AUDIT_MESSAGE); - } - - - @Override - public String getSupportablityStatusCode() { - return MDC.get(ILogConfiguration.MDC_SUPPORTABLITY_STATUS_CODE); - } - - @Override - public String getSupportablityAction() { - return MDC.get(ILogConfiguration.MDC_SUPPORTABLITY_ACTION); - - } - - - @Override - public String getRemoteHost() { - return MDC.get(ILogConfiguration.MDC_REMOTE_HOST); - } - - @Override - public String getServerIpAddress() { - return MDC.get(ILogConfiguration.MDC_SERVER_IP_ADDRESS); - } + private final static String dateFormatPattern = "yyyy-MM-dd'T'HH:mm:ss.SSSz"; + protected static Logger log = LoggerFactory.getLogger(LogFieldsMdcHandler.class.getName()); + protected static String hostAddress; + protected static String fqdn; + private static LogFieldsMdcHandler instanceMdcWrapper = new LogFieldsMdcHandler(); + + static { + try { + hostAddress = InetAddress.getLocalHost().getHostAddress(); + fqdn = InetAddress.getByName(hostAddress).getCanonicalHostName(); + } catch (Exception ex) { + log.error("failed to get machine parameters", ex); + } + } + + private final DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern(dateFormatPattern); + + public static LogFieldsMdcHandler getInstance() { + return instanceMdcWrapper; + } + + @Override + public void startAuditTimer() { + if (StringUtils.isEmpty(MDC.get(ONAPLogConstants.MDCs.ENTRY_TIMESTAMP))) { + MDC.put(ONAPLogConstants.MDCs.ENTRY_TIMESTAMP, generatedTimeNow()); + } + } + + @Override + public void startMetricTimer() { + if (StringUtils.isEmpty(MDC.get(ONAPLogConstants.MDCs.INVOKE_TIMESTAMP))) { + MDC.put(ONAPLogConstants.MDCs.INVOKE_TIMESTAMP, generatedTimeNow()); + } + } + + @Override + public void stopAuditTimer() { + //set start time if it is not set yet + startAuditTimer(); + MDC.put(ILogConfiguration.MDC_END_TIMESTAMP, generatedTimeNow()); + setElapsedTime(MDC.get(ONAPLogConstants.MDCs.ENTRY_TIMESTAMP)); + } + + @Override + public void stopMetricTimer() { + //set start time if it is not set yet + startMetricTimer(); + MDC.put(ILogConfiguration.MDC_END_TIMESTAMP, generatedTimeNow()); + setElapsedTime(MDC.get(ONAPLogConstants.MDCs.INVOKE_TIMESTAMP)); + } + + @Override + public void setClassName(String className) { + MDC.put(ILogConfiguration.MDC_CLASS_NAME, className); + } + + @Override + public void setServerFQDN(String serverFQDN) { + MDC.put(ONAPLogConstants.MDCs.SERVER_FQDN, serverFQDN); + } + + @Override + public void setServerIPAddress(String serverIPAddress) { + MDC.put(ILogConfiguration.MDC_SERVER_IP_ADDRESS, serverIPAddress); + } + + @Override + public void setServerFQDNInternally() { + setServerFQDN(fqdn); + } + + @Override + public void setServerIPAddressInternally() { + setServerIPAddress(hostAddress); + } + + @Override + public void setInstanceUUID(String instanceUUID) { + MDC.put(ONAPLogConstants.MDCs.INSTANCE_UUID, instanceUUID); + } + + @Override + public void setProcessKey(String processKey) { + MDC.put(ILogConfiguration.MDC_PROCESS_KEY, processKey); + } + + @Override + public void setAlertSeverity(Severity alertSeverity) { + MDC.put(ONAPLogConstants.MDCs.RESPONSE_SEVERITY, String.valueOf(alertSeverity.getSeverityType())); + } + + @Override + public void setOptCustomField1(String customField1) { + MDC.put(ILogConfiguration.MDC_OPT_FIELD1, customField1); + } + + @Override + public void setOutgoingInvocationId(String outgoingInvocationId) { + MDC.put(ILogConfiguration.MDC_OUTGOING_INVOCATION_ID, outgoingInvocationId); + } + + @Override + public void setStatusCode(String statusCode) { + MDC.put(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE, statusCode); + } + + @Override + public void setResponseCode(int responseCode) { + MDC.put(ONAPLogConstants.MDCs.RESPONSE_CODE, Integer.toString(responseCode)); + } + + @Override + public void setResponseDesc(String responseDesc) { + MDC.put(ONAPLogConstants.MDCs.RESPONSE_DESCRIPTION, responseDesc); + } + + @Override + public void setServiceInstanceId(String serviceInstanceId) { + MDC.put(ILogConfiguration.MDC_SERVICE_INSTANCE_ID, serviceInstanceId); + } + + @Override + public void setTargetVirtualEntity(String targetVirtualEntity) { + MDC.put(ILogConfiguration.MDC_TARGET_VIRTUAL_ENTITY, targetVirtualEntity); + } + + @Override + public String getErrorCode() { + return MDC.get(ILogConfiguration.MDC_ERROR_CODE); + } + + @Override + public void setErrorCode(int errorCode) { + MDC.put(ILogConfiguration.MDC_ERROR_CODE, valueOf(errorCode).toString()); + } + + @Override + public String getServiceName() { + return MDC.get(ONAPLogConstants.MDCs.SERVICE_NAME); + } + + @Override + public void setServiceName(String serviceName) { + MDC.put(ONAPLogConstants.MDCs.SERVICE_NAME, serviceName); + } + + @Override + public String getErrorCategory() { + return MDC.get(ILogConfiguration.MDC_ERROR_CATEGORY); + } + + @Override + public void setErrorCategory(String errorCategory) { + MDC.put(ILogConfiguration.MDC_ERROR_CATEGORY, errorCategory); + } + + @Override + public void clear() { + MDC.clear(); + } + + @Override + public boolean isMDCParamEmpty(String mdcKeyName) { + return StringUtils.isEmpty(MDC.get(mdcKeyName)); + } + + @Override + public String getFqdn() { + return fqdn; + } + + @Override + public String getHostAddress() { + return hostAddress; + } + + @Override + public String getKeyRequestId() { + return MDC.get(ONAPLogConstants.MDCs.REQUEST_ID); + } + + @Override + public void setKeyRequestId(String keyRequestId) { + MDC.put(ONAPLogConstants.MDCs.REQUEST_ID, + keyRequestId); // eg. servletRequest.getSession().getId() + } + + @Override + public String getTargetEntity() { + return MDC.get(ONAPLogConstants.MDCs.TARGET_ENTITY); + } + + @Override + public void setTargetEntity(String targetEntity) { + MDC.put(ONAPLogConstants.MDCs.TARGET_ENTITY, targetEntity); + } + + @Override + public String getTargetServiceName() { + return MDC.get(ONAPLogConstants.MDCs.TARGET_SERVICE_NAME); + } + + @Override + public void setTargetServiceName(String targetServiceName) { + MDC.put(ONAPLogConstants.MDCs.TARGET_SERVICE_NAME, targetServiceName); + } + + @Override + public void removeStatusCode() { + MDC.remove(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE); + } + + @Override + public void removePartnerName() { + MDC.remove(ONAPLogConstants.MDCs.PARTNER_NAME); + } + + @Override + public void removeResponseCode() { + MDC.remove(ONAPLogConstants.MDCs.RESPONSE_CODE); + } + + @Override + public void removeResponseDesc() { + MDC.remove(ONAPLogConstants.MDCs.RESPONSE_DESCRIPTION); + } + + @Override + public void removeServiceInstanceId() { + MDC.remove(ILogConfiguration.MDC_SERVICE_INSTANCE_ID); + } + + @Override + public void removeTargetEntity() { + MDC.remove(ONAPLogConstants.MDCs.TARGET_ENTITY); + } + + @Override + public void removeTargetServiceName() { + MDC.remove(ONAPLogConstants.MDCs.TARGET_SERVICE_NAME); + } + + @Override + public void removeTargetVirtualEntity() { + MDC.remove(ILogConfiguration.MDC_TARGET_VIRTUAL_ENTITY); + } + + @Override + public void removeErrorCode() { + MDC.remove(ILogConfiguration.MDC_ERROR_CODE); + } + + @Override + public void removeErrorCategory() { + MDC.remove(ILogConfiguration.MDC_ERROR_CATEGORY); + } + + @Override + public void removeErrorDescription() { + MDC.remove(ILogConfiguration.MDC_ERROR_DESC); + } + + @Override + public String getAuditMessage() { + return MDC.get(ILogConfiguration.MDC_AUDIT_MESSAGE); + } + + @Override + public void setAuditMessage(String message) { + MDC.put(ILogConfiguration.MDC_AUDIT_MESSAGE, message); + } + + @Override + public String getSupportablityStatusCode() { + return MDC.get(ILogConfiguration.MDC_SUPPORTABLITY_STATUS_CODE); + } + + @Override + public void setSupportablityStatusCode(String statusCode) { + MDC.put(ILogConfiguration.MDC_SUPPORTABLITY_STATUS_CODE, statusCode); + } + + @Override + public String getSupportablityAction() { + return MDC.get(ILogConfiguration.MDC_SUPPORTABLITY_ACTION); + } + + @Override + public void setSupportablityAction(String action) { + MDC.put(ILogConfiguration.MDC_SUPPORTABLITY_ACTION, action); + } + + @Override + public String getRemoteHost() { + return MDC.get(ILogConfiguration.MDC_REMOTE_HOST); + } + + @Override + public void setRemoteHost(String remoteHost) { + MDC.put(ILogConfiguration.MDC_REMOTE_HOST, remoteHost); + } + @Override + public String getServerIpAddress() { + return MDC.get(ILogConfiguration.MDC_SERVER_IP_ADDRESS); + } // @Override + // public String getSupportablityCsarName() { + // return MDC.get(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_NAME); -// } - - @Override - public String getSupportablityCsarUUID() { - return MDC.get(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_UUID); - } - - @Override - public String getSupportablityCsarVersion() { - return MDC.get(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_VERSION); - - } - - @Override - public String getSupportablityComponentName() { - return MDC.get(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_NAME); - } - - @Override - public String getSupportablityComponentUUID() { - return MDC.get(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_UUID); - - } - - @Override - public String getSupportablityComponentVersion() { - return MDC.get(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_VERSION); - } - - @Override - public String getKeyInvocationId() { - return MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID); - } - - @Override - public void setSupportablityStatusCode(String statusCode) { - MDC.put(ILogConfiguration.MDC_SUPPORTABLITY_STATUS_CODE, statusCode); - } - - @Override - public void setSupportablityAction(String action) { - MDC.put(ILogConfiguration.MDC_SUPPORTABLITY_ACTION, action); - } - - @Override - public void setSupportablityCsarUUID(String uuid) { - MDC.put(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_UUID, uuid); - } - - @Override - public void setSupportablityCsarVersion(String version) { - MDC.put(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_VERSION, version); - } - - @Override - public void setSupportablityComponentName(String name) { - MDC.put(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_NAME, name); - } - - @Override - public void setSupportablityComponentUUID(String uuid) { - MDC.put(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_UUID, uuid); - } - - @Override - public void setSupportablityComponentVersion(String version) { - MDC.put(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_VERSION, version); - } - - @Override - public void removeSupportablityAction() { - MDC.remove(ILogConfiguration.MDC_SUPPORTABLITY_ACTION); - } - - @Override - public void removeSupportablityComponentName() { - MDC.remove(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_NAME); - } - - @Override - public void removeSupportablityComponentUUID() { - MDC.remove(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_UUID); - } - - @Override - public void removeSupportablityComponentVersion() { - MDC.remove(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_VERSION); - } -// @Override -// public void removeSupportablityCsarName() { -// MDC.remove(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_NAME); -// } + // } + @Override + public String getSupportablityCsarUUID() { + return MDC.get(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_UUID); + } + + @Override + public void setSupportablityCsarUUID(String uuid) { + MDC.put(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_UUID, uuid); + } + + @Override + public String getSupportablityCsarVersion() { + return MDC.get(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_VERSION); + } + + @Override + public void setSupportablityCsarVersion(String version) { + MDC.put(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_VERSION, version); + } + + @Override + public String getSupportablityComponentName() { + return MDC.get(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_NAME); + } + + @Override + public void setSupportablityComponentName(String name) { + MDC.put(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_NAME, name); + } + + @Override + public String getSupportablityComponentUUID() { + return MDC.get(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_UUID); + } + + @Override + public void setSupportablityComponentUUID(String uuid) { + MDC.put(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_UUID, uuid); + } + + @Override + public String getSupportablityComponentVersion() { + return MDC.get(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_VERSION); + } - @Override - public void removeSupportablityCsarUUID() { - MDC.remove(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_UUID); - } + @Override + public void setSupportablityComponentVersion(String version) { + MDC.put(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_VERSION, version); + } - @Override - public void removeSupportablityCsarVersion() { - MDC.remove(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_VERSION); - } + @Override + public String getKeyInvocationId() { + return MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID); + } - @Override - public void removeSupportablityStatusCode() { - MDC.remove(ILogConfiguration.MDC_SUPPORTABLITY_STATUS_CODE); - } + @Override + public void setKeyInvocationId(String invocationId) { + MDC.put(ONAPLogConstants.MDCs.INVOCATION_ID, invocationId); + } - @Override - public String getPartnerName() { - return MDC.get(ONAPLogConstants.MDCs.PARTNER_NAME); - } + @Override + public void removeSupportablityAction() { + MDC.remove(ILogConfiguration.MDC_SUPPORTABLITY_ACTION); + } - private void setElapsedTime(String beginTimestamp) { - try { - final LocalDateTime startTime = LocalDateTime.parse(beginTimestamp, dateTimeFormatter); - final LocalDateTime endTime = LocalDateTime - .parse(MDC.get(ILogConfiguration.MDC_END_TIMESTAMP), dateTimeFormatter); - final Duration timeDifference = Duration.between(startTime, endTime); + @Override + public void removeSupportablityComponentName() { + MDC.remove(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_NAME); + } - MDC.put(ILogConfiguration.MDC_ELAPSED_TIME, String.valueOf(timeDifference.toMillis())); + @Override + public void removeSupportablityComponentUUID() { + MDC.remove(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_UUID); + } + + @Override + public void removeSupportablityComponentVersion() { + MDC.remove(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_VERSION); + } - } catch (Exception ex) { - log.error("failed to calculate elapsed time", ex); + // } + @Override + public void removeSupportablityCsarUUID() { + MDC.remove(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_UUID); } - } +// @Override + +// public void removeSupportablityCsarName() { - private String generatedTimeNow() { - return dateTimeFormatter - .withZone(ZoneOffset.UTC) - .format(Instant.now()); - } +// MDC.remove(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_NAME); - public void collectRequestInfoForErrorAndDebugLogging(HttpServletRequest httpRequest) { - LogFieldsMdcHandler.getInstance().clear(); - String partnerName = LoggerBase.getPartnerName(httpRequest); - LogFieldsMdcHandler.getInstance().setPartnerName(partnerName); + @Override + public void removeSupportablityCsarVersion() { + MDC.remove(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_VERSION); + } - String serviceInstanceID = httpRequest.getHeader(ConstantsLogging.X_ECOMP_SERVICE_ID_HEADER); - LogFieldsMdcHandler.getInstance().setServiceInstanceId(serviceInstanceID); + @Override + public void removeSupportablityStatusCode() { + MDC.remove(ILogConfiguration.MDC_SUPPORTABLITY_STATUS_CODE); + } - LogFieldsMdcHandler.getInstance().setRemoteHost(httpRequest.getRemoteHost()); - LogFieldsMdcHandler.getInstance().setServerIPAddress(httpRequest.getLocalAddr()); + @Override + public String getPartnerName() { + return MDC.get(ONAPLogConstants.MDCs.PARTNER_NAME); + } - String requestId = LoggerBase.getRequestId(httpRequest); - LogFieldsMdcHandler.getInstance().setKeyRequestId(requestId); + @Override + public void setPartnerName(String partnerName) { + MDC.put(ONAPLogConstants.MDCs.PARTNER_NAME, partnerName); + } - LogFieldsMdcHandler.getInstance().setServiceName(httpRequest.getRequestURI()); - } + private void setElapsedTime(String beginTimestamp) { + try { + final LocalDateTime startTime = LocalDateTime.parse(beginTimestamp, dateTimeFormatter); + final LocalDateTime endTime = LocalDateTime.parse(MDC.get(ILogConfiguration.MDC_END_TIMESTAMP), dateTimeFormatter); + final Duration timeDifference = Duration.between(startTime, endTime); + MDC.put(ILogConfiguration.MDC_ELAPSED_TIME, String.valueOf(timeDifference.toMillis())); + } catch (Exception ex) { + log.error("failed to calculate elapsed time", ex); + } + } - public void addInfoForErrorAndDebugLogging(String partnerName){ - LogFieldsMdcHandler.getInstance().clear(); - LogFieldsMdcHandler.getInstance().setPartnerName(partnerName); + private String generatedTimeNow() { + return dateTimeFormatter.withZone(ZoneOffset.UTC).format(Instant.now()); + } - String requestId = LoggerBase.generateKeyRequestId(); - LogFieldsMdcHandler.getInstance().setKeyRequestId(requestId); - } + public void collectRequestInfoForErrorAndDebugLogging(HttpServletRequest httpRequest) { + LogFieldsMdcHandler.getInstance().clear(); + String partnerName = LoggerBase.getPartnerName(httpRequest); + LogFieldsMdcHandler.getInstance().setPartnerName(partnerName); + String serviceInstanceID = httpRequest.getHeader(ConstantsLogging.X_ECOMP_SERVICE_ID_HEADER); + LogFieldsMdcHandler.getInstance().setServiceInstanceId(serviceInstanceID); + LogFieldsMdcHandler.getInstance().setRemoteHost(httpRequest.getRemoteHost()); + LogFieldsMdcHandler.getInstance().setServerIPAddress(httpRequest.getLocalAddr()); + String requestId = LoggerBase.getRequestId(httpRequest); + LogFieldsMdcHandler.getInstance().setKeyRequestId(requestId); + LogFieldsMdcHandler.getInstance().setServiceName(httpRequest.getRequestURI()); + } + + public void addInfoForErrorAndDebugLogging(String partnerName) { + LogFieldsMdcHandler.getInstance().clear(); + LogFieldsMdcHandler.getInstance().setPartnerName(partnerName); + String requestId = LoggerBase.generateKeyRequestId(); + LogFieldsMdcHandler.getInstance().setKeyRequestId(requestId); + } } diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerAudit.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerAudit.java index 771ecfd9d4..97a0120773 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerAudit.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerAudit.java @@ -1,6 +1,9 @@ package org.openecomp.sdc.common.log.elements; - +import java.util.ArrayList; +import java.util.Arrays; +import java.util.Collections; +import java.util.List; import org.onap.logging.ref.slf4j.ONAPLogConstants; import org.openecomp.sdc.common.log.api.ILogConfiguration; import org.openecomp.sdc.common.log.api.ILogFieldsHandler; @@ -10,40 +13,36 @@ import org.slf4j.Logger; import org.slf4j.MDC; import org.slf4j.MarkerFactory; -import java.util.ArrayList; -import java.util.Arrays; -import java.util.Collections; -import java.util.List; - public class LoggerAudit extends LoggerBase { + private static ArrayList<String> mandatoryFields = new ArrayList<>(Arrays.asList( - ONAPLogConstants.MDCs.ENTRY_TIMESTAMP, - ILogConfiguration.MDC_END_TIMESTAMP, - ONAPLogConstants.MDCs.REQUEST_ID, - ONAPLogConstants.MDCs.SERVICE_NAME, - ONAPLogConstants.MDCs.PARTNER_NAME, - ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE, - ONAPLogConstants.MDCs.RESPONSE_CODE, - ILogConfiguration.MDC_SERVICE_INSTANCE_ID, - ONAPLogConstants.MDCs.RESPONSE_DESCRIPTION, - ILogConfiguration.MDC_ELAPSED_TIME, - ILogConfiguration.MDC_SERVER_IP_ADDRESS, - ONAPLogConstants.MDCs.SERVER_FQDN)); + ONAPLogConstants.MDCs.ENTRY_TIMESTAMP, + ILogConfiguration.MDC_END_TIMESTAMP, + ONAPLogConstants.MDCs.REQUEST_ID, + ONAPLogConstants.MDCs.SERVICE_NAME, + ONAPLogConstants.MDCs.PARTNER_NAME, + ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE, + ONAPLogConstants.MDCs.RESPONSE_CODE, + ILogConfiguration.MDC_SERVICE_INSTANCE_ID, + ONAPLogConstants.MDCs.RESPONSE_DESCRIPTION, + ILogConfiguration.MDC_ELAPSED_TIME, + ILogConfiguration.MDC_SERVER_IP_ADDRESS, + ONAPLogConstants.MDCs.SERVER_FQDN)); private static ArrayList<String> optionalFields = new ArrayList<>(Arrays.asList( - ONAPLogConstants.MDCs.INSTANCE_UUID, - ONAPLogConstants.MDCs.RESPONSE_SEVERITY, - ILogConfiguration.MDC_REMOTE_HOST, - ILogConfiguration.MDC_CLASS_NAME, - ILogConfiguration.MDC_PROCESS_KEY, - ILogConfiguration.MDC_OPT_FIELD1, - ILogConfiguration.MDC_OPT_FIELD2, - ILogConfiguration.MDC_OPT_FIELD3, - ILogConfiguration.MDC_OPT_FIELD4)); + ONAPLogConstants.MDCs.INSTANCE_UUID, + ONAPLogConstants.MDCs.RESPONSE_SEVERITY, + ILogConfiguration.MDC_REMOTE_HOST, + ILogConfiguration.MDC_CLASS_NAME, + ILogConfiguration.MDC_PROCESS_KEY, + ILogConfiguration.MDC_OPT_FIELD1, + ILogConfiguration.MDC_OPT_FIELD2, + ILogConfiguration.MDC_OPT_FIELD3, + ILogConfiguration.MDC_OPT_FIELD4)); LoggerAudit(ILogFieldsHandler ecompMdcWrapper, Logger logger) { //TODO Andrey, set default marker - super (ecompMdcWrapper, MarkerFactory.getMarker(ONAPLogConstants.Markers.ENTRY.getName()), logger); + super(ecompMdcWrapper, MarkerFactory.getMarker(ONAPLogConstants.Markers.ENTRY.getName()), logger); //put the remote host and FQDN values from another thread if they are set ecompMdcWrapper.setServerIPAddressInternally(); ecompMdcWrapper.setServerFQDNInternally(); @@ -102,7 +101,8 @@ public class LoggerAudit extends LoggerBase { } public LoggerAudit setStatusCodeByResponseCode(String responseCode) { - String respStatus = Integer.parseInt(responseCode) / 100 == 2 ? ONAPLogConstants.ResponseStatus.COMPLETE.name() : ONAPLogConstants.ResponseStatus.ERROR.name(); + String respStatus = Integer.parseInt(responseCode) / 100 == 2 ? ONAPLogConstants.ResponseStatus.COMPLETE.name() + : ONAPLogConstants.ResponseStatus.ERROR.name(); ecompLogFieldsHandler.setStatusCode(respStatus); return this; } @@ -112,7 +112,6 @@ public class LoggerAudit extends LoggerBase { return this; } - public LoggerAudit setPartnerName(String partnerName) { ecompLogFieldsHandler.setPartnerName(partnerName); return this; @@ -137,7 +136,6 @@ public class LoggerAudit extends LoggerBase { return ecompLogFieldsHandler.getAuditMessage(); } - @Override public List<String> getMandatoryFields() { return Collections.unmodifiableList(mandatoryFields); @@ -150,5 +148,4 @@ public class LoggerAudit extends LoggerBase { ecompLogFieldsHandler.setServerIPAddressInternally(); return this; } - } diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerBase.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerBase.java index 5295c4ab58..a409995244 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerBase.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerBase.java @@ -38,10 +38,9 @@ import org.slf4j.Logger; import org.slf4j.Marker; import org.slf4j.MarkerFactory; - /** - * Created by mm288v on 12/27/2017. This class holds the common behavior of all Loger-Typed classes. The Concrete - * loggers shoudl derive from this one. + * Created by mm288v on 12/27/2017. This class holds the common behavior of all Loger-Typed classes. The Concrete loggers shoudl derive from this + * one. */ public abstract class LoggerBase implements ILogger { @@ -66,16 +65,16 @@ public abstract class LoggerBase implements ILogger { String requestId = httpRequest.getHeader(ConstantsLogging.X_REQUEST_ID); String transactionReId = httpRequest.getHeader(ConstantsLogging.X_TRANSACTION_ID_HEADER); String ecompRequestId = httpRequest.getHeader(ConstantsLogging.X_ECOMP_REQUEST_ID_HEADER); - return Arrays.asList(onapRequestId, requestId, transactionReId, ecompRequestId).stream() - .filter(id -> !StringUtils.isEmpty(id)).findFirst().orElse(generateKeyRequestId()); + return Arrays.asList(onapRequestId, requestId, transactionReId, ecompRequestId).stream().filter(id -> !StringUtils.isEmpty(id)).findFirst() + .orElse(generateKeyRequestId()); } public static String getPartnerName(HttpServletRequest httpRequest) { String userId = httpRequest.getHeader(ConstantsLogging.USER_ID_HEADER); String onapPartnerName = httpRequest.getHeader(ONAPLogConstants.Headers.PARTNER_NAME); String reqUri = httpRequest.getHeader(ConstantsLogging.USER_AGENT_HEADER); - return Arrays.asList(userId, onapPartnerName, reqUri).stream() - .filter(pn -> !StringUtils.isEmpty(pn)).findFirst().orElse(ConstantsLogging.PartnerName_Unknown); + return Arrays.asList(userId, onapPartnerName, reqUri).stream().filter(pn -> !StringUtils.isEmpty(pn)).findFirst() + .orElse(ConstantsLogging.PartnerName_Unknown); } protected void setKeyRequestIdIfNotSetYet() { @@ -87,7 +86,6 @@ public abstract class LoggerBase implements ILogger { private void validateMandatoryFields(String originMsg) { // this method only checks if the mandatory fields have been initialized String filedNameThatHasNotBeenInitialized = checkMandatoryFieldsExistInMDC(); - if (myLogger.isDebugEnabled() && !"".equalsIgnoreCase(filedNameThatHasNotBeenInitialized)) { myLogger.debug(MarkerFactory.getMarker(LogMarkers.DEBUG_MARKER.getText()), String.format(missingLogFieldsMsg, filedNameThatHasNotBeenInitialized, originMsg)); @@ -127,7 +125,6 @@ public abstract class LoggerBase implements ILogger { @Override public void log(LogLevel logLevel, String message, Object... params) { validateMandatoryFields(message); - switch (logLevel) { case ERROR: case FATAL: //TODO check how to log "FATAL" word @@ -153,7 +150,6 @@ public abstract class LoggerBase implements ILogger { @Override public void log(LogLevel logLevel, String message, Throwable throwable) { validateMandatoryFields(message); - switch (logLevel) { case ERROR: case FATAL: //TODO check how to log "FATAL" word @@ -179,7 +175,6 @@ public abstract class LoggerBase implements ILogger { @Override public void log(Marker marker, LogLevel logLevel, String message, Object... params) { validateMandatoryFields(message); - switch (logLevel) { case ERROR: case FATAL: //TODO check how to log "FATAL" word @@ -206,7 +201,6 @@ public abstract class LoggerBase implements ILogger { return String.format("%s: %s", message, throwable.getLocalizedMessage()); } - @Override public ILogger clear() { ecompLogFieldsHandler.clear(); @@ -219,12 +213,9 @@ public abstract class LoggerBase implements ILogger { return this; } - @Override public ILogger setKeyInvocationId(String keyInvocationId) { ecompLogFieldsHandler.setKeyInvocationId(keyInvocationId); return this; } - - } diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerError.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerError.java index 347a60f9ea..7db91244c6 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerError.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerError.java @@ -72,61 +72,42 @@ public class LoggerError extends LoggerBase { return this; } - public void log(LogLevel logLevel, - EcompLoggerErrorCode errorCodeEnum, - String serviceName, - String targetEntity, - String message, Object... params) { + public void log(LogLevel logLevel, EcompLoggerErrorCode errorCodeEnum, String serviceName, String targetEntity, String message, + Object... params) { fillFieldsBeforeLogging(logLevel, errorCodeEnum, serviceName, targetEntity, null); super.log(logLevel, message, params); } - public void log(LogLevel logLevel, - EcompLoggerErrorCode errorCodeEnum, - String serviceName, - ErrorLogOptionalData errorLogOptionalData, - String description, - Object... params) { - fillFieldsBeforeLogging(logLevel, errorCodeEnum, serviceName, - errorLogOptionalData.getTargetEntity(), errorLogOptionalData.getTargetServiceName()); + public void log(LogLevel logLevel, EcompLoggerErrorCode errorCodeEnum, String serviceName, ErrorLogOptionalData errorLogOptionalData, + String description, Object... params) { + fillFieldsBeforeLogging(logLevel, errorCodeEnum, serviceName, errorLogOptionalData.getTargetEntity(), + errorLogOptionalData.getTargetServiceName()); super.log(logLevel, description, params); } - private void fillFieldsBeforeLogging(LogLevel logLevel, EcompLoggerErrorCode errorCodeEnum, String serviceName, - String targetEntity, String targetServiceName) { + private void fillFieldsBeforeLogging(LogLevel logLevel, EcompLoggerErrorCode errorCodeEnum, String serviceName, String targetEntity, + String targetServiceName) { clear(); ecompLogFieldsHandler.setErrorCode(errorCodeEnum.getErrorCode()); ecompLogFieldsHandler.setErrorCategory(logLevel.name()); - ecompLogFieldsHandler.setTargetEntity(targetEntity); ecompLogFieldsHandler.setTargetServiceName(targetServiceName); - if (StringUtils.isEmpty(ecompLogFieldsHandler.getServiceName())) { ecompLogFieldsHandler.setServiceName(serviceName); } - setKeyRequestIdIfNotSetYet(); } - public void log(EcompErrorSeverity errorSeverity, - EcompLoggerErrorCode errorCodeEnum, - String serviceName, - String targetEntity, - String message, Object... params) { + public void log(EcompErrorSeverity errorSeverity, EcompLoggerErrorCode errorCodeEnum, String serviceName, String targetEntity, String message, + Object... params) { log(convertFromSeverityErrorLevel(errorSeverity), errorCodeEnum, serviceName, targetEntity, message, params); } - public void log(LogLevel logLevel, - EcompLoggerErrorCode errorCodeEnum, - String serviceName, - String message, Object... params) { + public void log(LogLevel logLevel, EcompLoggerErrorCode errorCodeEnum, String serviceName, String message, Object... params) { log(logLevel, errorCodeEnum, serviceName, (String) null, message, params); } - public void log(LogLevel logLevel, - EcompLoggerErrorCode errorCodeEnum, - String serviceName, - String message) { + public void log(LogLevel logLevel, EcompLoggerErrorCode errorCodeEnum, String serviceName, String message) { log(logLevel, errorCodeEnum, serviceName, message); } @@ -160,5 +141,4 @@ public class LoggerError extends LoggerBase { } return LogLevel.ERROR; } - } diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerFactory.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerFactory.java index fb97ebddee..519bea0f6d 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerFactory.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerFactory.java @@ -3,9 +3,7 @@ package org.openecomp.sdc.common.log.elements; import org.slf4j.Logger; /** - * Created by dd4296 on 12/26/2017. - * this factory helps decouple the classes for Stopwatch and LogFieldsMdcHandler from - * the EcompLogger classes + * Created by dd4296 on 12/26/2017. this factory helps decouple the classes for Stopwatch and LogFieldsMdcHandler from the EcompLogger classes */ public class LoggerFactory { @@ -14,49 +12,38 @@ public class LoggerFactory { @SuppressWarnings("unchecked") public static <T, V> V getLogger(Class<T> type, Logger logger) { - if (type.isAssignableFrom(LoggerAudit.class)) { return (V) new LoggerAudit(new LogFieldsMdcHandler(), logger); } - if (type.isAssignableFrom(LoggerDebug.class)) { return (V) new LoggerDebug(new LogFieldsMdcHandler(), logger); } - if (type.isAssignableFrom(LoggerMetric.class)) { return (V) new LoggerMetric(new LogFieldsMdcHandler(), logger); } - if (type.isAssignableFrom(LoggerError.class)) { return (V) new LoggerError(new LogFieldsMdcHandler(), logger); } - return null; } @SuppressWarnings("unchecked") public static <T, V> V getMdcLogger(Class<T> type, Logger logger) { - if (type.isAssignableFrom(LoggerAudit.class)) { return (V) new LoggerAudit(LogFieldsMdcHandler.getInstance(), logger); } - if (type.isAssignableFrom(LoggerDebug.class)) { return (V) new LoggerDebug(LogFieldsMdcHandler.getInstance(), logger); } - if (type.isAssignableFrom(LoggerMetric.class)) { return (V) new LoggerMetric(LogFieldsMdcHandler.getInstance(), logger); } - if (type.isAssignableFrom(LoggerError.class)) { return (V) new LoggerError(LogFieldsMdcHandler.getInstance(), logger); } - if (type.isAssignableFrom(LoggerSupportability.class)) { return (V) new LoggerSupportability(LogFieldsMdcHandler.getInstance(), logger); } - return null; } } diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerMetric.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerMetric.java index c23861f1ff..4e98431a4b 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerMetric.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerMetric.java @@ -56,7 +56,6 @@ import org.openecomp.sdc.common.log.enums.Severity; import org.slf4j.Logger; import org.slf4j.MarkerFactory; - public class LoggerMetric extends LoggerBase { private static ArrayList<String> mandatoryFields = new ArrayList<>(Arrays.asList( @@ -96,11 +95,7 @@ public class LoggerMetric extends LoggerBase { ecompMdcWrapper.setServerFQDNInternally(); } - public void log(Response.StatusType statusInfo, - String className, - LogLevel logLevel, - Severity securityLevel, - String message) { + public void log(Response.StatusType statusInfo, String className, LogLevel logLevel, Severity securityLevel, String message) { log(statusInfo, className, logLevel, securityLevel, message); } @@ -142,13 +137,11 @@ public class LoggerMetric extends LoggerBase { return this; } - public LoggerMetric setInstanceUUID(String instanceUUID) { ecompLogFieldsHandler.setInstanceUUID(instanceUUID); return this; } - public LoggerMetric setOutgoingInvocationId(String out_invocationId) { ecompLogFieldsHandler.setOutgoingInvocationId(out_invocationId); return this; @@ -208,6 +201,4 @@ public class LoggerMetric extends LoggerBase { ecompLogFieldsHandler.setTargetVirtualEntity(targetVirtualEntity); return this; } - - } diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerSupportability.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerSupportability.java index cb22394463..d5bf374b47 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerSupportability.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/elements/LoggerSupportability.java @@ -47,8 +47,7 @@ public class LoggerSupportability extends LoggerBase { ILogConfiguration.MDC_SUPPORTABLITY_STATUS_CODE)); public LoggerSupportability(ILogFieldsHandler ecompLogFieldsHandler, Logger logger) { - super(ecompLogFieldsHandler, MarkerFactory.getMarker(LogMarkers.SUPPORTABILITY_MARKER.getText()), - logger); + super(ecompLogFieldsHandler, MarkerFactory.getMarker(LogMarkers.SUPPORTABILITY_MARKER.getText()), logger); } public static LoggerSupportability getLogger(Class<?> clazz) { @@ -56,12 +55,11 @@ public class LoggerSupportability extends LoggerBase { } public static LoggerSupportability getLogger(String className) { - return LoggerFactory.getMdcLogger(LoggerSupportability.class, - org.slf4j.LoggerFactory.getLogger(className)); + return LoggerFactory.getMdcLogger(LoggerSupportability.class, org.slf4j.LoggerFactory.getLogger(className)); } - public void log(LoggerSupportabilityActions action, Map<String, String> componentMetaData, StatusCode statusCode, - String message, Object... params) { + public void log(LoggerSupportabilityActions action, Map<String, String> componentMetaData, StatusCode statusCode, String message, + Object... params) { fillFieldsBeforeLogging(action, componentMetaData, statusCode); super.log(LogLevel.INFO, message, params); } @@ -70,20 +68,14 @@ public class LoggerSupportability extends LoggerBase { log(action, null, statusCode, message, params); } - private void fillFieldsBeforeLogging(LoggerSupportabilityActions action, Map<String, String> componentMetaData, - StatusCode statusCode) { + private void fillFieldsBeforeLogging(LoggerSupportabilityActions action, Map<String, String> componentMetaData, StatusCode statusCode) { clear(); if (componentMetaData != null) { - ecompLogFieldsHandler - .setSupportablityCsarUUID(componentMetaData.get(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_UUID)); - ecompLogFieldsHandler - .setSupportablityCsarVersion(componentMetaData.get(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_VERSION)); - ecompLogFieldsHandler.setSupportablityComponentName( - componentMetaData.get(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_NAME)); - ecompLogFieldsHandler.setSupportablityComponentUUID( - componentMetaData.get(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_UUID)); - ecompLogFieldsHandler.setSupportablityComponentVersion( - componentMetaData.get(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_VERSION)); + ecompLogFieldsHandler.setSupportablityCsarUUID(componentMetaData.get(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_UUID)); + ecompLogFieldsHandler.setSupportablityCsarVersion(componentMetaData.get(ILogConfiguration.MDC_SUPPORTABLITY_CSAR_VERSION)); + ecompLogFieldsHandler.setSupportablityComponentName(componentMetaData.get(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_NAME)); + ecompLogFieldsHandler.setSupportablityComponentUUID(componentMetaData.get(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_UUID)); + ecompLogFieldsHandler.setSupportablityComponentVersion(componentMetaData.get(ILogConfiguration.MDC_SUPPORTABLITY_COMPONENT_VERSION)); } ecompLogFieldsHandler.setSupportablityAction(action.getName()); ecompLogFieldsHandler.setSupportablityStatusCode(statusCode.getStatusCode()); @@ -101,7 +93,6 @@ public class LoggerSupportability extends LoggerBase { return this; } - @Override public List<String> getMandatoryFields() { return Collections.unmodifiableList(mandatoryFields); @@ -111,5 +102,4 @@ public class LoggerSupportability extends LoggerBase { public LoggerSupportability startTimer() { return this; } - } diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/ConstantsLogging.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/ConstantsLogging.java index 025de545a0..de1041b5c7 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/ConstantsLogging.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/ConstantsLogging.java @@ -1,6 +1,7 @@ package org.openecomp.sdc.common.log.enums; public final class ConstantsLogging { + public static final String USER_ID_HEADER = "USER_ID"; public static final String USER_AGENT_HEADER = "User-Agent"; public static final String PartnerName_Unknown = "UNKNOWN"; @@ -9,5 +10,4 @@ public final class ConstantsLogging { public static final String X_REQUEST_ID = "X-RequestID"; public static final String X_ECOMP_INSTANCE_ID_HEADER = "X-ECOMP-InstanceID"; public static final String X_ECOMP_SERVICE_ID_HEADER = "X-ECOMP-ServiceID"; - } diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/EcompErrorSeverity.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/EcompErrorSeverity.java index e88a074f0a..146c31c05e 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/EcompErrorSeverity.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/EcompErrorSeverity.java @@ -1,5 +1,3 @@ package org.openecomp.sdc.common.log.enums; -public enum EcompErrorSeverity { - INFO, WARN, ERROR, FATAL; -} +public enum EcompErrorSeverity {INFO, WARN, ERROR, FATAL;} diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/EcompLoggerErrorCode.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/EcompLoggerErrorCode.java index 736194de18..a2e51e9848 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/EcompLoggerErrorCode.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/EcompLoggerErrorCode.java @@ -19,7 +19,6 @@ * Modifications copyright (c) 2020 Nordix Foundation * ================================================================================ */ - package org.openecomp.sdc.common.log.enums; import java.util.Arrays; @@ -45,8 +44,7 @@ public enum EcompLoggerErrorCode { public static EcompLoggerErrorCode getByValue(String ecompErrorCode) { String errorPrefix = parseCode(ecompErrorCode); - Optional<EcompLoggerErrorCode> optionalCode = Arrays.stream(values()).filter(v -> isCode(v, errorPrefix)) - .findFirst(); + Optional<EcompLoggerErrorCode> optionalCode = Arrays.stream(values()).filter(v -> isCode(v, errorPrefix)).findFirst(); return optionalCode.orElse(UNKNOWN_ERROR); } @@ -61,5 +59,4 @@ public enum EcompLoggerErrorCode { return UNKNOWN_ERROR.name(); } } - } diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/LogLevel.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/LogLevel.java index 5b1ec9d4a9..9e4f495f91 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/LogLevel.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/LogLevel.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. @@ -17,18 +17,9 @@ * limitations under the License. * ============LICENSE_END========================================================= */ - package org.openecomp.sdc.common.log.enums; /** * Created by dd4296 on 12/14/2017. */ -public enum LogLevel { - INFO, - WARN, - DEBUG, - TRACE, - ERROR, - FATAL -} - +public enum LogLevel {INFO, WARN, DEBUG, TRACE, ERROR, FATAL} diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/LogMarkers.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/LogMarkers.java index fc7dca29fd..a884deb7c2 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/LogMarkers.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/LogMarkers.java @@ -30,11 +30,6 @@ import lombok.Getter; @Getter @AllArgsConstructor public enum LogMarkers { - DEBUG_MARKER("DEBUG_MARKER"), - ERROR_MARKER("ERROR_MARKER"), - METRIC_MARKER("METRICS"), - SUPPORTABILITY_MARKER("SUPPORTABILITY_MARKER"); - + DEBUG_MARKER("DEBUG_MARKER"), ERROR_MARKER("ERROR_MARKER"), METRIC_MARKER("METRICS"), SUPPORTABILITY_MARKER("SUPPORTABILITY_MARKER"); private final String text; - } diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/LoggerSupportabilityActions.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/LoggerSupportabilityActions.java index 4f61b63a54..88b6dbfb6a 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/LoggerSupportabilityActions.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/LoggerSupportabilityActions.java @@ -27,6 +27,7 @@ import lombok.Getter; @Getter @AllArgsConstructor public enum LoggerSupportabilityActions { + // @formatter:off IMPORT_CSAR("CREATE RESOURCE FROM CSAR"), CREATE_RESOURCE_FROM_YAML("CREATE RESOURCE FROM YAML"), CREATE_RI_AND_RELATIONS("CREATE RI AND RELATIONS"), @@ -80,6 +81,7 @@ public enum LoggerSupportabilityActions { UPDATE_INSTANCE_REQUIREMENT("UPDATE INSTANCE REQUIREMENT"), UPDATE_POLICY_TARGET("UPDATE POLICY TARGET"), UPDATE_POLICIES_PROPERTIES("UPDATE POLICIES PROPERTIES"); + // @formatter:on private final String name; diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/Severity.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/Severity.java index 78fe9761cf..b4c11c7319 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/Severity.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/Severity.java @@ -19,7 +19,6 @@ * Modifications copyright (c) 2020 Nordix Foundation * ================================================================================ */ - package org.openecomp.sdc.common.log.enums; import lombok.AllArgsConstructor; @@ -31,12 +30,6 @@ import lombok.Getter; @Getter @AllArgsConstructor public enum Severity { - OK(0), - WARNING(1), - CRITICAL(2), - DOWN(3), - UNREACHABLE(4); - + OK(0), WARNING(1), CRITICAL(2), DOWN(3), UNREACHABLE(4); private final int severityType; - } diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/StatusCode.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/StatusCode.java index ba9497eb5d..530b5b9cc4 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/StatusCode.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/enums/StatusCode.java @@ -27,11 +27,6 @@ import lombok.Getter; @Getter @AllArgsConstructor public enum StatusCode { - ERROR("ERROR"), - STARTED("STARTED"), - COMPLETE("COMPLETE"), - INPROGRESS("INPROGRESS"); - + ERROR("ERROR"), STARTED("STARTED"), COMPLETE("COMPLETE"), INPROGRESS("INPROGRESS"); private final String statusCode; - } diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/utils/EcompLogErrorCode.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/utils/EcompLogErrorCode.java index 1eaecca83b..477c114ebd 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/utils/EcompLogErrorCode.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/utils/EcompLogErrorCode.java @@ -21,7 +21,6 @@ */ package org.openecomp.sdc.common.log.utils; - import lombok.AllArgsConstructor; import lombok.Getter; @@ -30,7 +29,5 @@ import lombok.Getter; public enum EcompLogErrorCode { E_399("Internal Invalid Object. Description: %s"), E_210("Connection problem towards U-EB server. Reason: %s"); - private final String description; - } diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/utils/LoggingThreadLocalsHolder.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/utils/LoggingThreadLocalsHolder.java index c621a2a975..d7adad0937 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/utils/LoggingThreadLocalsHolder.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/utils/LoggingThreadLocalsHolder.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. @@ -17,26 +17,21 @@ * limitations under the License. * ============LICENSE_END========================================================= */ - package org.openecomp.sdc.common.log.utils; - public class LoggingThreadLocalsHolder { - private static final ThreadLocal<String> uuidThreadLocal = new ThreadLocal<>(); - - public static void setUuid(String uuid) { - uuidThreadLocal.set(uuid); - } - - public static String getUuid() { - return uuidThreadLocal.get(); - } - + private static final ThreadLocal<String> uuidThreadLocal = new ThreadLocal<>(); + public static String getUuid() { + return uuidThreadLocal.get(); + } - public static void cleanup() { - uuidThreadLocal.remove(); - } + public static void setUuid(String uuid) { + uuidThreadLocal.set(uuid); + } + public static void cleanup() { + uuidThreadLocal.remove(); + } } diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/wrappers/Logger.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/wrappers/Logger.java index 284104cd57..ae7dae4aa0 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/wrappers/Logger.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/wrappers/Logger.java @@ -1,22 +1,24 @@ package org.openecomp.sdc.common.log.wrappers; import com.google.common.annotations.VisibleForTesting; +import java.util.UUID; import org.onap.logging.ref.slf4j.ONAPLogConstants; -import org.openecomp.sdc.common.log.elements.*; +import org.openecomp.sdc.common.log.elements.ErrorLogOptionalData; +import org.openecomp.sdc.common.log.elements.LoggerDebug; +import org.openecomp.sdc.common.log.elements.LoggerError; +import org.openecomp.sdc.common.log.elements.LoggerFactory; +import org.openecomp.sdc.common.log.elements.LoggerMetric; import org.openecomp.sdc.common.log.enums.EcompErrorSeverity; import org.openecomp.sdc.common.log.enums.EcompLoggerErrorCode; import org.openecomp.sdc.common.log.enums.LogLevel; import org.slf4j.Marker; -import java.util.UUID; - - /** - * This class wraps {@link org.slf4j.Logger} object and provides mandatory information required by Ecomp logging rules. - * Note: All deprecated methods are supported to be compatible to the legacy code - * and have not be used by the new code + * This class wraps {@link org.slf4j.Logger} object and provides mandatory information required by Ecomp logging rules. Note: All deprecated methods + * are supported to be compatible to the legacy code and have not be used by the new code */ public class Logger implements org.slf4j.Logger { + private final LoggerDebug debug; private final LoggerError error; private final LoggerMetric metric; @@ -28,7 +30,6 @@ public class Logger implements org.slf4j.Logger { this.debug = LoggerFactory.getMdcLogger(LoggerDebug.class, logger); this.error = LoggerFactory.getMdcLogger(LoggerError.class, logger); this.metric = LoggerFactory.getMdcLogger(LoggerMetric.class, logger); - } private Logger(String className) { @@ -43,7 +44,6 @@ public class Logger implements org.slf4j.Logger { return new Logger(clazz.getName()); } - public boolean isDebugEnabled() { return logger.isDebugEnabled(); } @@ -57,12 +57,17 @@ public class Logger implements org.slf4j.Logger { return logger.isTraceEnabled(); } - public boolean isErrorEnabled() { return logger.isErrorEnabled(); } + public boolean isErrorEnabled() { + return logger.isErrorEnabled(); + } - public boolean isWarnEnabled() { return logger.isWarnEnabled(); } + public boolean isWarnEnabled() { + return logger.isWarnEnabled(); + } @Override - @Deprecated /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ + @Deprecated + /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ public void warn(String msg) { if (isWarnEnabled()) { error.log(LogLevel.WARN, msg); @@ -70,15 +75,17 @@ public class Logger implements org.slf4j.Logger { } @Override - @Deprecated /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ + @Deprecated + /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ public void warn(String msg, Object o) { - if (isWarnEnabled()) { error.log(LogLevel.WARN, msg, o); } } - public boolean isInfoEnabled() { return logger.isInfoEnabled(); } + public boolean isInfoEnabled() { + return logger.isInfoEnabled(); + } @Override public void info(String msg) { @@ -108,29 +115,20 @@ public class Logger implements org.slf4j.Logger { } public void metric(String msg, Object... params) { - metric.log(LogLevel.INFO, msg, params); + metric.log(LogLevel.INFO, msg, params); } public void invoke(String targetEntity, String targetServiceName, String serviceName, String msg, Object... params) { - String invocationId = UUID.randomUUID().toString(); String requestID = UUID.randomUUID().toString(); - - metric.startTimer() - .stopTimer() - .setOutgoingInvocationId(invocationId) - .setTargetServiceName(targetServiceName) - .setTargetEntity(targetEntity) - .setStatusCode(ONAPLogConstants.ResponseStatus.COMPLETE.name()) - .setKeyRequestId(requestID) - .setServiceName(serviceName); + metric.startTimer().stopTimer().setOutgoingInvocationId(invocationId).setTargetServiceName(targetServiceName).setTargetEntity(targetEntity) + .setStatusCode(ONAPLogConstants.ResponseStatus.COMPLETE.name()).setKeyRequestId(requestID).setServiceName(serviceName); metric.log(ONAPLogConstants.Markers.INVOKE, LogLevel.INFO, msg, params); } public void invokeReturn(String msg, Object... params) { try { - metric.startTimer() - .stopTimer(); + metric.startTimer().stopTimer(); } catch (Exception e) { error(e.getMessage(), e); } @@ -334,15 +332,17 @@ public class Logger implements org.slf4j.Logger { } } - @Deprecated /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ - public void warn(String msg, Object... params){ + @Deprecated + /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ + public void warn(String msg, Object... params) { if (isWarnEnabled()) { error.log(LogLevel.WARN, msg, params); } } @Override - @Deprecated /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ + @Deprecated + /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ public void warn(String msg, Object o, Object o1) { if (isWarnEnabled()) { error.log(LogLevel.WARN, msg, o, o1); @@ -350,7 +350,8 @@ public class Logger implements org.slf4j.Logger { } @Override - @Deprecated /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ + @Deprecated + /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ public void warn(String msg, Throwable throwable) { if (isWarnEnabled()) { error.log(LogLevel.WARN, msg, throwable); @@ -363,7 +364,8 @@ public class Logger implements org.slf4j.Logger { } @Override - @Deprecated /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ + @Deprecated + /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ public void warn(Marker marker, String msg) { if (isWarnEnabled()) { error.log(LogLevel.WARN, msg); @@ -371,7 +373,8 @@ public class Logger implements org.slf4j.Logger { } @Override - @Deprecated /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ + @Deprecated + /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ public void warn(Marker marker, String msg, Object o) { if (isWarnEnabled()) { error.log(LogLevel.WARN, msg, o); @@ -379,7 +382,8 @@ public class Logger implements org.slf4j.Logger { } @Override - @Deprecated /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ + @Deprecated + /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ public void warn(Marker marker, String msg, Object o, Object o1) { if (isWarnEnabled()) { error.log(LogLevel.WARN, msg, o, o1); @@ -387,7 +391,8 @@ public class Logger implements org.slf4j.Logger { } @Override - @Deprecated /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ + @Deprecated + /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ public void warn(Marker marker, String msg, Object... objects) { if (isWarnEnabled()) { error.log(LogLevel.WARN, msg, objects); @@ -395,22 +400,25 @@ public class Logger implements org.slf4j.Logger { } @Override - @Deprecated /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ + @Deprecated + /** Please use method {@link #warn(EcompLoggerErrorCode, String, String)} **/ public void warn(Marker marker, String msg, Throwable throwable) { if (isWarnEnabled()) { error.log(LogLevel.WARN, msg, throwable); } } - @Deprecated /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ - public void error(String msg, Object... params){ + @Deprecated + /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ + public void error(String msg, Object... params) { if (isErrorEnabled()) { error.log(LogLevel.ERROR, msg, params); } } @Override - @Deprecated /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ + @Deprecated + /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ public void error(String msg, Throwable throwable) { if (isErrorEnabled()) { error.log(LogLevel.ERROR, msg, throwable); @@ -423,7 +431,8 @@ public class Logger implements org.slf4j.Logger { } @Override - @Deprecated /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ + @Deprecated + /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ public void error(Marker marker, String msg) { if (isErrorEnabled()) { error.log(LogLevel.ERROR, msg); @@ -431,7 +440,8 @@ public class Logger implements org.slf4j.Logger { } @Override - @Deprecated /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ + @Deprecated + /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ public void error(Marker marker, String msg, Object o) { if (isErrorEnabled()) { error.log(LogLevel.ERROR, msg, o); @@ -439,7 +449,8 @@ public class Logger implements org.slf4j.Logger { } @Override - @Deprecated /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ + @Deprecated + /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ public void error(Marker marker, String msg, Object o, Object o1) { if (isErrorEnabled()) { error.log(LogLevel.ERROR, msg, o, o1); @@ -447,7 +458,8 @@ public class Logger implements org.slf4j.Logger { } @Override - @Deprecated /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ + @Deprecated + /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ public void error(Marker marker, String msg, Object... params) { if (isErrorEnabled()) { error.log(LogLevel.ERROR, msg, params); @@ -455,22 +467,25 @@ public class Logger implements org.slf4j.Logger { } @Override - @Deprecated /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ + @Deprecated + /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ public void error(Marker marker, String msg, Throwable throwable) { if (isErrorEnabled()) { error.log(LogLevel.ERROR, msg, throwable); } } - @Deprecated /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ - public void error(String msg){ + @Deprecated + /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ + public void error(String msg) { if (isErrorEnabled()) { error.log(LogLevel.ERROR, msg); } } @Override - @Deprecated /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ + @Deprecated + /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ public void error(String msg, Object o) { if (isErrorEnabled()) { error.log(LogLevel.ERROR, msg, o); @@ -478,7 +493,8 @@ public class Logger implements org.slf4j.Logger { } @Override - @Deprecated /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ + @Deprecated + /** Please use method {@link #error(EcompLoggerErrorCode, String, String)} **/ public void error(String msg, Object o, Object o1) { if (isErrorEnabled()) { error.log(LogLevel.ERROR, msg, o, o1); @@ -487,17 +503,15 @@ public class Logger implements org.slf4j.Logger { /** * Writes out ERROR logging level message to the application error log - * @param errorLevel code representing the error severity level - * @param serviceName name of the API invoked at the logging component - * @param targetEntity name of the ECOMP component or sub-component, or external entity at which the error occurred or null + * + * @param errorLevel code representing the error severity level + * @param serviceName name of the API invoked at the logging component + * @param targetEntity name of the ECOMP component or sub-component, or external entity at which the error occurred or null * @param errorDescription a human readable description of the error condition - * @param params optional parameters of a given error description + * @param params optional parameters of a given error description */ - public void error(EcompErrorSeverity errorLevel, - EcompLoggerErrorCode errorCodeEnum, - String serviceName, - String targetEntity, - String errorDescription, Object...params) { + public void error(EcompErrorSeverity errorLevel, EcompLoggerErrorCode errorCodeEnum, String serviceName, String targetEntity, + String errorDescription, Object... params) { if (isErrorEnabled()) { error.log(errorLevel, errorCodeEnum, serviceName, targetEntity, errorDescription, params); } @@ -505,17 +519,20 @@ public class Logger implements org.slf4j.Logger { /** * Writes out ERROR logging level message to the application error log - * @param errorCodeEnum code representing the error condition - * @param serviceName name of the API invoked at the logging component - * @param targetEntity name of the ECOMP component or sub-component, or external entity at which the error occurred or null + * + * @param errorCodeEnum code representing the error condition + * @param serviceName name of the API invoked at the logging component + * @param targetEntity name of the ECOMP component or sub-component, or external entity at which the error occurred or null * @param errorDescription a human readable description of the error condition - * @param params optional parameters of a given error description + * @param params optional parameters of a given error description */ - @Deprecated /** Please use method {@link #error(EcompLoggerErrorCode, String, ErrorLogOptionalData, String, Object...)} **/ + + @Deprecated + /** Please use method {@link #error(EcompLoggerErrorCode, String, ErrorLogOptionalData, String, Object...)} **/ public void error(EcompLoggerErrorCode errorCodeEnum, String serviceName, String targetEntity, - String errorDescription, Object...params) { + String errorDescription, Object... params) { if (isErrorEnabled()) { error.log(LogLevel.ERROR, errorCodeEnum, serviceName, targetEntity, errorDescription, params); } @@ -526,25 +543,21 @@ public class Logger implements org.slf4j.Logger { * @param errorDescription a human readable description of the error condition * @param params optional parameters of a given error description */ - - public void error(EcompLoggerErrorCode errorCodeEnum, String serviceName, - String errorDescription, Object...params) { - error(errorCodeEnum, serviceName, (String)null, errorDescription, params); + public void error(EcompLoggerErrorCode errorCodeEnum, String serviceName, String errorDescription, Object... params) { + error(errorCodeEnum, serviceName, (String) null, errorDescription, params); } /** * Writes out ERROR logging level message to the application error log - * @param errorCodeEnum code representing the error condition - * @param serviceName name of the API invoked at the logging component + * + * @param errorCodeEnum code representing the error condition + * @param serviceName name of the API invoked at the logging component * @param errorLogOptionalData elements that contans all relevant data of the error - * @param errorDescription a human readable description of the error condition - * @param params optional parameters of a given error description + * @param errorDescription a human readable description of the error condition + * @param params optional parameters of a given error description */ - public void error(EcompLoggerErrorCode errorCodeEnum, - String serviceName, - ErrorLogOptionalData errorLogOptionalData, - String errorDescription, - Object...params) { + public void error(EcompLoggerErrorCode errorCodeEnum, String serviceName, ErrorLogOptionalData errorLogOptionalData, String errorDescription, + Object... params) { if (isErrorEnabled()) { error.log(LogLevel.ERROR, errorCodeEnum, serviceName, errorLogOptionalData, errorDescription, params); } @@ -552,16 +565,14 @@ public class Logger implements org.slf4j.Logger { /** * Writes out WARN logging level message to the application error log - * @param errorCodeEnum code representing the error condition - * @param serviceName name of the API invoked at the logging component - * @param targetEntity name of the ECOMP component or sub-component, or external entity at which the error occurred or null + * + * @param errorCodeEnum code representing the error condition + * @param serviceName name of the API invoked at the logging component + * @param targetEntity name of the ECOMP component or sub-component, or external entity at which the error occurred or null * @param errorDescription a human readable description of the error condition - * @param params optional parameters of a given error description + * @param params optional parameters of a given error description */ - public void warn(EcompLoggerErrorCode errorCodeEnum, - String serviceName, - String targetEntity, - String errorDescription, Object...params) { + public void warn(EcompLoggerErrorCode errorCodeEnum, String serviceName, String targetEntity, String errorDescription, Object... params) { if (isWarnEnabled()) { error.log(LogLevel.WARN, errorCodeEnum, serviceName, targetEntity, errorDescription, params); } @@ -569,16 +580,15 @@ public class Logger implements org.slf4j.Logger { /** * Writes out WARN logging level message to the application error log - * @param errorCodeEnum code representing the error condition - * @param serviceName name of the API invoked at the logging component + * + * @param errorCodeEnum code representing the error condition + * @param serviceName name of the API invoked at the logging component * @param errorLogOptionalData elements that contans all relevant data of the error - * @param description a human readable description of the error condition - * @param params optional parameters of a given error description + * @param description a human readable description of the error condition + * @param params optional parameters of a given error description */ - public void warn(EcompLoggerErrorCode errorCodeEnum, - String serviceName, - ErrorLogOptionalData errorLogOptionalData, - String description, Object...params) { + public void warn(EcompLoggerErrorCode errorCodeEnum, String serviceName, ErrorLogOptionalData errorLogOptionalData, String description, + Object... params) { if (isWarnEnabled()) { error.log(LogLevel.WARN, errorCodeEnum, serviceName, errorLogOptionalData, description, params); } @@ -586,31 +596,28 @@ public class Logger implements org.slf4j.Logger { /** * Writes out WARN logging level message to the application error log - * @param errorCodeEnum code representing the error condition - * @param serviceName name of the API invoked at the logging component + * + * @param errorCodeEnum code representing the error condition + * @param serviceName name of the API invoked at the logging component * @param errorDescription a human readable description of the error condition - * @param params optional parameters of a given error description + * @param params optional parameters of a given error description */ - public void warn(EcompLoggerErrorCode errorCodeEnum, - String serviceName, - String errorDescription, Object...params) { + public void warn(EcompLoggerErrorCode errorCodeEnum, String serviceName, String errorDescription, Object... params) { if (isWarnEnabled()) { - error.log(LogLevel.WARN, errorCodeEnum, serviceName, (String)null, errorDescription, params); + error.log(LogLevel.WARN, errorCodeEnum, serviceName, (String) null, errorDescription, params); } } /** * Writes out FATAL logging level message to the application error log - * @param errorCodeEnum code representing the error condition - * @param serviceName name of the API invoked at the logging component - * @param targetEntity name of the ECOMP component or sub-component, or external entity at which the error occurred or null + * + * @param errorCodeEnum code representing the error condition + * @param serviceName name of the API invoked at the logging component + * @param targetEntity name of the ECOMP component or sub-component, or external entity at which the error occurred or null * @param errorDescription a human readable description of the error condition - * @param params optional parameters of a given error description + * @param params optional parameters of a given error description */ - public void fatal(EcompLoggerErrorCode errorCodeEnum, - String serviceName, - String targetEntity, - String errorDescription, Object...params) { + public void fatal(EcompLoggerErrorCode errorCodeEnum, String serviceName, String targetEntity, String errorDescription, Object... params) { if (isErrorEnabled()) { error.log(LogLevel.FATAL, errorCodeEnum, serviceName, targetEntity, errorDescription, params); } @@ -618,18 +625,17 @@ public class Logger implements org.slf4j.Logger { /** * Writes out FATAL logging level message to the application error log - * @param errorCodeEnum code representing the error condition - * @param serviceName name of the API invoked at the logging component + * + * @param errorCodeEnum code representing the error condition + * @param serviceName name of the API invoked at the logging component * @param errorLogOptionalData elements that contans all relevant data of the error - * @param description a human readable description of the error condition - * @param params optional parameters of a given error description + * @param description a human readable description of the error condition + * @param params optional parameters of a given error description */ - public void fatal(EcompLoggerErrorCode errorCodeEnum, String serviceName, - ErrorLogOptionalData errorLogOptionalData, - String description, Object...params) { + public void fatal(EcompLoggerErrorCode errorCodeEnum, String serviceName, ErrorLogOptionalData errorLogOptionalData, String description, + Object... params) { if (isErrorEnabled()) { error.log(LogLevel.FATAL, errorCodeEnum, serviceName, errorLogOptionalData, description, params); } } } - diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/wrappers/LoggerSdcAudit.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/wrappers/LoggerSdcAudit.java index b8c1b268e1..f68fbe155d 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/wrappers/LoggerSdcAudit.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/wrappers/LoggerSdcAudit.java @@ -1,10 +1,13 @@ package org.openecomp.sdc.common.log.wrappers; +import java.util.UUID; +import javax.ws.rs.container.ContainerRequestContext; +import javax.ws.rs.core.Response; import org.apache.commons.lang3.StringUtils; import org.onap.logging.ref.slf4j.ONAPLogConstants; -import org.openecomp.sdc.common.log.enums.ConstantsLogging; import org.openecomp.sdc.common.log.elements.LoggerAudit; import org.openecomp.sdc.common.log.elements.LoggerFactory; +import org.openecomp.sdc.common.log.enums.ConstantsLogging; import org.openecomp.sdc.common.log.enums.EcompLoggerErrorCode; import org.openecomp.sdc.common.log.enums.LogLevel; import org.openecomp.sdc.common.log.enums.Severity; @@ -12,146 +15,87 @@ import org.openecomp.sdc.common.log.utils.LoggingThreadLocalsHolder; import org.slf4j.MDC; import org.slf4j.Marker; -import javax.ws.rs.container.ContainerRequestContext; -import javax.ws.rs.core.Response; -import java.util.UUID; - - /** * Created by dd4296 on 12/19/2017. - * - * audit log for asdc using the log library - * this is adapted for filter classes + * <p> + * audit log for asdc using the log library this is adapted for filter classes */ public class LoggerSdcAudit extends LoggerSdcUtilBase { private static String AUDIT_ON = "auditOn"; - private String className; private final LoggerAudit ecompLoggerAudit; + private String className; public LoggerSdcAudit(Class<?> clazz) { this.className = clazz.getName(); ecompLoggerAudit = LoggerFactory.getMdcLogger(LoggerAudit.class, org.slf4j.LoggerFactory.getLogger(clazz)); } + public static boolean isFlowBeingTakenCare() { + String auditOn = MDC.get(AUDIT_ON); + return !StringUtils.isEmpty(auditOn) && "true".equals(auditOn); + } + public void startLog(ContainerRequestContext requestContext) { - ecompLoggerAudit.clear() - .startTimer() - .setPartnerName(getPartnerName( - requestContext.getHeaderString("user-agent"), - requestContext.getHeaderString("USER_ID"), - getUrl(requestContext), - requestContext.getHeaderString("X-ONAP-PartnerName"))) - .setServiceName(getServiceName(requestContext)) - .setKeyRequestId(LoggingThreadLocalsHolder.getUuid()) - .setKeyInvocationId(UUID.randomUUID().toString()); + ecompLoggerAudit.clear().startTimer().setPartnerName( + getPartnerName(requestContext.getHeaderString("user-agent"), requestContext.getHeaderString("USER_ID"), getUrl(requestContext), + requestContext.getHeaderString("X-ONAP-PartnerName"))).setServiceName(getServiceName(requestContext)) + .setKeyRequestId(LoggingThreadLocalsHolder.getUuid()).setKeyInvocationId(UUID.randomUUID().toString()); MDC.put(AUDIT_ON, "true"); } public void startAuditFetchLog(String partnerName, String serviceName) { - ecompLoggerAudit.clear() - .startTimer() - .setPartnerName(partnerName) - .setServiceName(serviceName) - .setOptClassName(serviceName); + ecompLoggerAudit.clear().startTimer().setPartnerName(partnerName).setServiceName(serviceName).setOptClassName(serviceName); MDC.put(AUDIT_ON, "true"); } - public static boolean isFlowBeingTakenCare() { - String auditOn = MDC.get(AUDIT_ON); - return !StringUtils.isEmpty(auditOn) && "true".equals(auditOn); - } - //this function clears the MDC data that relevant for this class - public void clearMyData(){ + public void clearMyData() { ecompLoggerAudit.clear(); } - public void logExit(String remoteAddress, - ContainerRequestContext requestContext, - Response.StatusType statusInfo, - LogLevel logLevel, - Severity securityLevel, - String message, - Marker marker) { - + public void logExit(String remoteAddress, ContainerRequestContext requestContext, Response.StatusType statusInfo, LogLevel logLevel, + Severity securityLevel, String message, Marker marker) { try { - - String msg = ecompLoggerAudit.getAuditMessage() == null ? - message : ecompLoggerAudit.getAuditMessage(); - ecompLoggerAudit.stopTimer() - .setRemoteHost(remoteAddress) - .setResponseCode(convertHttpCodeToErrorCode(statusInfo.getStatusCode())) - .setStatusCodeByResponseCode(Integer.toString(statusInfo.getStatusCode())) - .setResponseDesc(statusInfo.getReasonPhrase()) - .setInstanceUUID(requestContext.getHeaderString(ConstantsLogging.X_ECOMP_INSTANCE_ID_HEADER)) - .setOptServiceInstanceId(requestContext.getHeaderString(ConstantsLogging.X_ECOMP_SERVICE_ID_HEADER)) - .setOptClassName(className) - .setOptAlertSeverity(securityLevel) - .log(marker, logLevel, msg); - } - catch (Exception e) { + String msg = ecompLoggerAudit.getAuditMessage() == null ? message : ecompLoggerAudit.getAuditMessage(); + ecompLoggerAudit.stopTimer().setRemoteHost(remoteAddress).setResponseCode(convertHttpCodeToErrorCode(statusInfo.getStatusCode())) + .setStatusCodeByResponseCode(Integer.toString(statusInfo.getStatusCode())).setResponseDesc(statusInfo.getReasonPhrase()) + .setInstanceUUID(requestContext.getHeaderString(ConstantsLogging.X_ECOMP_INSTANCE_ID_HEADER)) + .setOptServiceInstanceId(requestContext.getHeaderString(ConstantsLogging.X_ECOMP_SERVICE_ID_HEADER)).setOptClassName(className) + .setOptAlertSeverity(securityLevel).log(marker, logLevel, msg); + } catch (Exception e) { log.warn("Failed to write to Audit Log. Original Message: {}", message, e); - } - finally { - MDC.put(AUDIT_ON,"false"); + } finally { + MDC.put(AUDIT_ON, "false"); } } - public void logEntry(String remoteAddress, - ContainerRequestContext requestContext, - LogLevel logLevel, - Severity securityLevel, - String message, - Marker marker) { - + public void logEntry(String remoteAddress, ContainerRequestContext requestContext, LogLevel logLevel, Severity securityLevel, String message, + Marker marker) { try { - - String msg = ecompLoggerAudit.getAuditMessage() == null ? - message : ecompLoggerAudit.getAuditMessage(); - ecompLoggerAudit.stopTimer() - .setRemoteHost(remoteAddress) - .setResponseCode(EcompLoggerErrorCode.SUCCESS) - .setStatusCode(ONAPLogConstants.ResponseStatus.INPROGRESS.name()) - .setResponseDesc("") - .setInstanceUUID(requestContext.getHeaderString(ConstantsLogging.X_ECOMP_INSTANCE_ID_HEADER)) - .setOptServiceInstanceId(requestContext.getHeaderString(ConstantsLogging.X_ECOMP_SERVICE_ID_HEADER)) - .setOptClassName(className) - .setOptAlertSeverity(securityLevel) - .log(marker, logLevel, msg); - } - catch (Exception e) { + String msg = ecompLoggerAudit.getAuditMessage() == null ? message : ecompLoggerAudit.getAuditMessage(); + ecompLoggerAudit.stopTimer().setRemoteHost(remoteAddress).setResponseCode(EcompLoggerErrorCode.SUCCESS) + .setStatusCode(ONAPLogConstants.ResponseStatus.INPROGRESS.name()).setResponseDesc("") + .setInstanceUUID(requestContext.getHeaderString(ConstantsLogging.X_ECOMP_INSTANCE_ID_HEADER)) + .setOptServiceInstanceId(requestContext.getHeaderString(ConstantsLogging.X_ECOMP_SERVICE_ID_HEADER)).setOptClassName(className) + .setOptAlertSeverity(securityLevel).log(marker, logLevel, msg); + } catch (Exception e) { log.warn("Failed to write to Audit Log. Original Message: {}", message, e); - } - finally { - MDC.put(AUDIT_ON,"false"); + } finally { + MDC.put(AUDIT_ON, "false"); } } - public void logEntry(LogLevel logLevel, - Severity securityLevel, - String message, - Marker marker, - String requestId) { - + public void logEntry(LogLevel logLevel, Severity securityLevel, String message, Marker marker, String requestId) { try { - - String msg = ecompLoggerAudit.getAuditMessage() == null ? - message : ecompLoggerAudit.getAuditMessage(); - ecompLoggerAudit.stopTimer() - .setKeyRequestId(requestId) - .setResponseCode(EcompLoggerErrorCode.SUCCESS) - .setStatusCode(ONAPLogConstants.ResponseStatus.COMPLETE.name()) - .setResponseDesc("") - .setOptAlertSeverity(securityLevel) - .log(marker, logLevel, msg); - } - catch (Exception e) { + String msg = ecompLoggerAudit.getAuditMessage() == null ? message : ecompLoggerAudit.getAuditMessage(); + ecompLoggerAudit.stopTimer().setKeyRequestId(requestId).setResponseCode(EcompLoggerErrorCode.SUCCESS) + .setStatusCode(ONAPLogConstants.ResponseStatus.COMPLETE.name()).setResponseDesc("").setOptAlertSeverity(securityLevel) + .log(marker, logLevel, msg); + } catch (Exception e) { log.warn("Failed to write to Audit Log. Original Message: {}", message, e); - } - finally { - MDC.put(AUDIT_ON,"false"); + } finally { + MDC.put(AUDIT_ON, "false"); } } - } diff --git a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/wrappers/LoggerSdcUtilBase.java b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/wrappers/LoggerSdcUtilBase.java index 6ca71281d3..87c2c2d759 100644 --- a/common-app-logging/src/main/java/org/openecomp/sdc/common/log/wrappers/LoggerSdcUtilBase.java +++ b/common-app-logging/src/main/java/org/openecomp/sdc/common/log/wrappers/LoggerSdcUtilBase.java @@ -1,21 +1,34 @@ package org.openecomp.sdc.common.log.wrappers; +import static java.net.HttpURLConnection.HTTP_BAD_METHOD; +import static java.net.HttpURLConnection.HTTP_BAD_REQUEST; +import static java.net.HttpURLConnection.HTTP_CLIENT_TIMEOUT; +import static java.net.HttpURLConnection.HTTP_CONFLICT; +import static java.net.HttpURLConnection.HTTP_ENTITY_TOO_LARGE; +import static java.net.HttpURLConnection.HTTP_FORBIDDEN; +import static java.net.HttpURLConnection.HTTP_GONE; +import static java.net.HttpURLConnection.HTTP_LENGTH_REQUIRED; +import static java.net.HttpURLConnection.HTTP_NOT_ACCEPTABLE; +import static java.net.HttpURLConnection.HTTP_NOT_FOUND; +import static java.net.HttpURLConnection.HTTP_PAYMENT_REQUIRED; +import static java.net.HttpURLConnection.HTTP_PRECON_FAILED; +import static java.net.HttpURLConnection.HTTP_PROXY_AUTH; +import static java.net.HttpURLConnection.HTTP_REQ_TOO_LONG; +import static java.net.HttpURLConnection.HTTP_UNAUTHORIZED; +import static java.net.HttpURLConnection.HTTP_UNSUPPORTED_TYPE; + +import java.util.List; +import java.util.StringTokenizer; +import javax.ws.rs.container.ContainerRequestContext; import org.apache.commons.lang3.StringUtils; import org.openecomp.sdc.common.log.enums.EcompLoggerErrorCode; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import javax.ws.rs.container.ContainerRequestContext; -import java.util.List; -import java.util.StringTokenizer; - -import static java.net.HttpURLConnection.*; - /** * Created by dd4296 on 12/20/2017. - * - * base class for metric and audit log logging - * holding the specific logic for data extraction + * <p> + * base class for metric and audit log logging holding the specific logic for data extraction */ public class LoggerSdcUtilBase { @@ -23,20 +36,18 @@ public class LoggerSdcUtilBase { String getRequestIDfromHeaders(List<Object> requestHeader) { // this method gets list of type object. + // toString method returns the RequestId with brackets. String requestHeaderString = requestHeader.toString(); - return requestHeaderString.replace("[","").replace("]",""); + return requestHeaderString.replace("[", "").replace("]", ""); } - - - // this method translates http error code to ECOMP Logger Error code + // this is a naive translation and is not a result of any documented format ECOMP specification protected EcompLoggerErrorCode convertHttpCodeToErrorCode(int httpResponseCode) { if (isSuccessError(httpResponseCode)) { return EcompLoggerErrorCode.SUCCESS; } - if (isSchemaError(httpResponseCode)) { return EcompLoggerErrorCode.SCHEMA_ERROR; } @@ -56,7 +67,6 @@ public class LoggerSdcUtilBase { } private boolean isTimeoutOrAvailabilityError(int httpResponseCode) { - switch (httpResponseCode) { case HTTP_BAD_REQUEST: case HTTP_UNAUTHORIZED: @@ -67,11 +77,9 @@ public class LoggerSdcUtilBase { default: return false; } - } private boolean isPermissionsError(int httpResponseCode) { - switch (httpResponseCode) { case HTTP_PAYMENT_REQUIRED: case HTTP_FORBIDDEN: @@ -79,12 +87,10 @@ public class LoggerSdcUtilBase { case HTTP_PROXY_AUTH: return true; } - return false; } private boolean isDataError(int httpResponseCode) { - switch (httpResponseCode) { case HTTP_NOT_ACCEPTABLE: case HTTP_LENGTH_REQUIRED: @@ -94,7 +100,6 @@ public class LoggerSdcUtilBase { case HTTP_UNSUPPORTED_TYPE: return true; } - return false; } @@ -111,28 +116,23 @@ public class LoggerSdcUtilBase { } protected String getPartnerName(String userAgent, String userId, String url, String xOnapPartnerName) { - //On called side (receiver) If the API call is authenticated, then log the userid/mechid (fully qualified if that is what was provided) if (isFound(userId)) { return userId; } - String urlUser = getUserIdFromUrl(url); if (isFound(urlUser)) { return urlUser; } - //Otherwise, if X-ONAP-PartnerName was provided, then log that - if (isFound(xOnapPartnerName)){ + if (isFound(xOnapPartnerName)) { return xOnapPartnerName; } - //Otherwise, for an HTTP API call, log the part of the URI specifying the agent that the caller used to make the call String userAgentName = getUserIdFromUserAgent(userAgent); if (isFound(userAgentName)) { return userAgentName; } - return "UNKNOWN"; } @@ -141,15 +141,12 @@ public class LoggerSdcUtilBase { if (userAgent.toLowerCase().contains("firefox")) { return "fireFox_FE"; } - if (userAgent.toLowerCase().contains("msie")) { return "explorer_FE"; } - if (userAgent.toLowerCase().contains("chrome")) { return "chrome_FE"; } - return userAgent; } return null; @@ -169,7 +166,6 @@ public class LoggerSdcUtilBase { protected String getUrl(ContainerRequestContext requestContext) { String url = ""; - try { if (requestContext.getUriInfo() != null && requestContext.getUriInfo().getRequestUri() != null) { url = requestContext.getUriInfo().getRequestUri().toURL().toString(); @@ -177,13 +173,11 @@ public class LoggerSdcUtilBase { } catch (Exception ex) { log.error("failed to get url from request context ", ex); } - return url; } protected String getServiceName(ContainerRequestContext requestContext) { - return (requestContext.getUriInfo().getRequestUri().toString()) - .replace(requestContext.getUriInfo().getBaseUri().toString(), "/"); + return (requestContext.getUriInfo().getRequestUri().toString()).replace(requestContext.getUriInfo().getBaseUri().toString(), "/"); } private boolean isFound(String value) { @@ -192,4 +186,4 @@ public class LoggerSdcUtilBase { } return false; } -}
\ No newline at end of file +} |