catalog-dao/src/test/java/org/openecomp/sdc/be/dao/cassandra/CassandraClientTest.java

   1 package org.openecomp.sdc.be.dao.cassandra;
   2
   3 import com.datastax.driver.core.Cluster;
   4 import com.datastax.driver.core.Cluster.Builder;
   5 import com.datastax.driver.core.Session;
   6 import com.datastax.driver.mapping.MappingManager;
   7 import fj.data.Either;
   8 import mockit.Deencapsulation;
   9 import org.apache.commons.lang3.tuple.ImmutablePair;
  10 import org.apache.tinkerpop.gremlin.structure.T;
  11 import org.junit.Test;
  12 import org.mockito.Mockito;
  13 import org.openecomp.sdc.be.config.ConfigurationManager;
  14 import org.openecomp.sdc.be.utils.DAOConfDependentTest;
  15
  16 public class CassandraClientTest extends DAOConfDependentTest {
  17
  18         private CassandraClient createTestSubject() {
  19                 return new CassandraClient();
  20         }
  21
  22         @Test
  23         public void testSetLocalDc() throws Exception {
  24                 CassandraClient testSubject;
  25                 Cluster.Builder clusterBuilder = null;
  26
  27                 Builder mock = Mockito.mock(Cluster.Builder.class);
  28                 Mockito.when(mock.withLoadBalancingPolicy(Mockito.any())).thenReturn(new Builder());
  29                 // default test
  30                 testSubject = createTestSubject();
  31                 Deencapsulation.invoke(testSubject, "setLocalDc", new Object[] { Cluster.Builder.class });
  32
  33                 ConfigurationManager.getConfigurationManager().getConfiguration().getCassandraConfig()
  34                                 .setLocalDataCenter("mock");
  35
  36                 testSubject = createTestSubject();
  37                 Deencapsulation.invoke(testSubject, "setLocalDc", mock);
  38         }
  39
  40         @Test
  41         public void testEnableSsl() throws Exception {
  42                 CassandraClient testSubject;
  43                 Cluster.Builder clusterBuilder = null;
  44
  45                 Builder mock = Mockito.mock(Cluster.Builder.class);
  46                 Mockito.when(mock.withSSL()).thenReturn(new Builder());
  47
  48                 ConfigurationManager.getConfigurationManager().getConfiguration().getCassandraConfig().setSsl(false);
  49                 // default test
  50                 testSubject = createTestSubject();
  51                 Deencapsulation.invoke(testSubject, "enableSsl", mock);
  52
  53                 ConfigurationManager.getConfigurationManager().getConfiguration().getCassandraConfig().setSsl(true);
  54                 // default test
  55                 testSubject = createTestSubject();
  56                 Deencapsulation.invoke(testSubject, "enableSsl", mock);
  57                 ConfigurationManager.getConfigurationManager().getConfiguration().getCassandraConfig().setTruststorePath(null);
  58                 ConfigurationManager.getConfigurationManager().getConfiguration().getCassandraConfig()
  59                                 .setTruststorePassword(null);
  60                 Deencapsulation.invoke(testSubject, "enableSsl", mock);
  61         }
  62
  63         @Test
  64         public void testEnableAuthentication() throws Exception {
  65                 CassandraClient testSubject;
  66                 Builder mock = Mockito.mock(Cluster.Builder.class);
  67                 Mockito.when(mock.withCredentials(Mockito.any(), Mockito.any())).thenReturn(new Builder());
  68
  69                 // default test
  70                 testSubject = createTestSubject();
  71                 Deencapsulation.invoke(testSubject, "enableAuthentication", Cluster.Builder.class);
  72
  73                 ConfigurationManager.getConfigurationManager().getConfiguration().getCassandraConfig().setAuthenticate(true);
  74                 Deencapsulation.invoke(testSubject, "enableAuthentication", mock);
  75                 ConfigurationManager.getConfigurationManager().getConfiguration().getCassandraConfig().setUsername(null);
  76                 ConfigurationManager.getConfigurationManager().getConfiguration().getCassandraConfig().setPassword(null);
  77                 Deencapsulation.invoke(testSubject, "enableAuthentication", mock);
  78         }
  79
  80         @Test
  81         public void testConnect() throws Exception {
  82                 CassandraClient testSubject;
  83                 String keyspace = "";
  84                 Either<ImmutablePair<Session, MappingManager>, CassandraOperationStatus> result;
  85
  86                 // default test
  87                 testSubject = createTestSubject();
  88                 result = testSubject.connect(keyspace);
  89         }
  90
  91         @Test
  92         public void testSave() throws Exception {
  93                 CassandraClient testSubject;
  94                 T entity = null;
  95                 Class<T> clazz = null;
  96                 MappingManager manager = null;
  97                 CassandraOperationStatus result;
  98
  99                 // default test
 100                 testSubject = createTestSubject();
 101                 result = testSubject.save(entity, clazz, manager);
 102         }
 103
 104         @Test
 105         public void testGetById() throws Exception {
 106                 CassandraClient testSubject;
 107                 String id = "";
 108                 Class<T> clazz = null;
 109                 MappingManager manager = null;
 110                 Either<T, CassandraOperationStatus> result;
 111
 112                 // default test
 113                 testSubject = createTestSubject();
 114                 result = testSubject.getById(id, clazz, manager);
 115         }
 116
 117         @Test
 118         public void testDelete() throws Exception {
 119                 CassandraClient testSubject;
 120                 String id = "";
 121                 Class<T> clazz = null;
 122                 MappingManager manager = null;
 123                 CassandraOperationStatus result;
 124
 125                 // default test
 126                 testSubject = createTestSubject();
 127                 result = testSubject.delete(id, clazz, manager);
 128         }
 129
 130         @Test
 131         public void testIsConnected() throws Exception {
 132                 CassandraClient testSubject;
 133                 boolean result;
 134
 135                 // default test
 136                 testSubject = createTestSubject();
 137                 result = testSubject.isConnected();
 138         }
 139
 140         @Test
 141         public void testCloseClient() throws Exception {
 142                 CassandraClient testSubject;
 143
 144                 // default test
 145                 testSubject = createTestSubject();
 146                 testSubject.closeClient();
 147         }
 148 }