catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/ecompopenv/AuditEcompOpEnvEventTest.java

   1 package org.openecomp.sdc.be.auditing.impl.ecompopenv;
   2
   3 import org.junit.Before;
   4 import org.junit.Test;
   5 import org.junit.runner.RunWith;
   6 import org.mockito.ArgumentCaptor;
   7 import org.mockito.Captor;
   8 import org.mockito.Mock;
   9 import org.mockito.junit.MockitoJUnitRunner;
  10 import org.openecomp.sdc.be.auditing.api.AuditEventFactory;
  11 import org.openecomp.sdc.be.auditing.impl.AuditEcompOpEnvEventFactory;
  12 import org.openecomp.sdc.be.auditing.impl.AuditingManager;
  13 import org.openecomp.sdc.be.config.Configuration;
  14 import org.openecomp.sdc.be.dao.api.ActionStatus;
  15 import org.openecomp.sdc.be.dao.cassandra.AuditCassandraDao;
  16 import org.openecomp.sdc.be.dao.cassandra.CassandraOperationStatus;
  17 import org.openecomp.sdc.be.dao.impl.AuditingDao;
  18 import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum;
  19 import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent;
  20 import org.openecomp.sdc.be.resources.data.auditing.EcompOperationalEnvironmentEvent;
  21
  22 import static org.assertj.core.api.Assertions.assertThat;
  23 import static org.mockito.ArgumentMatchers.any;
  24 import static org.mockito.ArgumentMatchers.eq;
  25 import static org.mockito.Mockito.verify;
  26 import static org.mockito.Mockito.when;
  27 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.*;
  28
  29 @RunWith(MockitoJUnitRunner.class)
  30 public class AuditEcompOpEnvEventTest {
  31
  32     private AuditingManager auditingManager;
  33
  34     @Mock
  35     private static AuditCassandraDao cassandraDao;
  36     @Mock
  37     private static AuditingDao auditingDao;
  38     @Mock
  39     private static Configuration.ElasticSearchConfig esConfig;
  40
  41     @Captor
  42     private ArgumentCaptor<EcompOperationalEnvironmentEvent> eventCaptor;
  43
  44     @Before
  45     public void setUp() {
  46         init(esConfig);
  47         auditingManager = new AuditingManager(auditingDao, cassandraDao);
  48     }
  49
  50     @Test
  51     public void testCreateOpEnvEvent() {
  52         AuditEventFactory factory = new AuditEcompOpEnvEventFactory(AuditingActionEnum.CREATE_ENVIRONMENT,
  53                 OP_ENV_ID, OP_ENV_NAME, OP_ENV_TYPE, OP_ENV_ACTION, TENANT_CONTEXT);
  54
  55         when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.CREATE_ENVIRONMENT.getAuditingEsType())))
  56                 .thenReturn(ActionStatus.OK);
  57         when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK);
  58
  59         assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_CREATE_OP_ENV_LOG_STR);
  60         verifyEvent(AuditingActionEnum.CREATE_ENVIRONMENT.getName());
  61     }
  62
  63     @Test
  64     public void testUnsupportedTypeOpEnvEvent() {
  65         AuditEventFactory factory = new AuditEcompOpEnvEventFactory(AuditingActionEnum.UNSUPPORTED_ENVIRONMENT_TYPE,
  66                 OP_ENV_ID, OP_ENV_NAME, OP_ENV_TYPE, OP_ENV_ACTION, TENANT_CONTEXT);
  67
  68         when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.UNSUPPORTED_ENVIRONMENT_TYPE.getAuditingEsType())))
  69                 .thenReturn(ActionStatus.OK);
  70         when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK);
  71
  72         assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_UNSUPPORTED_TYPE_OP_ENV_LOG_STR);
  73         verifyEvent(AuditingActionEnum.UNSUPPORTED_ENVIRONMENT_TYPE.getName());
  74     }
  75
  76     @Test
  77     public void testUnknownNotificationOpEnvEvent() {
  78         AuditEventFactory factory = new AuditEcompOpEnvEventFactory(AuditingActionEnum.UNKNOWN_ENVIRONMENT_NOTIFICATION,
  79                 OP_ENV_ID, OP_ENV_NAME, OP_ENV_TYPE, OP_ENV_ACTION, TENANT_CONTEXT);
  80
  81         when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.UNKNOWN_ENVIRONMENT_NOTIFICATION.getAuditingEsType())))
  82                 .thenReturn(ActionStatus.OK);
  83         when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK);
  84
  85         assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_UNKNOWN_NOTIFICATION_OP_ENV_LOG_STR);
  86         verifyEvent(AuditingActionEnum.UNKNOWN_ENVIRONMENT_NOTIFICATION.getName());
  87     }
  88
  89     private void verifyEvent(String action) {
  90         verify(cassandraDao).saveRecord(eventCaptor.capture());
  91         EcompOperationalEnvironmentEvent storedEvent = eventCaptor.getValue();
  92         assertThat(storedEvent.getAction()).isEqualTo(action);
  93         assertThat(storedEvent.getOperationalEnvironmentId()).isEqualTo(OP_ENV_ID);
  94         assertThat(storedEvent.getOperationalEnvironmentName()).isEqualTo(OP_ENV_NAME);
  95         assertThat(storedEvent.getOperationalEnvironmentType()).isEqualTo(OP_ENV_TYPE);
  96         assertThat(storedEvent.getTenantContext()).isEqualTo(TENANT_CONTEXT);
  97     }
  98
  99 }