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

   1 package org.openecomp.sdc.be.dao.cassandra;
   2
   3 import com.datastax.driver.core.Session;
   4 import com.datastax.driver.mapping.MappingManager;
   5 import com.datastax.driver.mapping.Result;
   6 import fj.data.Either;
   7 import org.apache.commons.lang3.tuple.ImmutablePair;
   8 import org.junit.Before;
   9 import org.junit.Test;
  10 import org.mockito.InjectMocks;
  11 import org.mockito.Mock;
  12 import org.mockito.Mockito;
  13 import org.mockito.MockitoAnnotations;
  14 import org.openecomp.sdc.be.dao.api.ActionStatus;
  15 import org.openecomp.sdc.be.resources.data.auditing.*;
  16
  17 import java.util.LinkedList;
  18 import java.util.List;
  19
  20 public class AuditCassandraDaoTest {
  21
  22         @InjectMocks
  23         AuditCassandraDao testSubject;
  24
  25         @Mock
  26         AuditAccessor auditAccessor;
  27
  28         @Mock
  29         CassandraClient client;
  30
  31         @Before
  32         public void setUp() throws Exception {
  33                 MockitoAnnotations.initMocks(this);
  34         }
  35
  36         @Test(expected = RuntimeException.class)
  37         public void testInit() throws Exception {
  38                 Mockito.when(client.isConnected()).thenReturn(true);
  39                 Either<ImmutablePair<Session, MappingManager>, CassandraOperationStatus> value = Either
  40                                 .right(CassandraOperationStatus.CLUSTER_NOT_CONNECTED);
  41                 Mockito.when(client.connect(Mockito.anyString())).thenReturn(value);
  42                 testSubject.init();
  43         }
  44
  45         @Test
  46         public void testInitFail2() throws Exception {
  47                 Mockito.when(client.isConnected()).thenReturn(false);
  48                 testSubject.init();
  49         }
  50
  51         @Test
  52         public void testGetListOfDistributionStatuses() throws Exception {
  53                 String did = "";
  54                 Either<List<DistributionStatusEvent>, ActionStatus> result;
  55
  56                 Result<DistributionStatusEvent> value = Mockito.mock(Result.class);
  57                 LinkedList<DistributionStatusEvent> value2 = new LinkedList<>();
  58                 value2.add(new DistributionStatusEvent());
  59                 Mockito.when(value.all()).thenReturn(value2);
  60                 Mockito.when(auditAccessor.getListOfDistributionStatuses(Mockito.anyString())).thenReturn(value);
  61
  62                 // default test
  63                 result = testSubject.getListOfDistributionStatuses(did);
  64         }
  65
  66         @Test
  67         public void testGetListOfDistributionStatusesException() throws Exception {
  68                 String did = "";
  69                 Either<List<DistributionStatusEvent>, ActionStatus> result;
  70
  71                 Mockito.when(auditAccessor.getListOfDistributionStatuses(Mockito.anyString()))
  72                                 .thenThrow(RuntimeException.class);
  73
  74                 // default test
  75                 result = testSubject.getListOfDistributionStatuses(did);
  76         }
  77
  78         @Test
  79         public void testGetListOfDistributionStatusesEmptyList() throws Exception {
  80                 String did = "";
  81                 Either<List<DistributionStatusEvent>, ActionStatus> result;
  82
  83                 // default test
  84                 result = testSubject.getListOfDistributionStatuses(did);
  85         }
  86
  87         @Test
  88         public void testGetDistributionDeployByStatus() throws Exception {
  89                 String did = "";
  90                 String action = "";
  91                 String status = "";
  92                 Either<List<DistributionDeployEvent>, ActionStatus> result;
  93
  94                 Result<DistributionDeployEvent> value = Mockito.mock(Result.class);
  95                 LinkedList<DistributionDeployEvent> value2 = new LinkedList<>();
  96                 value2.add(new DistributionDeployEvent());
  97                 Mockito.when(value.all()).thenReturn(value2);
  98                 Mockito.when(auditAccessor.getDistributionDeployByStatus(Mockito.anyString(), Mockito.anyString(),
  99                                 Mockito.anyString())).thenReturn(value);
 100
 101                 // default test
 102                 result = testSubject.getDistributionDeployByStatus(did, action, status);
 103         }
 104
 105         @Test
 106         public void testGetDistributionDeployByStatusEmptyList() throws Exception {
 107                 String did = "";
 108                 String action = "";
 109                 String status = "";
 110                 Either<List<DistributionDeployEvent>, ActionStatus> result;
 111
 112                 Result<DistributionDeployEvent> value = Mockito.mock(Result.class);
 113                 LinkedList<DistributionDeployEvent> value2 = new LinkedList<>();
 114                 value2.add(new DistributionDeployEvent());
 115                 Mockito.when(value.all()).thenReturn(value2);
 116                 Mockito.when(auditAccessor.getDistributionDeployByStatus(Mockito.anyString(), Mockito.anyString(),
 117                                 Mockito.anyString())).thenReturn(null);
 118
 119                 // default test
 120                 result = testSubject.getDistributionDeployByStatus(did, action, status);
 121         }
 122
 123         @Test
 124         public void testGetDistributionDeployByStatusException() throws Exception {
 125                 String did = "";
 126                 String action = "";
 127                 String status = "";
 128                 Either<List<DistributionDeployEvent>, ActionStatus> result;
 129
 130                 Mockito.when(auditAccessor.getDistributionDeployByStatus(Mockito.anyString(), Mockito.anyString(),
 131                                 Mockito.anyString())).thenThrow(RuntimeException.class);
 132
 133                 // default test
 134                 result = testSubject.getDistributionDeployByStatus(did, action, status);
 135         }
 136
 137         @Test
 138         public void testGetDistributionRequest() throws Exception {
 139                 String did = "";
 140                 String action = "";
 141                 Either<List<ResourceAdminEvent>, ActionStatus> result;
 142
 143                 // default test
 144                 result = testSubject.getDistributionRequest(did, action);
 145         }
 146
 147         @Test
 148         public void testGetDistributionRequestList() throws Exception {
 149                 String did = "";
 150                 String action = "";
 151                 Either<List<ResourceAdminEvent>, ActionStatus> result;
 152
 153                 Result<ResourceAdminEvent> value = Mockito.mock(Result.class);
 154                 List<ResourceAdminEvent> value2 = new LinkedList<>();
 155                 value2.add(new ResourceAdminEvent());
 156                 Mockito.when(value.all()).thenReturn(value2);
 157                 Mockito.when(auditAccessor.getDistributionRequest(Mockito.anyString(), Mockito.anyString())).thenReturn(value);
 158
 159                 // default test
 160                 result = testSubject.getDistributionRequest(did, action);
 161         }
 162
 163         @Test
 164         public void testGetDistributionRequestException() throws Exception {
 165                 String did = "";
 166                 String action = "";
 167                 Either<List<ResourceAdminEvent>, ActionStatus> result;
 168
 169                 Mockito.when(auditAccessor.getDistributionRequest(Mockito.anyString(), Mockito.anyString()))
 170                                 .thenThrow(RuntimeException.class);
 171
 172                 // default test
 173                 result = testSubject.getDistributionRequest(did, action);
 174         }
 175
 176         @Test
 177         public void testGetDistributionNotify() throws Exception {
 178                 String did = "";
 179                 String action = "";
 180                 Either<List<DistributionNotificationEvent>, ActionStatus> result;
 181
 182                 Result<DistributionNotificationEvent> value = Mockito.mock(Result.class);
 183                 List<DistributionNotificationEvent> value2 = new LinkedList<>();
 184                 value2.add(new DistributionNotificationEvent());
 185                 Mockito.when(value.all()).thenReturn(value2);
 186
 187                 Mockito.when(auditAccessor.getDistributionNotify(Mockito.anyString(), Mockito.anyString())).thenReturn(value);
 188
 189                 // default test
 190                 result = testSubject.getDistributionNotify(did, action);
 191         }
 192
 193         @Test
 194         public void testGetDistributionNotifyException() throws Exception {
 195                 String did = "";
 196                 String action = "";
 197                 Either<List<DistributionNotificationEvent>, ActionStatus> result;
 198
 199                 Mockito.when(auditAccessor.getDistributionNotify(Mockito.anyString(), Mockito.anyString()))
 200                                 .thenThrow(RuntimeException.class);
 201
 202                 // default test
 203                 result = testSubject.getDistributionNotify(did, action);
 204         }
 205
 206         @Test
 207         public void testGetDistributionNotifyNull() throws Exception {
 208                 String did = "";
 209                 String action = "";
 210                 Either<List<DistributionNotificationEvent>, ActionStatus> result;
 211
 212                 // default test
 213                 result = testSubject.getDistributionNotify(did, action);
 214         }
 215
 216         @Test
 217         public void testGetByServiceInstanceId() throws Exception {
 218                 String serviceInstanceId = "";
 219                 Either<List<ResourceAdminEvent>, ActionStatus> result;
 220
 221                 Result<ResourceAdminEvent> value = Mockito.mock(Result.class);
 222                 List<ResourceAdminEvent> value2 = new LinkedList<>();
 223                 value2.add(new ResourceAdminEvent());
 224                 Mockito.when(value.all()).thenReturn(value2);
 225                 Mockito.when(auditAccessor.getByServiceInstanceId(Mockito.anyString())).thenReturn(value);
 226                 // default test
 227                 result = testSubject.getByServiceInstanceId(serviceInstanceId);
 228         }
 229
 230         @Test
 231         public void testGetByServiceInstanceIdException() throws Exception {
 232                 String serviceInstanceId = "";
 233                 Either<List<ResourceAdminEvent>, ActionStatus> result;
 234
 235                 Mockito.when(auditAccessor.getByServiceInstanceId(Mockito.anyString())).thenThrow(RuntimeException.class);
 236                 // default test
 237                 result = testSubject.getByServiceInstanceId(serviceInstanceId);
 238         }
 239
 240         @Test
 241         public void testGetByServiceInstanceIdNull() throws Exception {
 242                 String serviceInstanceId = "";
 243                 Either<List<ResourceAdminEvent>, ActionStatus> result;
 244
 245                 // default test
 246                 result = testSubject.getByServiceInstanceId(serviceInstanceId);
 247         }
 248
 249         @Test
 250         public void testGetServiceDistributionStatusesList() throws Exception {
 251                 String serviceInstanceId = "";
 252                 Either<List<? extends AuditingGenericEvent>, ActionStatus> result;
 253
 254                 Result<ResourceAdminEvent> value = Mockito.mock(Result.class);
 255                 List<ResourceAdminEvent> value2 = new LinkedList<>();
 256                 value2.add(new ResourceAdminEvent());
 257                 Mockito.when(value.all()).thenReturn(value2);
 258                 Mockito.when(auditAccessor.getServiceDistributionStatus(Mockito.anyString())).thenReturn(value);
 259
 260                 // default test
 261                 result = testSubject.getServiceDistributionStatusesList(serviceInstanceId);
 262         }
 263
 264         @Test
 265         public void testGetServiceDistributionStatusesList2() throws Exception {
 266                 String serviceInstanceId = "";
 267                 Either<List<? extends AuditingGenericEvent>, ActionStatus> result;
 268
 269                 Result<ResourceAdminEvent> value = Mockito.mock(Result.class);
 270                 List<ResourceAdminEvent> value2 = new LinkedList<>();
 271                 value2.add(new ResourceAdminEvent());
 272                 Mockito.when(value.all()).thenReturn(value2);
 273                 Mockito.when(auditAccessor.getServiceDistributionStatus(Mockito.anyString())).thenReturn(value);
 274
 275                 Result<DistributionDeployEvent> value3 = Mockito.mock(Result.class);
 276                 List<DistributionDeployEvent> value4 = new LinkedList<>();
 277                 value4.add(new DistributionDeployEvent());
 278                 Mockito.when(value3.all()).thenReturn(value4);
 279                 Mockito.when(auditAccessor.getServiceDistributionDeploy(Mockito.anyString())).thenReturn(value3);
 280
 281                 // default test
 282                 result = testSubject.getServiceDistributionStatusesList(serviceInstanceId);
 283         }
 284
 285         @Test
 286         public void testGetServiceDistributionStatusesList3() throws Exception {
 287                 String serviceInstanceId = "";
 288                 Either<List<? extends AuditingGenericEvent>, ActionStatus> result;
 289
 290                 Result<ResourceAdminEvent> value = Mockito.mock(Result.class);
 291                 List<ResourceAdminEvent> value2 = new LinkedList<>();
 292                 value2.add(new ResourceAdminEvent());
 293                 Mockito.when(value.all()).thenReturn(value2);
 294                 Mockito.when(auditAccessor.getServiceDistributionStatus(Mockito.anyString())).thenReturn(value);
 295
 296                 Result<DistributionDeployEvent> value3 = Mockito.mock(Result.class);
 297                 List<DistributionDeployEvent> value4 = new LinkedList<>();
 298                 value4.add(new DistributionDeployEvent());
 299                 Mockito.when(value3.all()).thenReturn(value4);
 300                 Mockito.when(auditAccessor.getServiceDistributionDeploy(Mockito.anyString())).thenReturn(value3);
 301
 302
 303                 Result<DistributionNotificationEvent> value5 = Mockito.mock(Result.class);
 304                 List<DistributionNotificationEvent> value6 = new LinkedList<>();
 305                 value6.add(new DistributionNotificationEvent());
 306                 Mockito.when(value5.all()).thenReturn(value6);
 307                 Mockito.when(auditAccessor.getServiceDistributionNotify(Mockito.anyString())).thenReturn(value5);
 308
 309                 // default test
 310                 result = testSubject.getServiceDistributionStatusesList(serviceInstanceId);
 311         }
 312
 313         @Test
 314         public void testGetServiceDistributionStatusesListException3() throws Exception {
 315                 String serviceInstanceId = "";
 316                 Either<List<? extends AuditingGenericEvent>, ActionStatus> result;
 317
 318                 Result<ResourceAdminEvent> value = Mockito.mock(Result.class);
 319                 List<ResourceAdminEvent> value2 = new LinkedList<>();
 320                 value2.add(new ResourceAdminEvent());
 321                 Mockito.when(value.all()).thenReturn(value2);
 322                 Mockito.when(auditAccessor.getServiceDistributionStatus(Mockito.anyString())).thenReturn(value);
 323
 324                 Result<DistributionDeployEvent> value3 = Mockito.mock(Result.class);
 325                 List<DistributionDeployEvent> value4 = new LinkedList<>();
 326                 value4.add(new DistributionDeployEvent());
 327                 Mockito.when(value3.all()).thenReturn(value4);
 328                 Mockito.when(auditAccessor.getServiceDistributionDeploy(Mockito.anyString())).thenReturn(value3);
 329
 330                 Mockito.when(auditAccessor.getServiceDistributionNotify(Mockito.anyString())).thenThrow(RuntimeException.class);
 331
 332                 // default test
 333                 result = testSubject.getServiceDistributionStatusesList(serviceInstanceId);
 334         }
 335
 336         @Test
 337         public void testGetServiceDistributionStatusesListException2() throws Exception {
 338                 String serviceInstanceId = "";
 339                 Either<List<? extends AuditingGenericEvent>, ActionStatus> result;
 340
 341                 Result<ResourceAdminEvent> value = Mockito.mock(Result.class);
 342                 List<ResourceAdminEvent> value2 = new LinkedList<>();
 343                 value2.add(new ResourceAdminEvent());
 344                 Mockito.when(value.all()).thenReturn(value2);
 345                 Mockito.when(auditAccessor.getServiceDistributionStatus(Mockito.anyString())).thenReturn(value);
 346
 347                 Mockito.when(auditAccessor.getServiceDistributionDeploy(Mockito.anyString())).thenThrow(RuntimeException.class);
 348
 349                 // default test
 350                 result = testSubject.getServiceDistributionStatusesList(serviceInstanceId);
 351         }
 352
 353         @Test
 354         public void testGetServiceDistributionStatusesListException() throws Exception {
 355                 String serviceInstanceId = "";
 356                 Either<List<? extends AuditingGenericEvent>, ActionStatus> result;
 357
 358                 Mockito.when(auditAccessor.getServiceDistributionStatus(Mockito.anyString())).thenThrow(RuntimeException.class);
 359
 360                 // default test
 361                 result = testSubject.getServiceDistributionStatusesList(serviceInstanceId);
 362         }
 363
 364         @Test
 365         public void testGetServiceDistributionStatusesListNull() throws Exception {
 366                 String serviceInstanceId = "";
 367                 Either<List<? extends AuditingGenericEvent>, ActionStatus> result;
 368
 369                 // default test
 370                 result = testSubject.getServiceDistributionStatusesList(serviceInstanceId);
 371         }
 372
 373         @Test
 374         public void testGetAuditByServiceIdAndPrevVersionNull() throws Exception {
 375                 String serviceInstanceId = "";
 376                 String prevVersion = "";
 377                 Either<List<ResourceAdminEvent>, ActionStatus> result;
 378
 379                 // default test
 380                 result = testSubject.getAuditByServiceIdAndPrevVersion(serviceInstanceId, prevVersion);
 381         }
 382
 383         @Test
 384         public void testGetAuditByServiceIdAndPrevVersion() throws Exception {
 385                 String serviceInstanceId = "";
 386                 String prevVersion = "";
 387                 Either<List<ResourceAdminEvent>, ActionStatus> result;
 388
 389                 Result<ResourceAdminEvent> value = Mockito.mock(Result.class);
 390                 List<ResourceAdminEvent> value2 = new LinkedList<>();
 391                 value2.add(new ResourceAdminEvent());
 392                 Mockito.when(value.all()).thenReturn(value2);
 393                 Mockito.when(auditAccessor.getAuditByServiceIdAndPrevVersion(Mockito.anyString(), Mockito.anyString())).thenReturn(value);
 394
 395                 // default test
 396                 result = testSubject.getAuditByServiceIdAndPrevVersion(serviceInstanceId, prevVersion);
 397         }
 398
 399         @Test
 400         public void testGetAuditByServiceIdAndPrevVersionException() throws Exception {
 401                 String serviceInstanceId = "";
 402                 String prevVersion = "";
 403                 Either<List<ResourceAdminEvent>, ActionStatus> result;
 404
 405                 Mockito.when(auditAccessor.getAuditByServiceIdAndPrevVersion(Mockito.anyString(), Mockito.anyString())).thenThrow(RuntimeException.class);
 406
 407                 // default test
 408                 result = testSubject.getAuditByServiceIdAndPrevVersion(serviceInstanceId, prevVersion);
 409         }
 410
 411         @Test
 412         public void testGetAuditByServiceIdAndCurrVersionNull() throws Exception {
 413                 String serviceInstanceId = "";
 414                 String currVersion = "";
 415                 Either<List<ResourceAdminEvent>, ActionStatus> result;
 416
 417                 // default test
 418                 result = testSubject.getAuditByServiceIdAndCurrVersion(serviceInstanceId, currVersion);
 419         }
 420
 421         @Test
 422         public void testGetAuditByServiceIdAndCurrVersion() throws Exception {
 423                 String serviceInstanceId = "";
 424                 String currVersion = "";
 425                 Either<List<ResourceAdminEvent>, ActionStatus> result;
 426
 427                 Result<ResourceAdminEvent> value = Mockito.mock(Result.class);
 428                 List<ResourceAdminEvent> value2 = new LinkedList<>();
 429                 value2.add(new ResourceAdminEvent());
 430                 Mockito.when(value.all()).thenReturn(value2);
 431                 Mockito.when(auditAccessor.getAuditByServiceIdAndCurrVersion(Mockito.anyString(), Mockito.anyString())).thenReturn(value);
 432
 433                 // default test
 434                 result = testSubject.getAuditByServiceIdAndCurrVersion(serviceInstanceId, currVersion);
 435         }
 436
 437         @Test
 438         public void testGetAuditByServiceIdAndCurrVersionException() throws Exception {
 439                 String serviceInstanceId = "";
 440                 String currVersion = "";
 441                 Either<List<ResourceAdminEvent>, ActionStatus> result;
 442
 443                 Mockito.when(auditAccessor.getAuditByServiceIdAndCurrVersion(Mockito.anyString(), Mockito.anyString())).thenThrow(RuntimeException.class);
 444
 445                 // default test
 446                 result = testSubject.getAuditByServiceIdAndCurrVersion(serviceInstanceId, currVersion);
 447         }
 448
 449         @Test
 450         public void testIsTableEmpty() throws Exception {
 451                 String tableName = "";
 452                 Either<Boolean, CassandraOperationStatus> result;
 453
 454                 // default test
 455                 result = testSubject.isTableEmpty(tableName);
 456         }
 457
 458         @Test
 459         public void testDeleteAllAudit() throws Exception {
 460                 CassandraOperationStatus result;
 461
 462                 // default test
 463                 result = testSubject.deleteAllAudit();
 464         }
 465 }