updating logging filters
[logging-analytics.git] / reference / logging-filter / logging-filter-base / src / test / java / org / onap / logging / filter / base / AbstractFilterTest.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 AbstractFilterTest extends AbstractFilter {
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 setMDCPartnerNameTest() {
195         MultivaluedMap<String, String> headerMap = new MultivaluedHashMap<>();
196         headerMap.putSingle(ONAPLogConstants.Headers.PARTNER_NAME, "SO");
197         SimpleMap headers = new SimpleJaxrsHeadersMap(headerMap);
198
199         setMDCPartnerName(headers);
200
201         assertEquals("SO", MDC.get(ONAPLogConstants.MDCs.PARTNER_NAME));
202     }
203
204     @Test
205     public void setMDCPartnerNameUserAgentHeaderTest() {
206         MultivaluedMap<String, String> headerMap = new MultivaluedHashMap<>();
207         headerMap.putSingle(HttpHeaders.USER_AGENT, "Apache-HttpClient/4.5.8 (Java/1.8.0_191)");
208         SimpleMap headers = new SimpleJaxrsHeadersMap(headerMap);
209
210         setMDCPartnerName(headers);
211
212         assertEquals("Apache-HttpClient/4.5.8 (Java/1.8.0_191)", MDC.get(ONAPLogConstants.MDCs.PARTNER_NAME));
213     }
214
215     @Test
216     public void setMDCPartnerNameClientIdHeaderTest() {
217         MultivaluedMap<String, String> headerMap = new MultivaluedHashMap<>();
218         headerMap.putSingle(Constants.HttpHeaders.CLIENT_ID, "SO");
219         SimpleMap headers = new SimpleJaxrsHeadersMap(headerMap);
220
221         setMDCPartnerName(headers);
222
223         assertEquals("SO", MDC.get(ONAPLogConstants.MDCs.PARTNER_NAME));
224     }
225
226     @Test
227     public void setMDCPartnerNameNoHeaderTest() {
228         MultivaluedMap<String, String> headerMap = new MultivaluedHashMap<>();
229         SimpleMap headers = new SimpleJaxrsHeadersMap(headerMap);
230
231         setMDCPartnerName(headers);
232
233         assertEquals("UNKNOWN", MDC.get(ONAPLogConstants.MDCs.PARTNER_NAME));
234     }
235
236     @Test
237     public void setServerFQDNTest() {
238         setServerFQDN();
239         assertNotNull(MDC.get(ONAPLogConstants.MDCs.SERVER_IP_ADDRESS));
240         assertNotNull(MDC.get(ONAPLogConstants.MDCs.SERVER_FQDN));
241     }
242
243     @Test
244     public void setClientIPAddressTest() {
245         when(httpServletRequest.getHeader("X-Forwarded-For")).thenReturn("127.0.0.2");
246         setClientIPAddress(httpServletRequest);
247
248         assertEquals("127.0.0.2", MDC.get(ONAPLogConstants.MDCs.CLIENT_IP_ADDRESS));
249     }
250
251     @Test
252     public void setClientIPAddressNoHeaderTest() {
253         when(httpServletRequest.getRemoteAddr()).thenReturn("127.0.0.1");
254         setClientIPAddress(httpServletRequest);
255
256         assertEquals("127.0.0.1", MDC.get(ONAPLogConstants.MDCs.CLIENT_IP_ADDRESS));
257     }
258
259     @Test
260     public void setClientIPAddressNullTest() {
261         setClientIPAddress(null);
262
263         assertEquals("", MDC.get(ONAPLogConstants.MDCs.CLIENT_IP_ADDRESS));
264     }
265
266     @Test
267     public void setEntryTimeStampTest() {
268         setEntryTimeStamp();
269
270         assertNotNull(MDC.get(ONAPLogConstants.MDCs.ENTRY_TIMESTAMP));
271     }
272
273     @Test
274     public void setLogTimestampTest() {
275         setLogTimestamp();
276
277         assertNotNull(MDC.get(ONAPLogConstants.MDCs.LOG_TIMESTAMP));
278     }
279
280     @Test
281     public void setInstanceIDTest() {
282         setInstanceID();
283
284         assertNotNull(MDC.get(ONAPLogConstants.MDCs.INSTANCE_UUID));
285     }
286
287     @Test
288     public void getPropertyTest() {
289         System.setProperty("partnerName", "partnerName");
290
291         String partnerName = getProperty("partnerName");
292         assertEquals("partnerName", partnerName);
293     }
294
295     @Test
296     public void getPropertyNullTest() {
297         String partnerName = getProperty("partner");
298         assertEquals("UNKNOWN", partnerName);
299     }
300
301 }