2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017 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
11 * http://www.apache.org/licenses/LICENSE-2.0
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=========================================================
21 package org.onap.so.adapters.requestsdb.adapters;
23 import static org.junit.Assert.*;
25 import javax.ws.rs.core.Response;
27 import org.json.JSONException;
28 import org.junit.Test;
29 import org.junit.runner.RunWith;
30 import org.onap.logging.ref.slf4j.ONAPLogConstants;
31 import org.onap.so.adapters.requestsdb.application.MSORequestDBApplication;
32 import org.onap.so.adapters.requestsdb.application.TestAppender;
33 import org.onap.so.logger.MsoLogger;
34 import org.springframework.boot.context.embedded.LocalServerPort;
35 import org.springframework.boot.test.context.SpringBootTest;
36 import org.springframework.boot.test.web.client.TestRestTemplate;
37 import org.springframework.http.HttpEntity;
38 import org.springframework.http.HttpHeaders;
39 import org.springframework.http.HttpMethod;
40 import org.springframework.http.ResponseEntity;
41 import org.springframework.test.context.ActiveProfiles;
42 import org.springframework.test.context.junit4.SpringRunner;
43 import ch.qos.logback.classic.spi.ILoggingEvent;
46 @RunWith(SpringRunner.class)
47 @SpringBootTest(classes = MSORequestDBApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
48 @ActiveProfiles("test")
49 public class HealthCheckHandlerTest {
54 TestRestTemplate restTemplate = new TestRestTemplate();
56 HttpHeaders headers = new HttpHeaders();
60 public void testHealthcheck() throws JSONException {
61 TestAppender.events.clear();
62 HttpEntity<String> entity = new HttpEntity<String>(null, headers);
64 ResponseEntity<String> response = restTemplate.exchange(
65 createURLWithPort("/manage/health"),
66 HttpMethod.GET, entity, String.class);
68 assertEquals(Response.Status.OK.getStatusCode(),response.getStatusCode().value());
69 for(ILoggingEvent logEvent : TestAppender.events)
70 if(logEvent.getLoggerName().equals("org.onap.so.logging.spring.interceptor.LoggingInterceptor") &&
71 logEvent.getMarker().getName().equals("ENTRY")
73 Map<String,String> mdc = logEvent.getMDCPropertyMap();
74 assertNotNull(mdc.get(ONAPLogConstants.MDCs.INSTANCE_UUID));
75 assertNotNull(mdc.get(ONAPLogConstants.MDCs.REQUEST_ID));
76 assertNotNull(mdc.get(ONAPLogConstants.MDCs.INVOCATION_ID));
77 assertEquals("",mdc.get(ONAPLogConstants.MDCs.PARTNER_NAME));
78 assertEquals("/manage/health",mdc.get(ONAPLogConstants.MDCs.SERVICE_NAME));
79 assertEquals("INPROGRESS",mdc.get(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE));
80 }else if(logEvent.getLoggerName().equals("org.onap.so.logging.spring.interceptor.LoggingInterceptor") &&
81 logEvent.getMarker()!= null && logEvent.getMarker().getName().equals("EXIT")){
82 Map<String,String> mdc = logEvent.getMDCPropertyMap();
83 assertNotNull(mdc.get(ONAPLogConstants.MDCs.REQUEST_ID));
84 assertNotNull(mdc.get(ONAPLogConstants.MDCs.INVOCATION_ID));
85 assertEquals("200",mdc.get(ONAPLogConstants.MDCs.RESPONSE_CODE));
86 assertEquals("",mdc.get(ONAPLogConstants.MDCs.PARTNER_NAME));
87 assertEquals("/manage/health",mdc.get(ONAPLogConstants.MDCs.SERVICE_NAME));
88 assertEquals("COMPLETED",mdc.get(ONAPLogConstants.MDCs.RESPONSE_STATUS_CODE));
90 TestAppender.events.clear();
93 private String createURLWithPort(String uri) {
94 return "http://localhost:" + port + uri;