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

   1 package org.openecomp.sdc.be.components.distribution.engine;
   2
   3 import com.att.nsa.mr.client.MRConsumer;
   4 import mockit.Deencapsulation;
   5 import org.junit.Test;
   6 import org.openecomp.sdc.be.config.DmaapConsumerConfiguration;
   7 import org.openecomp.sdc.be.config.DmaapConsumerConfiguration.Credential;
   8
   9 import java.io.File;
  10 import java.security.GeneralSecurityException;
  11 import java.util.Properties;
  12
  13 public class DmaapClientFactoryTest {
  14
  15         private DmaapClientFactory createTestSubject() {
  16                 return new DmaapClientFactory();
  17         }
  18
  19         @Test
  20         public void testCreate() throws Exception {
  21                 DmaapClientFactory testSubject;
  22                 DmaapConsumerConfiguration parameters = new DmaapConsumerConfiguration();
  23                 MRConsumer result;
  24                 String filePath = "src/test/resources/config/mock.txt";
  25
  26                 Credential credential = new Credential();
  27                 credential.setPassword("hmXYcznAljMSisdy8zgcag==");
  28                 credential.setUsername("mock");
  29                 parameters.setCredential(credential);
  30                 parameters.setLatitude(new Double(32452));
  31                 parameters.setLongitude(new Double(543534));
  32                 parameters.setVersion("mock");
  33                 parameters.setServiceName("mock");
  34                 parameters.setServiceName("mock");
  35                 parameters.setEnvironment("mock");
  36                 parameters.setPartner("mock");
  37                 parameters.setRouteOffer("mock");
  38                 parameters.setProtocol("mock");
  39                 parameters.setContenttype("mock");
  40                 parameters.setHosts("mock");
  41                 parameters.setTopic("mock");
  42                 parameters.setConsumerGroup("mock");
  43                 parameters.setConsumerId("mock");
  44                 parameters.setTimeoutMs(42354);
  45                 parameters.setLimit(43534);
  46                 parameters.setDme2TraceOn(true);
  47                 parameters.setAftEnvironment("mock");
  48                 parameters.setAftDme2ConnectionTimeoutMs(234324);
  49                 parameters.setAftDme2RoundtripTimeoutMs(435345);
  50                 parameters.setAftDme2ReadTimeoutMs(5645);
  51                 parameters.setDme2preferredRouterFilePath(filePath);
  52
  53                 // default test
  54                 testSubject = createTestSubject();
  55                 result = testSubject.create(parameters);
  56                 File file = new File(filePath);
  57                 file.delete();
  58
  59         }
  60
  61         @Test
  62         public void testBuildProperties() throws Exception {
  63                 DmaapClientFactory testSubject;
  64                 DmaapConsumerConfiguration parameters = new DmaapConsumerConfiguration();
  65                 Properties result;
  66                 String filePath = "src/test/resources/config/mock.txt";
  67
  68                 Credential credential = new Credential();
  69                 credential.setPassword("hmXYcznAljMSisdy8zgcag==");
  70                 credential.setUsername("mock");
  71                 parameters.setCredential(credential);
  72                 parameters.setLatitude(new Double(32452));
  73                 parameters.setLongitude(new Double(543534));
  74                 parameters.setVersion("mock");
  75                 parameters.setServiceName("mock");
  76                 parameters.setServiceName("mock");
  77                 parameters.setEnvironment("mock");
  78                 parameters.setPartner("mock");
  79                 parameters.setRouteOffer("mock");
  80                 parameters.setProtocol("mock");
  81                 parameters.setContenttype("mock");
  82                 parameters.setHosts("mock");
  83                 parameters.setTopic("mock");
  84                 parameters.setConsumerGroup("mock");
  85                 parameters.setConsumerId("mock");
  86                 parameters.setTimeoutMs(42354);
  87                 parameters.setLimit(43534);
  88                 parameters.setDme2TraceOn(true);
  89                 parameters.setAftEnvironment("mock");
  90                 parameters.setAftDme2ConnectionTimeoutMs(234324);
  91                 parameters.setAftDme2RoundtripTimeoutMs(435345);
  92                 parameters.setAftDme2ReadTimeoutMs(5645);
  93                 parameters.setDme2preferredRouterFilePath(filePath);
  94
  95                 // default test
  96                 testSubject = createTestSubject();
  97                 result = Deencapsulation.invoke(testSubject, "buildProperties", parameters);
  98
  99                 File file = new File(filePath);
 100                 file.delete();
 101         }
 102
 103         @Test(expected = GeneralSecurityException.class)
 104         public void testBuildProperties_2() throws Exception {
 105                 DmaapClientFactory testSubject;
 106                 DmaapConsumerConfiguration parameters = new DmaapConsumerConfiguration();
 107                 Properties result;
 108                 String filePath = "src/test/resources/config/mock.txt";
 109
 110                 Credential credential = new Credential();
 111                 credential.setPassword("mock");
 112                 parameters.setCredential(credential);
 113
 114                 // default test
 115                 testSubject = createTestSubject();
 116                 result = Deencapsulation.invoke(testSubject, "buildProperties", parameters);
 117         }
 118
 119         @Test
 120         public void testEnsureFileExists() throws Exception {
 121                 DmaapClientFactory testSubject;
 122                 String filePath = "src/test/resources/config/mock.txt";
 123
 124                 // default test
 125                 testSubject = createTestSubject();
 126                 Deencapsulation.invoke(testSubject, "ensureFileExists", new Object[] { filePath });
 127                 Deencapsulation.invoke(testSubject, "ensureFileExists", filePath);
 128                 File file = new File(filePath);
 129                 file.delete();
 130         }
 131 }