catalog-be/src/test/java/org/openecomp/sdc/be/components/distribution/engine/CambriaHandlerTest.java

   1 package org.openecomp.sdc.be.components.distribution.engine;
   2
   3 import com.att.nsa.apiClient.credentials.ApiCredential;
   4 import com.att.nsa.apiClient.http.HttpException;
   5 import com.att.nsa.cambria.client.CambriaClient.CambriaApiException;
   6 import com.att.nsa.cambria.client.CambriaIdentityManager;
   7 import fj.data.Either;
   8 import org.junit.Before;
   9 import org.junit.BeforeClass;
  10 import org.junit.Test;
  11 import org.junit.runner.RunWith;
  12 import org.mockito.Mock;
  13 import org.mockito.Mockito;
  14 import org.mockito.Spy;
  15 import org.mockito.junit.MockitoJUnitRunner;
  16 import org.openecomp.sdc.be.config.ConfigurationManager;
  17 import org.openecomp.sdc.be.distribution.api.client.CambriaOperationStatus;
  18 import org.openecomp.sdc.common.api.ConfigurationSource;
  19 import org.openecomp.sdc.common.impl.ExternalConfiguration;
  20 import org.openecomp.sdc.common.impl.FSConfigurationSource;
  21
  22 import java.io.IOException;
  23 import java.net.MalformedURLException;
  24 import java.security.GeneralSecurityException;
  25 import java.util.Arrays;
  26
  27 import static org.junit.Assert.assertEquals;
  28 import static org.junit.Assert.assertTrue;
  29 import static org.mockito.Matchers.any;
  30 import static org.mockito.Mockito.doReturn;
  31
  32 @RunWith(MockitoJUnitRunner.class)
  33 public class CambriaHandlerTest {
  34     @Spy
  35     private CambriaHandler handler = new CambriaHandler();
  36
  37     @Mock
  38     private CambriaIdentityManager createIdentityManager;
  39
  40     private ApiCredential apiCredential = new ApiCredential("apiKey", "apiSecret");
  41
  42     @BeforeClass
  43     public static void beforeClass() {
  44         String appConfigDir = "src/test/resources/config/catalog-be";
  45         ConfigurationSource configurationSource = new FSConfigurationSource(ExternalConfiguration.getChangeListener(), appConfigDir);
  46         new ConfigurationManager(configurationSource);
  47     }
  48
  49
  50     @Before
  51     public void startUp() throws MalformedURLException, GeneralSecurityException {
  52         doReturn(createIdentityManager).when(handler).buildCambriaClient(any());
  53     }
  54
  55     @Test
  56     public void testCreateUebKeys() throws HttpException, CambriaApiException, IOException {
  57         Mockito.when(createIdentityManager.createApiKey(Mockito.anyString(), Mockito.anyString())).thenReturn(apiCredential);
  58         Either<ApiCredential, CambriaErrorResponse> eitherCreateUebKeys = handler.createUebKeys(Arrays.asList("Myhost:1234") );
  59
  60         Mockito.verify(createIdentityManager).setApiCredentials(Mockito.anyString(), Mockito.anyString());
  61
  62         assertTrue("Unexpected Operational Status", eitherCreateUebKeys.isLeft());
  63
  64     }
  65
  66     @Test
  67     public void testCreateUebKeys_FAIL() throws HttpException, CambriaApiException, IOException {
  68         Mockito.when(createIdentityManager.createApiKey(Mockito.anyString(), Mockito.anyString())).thenThrow(new CambriaApiException("Error Message"));
  69         Either<ApiCredential, CambriaErrorResponse> eitherCreateUebKeys = handler.createUebKeys(Arrays.asList("Myhost:1234") );
  70         Mockito.verify(createIdentityManager, Mockito.never()).setApiCredentials(Mockito.anyString(), Mockito.anyString());
  71         assertTrue("Unexpected Operational Status", eitherCreateUebKeys.isRight());
  72         CambriaErrorResponse response = eitherCreateUebKeys.right().value();
  73         assertEquals("Unexpected Operational Status", CambriaOperationStatus.CONNNECTION_ERROR, response.getOperationStatus());
  74         assertEquals("Unexpected HTTP Code", 500, response.getHttpCode().intValue());
  75     }
  76
  77 }