import org.slf4j.LoggerFactory;
import org.slf4j.MDC;
-public abstract class AbstractAuditLogFilter<GenericRequest, GenericResponse> {
+public abstract class AbstractAuditLogFilter<GenericRequest, GenericResponse> extends AbstractFilter {
protected static final Logger logger = LoggerFactory.getLogger(AbstractAuditLogFilter.class);
- protected void pre(MDCSetup mdcSetup, SimpleMap headers, GenericRequest request,
- HttpServletRequest httpServletRequest) {
+ protected void pre(SimpleMap headers, GenericRequest request, HttpServletRequest httpServletRequest) {
try {
- String requestId = mdcSetup.getRequestId(headers);
+ String requestId = getRequestId(headers);
MDC.put(ONAPLogConstants.MDCs.REQUEST_ID, requestId);
- mdcSetup.setInvocationId(headers);
+ setInvocationId(headers);
setServiceName(request);
- mdcSetup.setMDCPartnerName(headers);
- mdcSetup.setServerFQDN();
- mdcSetup.setClientIPAddress(httpServletRequest);
- mdcSetup.setInstanceID();
- mdcSetup.setEntryTimeStamp();
+ setMDCPartnerName(headers);
+ setServerFQDN();
+ setClientIPAddress(httpServletRequest);
+ setInstanceID();
+ setEntryTimeStamp();
MDC.put(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE, ONAPLogConstants.ResponseStatus.INPROGRESS.toString());
additionalPreHandling(request);
- mdcSetup.setLogTimestamp();
- mdcSetup.setElapsedTime();
+ setLogTimestamp();
+ setElapsedTime();
logger.info(ONAPLogConstants.Markers.ENTRY, "Entering");
} catch (Exception e) {
logger.warn("Error in AbstractInboundFilter pre", e);
}
}
- protected void post(MDCSetup mdcSetup, GenericResponse response) {
+ protected void post(GenericResponse response) {
try {
int responseCode = getResponseCode(response);
- mdcSetup.setResponseStatusCode(responseCode);
+ setResponseStatusCode(responseCode);
MDC.put(ONAPLogConstants.MDCs.RESPONSE_CODE, String.valueOf(responseCode));
- mdcSetup.setResponseDescription(responseCode);
- mdcSetup.setLogTimestamp();
- mdcSetup.setElapsedTime();
+ setResponseDescription(responseCode);
+ setLogTimestamp();
+ setElapsedTime();
logger.info(ONAPLogConstants.Markers.EXIT, "Exiting.");
additionalPostHandling(response);
} catch (Exception e) {
import org.slf4j.LoggerFactory;
import org.slf4j.MDC;
-public class MDCSetup {
+public abstract class AbstractFilter {
- protected static Logger logger = LoggerFactory.getLogger(MDCSetup.class);
+ protected static Logger logger = LoggerFactory.getLogger(AbstractFilter.class);
private static final String INSTANCE_UUID = UUID.randomUUID().toString();
- public void setInstanceID() {
+ protected void setInstanceID() {
MDC.put(ONAPLogConstants.MDCs.INSTANCE_UUID, INSTANCE_UUID);
}
- public void setServerFQDN() {
+ protected void setServerFQDN() {
String serverFQDN = "";
InetAddress addr = null;
try {
MDC.put(ONAPLogConstants.MDCs.SERVER_FQDN, serverFQDN);
}
- public void setClientIPAddress(HttpServletRequest httpServletRequest) {
+ protected void setClientIPAddress(HttpServletRequest httpServletRequest) {
String clientIpAddress = "";
if (httpServletRequest != null) {
// This logic is to avoid setting the client ip address to that of the load
MDC.put(ONAPLogConstants.MDCs.CLIENT_IP_ADDRESS, clientIpAddress);
}
- public void setEntryTimeStamp() {
+ protected void setEntryTimeStamp() {
MDC.put(ONAPLogConstants.MDCs.ENTRY_TIMESTAMP,
ZonedDateTime.now(ZoneOffset.UTC).format(DateTimeFormatter.ISO_INSTANT));
}
- public void setServiceName(HttpServletRequest request) {
- MDC.put(ONAPLogConstants.MDCs.SERVICE_NAME, request.getRequestURI());
- }
-
- public String getRequestId(SimpleMap headers) {
+ protected String getRequestId(SimpleMap headers) {
logger.trace("Checking X-ONAP-RequestID header for requestId.");
String requestId = headers.get(ONAPLogConstants.Headers.REQUEST_ID);
if (requestId != null && !requestId.isEmpty()) {
return UUID.randomUUID().toString();
}
- public void setInvocationId(SimpleMap headers) {
+ protected void setInvocationId(SimpleMap headers) {
String invocationId = headers.get(ONAPLogConstants.Headers.INVOCATION_ID);
if (invocationId == null || invocationId.isEmpty())
invocationId = UUID.randomUUID().toString();
MDC.put(ONAPLogConstants.MDCs.INVOCATION_ID, invocationId);
}
- public void setInvocationIdFromMDC() {
+ protected void setInvocationIdFromMDC() {
String invocationId = MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID);
if (invocationId == null || invocationId.isEmpty())
invocationId = UUID.randomUUID().toString();
MDC.put(ONAPLogConstants.MDCs.INVOCATION_ID, invocationId);
}
- public void setMDCPartnerName(SimpleMap headers) {
+ protected void setMDCPartnerName(SimpleMap headers) {
logger.trace("Checking X-ONAP-PartnerName header for partnerName.");
String partnerName = headers.get(ONAPLogConstants.Headers.PARTNER_NAME);
if (partnerName == null || partnerName.isEmpty()) {
MDC.put(ONAPLogConstants.MDCs.PARTNER_NAME, partnerName);
}
- public void setLogTimestamp() {
+ protected void setLogTimestamp() {
MDC.put(ONAPLogConstants.MDCs.LOG_TIMESTAMP,
ZonedDateTime.now(ZoneOffset.UTC).format(DateTimeFormatter.ISO_INSTANT));
}
- public void setElapsedTime() {
+ protected void setElapsedTime() {
DateTimeFormatter timeFormatter = DateTimeFormatter.ISO_ZONED_DATE_TIME;
ZonedDateTime entryTimestamp =
ZonedDateTime.parse(MDC.get(ONAPLogConstants.MDCs.ENTRY_TIMESTAMP), timeFormatter);
Long.toString(ChronoUnit.MILLIS.between(entryTimestamp, endTimestamp)));
}
- public void setElapsedTimeInvokeTimestamp() {
+ protected void setElapsedTimeInvokeTimestamp() {
DateTimeFormatter timeFormatter = DateTimeFormatter.ISO_ZONED_DATE_TIME;
ZonedDateTime entryTimestamp =
ZonedDateTime.parse(MDC.get(ONAPLogConstants.MDCs.INVOKE_TIMESTAMP), timeFormatter);
Long.toString(ChronoUnit.MILLIS.between(entryTimestamp, endTimestamp)));
}
- public void setResponseStatusCode(int code) {
+ protected void setResponseStatusCode(int code) {
String statusCode;
if (Response.Status.Family.familyOf(code).equals(Response.Status.Family.SUCCESSFUL)) {
statusCode = ONAPLogConstants.ResponseStatus.COMPLETE.toString();
MDC.put(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE, statusCode);
}
- public void setTargetEntity(ONAPComponentsList targetEntity) {
+ protected void setTargetEntity(ONAPComponents targetEntity) {
MDC.put(ONAPLogConstants.MDCs.TARGET_ENTITY, targetEntity.toString());
}
- public void clearClientMDCs() {
+ protected void clearClientMDCs() {
MDC.remove(ONAPLogConstants.MDCs.INVOCATION_ID);
MDC.remove(ONAPLogConstants.MDCs.RESPONSE_DESCRIPTION);
MDC.remove(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE);
MDC.remove(ONAPLogConstants.MDCs.ERROR_DESC);
}
- public void setResponseDescription(int statusCode) {
+ protected void setResponseDescription(int statusCode) {
MDC.put(ONAPLogConstants.MDCs.RESPONSE_DESCRIPTION, Response.Status.fromStatusCode(statusCode).toString());
}
- public void setErrorCode(int statusCode) {
+ protected void setErrorCode(int statusCode) {
MDC.put(ONAPLogConstants.MDCs.ERROR_CODE, String.valueOf(statusCode));
}
- public void setErrorDesc(int statusCode) {
+ protected void setErrorDesc(int statusCode) {
MDC.put(ONAPLogConstants.MDCs.ERROR_DESC, Response.Status.fromStatusCode(statusCode).toString());
}
+ protected String getProperty(String property) {
+ logger.info("Checking for system property [{}]", property);
+ String propertyValue = System.getProperty(property);
+ if (propertyValue == null || propertyValue.isEmpty()) {
+ logger.info("System property was null or empty. Checking environment variable for: {}", property);
+ propertyValue = System.getenv(property);
+ if (propertyValue == null || propertyValue.isEmpty()) {
+ logger.info("Environment variable: {} was null or empty. Returning value: {}", property,
+ Constants.DefaultValues.UNKNOWN);
+ propertyValue = Constants.DefaultValues.UNKNOWN;
+ }
+ }
+ return propertyValue;
+ }
}
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - Logging
+ * ================================================================================
+ * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.logging.filter.base;
+
+import java.time.ZoneOffset;
+import java.time.ZonedDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.UUID;
+import org.onap.logging.ref.slf4j.ONAPLogConstants;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.slf4j.MDC;
+import org.slf4j.Marker;
+import org.slf4j.MarkerFactory;
+
+public abstract class AbstractMetricLogFilter<Request, Response, RequestHeaders> extends AbstractFilter {
+ protected static final Logger logger = LoggerFactory.getLogger(AbstractMetricLogFilter.class);
+ private final String partnerName;
+ private static final Marker INVOKE_RETURN = MarkerFactory.getMarker("INVOKE-RETURN");
+
+ public AbstractMetricLogFilter() {
+ partnerName = getPartnerName();
+ }
+
+ protected abstract void addHeader(RequestHeaders requestHeaders, String headerName, String headerValue);
+
+ protected abstract String getTargetServiceName(Request request);
+
+ protected abstract String getServiceName(Request request);
+
+ protected abstract int getHttpStatusCode(Response response);
+
+ protected abstract String getResponseCode(Response response);
+
+ protected abstract String getTargetEntity(Request request);
+
+ protected void pre(Request request, RequestHeaders requestHeaders) {
+ try {
+ setupMDC(request);
+ setupHeaders(request, requestHeaders);
+ logger.info(ONAPLogConstants.Markers.INVOKE, "Invoke");
+ } catch (Exception e) {
+ logger.warn("Error in AbstractMetricLogFilter pre", e);
+ }
+ }
+
+ protected void setupHeaders(Request clientRequest, RequestHeaders requestHeaders) {
+ String requestId = extractRequestID();
+ addHeader(requestHeaders, ONAPLogConstants.Headers.REQUEST_ID, requestId);
+ addHeader(requestHeaders, Constants.HttpHeaders.HEADER_REQUEST_ID, requestId);
+ addHeader(requestHeaders, Constants.HttpHeaders.TRANSACTION_ID, requestId);
+ addHeader(requestHeaders, Constants.HttpHeaders.ECOMP_REQUEST_ID, requestId);
+ addHeader(requestHeaders, ONAPLogConstants.Headers.INVOCATION_ID, MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID));
+ addHeader(requestHeaders, ONAPLogConstants.Headers.PARTNER_NAME, partnerName);
+ }
+
+ protected void setupMDC(Request request) {
+ MDC.put(ONAPLogConstants.MDCs.INVOKE_TIMESTAMP,
+ ZonedDateTime.now(ZoneOffset.UTC).format(DateTimeFormatter.ISO_INSTANT));
+ MDC.put(ONAPLogConstants.MDCs.TARGET_SERVICE_NAME, getTargetServiceName(request));
+ MDC.put(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE, ONAPLogConstants.ResponseStatus.INPROGRESS.toString());
+ setInvocationIdFromMDC();
+
+ if (MDC.get(ONAPLogConstants.MDCs.TARGET_ENTITY) == null) {
+ String targetEntity = getTargetEntity(request);
+ if (targetEntity != null) {
+ MDC.put(ONAPLogConstants.MDCs.TARGET_ENTITY, targetEntity);
+ } else {
+ MDC.put(ONAPLogConstants.MDCs.TARGET_ENTITY, Constants.DefaultValues.UNKNOWN_TARGET_ENTITY);
+ }
+ }
+
+ if (MDC.get(ONAPLogConstants.MDCs.SERVICE_NAME) == null) {
+ MDC.put(ONAPLogConstants.MDCs.SERVICE_NAME, getServiceName(request));
+ }
+ setServerFQDN();
+ }
+
+ protected String extractRequestID() {
+ String requestId = MDC.get(ONAPLogConstants.MDCs.REQUEST_ID);
+ if (requestId == null || requestId.isEmpty()) {
+ requestId = UUID.randomUUID().toString();
+ setLogTimestamp();
+ setElapsedTimeInvokeTimestamp();
+ logger.warn("No value found in MDC when checking key {} value will be set to {}",
+ ONAPLogConstants.MDCs.REQUEST_ID, requestId);
+ MDC.put(ONAPLogConstants.MDCs.REQUEST_ID, requestId);
+ }
+ return requestId;
+ }
+
+ protected void post(Request request, Response response) {
+ try {
+ setLogTimestamp();
+ setElapsedTimeInvokeTimestamp();
+ setResponseStatusCode(getHttpStatusCode(response));
+ setResponseDescription(getHttpStatusCode(response));
+ MDC.put(ONAPLogConstants.MDCs.RESPONSE_CODE, getResponseCode(response));
+ logger.info(INVOKE_RETURN, "InvokeReturn");
+ clearClientMDCs();
+ } catch (Exception e) {
+ logger.warn("Error in AbstractMetricLogFilter post", e);
+ }
+ }
+
+ protected String getPartnerName() {
+ return getProperty(Constants.Property.PARTNER_NAME);
+ }
+
+}
@Context
private Providers providers;
- private MDCSetup mdcSetup = new MDCSetup();
-
@Override
public void filter(ContainerRequestContext containerRequest) {
SimpleMap headers = new SimpleJaxrsHeadersMap(containerRequest.getHeaders());
- pre(mdcSetup, headers, containerRequest, httpServletRequest);
+ pre(headers, containerRequest, httpServletRequest);
}
@Override
public void filter(ContainerRequestContext requestContext, ContainerResponseContext responseContext)
throws IOException {
- post(mdcSetup, responseContext);
+ post(responseContext);
}
@Override
@Override
public void doFilter(final ServletRequest request, final ServletResponse response, final FilterChain filterChain)
throws IOException, ServletException {
- MDCSetup mdcSetup = new MDCSetup();
try {
if (request != null && request instanceof HttpServletRequest) {
- pre((HttpServletRequest) request, mdcSetup);
+ pre((HttpServletRequest) request);
}
filterChain.doFilter(request, response);
} finally {
if (request != null && request instanceof HttpServletRequest) {
- post((HttpServletRequest) request, (HttpServletResponse) response, mdcSetup);
+ post((HttpServletRequest) request, (HttpServletResponse) response);
}
MDC.clear();
}
// this method does nothing
}
- protected void pre(HttpServletRequest request, MDCSetup mdcSetup) {
+ protected void pre(HttpServletRequest request) {
SimpleMap headers = new SimpleServletHeadersMap(request);
- pre(mdcSetup, headers, request, request);
+ pre(headers, request, request);
}
@Override
MDC.put(ONAPLogConstants.MDCs.SERVICE_NAME, request.getRequestURI());
}
- private void post(HttpServletRequest request, HttpServletResponse response, MDCSetup mdcSetup) {
- post(mdcSetup, response);
+ private void post(HttpServletRequest request, HttpServletResponse response) {
+ post(response);
}
@Override
package org.onap.logging.filter.base;
-import java.time.ZoneOffset;
-import java.time.ZonedDateTime;
-import java.time.format.DateTimeFormatter;
-import java.util.UUID;
import javax.annotation.Priority;
import javax.ws.rs.client.ClientRequestContext;
import javax.ws.rs.client.ClientRequestFilter;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.MultivaluedMap;
import javax.ws.rs.ext.Providers;
-import org.onap.logging.ref.slf4j.ONAPLogConstants;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.slf4j.MDC;
-import org.slf4j.Marker;
-import org.slf4j.MarkerFactory;
@Priority(0)
-public class MetricLogClientFilter implements ClientRequestFilter, ClientResponseFilter {
+public class MetricLogClientFilter
+ extends AbstractMetricLogFilter<ClientRequestContext, ClientResponseContext, MultivaluedMap<String, Object>>
+ implements ClientRequestFilter, ClientResponseFilter {
@Context
private Providers providers;
- private MDCSetup mdcSetup = new MDCSetup();
- private static final String TRACE = "trace-#";
- private static Logger logger = LoggerFactory.getLogger(MetricLogClientFilter.class);
- private final String partnerName;
- private static final Marker INVOKE_RETURN = MarkerFactory.getMarker("INVOKE-RETURN");
- public MetricLogClientFilter() {
- partnerName = getPartnerName();
+ @Override
+ public void filter(ClientRequestContext clientRequest) {
+ pre(clientRequest, clientRequest.getHeaders());
}
@Override
- public void filter(ClientRequestContext clientRequest) {
- try {
- setupMDC(clientRequest);
- setupHeaders(clientRequest);
- logger.info(ONAPLogConstants.Markers.INVOKE, "Invoke");
- } catch (Exception e) {
- logger.warn("Error in JAX-RS client request filter", e);
- }
+ public void filter(ClientRequestContext requestContext, ClientResponseContext responseContext) {
+ post(requestContext, responseContext);
}
- protected void setupHeaders(ClientRequestContext clientRequest) {
- MultivaluedMap<String, Object> headers = clientRequest.getHeaders();
- String requestId = extractRequestID(clientRequest);
- headers.add(ONAPLogConstants.Headers.REQUEST_ID, requestId);
- headers.add(Constants.HttpHeaders.HEADER_REQUEST_ID, requestId);
- headers.add(Constants.HttpHeaders.TRANSACTION_ID, requestId);
- headers.add(Constants.HttpHeaders.ECOMP_REQUEST_ID, requestId);
- headers.add(ONAPLogConstants.Headers.INVOCATION_ID, MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID));
- headers.add(ONAPLogConstants.Headers.PARTNER_NAME, partnerName);
+ @Override
+ protected void addHeader(MultivaluedMap<String, Object> requestHeaders, String headerName, String headerValue) {
+ requestHeaders.add(headerName, headerValue);
}
- protected void setupMDC(ClientRequestContext clientRequest) {
- MDC.put(ONAPLogConstants.MDCs.INVOKE_TIMESTAMP,
- ZonedDateTime.now(ZoneOffset.UTC).format(DateTimeFormatter.ISO_INSTANT));
- MDC.put(ONAPLogConstants.MDCs.TARGET_SERVICE_NAME, clientRequest.getUri().toString());
- MDC.put(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE, ONAPLogConstants.ResponseStatus.INPROGRESS.toString());
- mdcSetup.setInvocationIdFromMDC();
- String targetEntity = MDC.get(ONAPLogConstants.MDCs.TARGET_ENTITY);
- if (targetEntity != null) {
- MDC.put(ONAPLogConstants.MDCs.TARGET_ENTITY, targetEntity);
- } else {
- MDC.put(ONAPLogConstants.MDCs.TARGET_ENTITY, Constants.DefaultValues.UNKNOWN_TARGET_ENTITY);
- }
- if (MDC.get(ONAPLogConstants.MDCs.SERVICE_NAME) == null) {
- MDC.put(ONAPLogConstants.MDCs.SERVICE_NAME, clientRequest.getUri().getPath());
- }
- mdcSetup.setServerFQDN();
+ @Override
+ protected String getTargetServiceName(ClientRequestContext request) {
+ return request.getUri().toString();
}
- protected String extractRequestID(ClientRequestContext clientRequest) {
- String requestId = MDC.get(ONAPLogConstants.MDCs.REQUEST_ID);
- if (requestId == null || requestId.isEmpty() || requestId.equals(TRACE)) {
- requestId = UUID.randomUUID().toString();
- mdcSetup.setLogTimestamp();
- mdcSetup.setElapsedTimeInvokeTimestamp();
- logger.warn("Could not Find Request ID Generating New One: {}", clientRequest.getUri().getPath());
- MDC.put(ONAPLogConstants.MDCs.REQUEST_ID, requestId);
- }
- return requestId;
+ @Override
+ protected String getServiceName(ClientRequestContext request) {
+ return request.getUri().getPath();
}
@Override
- public void filter(ClientRequestContext requestContext, ClientResponseContext responseContext) {
- try {
- mdcSetup.setLogTimestamp();
- mdcSetup.setElapsedTimeInvokeTimestamp();
- mdcSetup.setResponseStatusCode(responseContext.getStatus());
- mdcSetup.setResponseDescription(responseContext.getStatus());
- MDC.put(ONAPLogConstants.MDCs.RESPONSE_CODE, String.valueOf(responseContext.getStatus()));
- logger.info(INVOKE_RETURN, "InvokeReturn");
- mdcSetup.clearClientMDCs();
- } catch (Exception e) {
- logger.warn("Error in JAX-RS request,response client filter", e);
- }
+ protected int getHttpStatusCode(ClientResponseContext response) {
+ return response.getStatus();
+ }
+
+ @Override
+ protected String getResponseCode(ClientResponseContext response) {
+ return String.valueOf(response.getStatus());
}
- protected String getPartnerName() {
- PropertyUtil p = new PropertyUtil();
- return p.getProperty(Constants.Property.PARTNER_NAME);
+ @Override
+ protected String getTargetEntity(ClientRequestContext request) {
+ return Constants.DefaultValues.UNKNOWN_TARGET_ENTITY;
}
+
}
this.maxEntitySize = Integer.min(maxPayloadSize, 1024 * 1024);
}
- private void log(StringBuilder sb) {
- logger.debug(sb.toString());
- }
-
protected InputStream logInboundEntity(final StringBuilder b, InputStream stream, final Charset charset)
throws IOException {
if (!stream.markSupported()) {
requestContext.setProperty(ENTITY_STREAM_PROPERTY, stream);
}
String method = formatMethod(requestContext);
- log(new StringBuilder("Making " + method + " request to: " + requestContext.getUri() + "\nRequest Headers: "
- + getHeaders(requestContext.getHeaders())));
-
+ logger.debug("Sending HTTP {} to:{} with request headers:{}", method, requestContext.getUri(),
+ getHeaders(requestContext.getHeaders()));
}
protected String getHeaders(MultivaluedMap<String, Object> headers) {
final StringBuilder sb = new StringBuilder();
if (responseContext.hasEntity()) {
responseContext.setEntityStream(logInboundEntity(sb, responseContext.getEntityStream(), DEFAULT_CHARSET));
- String method = formatMethod(requestContext);
- log(sb.insert(0, "Response from " + method + ": " + requestContext.getUri() + "\nResponse Headers: "
- + responseContext.getHeaders().toString()));
}
+ String method = formatMethod(requestContext);
+ logger.debug("Response from method:{} performed on uri:{} has http status code:{} and response headers:{}",
+ method, requestContext.getUri(), responseContext.getStatus(), responseContext.getHeaders().toString());
}
@Override
final LoggingStream stream = (LoggingStream) context.getProperty(ENTITY_STREAM_PROPERTY);
context.proceed();
if (stream != null) {
- log(stream.getStringBuilder(DEFAULT_CHARSET));
+ logger.debug(stream.getStringBuilder(DEFAULT_CHARSET).toString());
}
}
requestHeaders.append(":");
requestHeaders.append(httpRequest.getRequestURL().toString());
requestHeaders.append("|");
- String header;
- for (Enumeration<String> e = httpRequest.getHeaderNames(); e.hasMoreElements();) {
- header = e.nextElement();
- requestHeaders.append(header);
- requestHeaders.append(":");
- if (header.equalsIgnoreCase(HttpHeaders.AUTHORIZATION)) {
- requestHeaders.append(REDACTED);
- } else {
- requestHeaders.append(httpRequest.getHeader(header));
- }
- requestHeaders.append(";");
- }
+ requestHeaders.append(getSecureRequestHeaders(httpRequest));
log.info(requestHeaders.toString());
log.info("REQUEST BODY|" + new String(bufferedRequest.getBuffer()));
try {
byte[] bytes = baos.toByteArray();
StringBuilder responseHeaders = new StringBuilder("RESPONSE HEADERS|");
-
- for (String headerName : response.getHeaderNames()) {
- responseHeaders.append(headerName);
- responseHeaders.append(":");
- responseHeaders.append(response.getHeader(headerName));
- responseHeaders.append(";");
- }
+ responseHeaders.append(formatResponseHeaders(response));
responseHeaders.append("Status:");
responseHeaders.append(response.getStatus());
responseHeaders.append(";IsCommited:" + wrappedResp.isCommitted());
}
return str.toString();
}
+
+ protected String getSecureRequestHeaders(HttpServletRequest httpRequest) {
+ StringBuilder sb = new StringBuilder();
+ String header;
+ for (Enumeration<String> e = httpRequest.getHeaderNames(); e.hasMoreElements();) {
+ header = e.nextElement();
+ sb.append(header);
+ sb.append(":");
+ if (header.equalsIgnoreCase(HttpHeaders.AUTHORIZATION)) {
+ sb.append(REDACTED);
+ } else {
+ sb.append(httpRequest.getHeader(header));
+ }
+ sb.append(";");
+ }
+ return sb.toString();
+ }
+
+ protected String formatResponseHeaders(HttpServletResponse response) {
+ StringBuilder sb = new StringBuilder();
+ for (String headerName : response.getHeaderNames()) {
+ sb.append(headerName);
+ sb.append(":");
+ sb.append(response.getHeader(headerName));
+ sb.append(";");
+ }
+ return sb.toString();
+ }
}
+++ /dev/null
-/*-
- * ============LICENSE_START=======================================================
- * ONAP - Logging
- * ================================================================================
- * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.onap.logging.filter.base;
-
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class PropertyUtil {
- private final Logger logger = LoggerFactory.getLogger(this.getClass());
-
- public String getProperty(String property) {
- logger.info("Checking for system property [{}]", property);
- String propertyValue = System.getProperty(property);
- if (propertyValue == null || propertyValue.isEmpty()) {
- logger.info("System property was null or empty. Checking environment variable for: {}", property);
- propertyValue = System.getenv(property);
- if (propertyValue == null || propertyValue.isEmpty()) {
- logger.info("Environment variable: {} was null or empty. Returning value: {}", property,
- Constants.DefaultValues.UNKNOWN);
- propertyValue = Constants.DefaultValues.UNKNOWN;
- }
- }
- return propertyValue;
- }
-}
import org.junit.After;
import org.junit.Test;
import org.junit.runner.RunWith;
-import org.mockito.InjectMocks;
import org.mockito.Mock;
-import org.mockito.Spy;
import org.mockito.junit.MockitoJUnitRunner;
-import org.onap.logging.filter.base.Constants;
-import org.onap.logging.filter.base.MDCSetup;
-import org.onap.logging.filter.base.ONAPComponents;
-import org.onap.logging.filter.base.SimpleHashMap;
-import org.onap.logging.filter.base.SimpleJaxrsHeadersMap;
-import org.onap.logging.filter.base.SimpleMap;
import org.onap.logging.ref.slf4j.ONAPLogConstants;
import org.slf4j.MDC;
@RunWith(MockitoJUnitRunner.class)
-public class MDCSetupTest {
+public class AbstractFilterTest extends AbstractFilter {
@Mock
private HttpServletRequest httpServletRequest;
- @Spy
- @InjectMocks
- private MDCSetup mdcSetup = new MDCSetup();
-
private String requestId = "4d31fe02-4918-4975-942f-fe51a44e6a9b";
private String invocationId = "4d31fe02-4918-4975-942f-fe51a44e6a9a";
@After
public void tearDown() {
MDC.clear();
+ System.clearProperty("partnerName");
}
@Test
MDC.put(ONAPLogConstants.MDCs.ENTRY_TIMESTAMP, "2019-06-18T02:09:06.024Z");
MDC.put(ONAPLogConstants.MDCs.LOG_TIMESTAMP, "2019-06-18T02:09:06.342Z");
- mdcSetup.setElapsedTime();
+ setElapsedTime();
assertEquals(expected, MDC.get(ONAPLogConstants.MDCs.ELAPSED_TIME));
}
MDC.put(ONAPLogConstants.MDCs.INVOKE_TIMESTAMP, "2019-06-18T02:09:06.024Z");
MDC.put(ONAPLogConstants.MDCs.LOG_TIMESTAMP, "2019-06-18T02:09:06.342Z");
- mdcSetup.setElapsedTimeInvokeTimestamp();
+ setElapsedTimeInvokeTimestamp();
assertEquals(expected, MDC.get(ONAPLogConstants.MDCs.ELAPSED_TIME));
}
public void setRequestIdTest() {
HashMap<String, String> headers = new HashMap<>();
headers.put(ONAPLogConstants.Headers.REQUEST_ID, requestId);
- String fetchedRequestId = mdcSetup.getRequestId(new SimpleHashMap(headers));
+ String fetchedRequestId = getRequestId(new SimpleHashMap(headers));
assertEquals(requestId, fetchedRequestId);
}
public void setRequestIdRequestIdHeaderTest() {
HashMap<String, String> headers = new HashMap<>();
headers.put(Constants.HttpHeaders.HEADER_REQUEST_ID, requestId);
- String fetchedRequestId = mdcSetup.getRequestId(new SimpleHashMap(headers));
+ String fetchedRequestId = getRequestId(new SimpleHashMap(headers));
assertEquals(requestId, fetchedRequestId);
}
public void setRequestIdTransactionIdHeaderTest() {
HashMap<String, String> headers = new HashMap<>();
headers.put(Constants.HttpHeaders.TRANSACTION_ID, requestId);
- String fetchedRequestId = mdcSetup.getRequestId(new SimpleHashMap(headers));
+ String fetchedRequestId = getRequestId(new SimpleHashMap(headers));
assertEquals(requestId, fetchedRequestId);
}
public void setRequestIdEcompRequestIdHeaderTest() {
HashMap<String, String> headers = new HashMap<>();
headers.put(Constants.HttpHeaders.ECOMP_REQUEST_ID, requestId);
- String fetchedRequestId = mdcSetup.getRequestId(new SimpleHashMap(headers));
+ String fetchedRequestId = getRequestId(new SimpleHashMap(headers));
assertEquals(requestId, fetchedRequestId);
}
@Test
public void setRequestIdNoHeaderTest() {
HashMap<String, String> headers = new HashMap<>();
- String fetchedRequestId = mdcSetup.getRequestId(new SimpleHashMap(headers));
+ String fetchedRequestId = getRequestId(new SimpleHashMap(headers));
assertNotNull(fetchedRequestId);
}
public void setInvocationIdTest() {
HashMap<String, String> headers = new HashMap<>();
headers.put(ONAPLogConstants.Headers.INVOCATION_ID, invocationId);
- mdcSetup.setInvocationId(new SimpleHashMap(headers));
+ setInvocationId(new SimpleHashMap(headers));
assertEquals(invocationId, MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID));
}
@Test
public void setInvocationIdNoHeaderTest() {
HashMap<String, String> headers = new HashMap<>();
- mdcSetup.setInvocationId(new SimpleHashMap(headers));
+ setInvocationId(new SimpleHashMap(headers));
assertNotNull(MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID));
}
@Test
public void setInvovationIdFromMDCTest() {
MDC.put(ONAPLogConstants.MDCs.INVOCATION_ID, "7b77143c-9b50-410c-ac2f-05758a68e3e8");
- mdcSetup.setInvocationIdFromMDC();
+ setInvocationIdFromMDC();
assertEquals("7b77143c-9b50-410c-ac2f-05758a68e3e8", MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID));
}
@Test
public void setInvocationIdFromMDCNoInvocationIdTest() {
- mdcSetup.setInvocationIdFromMDC();
+ setInvocationIdFromMDC();
// InvocationId is set to a random UUID
assertNotNull(MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID));
}
@Test
public void setResponseStatusCodeTest() {
- mdcSetup.setResponseStatusCode(200);
+ setResponseStatusCode(200);
assertEquals("COMPLETE", MDC.get(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE));
}
@Test
public void setResponseStatusCodeErrorTest() {
- mdcSetup.setResponseStatusCode(400);
+ setResponseStatusCode(400);
assertEquals("ERROR", MDC.get(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE));
assertEquals("400", MDC.get(ONAPLogConstants.MDCs.ERROR_CODE));
assertEquals("Bad Request", MDC.get(ONAPLogConstants.MDCs.ERROR_DESC));
MDC.put(ONAPLogConstants.MDCs.TARGET_SERVICE_NAME, "SDNC");
MDC.put(ONAPLogConstants.MDCs.INVOKE_TIMESTAMP, "2019-06-18T02:09:06.024Z");
- mdcSetup.clearClientMDCs();
+ clearClientMDCs();
assertNull(MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID));
assertNull(MDC.get(ONAPLogConstants.MDCs.RESPONSE_DESCRIPTION));
assertNull(MDC.get(ONAPLogConstants.MDCs.ERROR_CODE));
@Test
public void setTargetEntityTest() {
- mdcSetup.setTargetEntity(ONAPComponents.SO);
+ setTargetEntity(ONAPComponents.SO);
assertEquals("SO", MDC.get(ONAPLogConstants.MDCs.TARGET_ENTITY));
}
@Test
public void setResponseDescriptionTest() {
- mdcSetup.setResponseDescription(502);
+ setResponseDescription(502);
assertEquals("Bad Gateway", MDC.get(ONAPLogConstants.MDCs.RESPONSE_DESCRIPTION));
}
headerMap.putSingle(ONAPLogConstants.Headers.PARTNER_NAME, "SO");
SimpleMap headers = new SimpleJaxrsHeadersMap(headerMap);
- mdcSetup.setMDCPartnerName(headers);
+ setMDCPartnerName(headers);
assertEquals("SO", MDC.get(ONAPLogConstants.MDCs.PARTNER_NAME));
}
headerMap.putSingle(HttpHeaders.USER_AGENT, "Apache-HttpClient/4.5.8 (Java/1.8.0_191)");
SimpleMap headers = new SimpleJaxrsHeadersMap(headerMap);
- mdcSetup.setMDCPartnerName(headers);
+ setMDCPartnerName(headers);
assertEquals("Apache-HttpClient/4.5.8 (Java/1.8.0_191)", MDC.get(ONAPLogConstants.MDCs.PARTNER_NAME));
}
headerMap.putSingle(Constants.HttpHeaders.CLIENT_ID, "SO");
SimpleMap headers = new SimpleJaxrsHeadersMap(headerMap);
- mdcSetup.setMDCPartnerName(headers);
+ setMDCPartnerName(headers);
assertEquals("SO", MDC.get(ONAPLogConstants.MDCs.PARTNER_NAME));
}
MultivaluedMap<String, String> headerMap = new MultivaluedHashMap<>();
SimpleMap headers = new SimpleJaxrsHeadersMap(headerMap);
- mdcSetup.setMDCPartnerName(headers);
+ setMDCPartnerName(headers);
assertEquals("UNKNOWN", MDC.get(ONAPLogConstants.MDCs.PARTNER_NAME));
}
@Test
public void setServerFQDNTest() {
- mdcSetup.setServerFQDN();
+ setServerFQDN();
assertNotNull(MDC.get(ONAPLogConstants.MDCs.SERVER_IP_ADDRESS));
assertNotNull(MDC.get(ONAPLogConstants.MDCs.SERVER_FQDN));
}
@Test
public void setClientIPAddressTest() {
when(httpServletRequest.getHeader("X-Forwarded-For")).thenReturn("127.0.0.2");
- mdcSetup.setClientIPAddress(httpServletRequest);
+ setClientIPAddress(httpServletRequest);
assertEquals("127.0.0.2", MDC.get(ONAPLogConstants.MDCs.CLIENT_IP_ADDRESS));
}
@Test
public void setClientIPAddressNoHeaderTest() {
when(httpServletRequest.getRemoteAddr()).thenReturn("127.0.0.1");
- mdcSetup.setClientIPAddress(httpServletRequest);
+ setClientIPAddress(httpServletRequest);
assertEquals("127.0.0.1", MDC.get(ONAPLogConstants.MDCs.CLIENT_IP_ADDRESS));
}
@Test
public void setClientIPAddressNullTest() {
- mdcSetup.setClientIPAddress(null);
+ setClientIPAddress(null);
assertEquals("", MDC.get(ONAPLogConstants.MDCs.CLIENT_IP_ADDRESS));
}
@Test
public void setEntryTimeStampTest() {
- mdcSetup.setEntryTimeStamp();
+ setEntryTimeStamp();
assertNotNull(MDC.get(ONAPLogConstants.MDCs.ENTRY_TIMESTAMP));
}
@Test
public void setLogTimestampTest() {
- mdcSetup.setLogTimestamp();
+ setLogTimestamp();
assertNotNull(MDC.get(ONAPLogConstants.MDCs.LOG_TIMESTAMP));
}
@Test
public void setInstanceIDTest() {
- mdcSetup.setInstanceID();
+ setInstanceID();
assertNotNull(MDC.get(ONAPLogConstants.MDCs.INSTANCE_UUID));
}
@Test
- public void setServiceNameTest() {
- String requestUri = "onap/so/serviceInstances";
- when(httpServletRequest.getRequestURI()).thenReturn(requestUri);
- mdcSetup.setServiceName(httpServletRequest);
+ public void getPropertyTest() {
+ System.setProperty("partnerName", "partnerName");
- assertEquals("onap/so/serviceInstances", MDC.get(ONAPLogConstants.MDCs.SERVICE_NAME));
+ String partnerName = getProperty("partnerName");
+ assertEquals("partnerName", partnerName);
}
+
+ @Test
+ public void getPropertyNullTest() {
+ String partnerName = getProperty("partner");
+ assertEquals("UNKNOWN", partnerName);
+ }
+
}
package org.onap.logging.filter.base;
import static org.junit.Assert.assertEquals;
-import static org.mockito.ArgumentMatchers.any;
-import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.when;
import javax.ws.rs.container.ContainerRequestContext;
import javax.ws.rs.container.ContainerResponseContext;
+import javax.ws.rs.core.MultivaluedHashMap;
+import javax.ws.rs.core.MultivaluedMap;
import javax.ws.rs.core.UriInfo;
import org.junit.After;
import org.junit.Test;
import org.mockito.Mock;
import org.mockito.Spy;
import org.mockito.junit.MockitoJUnitRunner;
-import org.onap.logging.filter.base.AuditLogContainerFilter;
-import org.onap.logging.filter.base.MDCSetup;
-import org.onap.logging.filter.base.SimpleMap;
import org.onap.logging.ref.slf4j.ONAPLogConstants;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.slf4j.MDC;
@RunWith(MockitoJUnitRunner.class)
public class AuditLogContainerFilterTest {
+ protected static final Logger logger = LoggerFactory.getLogger(AbstractMetricLogFilter.class);
@Mock
private ContainerRequestContext containerRequest;
@Mock
private ContainerResponseContext containerResponse;
- @Mock
- private MDCSetup mdcSetup;
-
@Mock
private UriInfo uriInfo;
MDC.clear();
}
+
@Test
public void filterTest() {
- when(mdcSetup.getRequestId(any(SimpleMap.class))).thenReturn("e3b08fa3-535f-4c1b-8228-91318d2bb4ee");
+ MultivaluedMap<String, String> headerMap = new MultivaluedHashMap<>();
+ headerMap.putSingle(ONAPLogConstants.Headers.REQUEST_ID, "e3b08fa3-535f-4c1b-8228-91318d2bb4ee");
+ when(containerRequest.getHeaders()).thenReturn(headerMap);
when(uriInfo.getPath()).thenReturn("onap/so/serviceInstances");
- doReturn(uriInfo).when(containerRequest).getUriInfo();
+ when(containerRequest.getUriInfo()).thenReturn(uriInfo);
auditLogContainerFilter.filter(containerRequest);
assertEquals("e3b08fa3-535f-4c1b-8228-91318d2bb4ee", MDC.get(ONAPLogConstants.MDCs.REQUEST_ID));
package org.onap.logging.filter.base;
import static org.junit.Assert.assertEquals;
-import static org.mockito.ArgumentMatchers.any;
+import static org.junit.Assert.assertNotNull;
import static org.mockito.Mockito.when;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import org.mockito.Mock;
import org.mockito.Spy;
import org.mockito.junit.MockitoJUnitRunner;
-import org.onap.logging.filter.base.AuditLogServletFilter;
-import org.onap.logging.filter.base.MDCSetup;
-import org.onap.logging.filter.base.SimpleMap;
import org.onap.logging.ref.slf4j.ONAPLogConstants;
import org.slf4j.MDC;
@Mock
private ServletResponse response;
- @Mock
- private MDCSetup mdcSetup;
-
@Mock
private HttpServletRequest servletRequest;
@Test
public void preTest() {
- when(mdcSetup.getRequestId(any(SimpleMap.class))).thenReturn("e3b08fa3-535f-4c1b-8228-91318d2bb4ee");
when(servletRequest.getRequestURI()).thenReturn("onap/so/serviceInstances");
- auditLogServletFilter.pre(servletRequest, mdcSetup);
+ auditLogServletFilter.pre(servletRequest);
- assertEquals("e3b08fa3-535f-4c1b-8228-91318d2bb4ee", MDC.get(ONAPLogConstants.MDCs.REQUEST_ID));
+ assertNotNull(MDC.get(ONAPLogConstants.MDCs.REQUEST_ID));
assertEquals("onap/so/serviceInstances", MDC.get(ONAPLogConstants.MDCs.SERVICE_NAME));
assertEquals("INPROGRESS", MDC.get(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE));
}
assertEquals(200, responseCode);
}
+
}
import javax.ws.rs.core.MultivaluedHashMap;
import javax.ws.rs.core.MultivaluedMap;
import org.junit.Test;
-import org.onap.logging.filter.base.SimpleJaxrsHeadersMap;
-import org.onap.logging.filter.base.SimpleMap;
import org.onap.logging.ref.slf4j.ONAPLogConstants;
public class LoggingContainerFilterTest {
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.mockito.Mockito.doReturn;
-import static org.mockito.Mockito.when;
import java.net.URI;
import java.net.URISyntaxException;
+import java.time.ZoneOffset;
+import java.time.ZonedDateTime;
+import java.time.format.DateTimeFormatter;
import javax.ws.rs.client.ClientRequestContext;
import javax.ws.rs.core.MultivaluedHashMap;
import javax.ws.rs.core.MultivaluedMap;
import org.mockito.Mock;
import org.mockito.Spy;
import org.mockito.junit.MockitoJUnitRunner;
-import org.onap.logging.filter.base.Constants;
-import org.onap.logging.filter.base.MDCSetup;
-import org.onap.logging.filter.base.MetricLogClientFilter;
import org.onap.logging.ref.slf4j.ONAPLogConstants;
import org.slf4j.MDC;
@RunWith(MockitoJUnitRunner.class)
public class MetricLogClientFilterTest {
-
- @Mock
- private MDCSetup mdcSetup;
-
@Mock
private ClientRequestContext clientRequest;
public void setupHeadersTest() {
MDC.put(ONAPLogConstants.MDCs.INVOCATION_ID, "8819bfb4-69d2-43fc-b0d6-81d2690533ea");
MultivaluedMap<String, Object> headers = new MultivaluedHashMap<>();
- when(clientRequest.getHeaders()).thenReturn(headers);
- doReturn("0a908a5d-e774-4558-96ff-6edcbba65483").when(metricLogClientFilter).extractRequestID(clientRequest);
+ doReturn("0a908a5d-e774-4558-96ff-6edcbba65483").when(metricLogClientFilter).extractRequestID();
- metricLogClientFilter.setupHeaders(clientRequest);
+ metricLogClientFilter.setupHeaders(clientRequest, headers);
assertEquals("0a908a5d-e774-4558-96ff-6edcbba65483", headers.getFirst(ONAPLogConstants.Headers.REQUEST_ID));
assertEquals("0a908a5d-e774-4558-96ff-6edcbba65483", headers.getFirst(Constants.HttpHeaders.HEADER_REQUEST_ID));
@Test
public void setupMDCTest() throws URISyntaxException {
+ // TODO ingest change from upstream
MDC.put(ONAPLogConstants.MDCs.TARGET_ENTITY, "SO");
URI uri = new URI("onap/so/serviceInstances");
doReturn(uri).when(clientRequest).getUri();
@Test
public void extractRequestIDTest() {
MDC.put(ONAPLogConstants.MDCs.REQUEST_ID, "0a908a5d-e774-4558-96ff-6edcbba65483");
- String requestId = metricLogClientFilter.extractRequestID(clientRequest);
+ String requestId = metricLogClientFilter.extractRequestID();
assertEquals("0a908a5d-e774-4558-96ff-6edcbba65483", requestId);
}
@Test
public void extractRequestIDNullTest() throws URISyntaxException {
- URI uri = new URI("onap/so/serviceInstances");
- doReturn(uri).when(clientRequest).getUri();
- String requestId = metricLogClientFilter.extractRequestID(clientRequest);
+ MDC.put(ONAPLogConstants.MDCs.INVOKE_TIMESTAMP,
+ ZonedDateTime.now(ZoneOffset.UTC).format(DateTimeFormatter.ISO_INSTANT));
+ String requestId = metricLogClientFilter.extractRequestID();
assertNotNull(requestId);
assertNotNull(ONAPLogConstants.MDCs.LOG_TIMESTAMP);
assertNotNull(ONAPLogConstants.MDCs.ELAPSED_TIME);
import org.mockito.Mock;
import org.mockito.Spy;
import org.mockito.junit.MockitoJUnitRunner;
-import org.onap.logging.filter.base.Constants;
-import org.onap.logging.filter.base.PayloadLoggingClientFilter;
@RunWith(MockitoJUnitRunner.class)
public class PayloadLoggingClientFilterTest {
+++ /dev/null
-/*-
- * ============LICENSE_START=======================================================
- * ONAP - Logging
- * ================================================================================
- * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.onap.logging.filter.base;
-
-import static org.junit.Assert.assertEquals;
-import org.junit.After;
-import org.junit.Test;
-import org.onap.logging.filter.base.PropertyUtil;
-
-public class PropertyUtilTest {
-
- private PropertyUtil propertyUtil = new PropertyUtil();
-
- @After
- public void tearDown() {
- System.clearProperty("partnerName");
- }
-
- @Test
- public void getPropertyTest() {
- System.setProperty("partnerName", "partnerName");
-
- String partnerName = propertyUtil.getProperty("partnerName");
- assertEquals("partnerName", partnerName);
- }
-
- @Test
- public void getPropertyNullTest() {
- String partnerName = propertyUtil.getProperty("partner");
- assertEquals("UNKNOWN", partnerName);
- }
-}
import javax.ws.rs.core.MultivaluedHashMap;
import javax.ws.rs.core.MultivaluedMap;
import org.junit.Test;
-import org.onap.logging.filter.base.SimpleJaxrsHeadersMap;
-import org.onap.logging.filter.base.SimpleMap;
import org.onap.logging.ref.slf4j.ONAPLogConstants;
public class SimpleJaxrsHeadersMapTest {
import org.mockito.Mock;
import org.mockito.Spy;
import org.mockito.junit.MockitoJUnitRunner;
-import org.onap.logging.filter.base.SimpleServletHeadersMap;
@RunWith(MockitoJUnitRunner.class)
public class SimpleServletHeadersMapTest {
* ============LICENSE_END=========================================================
*/
+
package org.onap.logging.filter.spring;
-import java.util.Collections;
-import java.util.Map;
-import java.util.stream.Collectors;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.ws.rs.core.Context;
import javax.ws.rs.ext.Providers;
-import org.onap.logging.filter.base.MDCSetup;
+import org.onap.logging.filter.base.AbstractAuditLogFilter;
import org.onap.logging.filter.base.SimpleMap;
import org.onap.logging.filter.base.SimpleServletHeadersMap;
import org.onap.logging.ref.slf4j.ONAPLogConstants;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
import org.slf4j.MDC;
import org.springframework.stereotype.Component;
+import org.springframework.web.servlet.HandlerInterceptor;
import org.springframework.web.servlet.ModelAndView;
-import org.springframework.web.servlet.handler.HandlerInterceptorAdapter;
@Component
-public class LoggingInterceptor extends HandlerInterceptorAdapter {
-
- private static final Logger logger = LoggerFactory.getLogger(LoggingInterceptor.class);
-
- private MDCSetup mdcSetup = new MDCSetup();
+public class LoggingInterceptor extends AbstractAuditLogFilter<HttpServletRequest, HttpServletResponse>
+ implements HandlerInterceptor {
@Context
private Providers providers;
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler)
throws Exception {
SimpleMap headers = new SimpleServletHeadersMap(request);
- String requestId = mdcSetup.getRequestId(headers);
- MDC.put(ONAPLogConstants.MDCs.REQUEST_ID, requestId);
- mdcSetup.setInvocationId(headers);
- mdcSetup.setServiceName(request);
- mdcSetup.setMDCPartnerName(headers);
- mdcSetup.setClientIPAddress(request);
- mdcSetup.setEntryTimeStamp();
- mdcSetup.setInstanceID();
- mdcSetup.setServerFQDN();
- MDC.put(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE, ONAPLogConstants.ResponseStatus.INPROGRESS.toString());
- mdcSetup.setLogTimestamp();
- mdcSetup.setElapsedTime();
- logger.info(ONAPLogConstants.Markers.ENTRY, "Entering");
- if (logger.isDebugEnabled())
- logRequestInformation(request);
+ pre(headers, request, request);
return true;
}
- protected void logRequestInformation(HttpServletRequest request) {
- Map<String, String> headers = Collections.list((request).getHeaderNames()).stream()
- .collect(Collectors.toMap(h -> h, request::getHeader));
-
- logger.debug("===========================request begin================================================");
- logger.debug("URI : {}", request.getRequestURI());
- logger.debug("Method : {}", request.getMethod());
- logger.debug("Headers : {}", headers);
- logger.debug("==========================request end================================================");
+ @Override
+ public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler,
+ ModelAndView modelAndView) throws Exception {
+ post(response);
+ }
+ @Override
+ protected int getResponseCode(HttpServletResponse response) {
+ return response.getStatus();
}
@Override
- public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler,
- ModelAndView modelAndView) throws Exception {
- mdcSetup.setResponseStatusCode(response.getStatus());
- mdcSetup.setLogTimestamp();
- mdcSetup.setElapsedTime();
- mdcSetup.setResponseDescription(response.getStatus());
- MDC.put(ONAPLogConstants.MDCs.RESPONSE_CODE, String.valueOf(response.getStatus()));
- logger.info(ONAPLogConstants.Markers.EXIT, "Exiting.");
- MDC.clear();
+ protected void setServiceName(HttpServletRequest request) {
+ MDC.put(ONAPLogConstants.MDCs.SERVICE_NAME, request.getRequestURI());
}
+
}
package org.onap.logging.filter.spring;
import java.io.IOException;
-import java.nio.charset.Charset;
-import java.nio.charset.StandardCharsets;
-import java.time.ZoneOffset;
-import java.time.ZonedDateTime;
-import java.time.format.DateTimeFormatter;
import java.util.List;
-import java.util.UUID;
+import org.onap.logging.filter.base.AbstractMetricLogFilter;
import org.onap.logging.filter.base.Constants;
-import org.onap.logging.filter.base.MDCSetup;
-import org.onap.logging.filter.base.PropertyUtil;
import org.onap.logging.ref.slf4j.ONAPLogConstants;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
import org.slf4j.MDC;
-import org.slf4j.Marker;
-import org.slf4j.MarkerFactory;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpRequest;
import org.springframework.http.client.ClientHttpRequestExecution;
import org.springframework.http.client.ClientHttpRequestInterceptor;
import org.springframework.http.client.ClientHttpResponse;
-import org.springframework.util.StreamUtils;
-public class SpringClientFilter implements ClientHttpRequestInterceptor {
- private final Logger logger = LoggerFactory.getLogger(this.getClass());
- private static final String TRACE = "trace-#";
- private MDCSetup mdcSetup = new MDCSetup();
- private final String partnerName;
- private static final Marker INVOKE_RETURN = MarkerFactory.getMarker("INVOKE-RETURN");
+public class SpringClientFilter extends AbstractMetricLogFilter<HttpRequest, ClientHttpResponse, HttpHeaders>
+ implements ClientHttpRequestInterceptor {
public SpringClientFilter() {
- this.partnerName = getPartnerName();
+
}
@Override
public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution)
throws IOException {
- processRequest(request, body);
+ pre(request, request.getHeaders());
ClientHttpResponse response = execution.execute(request, body);
- processResponse(response);
+ post(request, response);
return response;
}
- protected void processRequest(HttpRequest request, byte[] body) throws IOException {
- mdcSetup.setInvocationIdFromMDC();
- setupMDC(request);
- setupHeaders(request);
- if (logger.isDebugEnabled()) {
- logger.debug("===========================request begin================================================");
- logger.debug("URI : {}", request.getURI());
- logger.debug("Method : {}", request.getMethod());
- logger.debug("Headers : {}", request.getHeaders());
- logger.debug("Request body: {}", new String(body, StandardCharsets.UTF_8));
- logger.debug("==========================request end================================================");
- }
+ @Override
+ protected void addHeader(HttpHeaders requestHeaders, String headerName, String headerValue) {
+ requestHeaders.add(headerName, headerValue);
}
- protected void setupHeaders(HttpRequest clientRequest) {
- HttpHeaders headers = clientRequest.getHeaders();
- String requestId = extractRequestID(clientRequest);
- headers.add(ONAPLogConstants.Headers.REQUEST_ID, requestId);
- headers.add(Constants.HttpHeaders.HEADER_REQUEST_ID, requestId);
- headers.add(Constants.HttpHeaders.TRANSACTION_ID, requestId);
- headers.add(Constants.HttpHeaders.ECOMP_REQUEST_ID, requestId);
- headers.add(ONAPLogConstants.Headers.INVOCATION_ID, MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID));
- headers.add(ONAPLogConstants.Headers.PARTNER_NAME, partnerName);
+ @Override
+ protected String getTargetServiceName(HttpRequest request) {
+ return request.getURI().toString();
+ }
+
+ @Override
+ protected String getServiceName(HttpRequest request) {
+ return request.getURI().getPath();
}
- protected String extractRequestID(HttpRequest clientRequest) {
- String requestId = MDC.get(ONAPLogConstants.MDCs.REQUEST_ID);
- if (requestId == null || requestId.isEmpty() || requestId.equals(TRACE)) {
- requestId = UUID.randomUUID().toString();
- mdcSetup.setLogTimestamp();
- mdcSetup.setElapsedTimeInvokeTimestamp();
- logger.warn("Could not Find Request ID Generating New One: {}", clientRequest.getURI());
- MDC.put(ONAPLogConstants.MDCs.REQUEST_ID, requestId);
+ @Override
+ protected int getHttpStatusCode(ClientHttpResponse response) {
+ try {
+ return response.getStatusCode().value();
+ } catch (IOException e) {
+ // TODO figure out the right thing to do here
+ return 500;
}
- return requestId;
}
- protected void setupMDC(HttpRequest clientRequest) {
- MDC.put(ONAPLogConstants.MDCs.INVOKE_TIMESTAMP,
- ZonedDateTime.now(ZoneOffset.UTC).format(DateTimeFormatter.ISO_INSTANT));
- MDC.put(ONAPLogConstants.MDCs.TARGET_SERVICE_NAME, clientRequest.getURI().toString());
- MDC.put(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE, ONAPLogConstants.ResponseStatus.INPROGRESS.toString());
- MDC.put(ONAPLogConstants.MDCs.TARGET_ENTITY, extractTargetEntity(clientRequest));
- if (MDC.get(ONAPLogConstants.MDCs.SERVICE_NAME) == null) {
- MDC.put(ONAPLogConstants.MDCs.SERVICE_NAME, clientRequest.getURI().getPath());
+ @Override
+ protected String getResponseCode(ClientHttpResponse response) {
+ try {
+ return response.getStatusCode().toString();
+ } catch (IOException e) {
+ return "500";
}
- mdcSetup.setServerFQDN();
}
- protected String extractTargetEntity(HttpRequest clientRequest) {
+ @Override
+ protected String getTargetEntity(HttpRequest clientRequest) {
HttpHeaders headers = clientRequest.getHeaders();
String headerTargetEntity = null;
List<String> headerTargetEntityList = headers.get(Constants.HttpHeaders.TARGET_ENTITY_HEADER);
return targetEntity;
}
- protected void processResponse(ClientHttpResponse response) throws IOException {
- if (logger.isDebugEnabled()) {
- logger.debug("============================response begin==========================================");
- logger.debug("Status code : {}", response.getStatusCode());
- logger.debug("Status text : {}", response.getStatusText());
- logger.debug("Headers : {}", response.getHeaders());
- logger.debug("Response body: {}", StreamUtils.copyToString(response.getBody(), Charset.defaultCharset()));
- logger.debug("=======================response end=================================================");
- }
- mdcSetup.setLogTimestamp();
- mdcSetup.setElapsedTimeInvokeTimestamp();
- mdcSetup.setResponseStatusCode(response.getRawStatusCode());
- int statusCode = response.getRawStatusCode();
- MDC.put(ONAPLogConstants.MDCs.RESPONSE_CODE, String.valueOf(statusCode));
- mdcSetup.setResponseDescription(statusCode);
- logger.info(INVOKE_RETURN, "InvokeReturn");
- mdcSetup.clearClientMDCs();
- }
-
- protected String getPartnerName() {
- PropertyUtil p = new PropertyUtil();
- return p.getProperty(Constants.Property.PARTNER_NAME);
- }
}
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - Logging
+ * ================================================================================
+ * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+
+package org.onap.logging.filter.spring;
+
+import java.io.IOException;
+import java.nio.charset.Charset;
+import java.nio.charset.StandardCharsets;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.http.HttpRequest;
+import org.springframework.http.client.ClientHttpRequestExecution;
+import org.springframework.http.client.ClientHttpRequestInterceptor;
+import org.springframework.http.client.ClientHttpResponse;
+import org.springframework.util.StreamUtils;
+
+public class SpringClientPayloadFilter implements ClientHttpRequestInterceptor {
+ private final Logger logger = LoggerFactory.getLogger(this.getClass());
+
+ @Override
+ public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution)
+ throws IOException {
+ logRequest(request, body);
+ ClientHttpResponse response = execution.execute(request, body);
+ logResponse(response);
+ return response;
+ }
+
+ protected void logRequest(HttpRequest request, byte[] body) throws IOException {
+ if (logger.isDebugEnabled()) {
+ logger.debug("===========================request begin================================================");
+ logger.debug("URI : {}", request.getURI());
+ logger.debug("Method : {}", request.getMethod());
+ logger.debug("Headers : {}", request.getHeaders());
+ logger.debug("Request body: {}", new String(body, StandardCharsets.UTF_8));
+ logger.debug("==========================request end================================================");
+ }
+ }
+
+ protected void logResponse(ClientHttpResponse response) throws IOException {
+ if (logger.isDebugEnabled()) {
+ logger.debug("============================response begin==========================================");
+ logger.debug("Status code : {}", response.getStatusCode());
+ logger.debug("Status text : {}", response.getStatusText());
+ logger.debug("Headers : {}", response.getHeaders());
+ logger.debug("Response body: {}", StreamUtils.copyToString(response.getBody(), Charset.defaultCharset()));
+ logger.debug("=======================response end=================================================");
+ }
+ }
+
+}
--- /dev/null
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - Logging
+ * ================================================================================
+ * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+
+package org.onap.logging.filter.spring;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import javax.ws.rs.core.Context;
+import javax.ws.rs.core.Response;
+import javax.ws.rs.ext.Providers;
+import org.onap.logging.filter.base.PayloadLoggingServletFilter;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+import org.springframework.web.servlet.HandlerInterceptor;
+import org.springframework.web.servlet.ModelAndView;
+
+// TODO do we want this class to log message payloads? In the previous implementation it did not
+@Component
+public class StatusLoggingInterceptor extends PayloadLoggingServletFilter implements HandlerInterceptor {
+
+ private static final Logger logger = LoggerFactory.getLogger(StatusLoggingInterceptor.class);
+
+ @Context
+ private Providers providers;
+
+ @Override
+ public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler)
+ throws Exception {
+ if (logger.isDebugEnabled()) {
+ logRequestInformation(request);
+ }
+ return true;
+ }
+
+ protected void logRequestInformation(HttpServletRequest request) {
+ logger.debug("===========================request begin================================================");
+ logger.debug("URI : {}", request.getRequestURI());
+ logger.debug("Method : {}", request.getMethod());
+ logger.debug("Headers : {}", getSecureRequestHeaders(request));
+ logger.debug("==========================request end================================================");
+ }
+
+ // TODO previously no response information was being logged, I followed the format in SpringClientPayloadFilter
+ @Override
+ public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler,
+ ModelAndView modelAndView) throws Exception {
+ if (logger.isDebugEnabled()) {
+ logger.debug("============================response begin==========================================");
+ logger.debug("Status code : {}", response.getStatus());
+ logger.debug("Status text : {}", Response.Status.fromStatusCode(response.getStatus()));
+ logger.debug("Headers : {}", formatResponseHeaders(response));
+ logger.debug("=======================response end=================================================");
+ }
+ }
+}
package org.onap.logging.filter.spring;
import static org.junit.Assert.assertEquals;
-import static org.mockito.ArgumentMatchers.any;
-import static org.mockito.Mockito.when;
+import static org.junit.Assert.assertNotNull;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import org.junit.Test;
import org.mockito.Mock;
import org.mockito.Spy;
import org.mockito.junit.MockitoJUnitRunner;
-import org.onap.logging.filter.base.MDCSetup;
-import org.onap.logging.filter.base.SimpleMap;
import org.onap.logging.ref.slf4j.ONAPLogConstants;
import org.slf4j.MDC;
@Mock
private Object handler;
- @Mock
- private MDCSetup mdcSetup;
-
@Spy
@InjectMocks
private LoggingInterceptor loggingInterceptor;
@Test
public void preHandleTest() throws Exception {
- when(mdcSetup.getRequestId(any(SimpleMap.class))).thenReturn("428443e6-eeb2-4e4a-9a8c-2ca9e2bc8067");
loggingInterceptor.preHandle(request, response, handler);
assertEquals(MDC.get(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE), "INPROGRESS");
- assertEquals("428443e6-eeb2-4e4a-9a8c-2ca9e2bc8067", MDC.get(ONAPLogConstants.MDCs.REQUEST_ID));
+ assertNotNull(MDC.get(ONAPLogConstants.MDCs.REQUEST_ID));
}
}
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
-import static org.mockito.Mockito.doNothing;
import static org.mockito.Mockito.doReturn;
import static org.mockito.Mockito.when;
import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
+import java.time.ZoneOffset;
+import java.time.ZonedDateTime;
+import java.time.format.DateTimeFormatter;
import org.junit.After;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.mockito.Mock;
import org.mockito.Spy;
import org.mockito.junit.MockitoJUnitRunner;
+import org.onap.logging.filter.base.AbstractFilter;
import org.onap.logging.filter.base.Constants;
-import org.onap.logging.filter.base.MDCSetup;
import org.onap.logging.ref.slf4j.ONAPLogConstants;
import org.slf4j.MDC;
import org.springframework.http.HttpHeaders;
import org.springframework.http.client.ClientHttpResponse;
@RunWith(MockitoJUnitRunner.class)
-public class SpringClientFilterTest {
+public class SpringClientFilterTest extends SpringClientFilter {
@Mock
- private MDCSetup mdcSetup;
+ private AbstractFilter mdcSetup;
@Mock
private ClientHttpResponse response;
@Test
public void processResponseTest() throws IOException {
- String partnerName = springClientFilter.getPartnerName();
-
+ String partnerName = getPartnerName();
assertEquals("UNKNOWN", partnerName);
}
headers.add(Constants.HttpHeaders.TARGET_ENTITY_HEADER, "SO");
when(clientRequest.getHeaders()).thenReturn(headers);
- String targetEntity = springClientFilter.extractTargetEntity(clientRequest);
+ String targetEntity = springClientFilter.getTargetEntity(clientRequest);
assertEquals("SO", targetEntity);
}
HttpHeaders headers = new HttpHeaders();
when(clientRequest.getHeaders()).thenReturn(headers);
- String targetEntity = springClientFilter.extractTargetEntity(clientRequest);
+ String targetEntity = springClientFilter.getTargetEntity(clientRequest);
assertEquals("SO", targetEntity);
}
HttpHeaders headers = new HttpHeaders();
when(clientRequest.getHeaders()).thenReturn(headers);
- String targetEntity = springClientFilter.extractTargetEntity(clientRequest);
+ String targetEntity = springClientFilter.getTargetEntity(clientRequest);
assertEquals("Unknown-Target-Entity", targetEntity);
}
@Test
public void setupMDCTest() throws URISyntaxException {
- doReturn("SO").when(springClientFilter).extractTargetEntity(clientRequest);
URI uri = new URI("onap/so/serviceInstances");
when(clientRequest.getURI()).thenReturn(uri);
-
- springClientFilter.setupMDC(clientRequest);
-
+ when(clientRequest.getHeaders()).thenReturn(new HttpHeaders());
+ setupMDC(clientRequest);
assertEquals("onap/so/serviceInstances", MDC.get(ONAPLogConstants.MDCs.TARGET_SERVICE_NAME));
- assertEquals("SO", MDC.get(ONAPLogConstants.MDCs.TARGET_ENTITY));
assertEquals("INPROGRESS", MDC.get(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE));
assertNotNull(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE);
assertNotNull(ONAPLogConstants.MDCs.SERVICE_NAME);
@Test
public void setupHeadersTest() {
MDC.put(ONAPLogConstants.MDCs.INVOCATION_ID, "8819bfb4-69d2-43fc-b0d6-81d2690533ea");
- HttpHeaders headers = new HttpHeaders();
- when(clientRequest.getHeaders()).thenReturn(headers);
- doReturn("0a908a5d-e774-4558-96ff-6edcbba65483").when(springClientFilter).extractRequestID(clientRequest);
+ MDC.put(ONAPLogConstants.MDCs.REQUEST_ID, "0a908a5d-e774-4558-96ff-6edcbba65483");
- springClientFilter.setupHeaders(clientRequest);
+ HttpHeaders headers = new HttpHeaders();
+ setupHeaders(clientRequest, headers);
assertEquals("0a908a5d-e774-4558-96ff-6edcbba65483", headers.getFirst(ONAPLogConstants.Headers.REQUEST_ID));
assertEquals("0a908a5d-e774-4558-96ff-6edcbba65483", headers.getFirst(Constants.HttpHeaders.HEADER_REQUEST_ID));
@Test
public void extractRequestIDTest() {
MDC.put(ONAPLogConstants.MDCs.REQUEST_ID, "0a908a5d-e774-4558-96ff-6edcbba65483");
- String requestId = springClientFilter.extractRequestID(clientRequest);
+ String requestId = extractRequestID();
assertEquals("0a908a5d-e774-4558-96ff-6edcbba65483", requestId);
}
@Test
public void extractRequestIDNullTest() {
- String requestId = springClientFilter.extractRequestID(clientRequest);
+ // NPE exception will occur when extractRequestID is called if INVOKE_TIMESTAMP is null
+ MDC.put(ONAPLogConstants.MDCs.INVOKE_TIMESTAMP,
+ ZonedDateTime.now(ZoneOffset.UTC).format(DateTimeFormatter.ISO_INSTANT));
+ String requestId = extractRequestID();
assertNotNull(requestId);
assertNotNull(ONAPLogConstants.MDCs.LOG_TIMESTAMP);
assertNotNull(ONAPLogConstants.MDCs.ELAPSED_TIME);
@Test
public void interceptTest() throws IOException {
byte[] body = new byte[3];
- doNothing().when(springClientFilter).processRequest(clientRequest, body);
doReturn(response).when(execution).execute(clientRequest, body);
- doNothing().when(springClientFilter).processResponse(response);
-
ClientHttpResponse httpResponse = springClientFilter.intercept(clientRequest, body, execution);
assertEquals(response, httpResponse);
}
Code Review / logging-analytics.git / commitdiff