add timeout to apih for the camunda activity check

Added timeout for camunda history lookups
Added error strings to be returned on task information lookup
Renamed method for getTaskInformation
Removed retry for taskInformation and updated logging for errors
Added spring logging interceptors to restTemplate
Made timeout and retry timeout configurable

Issue-ID: SO-2508
Signed-off-by: Benjamin, Max (mb388a) <mb388a@att.com>
Change-Id: Ibd5101fc2e0a933a2f8070077c40b02bbbcfea6f

2 files changed, 396 insertions, 303 deletions

diff --git a/mso-api-handlers/mso-api-handler-infra/src/test/java/org/onap/so/apihandlerinfra/CamundaRequestHandlerTest.java b/mso-api-handlers/mso-api-handler-infra/src/test/java/org/onap/so/apihandlerinfra/CamundaRequestHandlerTest.java
index 830f38f98b..4dc281b3fc 100644
--- a/mso-api-handlers/mso-api-handler-infra/src/test/java/org/onap/so/apihandlerinfra/CamundaRequestHandlerTest.java
+++ b/mso-api-handlers/mso-api-handler-infra/src/test/java/org/onap/so/apihandlerinfra/CamundaRequestHandlerTest.java
@@ -17,324 +17,39 @@
  * limitations under the License.
  * ============LICENSE_END=========================================================
  */
-
 package org.onap.so.apihandlerinfra;
 
-import static org.junit.Assert.assertEquals;
-import static org.mockito.Mockito.doReturn;
-import static org.mockito.Mockito.doThrow;
-import static org.mockito.Mockito.times;
-import static org.mockito.Mockito.verify;
-import static org.mockito.Mockito.when;
-import java.io.IOException;
-import java.nio.file.Files;
-import java.nio.file.Paths;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import org.camunda.bpm.engine.impl.persistence.entity.HistoricActivityInstanceEntity;
-import org.camunda.bpm.engine.impl.persistence.entity.HistoricProcessInstanceEntity;
-import org.junit.Before;
+import static com.github.tomakehurst.wiremock.client.WireMock.aResponse;
+import static com.github.tomakehurst.wiremock.client.WireMock.get;
+import javax.ws.rs.core.MediaType;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.rules.ExpectedException;
-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.so.apihandlerinfra.exceptions.ContactCamundaException;
-import org.onap.so.apihandlerinfra.exceptions.RequestDbFailureException;
-import org.springframework.core.ParameterizedTypeReference;
-import org.springframework.core.env.Environment;
-import org.springframework.http.HttpEntity;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpMethod;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.ResponseEntity;
-import org.springframework.web.client.HttpClientErrorException;
-import org.springframework.web.client.HttpStatusCodeException;
 import org.springframework.web.client.ResourceAccessException;
