adapters/mso-openstack-adapters/src/test/java/org/onap/so/adapters/audit/AuditStackServiceTest.java

   1 package org.onap.so.adapters.audit;
   2
   3 import static com.shazam.shazamcrest.MatcherAssert.assertThat;
   4 import static com.shazam.shazamcrest.matcher.Matchers.sameBeanAs;
   5 import static org.junit.Assert.assertEquals;
   6 import static org.junit.Assert.assertNotNull;
   7 import org.camunda.bpm.client.ExternalTaskClient;
   8 import org.camunda.bpm.client.interceptor.ClientRequestInterceptor;
   9 import org.camunda.bpm.client.interceptor.auth.BasicAuthProvider;
  10 import org.junit.Before;
  11 import org.junit.Test;
  12 import org.junit.runner.RunWith;
  13 import org.mockito.InjectMocks;
  14 import org.mockito.Mock;
  15 import org.mockito.Mockito;
  16 import org.mockito.Spy;
  17 import org.mockito.junit.MockitoJUnitRunner;
  18 import org.onap.so.utils.CryptoUtils;
  19 import org.springframework.core.env.Environment;
  20
  21 @RunWith(MockitoJUnitRunner.class)
  22 public class AuditStackServiceTest {
  23
  24     @Spy
  25     @InjectMocks
  26     AuditStackService auditStackService;
  27
  28     @Mock
  29     Environment mockEnvironment;
  30
  31
  32     @Before
  33     public void before() {
  34         Mockito.doReturn("5").when(mockEnvironment).getProperty("workflow.topics.maxClients", "10");
  35         Mockito.doReturn("6B466C603A260F3655DBF91E53CE54667041C01406D10E8CAF9CC24D8FA5388D06F90BFE4C852052B436")
  36                 .when(mockEnvironment).getRequiredProperty("mso.auth");
  37         Mockito.doReturn("07a7159d3bf51a0e53be7a8f89699be7").when(mockEnvironment).getRequiredProperty("mso.msoKey");
  38         Mockito.doReturn("something").when(mockEnvironment).getRequiredProperty("mso.config.cadi.aafId");
  39         Mockito.doReturn("host.com").when(mockEnvironment).getRequiredProperty("mso.workflow.endpoint");
  40     }
  41
  42     @Test
  43     public void testGetMaxClients() throws Exception {
  44         int actual = auditStackService.getMaxClients();
  45         assertEquals(5, actual);
  46     }
  47
  48     @Test
  49     public void testCreateClientRequestInterceptor() throws Exception {
  50         String auth = CryptoUtils.decrypt(
  51                 "6B466C603A260F3655DBF91E53CE54667041C01406D10E8CAF9CC24D8FA5388D06F90BFE4C852052B436",
  52                 "07a7159d3bf51a0e53be7a8f89699be7");
  53         ClientRequestInterceptor expected = new BasicAuthProvider("something", auth);
  54         ClientRequestInterceptor actual = auditStackService.createClientRequestInterceptor();
  55         assertThat(actual, sameBeanAs(expected));
  56
  57     }
  58
  59     @Test
  60     public void testCreateExternalTaskClient() throws Exception {
  61         String auth = CryptoUtils.decrypt(
  62                 "6B466C603A260F3655DBF91E53CE54667041C01406D10E8CAF9CC24D8FA5388D06F90BFE4C852052B436",
  63                 "07a7159d3bf51a0e53be7a8f89699be7");
  64         ClientRequestInterceptor inter = new BasicAuthProvider("something", auth);
  65         Mockito.doReturn(inter).when(auditStackService).createClientRequestInterceptor();
  66         ExternalTaskClient actual = auditStackService.createExternalTaskClient();
  67         assertNotNull(actual);
  68         Mockito.verify(auditStackService, Mockito.times(1)).createClientRequestInterceptor();
  69
  70     }
  71 }