reference/logging-filter/logging-filter-base/src/test/java/org/onap/logging/filter/base/MDCSetupTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - Logging
   4  * ================================================================================
   5  * Copyright (C) 2019 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.logging.filter.base;
  22
  23 import static org.junit.Assert.assertEquals;
  24 import static org.junit.Assert.assertNotNull;
  25 import static org.junit.Assert.assertNull;
  26 import static org.mockito.Mockito.when;
  27 import java.util.HashMap;
  28 import javax.servlet.http.HttpServletRequest;
  29 import javax.ws.rs.core.HttpHeaders;
  30 import javax.ws.rs.core.MultivaluedHashMap;
  31 import javax.ws.rs.core.MultivaluedMap;
  32 import org.junit.After;
  33 import org.junit.Test;
  34 import org.junit.runner.RunWith;
  35 import org.mockito.Mock;
  36 import org.mockito.junit.MockitoJUnitRunner;
  37 import org.onap.logging.ref.slf4j.ONAPLogConstants;
  38 import org.slf4j.MDC;
  39
  40 @RunWith(MockitoJUnitRunner.class)
  41 public class MDCSetupTest extends MDCSetup {
  42
  43     @Mock
  44     private HttpServletRequest httpServletRequest;
  45
  46     private String requestId = "4d31fe02-4918-4975-942f-fe51a44e6a9b";
  47     private String invocationId = "4d31fe02-4918-4975-942f-fe51a44e6a9a";
  48
  49     @After
  50     public void tearDown() {
  51         MDC.clear();
  52         System.clearProperty("partnerName");
  53     }
  54
  55     @Test
  56     public void setElapsedTimeTest() {
  57         String expected = "318";
  58         MDC.put(ONAPLogConstants.MDCs.ENTRY_TIMESTAMP, "2019-06-18T02:09:06.024Z");
  59         MDC.put(ONAPLogConstants.MDCs.LOG_TIMESTAMP, "2019-06-18T02:09:06.342Z");
  60
  61         setElapsedTime();
  62         assertEquals(expected, MDC.get(ONAPLogConstants.MDCs.ELAPSED_TIME));
  63     }
  64
  65     @Test
  66     public void setElapsedTimeInvokeTimestampTest() {
  67         String expected = "318";
  68         MDC.put(ONAPLogConstants.MDCs.INVOKE_TIMESTAMP, "2019-06-18T02:09:06.024Z");
  69         MDC.put(ONAPLogConstants.MDCs.LOG_TIMESTAMP, "2019-06-18T02:09:06.342Z");
  70
  71         setElapsedTimeInvokeTimestamp();
  72         assertEquals(expected, MDC.get(ONAPLogConstants.MDCs.ELAPSED_TIME));
  73     }
  74
  75     @Test
  76     public void setRequestIdTest() {
  77         HashMap<String, String> headers = new HashMap<>();
  78         headers.put(ONAPLogConstants.Headers.REQUEST_ID, requestId);
  79         String fetchedRequestId = getRequestId(new SimpleHashMap(headers));
  80         assertEquals(requestId, fetchedRequestId);
  81     }
  82
  83     @Test
  84     public void setRequestIdRequestIdHeaderTest() {
  85         HashMap<String, String> headers = new HashMap<>();
  86         headers.put(Constants.HttpHeaders.HEADER_REQUEST_ID, requestId);
  87         String fetchedRequestId = getRequestId(new SimpleHashMap(headers));
  88         assertEquals(requestId, fetchedRequestId);
  89     }
  90
  91     @Test
  92     public void setRequestIdTransactionIdHeaderTest() {
  93         HashMap<String, String> headers = new HashMap<>();
  94         headers.put(Constants.HttpHeaders.TRANSACTION_ID, requestId);
  95         String fetchedRequestId = getRequestId(new SimpleHashMap(headers));
  96         assertEquals(requestId, fetchedRequestId);
  97     }
  98
  99     @Test
 100     public void setRequestIdEcompRequestIdHeaderTest() {
 101         HashMap<String, String> headers = new HashMap<>();
 102         headers.put(Constants.HttpHeaders.ECOMP_REQUEST_ID, requestId);
 103         String fetchedRequestId = getRequestId(new SimpleHashMap(headers));
 104         assertEquals(requestId, fetchedRequestId);
 105     }
 106
 107     @Test
 108     public void setRequestIdNoHeaderTest() {
 109         HashMap<String, String> headers = new HashMap<>();
 110         String fetchedRequestId = getRequestId(new SimpleHashMap(headers));
 111         assertNotNull(fetchedRequestId);
 112     }
 113
 114     @Test
 115     public void setInvocationIdTest() {
 116         HashMap<String, String> headers = new HashMap<>();
 117         headers.put(ONAPLogConstants.Headers.INVOCATION_ID, invocationId);
 118         setInvocationId(new SimpleHashMap(headers));
 119         assertEquals(invocationId, MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID));
 120     }
 121
 122     @Test
 123     public void setInvocationIdNoHeaderTest() {
 124         HashMap<String, String> headers = new HashMap<>();
 125         setInvocationId(new SimpleHashMap(headers));
 126         assertNotNull(MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID));
 127     }
 128
 129     @Test
 130     public void setInvovationIdFromMDCTest() {
 131         MDC.put(ONAPLogConstants.MDCs.INVOCATION_ID, "7b77143c-9b50-410c-ac2f-05758a68e3e8");
 132         setInvocationIdFromMDC();
 133         assertEquals("7b77143c-9b50-410c-ac2f-05758a68e3e8", MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID));
 134     }
 135
 136     @Test
 137     public void setInvocationIdFromMDCNoInvocationIdTest() {
 138         setInvocationIdFromMDC();
 139         // InvocationId is set to a random UUID
 140         assertNotNull(MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID));
 141     }
 142
 143     @Test
 144     public void setResponseStatusCodeTest() {
 145         setResponseStatusCode(200);
 146         assertEquals("COMPLETE", MDC.get(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE));
 147     }
 148
 149     @Test
 150     public void setResponseStatusCodeErrorTest() {
 151         setResponseStatusCode(400);
 152         assertEquals("ERROR", MDC.get(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE));
 153         assertEquals("400", MDC.get(ONAPLogConstants.MDCs.ERROR_CODE));
 154         assertEquals("Bad Request", MDC.get(ONAPLogConstants.MDCs.ERROR_DESC));
 155     }
 156
 157     @Test
 158     public void clearClientMDCsTest() {
 159         MDC.put(ONAPLogConstants.MDCs.INVOCATION_ID, "7b77143c-9b50-410c-ac2f-05758a68e3e9");
 160         MDC.put(ONAPLogConstants.MDCs.RESPONSE_DESCRIPTION, "Bad Gateway");
 161         MDC.put(ONAPLogConstants.MDCs.ERROR_DESC, "Bad Gateway");
 162         MDC.put(ONAPLogConstants.MDCs.ERROR_CODE, "502");
 163         MDC.put(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE, "502");
 164         MDC.put(ONAPLogConstants.MDCs.RESPONSE_CODE, "502");
 165         MDC.put(ONAPLogConstants.MDCs.TARGET_ENTITY, "SO");
 166         MDC.put(ONAPLogConstants.MDCs.TARGET_SERVICE_NAME, "SDNC");
 167         MDC.put(ONAPLogConstants.MDCs.INVOKE_TIMESTAMP, "2019-06-18T02:09:06.024Z");
 168
 169         clearClientMDCs();
 170         assertNull(MDC.get(ONAPLogConstants.MDCs.INVOCATION_ID));
 171         assertNull(MDC.get(ONAPLogConstants.MDCs.RESPONSE_DESCRIPTION));
 172         assertNull(MDC.get(ONAPLogConstants.MDCs.ERROR_CODE));
 173         assertNull(MDC.get(ONAPLogConstants.MDCs.ERROR_DESC));
 174         assertNull(MDC.get(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE));
 175         assertNull(MDC.get(ONAPLogConstants.MDCs.RESPONSE_CODE));
 176         assertNull(MDC.get(ONAPLogConstants.MDCs.TARGET_ENTITY));
 177         assertNull(MDC.get(ONAPLogConstants.MDCs.TARGET_SERVICE_NAME));
 178         assertNull(MDC.get(ONAPLogConstants.MDCs.INVOKE_TIMESTAMP));
 179     }
 180
 181     @Test
 182     public void setTargetEntityTest() {
 183         setTargetEntity(ONAPComponents.SO);
 184         assertEquals("SO", MDC.get(ONAPLogConstants.MDCs.TARGET_ENTITY));
 185     }
 186
 187     @Test
 188     public void setResponseDescriptionTest() {
 189         setResponseDescription(502);
 190         assertEquals("Bad Gateway", MDC.get(ONAPLogConstants.MDCs.RESPONSE_DESCRIPTION));
 191     }
 192
 193     @Test
 194     public void setMDCPartnerNameFromBasicAuth() {
 195         MultivaluedMap<String, String> headerMap = new MultivaluedHashMap<>();
 196         String value = "Basic dXNlcjpwYXNz"; // decodes to user:pass
 197         headerMap.putSingle(HttpHeaders.AUTHORIZATION, value);
 198         SimpleMap headers = new SimpleJaxrsHeadersMap(headerMap);
 199
 200         setMDCPartnerName(headers);
 201
 202         assertEquals("user", MDC.get(ONAPLogConstants.MDCs.PARTNER_NAME));
 203     }
 204
 205     @Test
 206     public void setMDCPartnerNameTest() {
 207         MultivaluedMap<String, String> headerMap = new MultivaluedHashMap<>();
 208         headerMap.putSingle(ONAPLogConstants.Headers.PARTNER_NAME, "SO");
 209         SimpleMap headers = new SimpleJaxrsHeadersMap(headerMap);
 210
 211         setMDCPartnerName(headers);
 212
 213         assertEquals("SO", MDC.get(ONAPLogConstants.MDCs.PARTNER_NAME));
 214     }
 215
 216     @Test
 217     public void setMDCPartnerNameUserAgentHeaderTest() {
 218         MultivaluedMap<String, String> headerMap = new MultivaluedHashMap<>();
 219         headerMap.putSingle(HttpHeaders.USER_AGENT, "Apache-HttpClient/4.5.8 (Java/1.8.0_191)");
 220         SimpleMap headers = new SimpleJaxrsHeadersMap(headerMap);
 221
 222         setMDCPartnerName(headers);
 223
 224         assertEquals("Apache-HttpClient/4.5.8 (Java/1.8.0_191)", MDC.get(ONAPLogConstants.MDCs.PARTNER_NAME));
 225     }
 226
 227     @Test
 228     public void setMDCPartnerNameClientIdHeaderTest() {
 229         MultivaluedMap<String, String> headerMap = new MultivaluedHashMap<>();
 230         headerMap.putSingle(Constants.HttpHeaders.CLIENT_ID, "SO");
 231         SimpleMap headers = new SimpleJaxrsHeadersMap(headerMap);
 232
 233         setMDCPartnerName(headers);
 234
 235         assertEquals("SO", MDC.get(ONAPLogConstants.MDCs.PARTNER_NAME));
 236     }
 237
 238     @Test
 239     public void setMDCPartnerNameNoHeaderTest() {
 240         MultivaluedMap<String, String> headerMap = new MultivaluedHashMap<>();
 241         SimpleMap headers = new SimpleJaxrsHeadersMap(headerMap);
 242
 243         setMDCPartnerName(headers);
 244
 245         assertEquals("UNKNOWN", MDC.get(ONAPLogConstants.MDCs.PARTNER_NAME));
 246     }
 247
 248     @Test
 249     public void setServerFQDNTest() {
 250         setServerFQDN();
 251         assertNotNull(MDC.get(ONAPLogConstants.MDCs.SERVER_IP_ADDRESS));
 252         assertNotNull(MDC.get(ONAPLogConstants.MDCs.SERVER_FQDN));
 253     }
 254
 255     @Test
 256     public void setClientIPAddressTest() {
 257         when(httpServletRequest.getHeader("X-Forwarded-For")).thenReturn("127.0.0.2");
 258         setClientIPAddress(httpServletRequest);
 259
 260         assertEquals("127.0.0.2", MDC.get(ONAPLogConstants.MDCs.CLIENT_IP_ADDRESS));
 261     }
 262
 263     @Test
 264     public void setClientIPAddressNoHeaderTest() {
 265         when(httpServletRequest.getRemoteAddr()).thenReturn("127.0.0.1");
 266         setClientIPAddress(httpServletRequest);
 267
 268         assertEquals("127.0.0.1", MDC.get(ONAPLogConstants.MDCs.CLIENT_IP_ADDRESS));
 269     }
 270
 271     @Test
 272     public void setClientIPAddressNullTest() {
 273         setClientIPAddress(null);
 274
 275         assertEquals("", MDC.get(ONAPLogConstants.MDCs.CLIENT_IP_ADDRESS));
 276     }
 277
 278     @Test
 279     public void setEntryTimeStampTest() {
 280         setEntryTimeStamp();
 281
 282         assertNotNull(MDC.get(ONAPLogConstants.MDCs.ENTRY_TIMESTAMP));
 283     }
 284
 285     @Test
 286     public void setLogTimestampTest() {
 287         setLogTimestamp();
 288
 289         assertNotNull(MDC.get(ONAPLogConstants.MDCs.LOG_TIMESTAMP));
 290     }
 291
 292     @Test
 293     public void setInstanceIDTest() {
 294         setInstanceID();
 295
 296         assertNotNull(MDC.get(ONAPLogConstants.MDCs.INSTANCE_UUID));
 297     }
 298
 299     @Test
 300     public void getPropertyTest() {
 301         System.setProperty("partnerName", "partnerName");
 302
 303         String partnerName = getProperty("partnerName");
 304         assertEquals("partnerName", partnerName);
 305     }
 306
 307     @Test
 308     public void getPropertyNullTest() {
 309         String partnerName = getProperty("partner");
 310         assertEquals("UNKNOWN", partnerName);
 311     }
 312
 313 }