-import org.springframework.web.client.RestTemplate;
-import com.fasterxml.jackson.core.type.TypeReference;
-import com.fasterxml.jackson.databind.DeserializationFeature;
-import com.fasterxml.jackson.databind.ObjectMapper;
-
-@RunWith(MockitoJUnitRunner.class)
-public class CamundaRequestHandlerTest {
-
-    @Mock
-    private RestTemplate restTemplate;
 
-    @Mock
-    private Environment env;
+public class CamundaRequestHandlerTest extends BaseTest {
 
-    @InjectMocks
-    @Spy
+    @Autowired
     private CamundaRequestHandler camundaRequestHandler;
 
+    @Value("${wiremock.server.port}")
+    private String wiremockPort;
+
     @Rule
     public ExpectedException thrown = ExpectedException.none();
 
-    private static final String REQUEST_ID = "eca3a1b1-43ab-457e-ab1c-367263d148b4";
-    private ResponseEntity<List<HistoricActivityInstanceEntity>> activityInstanceResponse = null;
-    private ResponseEntity<List<HistoricProcessInstanceEntity>> processInstanceResponse = null;
-    private List<HistoricActivityInstanceEntity> activityInstanceList = null;
-    private List<HistoricProcessInstanceEntity> processInstanceList = null;
-
-
-
-    @Before
-    public void setup() throws IOException {
-        ObjectMapper mapper = new ObjectMapper().configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
-        activityInstanceList = mapper.readValue(
-                new String(Files.readAllBytes(
-                        Paths.get("src/test/resources/OrchestrationRequest/ActivityInstanceHistoryResponse.json"))),
-                new TypeReference<List<HistoricActivityInstanceEntity>>() {});
-        processInstanceList = mapper.readValue(
-                new String(Files.readAllBytes(
-                        Paths.get("src/test/resources/OrchestrationRequest/ProcessInstanceHistoryResponse.json"))),
-                new TypeReference<List<HistoricProcessInstanceEntity>>() {});
-        processInstanceResponse =
-                new ResponseEntity<List<HistoricProcessInstanceEntity>>(processInstanceList, HttpStatus.ACCEPTED);
-        activityInstanceResponse =
-                new ResponseEntity<List<HistoricActivityInstanceEntity>>(activityInstanceList, HttpStatus.ACCEPTED);
-
-        doReturn("/sobpmnengine/history/process-instance?variables=mso-request-id_eq_").when(env)
-                .getProperty("mso.camunda.rest.history.uri");
-        doReturn("/sobpmnengine/history/activity-instance?processInstanceId=").when(env)
-                .getProperty("mso.camunda.rest.activity.uri");
-        doReturn("auth").when(env).getRequiredProperty("mso.camundaAuth");
-        doReturn("key").when(env).getRequiredProperty("mso.msoKey");
-        doReturn("http://localhost:8089").when(env).getProperty("mso.camundaURL");
-    }
-
-    public HttpHeaders setHeaders() {
-        HttpHeaders headers = new HttpHeaders();
-        List<org.springframework.http.MediaType> acceptableMediaTypes = new ArrayList<>();
-        acceptableMediaTypes.add(org.springframework.http.MediaType.APPLICATION_JSON);
-        headers.setAccept(acceptableMediaTypes);
-        headers.add(HttpHeaders.AUTHORIZATION, "auth");
-
-        return headers;
-    }
-
-    @Test
-    public void getActivityNameTest() {
-        String expectedActivityName = "Last task executed: BB to Execute";
-        String actualActivityName = camundaRequestHandler.getActivityName(activityInstanceList);
-
-        assertEquals(expectedActivityName, actualActivityName);
-    }
-
-    @Test
-    public void getActivityNameNullActivityNameTest() {
-        String expectedActivityName = "Task name is null.";
-        HistoricActivityInstanceEntity activityInstance = new HistoricActivityInstanceEntity();
-        List<HistoricActivityInstanceEntity> activityInstanceList = new ArrayList<>();
-        activityInstanceList.add(activityInstance);
-
-        String actualActivityName = camundaRequestHandler.getActivityName(activityInstanceList);
-
-        assertEquals(expectedActivityName, actualActivityName);
-    }
-
-    @Test
-    public void getActivityNameNullListTest() {
-        String expectedActivityName = "No results returned on activityInstance history lookup.";
-        List<HistoricActivityInstanceEntity> activityInstanceList = null;
-        String actualActivityName = camundaRequestHandler.getActivityName(activityInstanceList);
-
-        assertEquals(expectedActivityName, actualActivityName);
-    }
-
-    @Test
-    public void getActivityNameEmptyListTest() {
-        String expectedActivityName = "No results returned on activityInstance history lookup.";
-        List<HistoricActivityInstanceEntity> activityInstanceList = new ArrayList<>();
-        String actualActivityName = camundaRequestHandler.getActivityName(activityInstanceList);
-
-        assertEquals(expectedActivityName, actualActivityName);
-    }
-
-    @Test
-    public void getTaskNameTest() throws ContactCamundaException {
-        doReturn(processInstanceResponse).when(camundaRequestHandler).getCamundaProcessInstanceHistory(REQUEST_ID);
-        doReturn(activityInstanceResponse).when(camundaRequestHandler)
-                .getCamundaActivityHistory("c4c6b647-a26e-11e9-b144-0242ac14000b", REQUEST_ID);
-        doReturn("Last task executed: BB to Execute").when(camundaRequestHandler).getActivityName(activityInstanceList);
-        String expectedTaskName = "Last task executed: BB to Execute";
-
-        String actualTaskName = camundaRequestHandler.getTaskName(REQUEST_ID);
-
-        assertEquals(expectedTaskName, actualTaskName);
-    }
-
-    @Test
-    public void getTaskNameNullProcessInstanceListTest() throws ContactCamundaException {
-        ResponseEntity<List<HistoricProcessInstanceEntity>> response = new ResponseEntity<>(null, HttpStatus.OK);
-        doReturn(response).when(camundaRequestHandler).getCamundaProcessInstanceHistory(REQUEST_ID);
-        String expected = "No processInstances returned for requestId: " + REQUEST_ID;
-
-        String actual = camundaRequestHandler.getTaskName(REQUEST_ID);
-
-        assertEquals(expected, actual);
-    }
-
     @Test
-    public void getTaskNameNullProcessInstanceIdTest() throws ContactCamundaException {
-        HistoricProcessInstanceEntity processInstance = new HistoricProcessInstanceEntity();
-        List<HistoricProcessInstanceEntity> processInstanceList = new ArrayList<>();
-        processInstanceList.add(processInstance);
-        ResponseEntity<List<HistoricProcessInstanceEntity>> response =
-                new ResponseEntity<>(processInstanceList, HttpStatus.OK);
-        doReturn(response).when(camundaRequestHandler).getCamundaProcessInstanceHistory(REQUEST_ID);
-        String expected = "No processInstanceId returned for requestId: " + REQUEST_ID;
-
-        String actual = camundaRequestHandler.getTaskName(REQUEST_ID);
-
-        assertEquals(expected, actual);
-    }
-
-    @Test
-    public void getTaskNameEmptyProcessInstanceListTest() throws ContactCamundaException {
-        ResponseEntity<List<HistoricProcessInstanceEntity>> response =
-                new ResponseEntity<>(Collections.emptyList(), HttpStatus.OK);
-        doReturn(response).when(camundaRequestHandler).getCamundaProcessInstanceHistory(REQUEST_ID);
-        String expected = "No processInstances returned for requestId: " + REQUEST_ID;
-
-        String actual = camundaRequestHandler.getTaskName(REQUEST_ID);
-
-        assertEquals(expected, actual);
-    }
-
-    @Test
-    public void getTaskNameProcessInstanceLookupFailureTest() throws ContactCamundaException {
-        doThrow(HttpClientErrorException.class).when(camundaRequestHandler)
-                .getCamundaProcessInstanceHistory(REQUEST_ID);
-
-        thrown.expect(ContactCamundaException.class);
-        camundaRequestHandler.getTaskName(REQUEST_ID);
-    }
-
-    @Test
-    public void getCamundaActivityHistoryTest() throws ContactCamundaException {
-        HttpHeaders headers = setHeaders();
-        HttpEntity<?> requestEntity = new HttpEntity<>(headers);
-        String targetUrl = "http://localhost:8089/sobpmnengine/history/activity-instance?processInstanceId="
-                + "c4c6b647-a26e-11e9-b144-0242ac14000b";
-        doReturn(activityInstanceResponse).when(restTemplate).exchange(targetUrl, HttpMethod.GET, requestEntity,
-                new ParameterizedTypeReference<List<HistoricActivityInstanceEntity>>() {});
-        doReturn(headers).when(camundaRequestHandler).setCamundaHeaders("auth", "key");
-        ResponseEntity<List<HistoricActivityInstanceEntity>> actualResponse =
-                camundaRequestHandler.getCamundaActivityHistory("c4c6b647-a26e-11e9-b144-0242ac14000b", REQUEST_ID);
-        assertEquals(activityInstanceResponse, actualResponse);
-    }
-
-    @Test
-    public void getCamundaActivityHistoryErrorTest() {
-        HttpHeaders headers = setHeaders();
-        HttpEntity<?> requestEntity = new HttpEntity<>(headers);
-        String targetUrl = "http://localhost:8089/sobpmnengine/history/activity-instance?processInstanceId="
-                + "c4c6b647-a26e-11e9-b144-0242ac14000b";
-        doThrow(new ResourceAccessException("IOException")).when(restTemplate).exchange(targetUrl, HttpMethod.GET,
-                requestEntity, new ParameterizedTypeReference<List<HistoricActivityInstanceEntity>>() {});
-        doReturn(headers).when(camundaRequestHandler).setCamundaHeaders("auth", "key");
-
-        try {
-            camundaRequestHandler.getCamundaActivityHistory("c4c6b647-a26e-11e9-b144-0242ac14000b", REQUEST_ID);
-        } catch (ContactCamundaException e) {
-            // Exception thrown after retries are completed
-        }
-
-        verify(restTemplate, times(4)).exchange(targetUrl, HttpMethod.GET, requestEntity,
-                new ParameterizedTypeReference<List<HistoricActivityInstanceEntity>>() {});
-    }
-
-    @Test
-    public void getCamundaProccesInstanceHistoryTest() {
-        HttpHeaders headers = setHeaders();
-        HttpEntity<?> requestEntity = new HttpEntity<>(headers);
-        String targetUrl =
-                "http://localhost:8089/sobpmnengine/history/process-instance?variables=mso-request-id_eq_" + REQUEST_ID;
-        doReturn(processInstanceResponse).when(restTemplate).exchange(targetUrl, HttpMethod.GET, requestEntity,
-                new ParameterizedTypeReference<List<HistoricProcessInstanceEntity>>() {});
-        doReturn(headers).when(camundaRequestHandler).setCamundaHeaders("auth", "key");
-
-        ResponseEntity<List<HistoricProcessInstanceEntity>> actualResponse =
-                camundaRequestHandler.getCamundaProcessInstanceHistory(REQUEST_ID);
-        assertEquals(processInstanceResponse, actualResponse);
-    }
-
-    @Test
-    public void getCamundaProccesInstanceHistoryRetryTest() {
-        HttpHeaders headers = setHeaders();
-        HttpEntity<?> requestEntity = new HttpEntity<>(headers);
-        String targetUrl =
-                "http://localhost:8089/sobpmnengine/history/process-instance?variables=mso-request-id_eq_" + REQUEST_ID;
-        doThrow(new ResourceAccessException("I/O error")).when(restTemplate).exchange(targetUrl, HttpMethod.GET,
-                requestEntity, new ParameterizedTypeReference<List<HistoricProcessInstanceEntity>>() {});
-        doReturn(headers).when(camundaRequestHandler).setCamundaHeaders("auth", "key");
-
-        try {
-            camundaRequestHandler.getCamundaProcessInstanceHistory(REQUEST_ID);
-        } catch (ResourceAccessException e) {
-            // Exception thrown after retries are completed
-        }
-        verify(restTemplate, times(4)).exchange(targetUrl, HttpMethod.GET, requestEntity,
-                new ParameterizedTypeReference<List<HistoricProcessInstanceEntity>>() {});
-    }
-
-    @Test
-    public void getCamundaProccesInstanceHistoryNoRetryTest() {
-        HttpHeaders headers = setHeaders();
-        HttpEntity<?> requestEntity = new HttpEntity<>(headers);
-        String targetUrl =
-                "http://localhost:8089/sobpmnengine/history/process-instance?variables=mso-request-id_eq_" + REQUEST_ID;
-        doThrow(HttpClientErrorException.class).when(restTemplate).exchange(targetUrl, HttpMethod.GET, requestEntity,
-                new ParameterizedTypeReference<List<HistoricProcessInstanceEntity>>() {});
-        doReturn(headers).when(camundaRequestHandler).setCamundaHeaders("auth", "key");
-
-        try {
-            camundaRequestHandler.getCamundaProcessInstanceHistory(REQUEST_ID);
-        } catch (HttpStatusCodeException e) {
-            // Exception thrown, no retries
-        }
-        verify(restTemplate, times(1)).exchange(targetUrl, HttpMethod.GET, requestEntity,
-                new ParameterizedTypeReference<List<HistoricProcessInstanceEntity>>() {});
-    }
-
-    @Test
-    public void getCamundaProccesInstanceHistoryFailThenSuccessTest() {
-        HttpHeaders headers = setHeaders();
-        HttpEntity<?> requestEntity = new HttpEntity<>(headers);
-        String targetUrl =
-                "http://localhost:8089/sobpmnengine/history/process-instance?variables=mso-request-id_eq_" + REQUEST_ID;
-        when(restTemplate.exchange(targetUrl, HttpMethod.GET, requestEntity,
-                new ParameterizedTypeReference<List<HistoricProcessInstanceEntity>>() {}))
-                        .thenThrow(new ResourceAccessException("I/O Exception")).thenReturn(processInstanceResponse);
-        doReturn(headers).when(camundaRequestHandler).setCamundaHeaders("auth", "key");
-
-        ResponseEntity<List<HistoricProcessInstanceEntity>> actualResponse =
-                camundaRequestHandler.getCamundaProcessInstanceHistory(REQUEST_ID);
-        assertEquals(processInstanceResponse, actualResponse);
-        verify(restTemplate, times(2)).exchange(targetUrl, HttpMethod.GET, requestEntity,
-                new ParameterizedTypeReference<List<HistoricProcessInstanceEntity>>() {});
-    }
-
-    @Test
-    public void setCamundaHeadersTest() {
-        String encryptedAuth = "015E7ACF706C6BBF85F2079378BDD2896E226E09D13DC2784BA309E27D59AB9FAD3A5E039DF0BB8408"; // user:password
-        String key = "07a7159d3bf51a0e53be7a8f89699be7";
-
-        HttpHeaders headers = camundaRequestHandler.setCamundaHeaders(encryptedAuth, key);
-        List<org.springframework.http.MediaType> acceptedType = headers.getAccept();
-
-        String expectedAcceptedType = "application/json";
-        assertEquals(expectedAcceptedType, acceptedType.get(0).toString());
-        String basicAuth = headers.getFirst(HttpHeaders.AUTHORIZATION);
-        String expectedBasicAuth = "Basic dXNlcjpwYXNzd29yZA==";
+    public void timeoutTest() {
+        wireMockServer.stubFor(get(
+                ("/sobpmnengine/history/process-instance?variables=mso-request-id_eq_6718de35-b9a5-4670-b19f-a0f4ac22bfaf"))
+                        .willReturn(aResponse().withHeader(HttpHeaders.CONTENT_TYPE, MediaType.APPLICATION_JSON)
+                                .withBodyFile("Camunda/HistoryCheckResponse.json")
+                                .withStatus(org.apache.http.HttpStatus.SC_OK).withFixedDelay(40000)));
 
-        assertEquals(expectedBasicAuth, basicAuth);
+        thrown.expect(ResourceAccessException.class);
+        camundaRequestHandler.getCamundaProcessInstanceHistory("6718de35-b9a5-4670-b19f-a0f4ac22bfaf", false);
     }
 }
diff --git a/mso-api-handlers/mso-api-handler-infra/src/test/java/org/onap/so/apihandlerinfra/CamundaRequestHandlerUnitTest.java b/mso-api-handlers/mso-api-handler-infra/src/test/java/org/onap/so/apihandlerinfra/CamundaRequestHandlerUnitTest.java
new file mode 100644
index 0000000000..261b64f2e6
--- /dev/null
+++ b/mso-api-handlers/mso-api-handler-infra/src/test/java/org/onap/so/apihandlerinfra/CamundaRequestHandlerUnitTest.java
@@ -0,0 +1,378 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ * 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.so.apihandlerinfra;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNull;
+import static org.mockito.Mockito.doReturn;
+import static org.mockito.Mockito.doThrow;
+import static org.mockito.Mockito.times;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.util.ArrayList;
+import java.util.List;
+import org.camunda.bpm.engine.impl.persistence.entity.HistoricActivityInstanceEntity;
+import org.camunda.bpm.engine.impl.persistence.entity.HistoricProcessInstanceEntity;
+import org.junit.Before;
+import org.junit.Rule;
+import org.junit.Test;
+import org.junit.rules.ExpectedException;
+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.so.apihandlerinfra.exceptions.ContactCamundaException;
+import org.onap.so.apihandlerinfra.exceptions.RequestDbFailureException;
+import org.springframework.core.ParameterizedTypeReference;
+import org.springframework.core.env.Environment;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
+import org.springframework.web.client.HttpClientErrorException;
+import org.springframework.web.client.HttpStatusCodeException;
+import org.springframework.web.client.ResourceAccessException;
+import org.springframework.web.client.RestClientException;
+import org.springframework.web.client.RestTemplate;
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+@RunWith(MockitoJUnitRunner.class)
+public class CamundaRequestHandlerUnitTest {
+
+    @Mock
+    private RestTemplate restTemplate;
+
+    @Mock
+    private RestTemplate restTemplateRetry;
+
+    @Mock
+    private Environment env;
+
+    @InjectMocks
+    @Spy
+    private CamundaRequestHandler camundaRequestHandler;
+
+    @Rule
+    public ExpectedException thrown = ExpectedException.none();
+
+    private static final String REQUEST_ID = "eca3a1b1-43ab-457e-ab1c-367263d148b4";
+    private ResponseEntity<List<HistoricActivityInstanceEntity>> activityInstanceResponse = null;
+    private ResponseEntity<List<HistoricProcessInstanceEntity>> processInstanceResponse = null;
+    private List<HistoricActivityInstanceEntity> activityInstanceList = null;
+    private List<HistoricProcessInstanceEntity> processInstanceList = null;
+
+
+
+    @Before
+    public void setup() throws IOException {
+        ObjectMapper mapper = new ObjectMapper().configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
+        activityInstanceList = mapper.readValue(
+                new String(Files.readAllBytes(
+                        Paths.get("src/test/resources/OrchestrationRequest/ActivityInstanceHistoryResponse.json"))),
+                new TypeReference<List<HistoricActivityInstanceEntity>>() {});
+        processInstanceList = mapper.readValue(
+                new String(Files.readAllBytes(
+                        Paths.get("src/test/resources/OrchestrationRequest/ProcessInstanceHistoryResponse.json"))),
+                new TypeReference<List<HistoricProcessInstanceEntity>>() {});
+        processInstanceResponse =
+                new ResponseEntity<List<HistoricProcessInstanceEntity>>(processInstanceList, HttpStatus.ACCEPTED);
+        activityInstanceResponse =
+                new ResponseEntity<List<HistoricActivityInstanceEntity>>(activityInstanceList, HttpStatus.ACCEPTED);
+
+        doReturn("/sobpmnengine/history/process-instance?variables=mso-request-id_eq_").when(env)
+                .getProperty("mso.camunda.rest.history.uri");
+        doReturn("/sobpmnengine/history/activity-instance?processInstanceId=").when(env)
+                .getProperty("mso.camunda.rest.activity.uri");
+        doReturn("auth").when(env).getRequiredProperty("mso.camundaAuth");
+        doReturn("key").when(env).getRequiredProperty("mso.msoKey");
+        doReturn("http://localhost:8089").when(env).getProperty("mso.camundaURL");
+
+        HttpComponentsClientHttpRequestFactory factory = new HttpComponentsClientHttpRequestFactory();
+        factory.setReadTimeout(30000);
+        factory.setConnectTimeout(30000);
+        restTemplate.setRequestFactory(factory);
+        doReturn(restTemplate).when(camundaRequestHandler).getRestTemplate(false);
+
+        HttpComponentsClientHttpRequestFactory factoryRetry = new HttpComponentsClientHttpRequestFactory();
+        factoryRetry.setReadTimeout(15000);
+        factoryRetry.setConnectTimeout(15000);
+        restTemplate.setRequestFactory(factoryRetry);
+        doReturn(restTemplateRetry).when(camundaRequestHandler).getRestTemplate(true);
+    }
+
+    public HttpHeaders setHeaders() {
+        HttpHeaders headers = new HttpHeaders();
+        List<org.springframework.http.MediaType> acceptableMediaTypes = new ArrayList<>();
+        acceptableMediaTypes.add(org.springframework.http.MediaType.APPLICATION_JSON);
+        headers.setAccept(acceptableMediaTypes);
+        headers.add(HttpHeaders.AUTHORIZATION, "auth");
+
+        return headers;
+    }
+
+    @Test
+    public void getActivityNameTest() throws IOException {
+        String expectedActivityName = "Last task executed: BB to Execute";
+        String actualActivityName = camundaRequestHandler.getActivityName(activityInstanceList);
+
+        assertEquals(expectedActivityName, actualActivityName);
+    }
+
+    @Test
+    public void getActivityNameNullActivityNameTest() throws IOException {
+        String expectedActivityName = "Task name is null.";
+        HistoricActivityInstanceEntity activityInstance = new HistoricActivityInstanceEntity();
+        List<HistoricActivityInstanceEntity> activityInstanceList = new ArrayList<>();
+        activityInstanceList.add(activityInstance);
+
+        String actualActivityName = camundaRequestHandler.getActivityName(activityInstanceList);
+
+        assertEquals(expectedActivityName, actualActivityName);
+    }
+
+    @Test
+    public void getActivityNameNullListTest() throws IOException {
+        String expectedActivityName = "No results returned on activityInstance history lookup.";
+        List<HistoricActivityInstanceEntity> activityInstanceList = null;
+        String actualActivityName = camundaRequestHandler.getActivityName(activityInstanceList);
+
+        assertEquals(expectedActivityName, actualActivityName);
+    }
+
+    @Test
+    public void getActivityNameEmptyListTest() throws IOException {
+        String expectedActivityName = "No results returned on activityInstance history lookup.";
+        List<HistoricActivityInstanceEntity> activityInstanceList = new ArrayList<>();
+        String actualActivityName = camundaRequestHandler.getActivityName(activityInstanceList);
+
+        assertEquals(expectedActivityName, actualActivityName);
+    }
+
+    @Test
+    public void getCamundActivityHistoryNullTest() throws IOException, ContactCamundaException {
+        HistoricProcessInstanceEntity processInstance = new HistoricProcessInstanceEntity();
+        processInstance.setId("c4c6b647-a26e-11e9-b144-0242ac14000b");
+        List<HistoricProcessInstanceEntity> processInstanceList = new ArrayList<>();
+        processInstanceList.add(processInstance);
+        ResponseEntity<List<HistoricProcessInstanceEntity>> response =
+                new ResponseEntity<>(processInstanceList, HttpStatus.OK);
+        doReturn(null).when(camundaRequestHandler).getCamundaActivityHistory("c4c6b647-a26e-11e9-b144-0242ac14000b");
+
+        String actualTaskName = camundaRequestHandler.getTaskInformation(response, REQUEST_ID);
+
+        assertNull(actualTaskName);
+    }
+
+    @Test
+    public void getCamundActivityHistoryErrorTest() throws IOException, ContactCamundaException {
+        HistoricProcessInstanceEntity processInstance = new HistoricProcessInstanceEntity();
+        processInstance.setId("c4c6b647-a26e-11e9-b144-0242ac14000b");
+        List<HistoricProcessInstanceEntity> processInstanceList = new ArrayList<>();
+        processInstanceList.add(processInstance);
+        ResponseEntity<List<HistoricProcessInstanceEntity>> response =
+                new ResponseEntity<>(processInstanceList, HttpStatus.OK);
+        doThrow(RestClientException.class).when(camundaRequestHandler)
+                .getCamundaActivityHistory("c4c6b647-a26e-11e9-b144-0242ac14000b");
+
+        String actualTaskName = camundaRequestHandler.getTaskInformation(response, REQUEST_ID);
+
+        assertNull(actualTaskName);
+    }
+
+    @Test
+    public void getTaskName() throws IOException, ContactCamundaException {
+        doReturn(processInstanceResponse).when(camundaRequestHandler).getCamundaProcessInstanceHistory(REQUEST_ID,
+                false);
+        doReturn(activityInstanceResponse).when(camundaRequestHandler)
+                .getCamundaActivityHistory("c4c6b647-a26e-11e9-b144-0242ac14000b");
+        doReturn("Last task executed: BB to Execute").when(camundaRequestHandler).getActivityName(activityInstanceList);
+        String expectedTaskName = "Last task executed: BB to Execute";
+
+        String actualTaskName = camundaRequestHandler.getTaskName(REQUEST_ID);
+
+        assertEquals(expectedTaskName, actualTaskName);
+    }
+
+    @Test
+    public void getTaskNameNullProcessInstanceListTest() throws IOException, ContactCamundaException {
+        ResponseEntity<List<HistoricProcessInstanceEntity>> response = new ResponseEntity<>(null, HttpStatus.OK);
+
+        String actual = camundaRequestHandler.getTaskInformation(response, REQUEST_ID);
+
+        assertNull(actual);
+    }
+
+    @Test
+    public void getTaskNameNullProcessInstanceIdTest() throws IOException, ContactCamundaException {
+        HistoricProcessInstanceEntity processInstance = new HistoricProcessInstanceEntity();
+        List<HistoricProcessInstanceEntity> processInstanceList = new ArrayList<>();
+        processInstanceList.add(processInstance);
+        ResponseEntity<List<HistoricProcessInstanceEntity>> response =
+                new ResponseEntity<>(processInstanceList, HttpStatus.OK);
+
+        String actual = camundaRequestHandler.getTaskInformation(response, REQUEST_ID);
+
+        assertNull(actual);
+    }
+
+    @Test
+    public void getTaskNameEmptyProcessInstanceListTest() throws IOException, ContactCamundaException {
+        List<HistoricProcessInstanceEntity> processInstanceList = new ArrayList<>();
+        ResponseEntity<List<HistoricProcessInstanceEntity>> response =
+                new ResponseEntity<>(processInstanceList, HttpStatus.OK);
+
+        String actual = camundaRequestHandler.getTaskInformation(response, REQUEST_ID);
+
+        assertNull(actual);
+    }
+
+    @Test
+    public void getTaskNameProcessInstanceLookupFailureTest() throws IOException, ContactCamundaException {
+        doThrow(HttpClientErrorException.class).when(camundaRequestHandler).getCamundaProcessInstanceHistory(REQUEST_ID,
+                false);
+
+        String result = camundaRequestHandler.getTaskName(REQUEST_ID);
+        assertNull(result);
+    }
+
+    @Test
+    public void getCamundaActivityHistoryTest() throws IOException, ContactCamundaException {
+        HttpHeaders headers = setHeaders();
+        HttpEntity<?> requestEntity = new HttpEntity<>(headers);
+        String targetUrl = "http://localhost:8089/sobpmnengine/history/activity-instance?processInstanceId="
+                + "c4c6b647-a26e-11e9-b144-0242ac14000b";
+        doReturn(activityInstanceResponse).when(restTemplate).exchange(targetUrl, HttpMethod.GET, requestEntity,
+                new ParameterizedTypeReference<List<HistoricActivityInstanceEntity>>() {});
+        doReturn(headers).when(camundaRequestHandler).setCamundaHeaders("auth", "key");
+        ResponseEntity<List<HistoricActivityInstanceEntity>> actualResponse =
+                camundaRequestHandler.getCamundaActivityHistory("c4c6b647-a26e-11e9-b144-0242ac14000b");
+        assertEquals(activityInstanceResponse, actualResponse);
+    }
+
+    @Test
+    public void getCamundaActivityHistoryErrorTest() {
+        HttpHeaders headers = setHeaders();
+        HttpEntity<?> requestEntity = new HttpEntity<>(headers);
+        String targetUrl = "http://localhost:8089/sobpmnengine/history/activity-instance?processInstanceId="
+                + "c4c6b647-a26e-11e9-b144-0242ac14000b";
+        doThrow(new ResourceAccessException("IOException")).when(restTemplate).exchange(targetUrl, HttpMethod.GET,
+                requestEntity, new ParameterizedTypeReference<List<HistoricActivityInstanceEntity>>() {});
+        doReturn(headers).when(camundaRequestHandler).setCamundaHeaders("auth", "key");
+
+        thrown.expect(ResourceAccessException.class);
+        camundaRequestHandler.getCamundaActivityHistory("c4c6b647-a26e-11e9-b144-0242ac14000b");
+
+        verify(restTemplate, times(1)).exchange(targetUrl, HttpMethod.GET, requestEntity,
+                new ParameterizedTypeReference<List<HistoricActivityInstanceEntity>>() {});
+    }
+
+    @Test
+    public void getCamundaProccesInstanceHistoryTest() throws IOException, ContactCamundaException {
+        HttpHeaders headers = setHeaders();
+        HttpEntity<?> requestEntity = new HttpEntity<>(headers);
+        String targetUrl =
+                "http://localhost:8089/sobpmnengine/history/process-instance?variables=mso-request-id_eq_" + REQUEST_ID;
+        doReturn(processInstanceResponse).when(restTemplate).exchange(targetUrl, HttpMethod.GET, requestEntity,
+                new ParameterizedTypeReference<List<HistoricProcessInstanceEntity>>() {});
+        doReturn(headers).when(camundaRequestHandler).setCamundaHeaders("auth", "key");
+
+        ResponseEntity<List<HistoricProcessInstanceEntity>> actualResponse =
+                camundaRequestHandler.getCamundaProcessInstanceHistory(REQUEST_ID, false);
+        assertEquals(processInstanceResponse, actualResponse);
+    }
+
+    @Test
+    public void getCamundaProccesInstanceHistoryRetryTest() {
+        HttpHeaders headers = setHeaders();
+        HttpEntity<?> requestEntity = new HttpEntity<>(headers);
+        String targetUrl =
+                "http://localhost:8089/sobpmnengine/history/process-instance?variables=mso-request-id_eq_" + REQUEST_ID;
+        doThrow(new ResourceAccessException("I/O error")).when(restTemplateRetry).exchange(targetUrl, HttpMethod.GET,
+                requestEntity, new ParameterizedTypeReference<List<HistoricProcessInstanceEntity>>() {});
+        doReturn(headers).when(camundaRequestHandler).setCamundaHeaders("auth", "key");
+
+        thrown.expect(ResourceAccessException.class);
+        camundaRequestHandler.getCamundaProcessInstanceHistory(REQUEST_ID, true);
+
+        verify(restTemplateRetry, times(2)).exchange(targetUrl, HttpMethod.GET, requestEntity,
+                new ParameterizedTypeReference<List<HistoricProcessInstanceEntity>>() {});
+    }
+
+    @Test
+    public void getCamundaProccesInstanceHistoryNoRetryTest() {
+        HttpHeaders headers = setHeaders();
+        HttpEntity<?> requestEntity = new HttpEntity<>(headers);
+        String targetUrl =
+                "http://localhost:8089/sobpmnengine/history/process-instance?variables=mso-request-id_eq_" + REQUEST_ID;
+        doThrow(HttpClientErrorException.class).when(restTemplate).exchange(targetUrl, HttpMethod.GET, requestEntity,
+                new ParameterizedTypeReference<List<HistoricProcessInstanceEntity>>() {});
+        doReturn(headers).when(camundaRequestHandler).setCamundaHeaders("auth", "key");
+
+        thrown.expect(HttpStatusCodeException.class);
+        camundaRequestHandler.getCamundaProcessInstanceHistory(REQUEST_ID, false);
+
+        verify(restTemplate, times(1)).exchange(targetUrl, HttpMethod.GET, requestEntity,
+                new ParameterizedTypeReference<List<HistoricProcessInstanceEntity>>() {});
+    }
+
+    @Test
+    public void getCamundaProccesInstanceHistoryFailThenSuccessTest() throws IOException, ContactCamundaException {
+        HttpHeaders headers = setHeaders();
+        HttpEntity<?> requestEntity = new HttpEntity<>(headers);
+        String targetUrl =
+                "http://localhost:8089/sobpmnengine/history/process-instance?variables=mso-request-id_eq_" + REQUEST_ID;
+        when(restTemplateRetry.exchange(targetUrl, HttpMethod.GET, requestEntity,
+                new ParameterizedTypeReference<List<HistoricProcessInstanceEntity>>() {}))
+                        .thenThrow(new ResourceAccessException("I/O Exception")).thenReturn(processInstanceResponse);
+        doReturn(headers).when(camundaRequestHandler).setCamundaHeaders("auth", "key");
+
+        ResponseEntity<List<HistoricProcessInstanceEntity>> actualResponse =
+                camundaRequestHandler.getCamundaProcessInstanceHistory(REQUEST_ID, true);
+
+        assertEquals(processInstanceResponse, actualResponse);
+        verify(restTemplateRetry, times(2)).exchange(targetUrl, HttpMethod.GET, requestEntity,
+                new ParameterizedTypeReference<List<HistoricProcessInstanceEntity>>() {});
+    }
+
+    @Test
+    public void setCamundaHeadersTest() throws ContactCamundaException, RequestDbFailureException {
+        String encryptedAuth = "015E7ACF706C6BBF85F2079378BDD2896E226E09D13DC2784BA309E27D59AB9FAD3A5E039DF0BB8408"; // user:password
+        String key = "07a7159d3bf51a0e53be7a8f89699be7";
+
+        HttpHeaders headers = camundaRequestHandler.setCamundaHeaders(encryptedAuth, key);
+        List<org.springframework.http.MediaType> acceptedType = headers.getAccept();
+
+        String expectedAcceptedType = "application/json";
+        assertEquals(expectedAcceptedType, acceptedType.get(0).toString());
+        String basicAuth = headers.getFirst(HttpHeaders.AUTHORIZATION);
+        String expectedBasicAuth = "Basic dXNlcjpwYXNzd29yZA==";
+
+        assertEquals(expectedBasicAuth, basicAuth);
+    }
+}