diff options
Diffstat (limited to 'catalog-be/src/test/java/org/openecomp/sdc/be/auditing')
33 files changed, 831 insertions, 1493 deletions
diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditBaseEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditBaseEventFactoryTest.java index e59ae40d80..3473693f01 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditBaseEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditBaseEventFactoryTest.java @@ -1,18 +1,12 @@ package org.openecomp.sdc.be.auditing.impl; -import static org.junit.Assert.assertEquals; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DESIGNER_USER_ROLE; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_EMAIL; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_EXTENDED_NAME; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_FIRST_NAME; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_LAST_NAME; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_UID; - import org.junit.Test; import org.openecomp.sdc.be.model.User; import org.openecomp.sdc.common.api.Constants; +import static org.junit.Assert.assertEquals; +import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.*; + public class AuditBaseEventFactoryTest { private User user = new User(); diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditConsumerEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditConsumerEventFactoryTest.java index b550aea646..64dd9f4a26 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditConsumerEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditConsumerEventFactoryTest.java @@ -1,5 +1,6 @@ package org.openecomp.sdc.be.auditing.impl; +import mockit.Deencapsulation; import org.junit.Assert; import org.junit.Test; import org.openecomp.sdc.be.model.ConsumerDefinition; @@ -9,8 +10,6 @@ import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder; -import mockit.Deencapsulation; - public class AuditConsumerEventFactoryTest { private AuditConsumerEventFactory createTestSubject() { diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditConsumerEventFuncTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditConsumerEventFuncTest.java index bf3c7c4e2a..665793b0ae 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditConsumerEventFuncTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditConsumerEventFuncTest.java @@ -1,28 +1,5 @@ package org.openecomp.sdc.be.auditing.impl; -import static org.assertj.core.api.Assertions.assertThat; -import static org.junit.Assert.assertEquals; -import static org.mockito.ArgumentMatchers.any; -import static org.mockito.ArgumentMatchers.anyMap; -import static org.mockito.ArgumentMatchers.eq; -import static org.mockito.Mockito.verify; -import static org.mockito.Mockito.when; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.CONSUMER_NAME; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.CONSUMER_PASSWORD; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.CONSUMER_SALT; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DESCRIPTION; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_ADD_ECOMP_USER_CRED_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_GET_ECOMP_USER_CRED_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.MODIFIER_UID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.REQUEST_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.SERVICE_INSTANCE_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.STATUS_OK; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.init; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.modifier; - -import java.util.EnumMap; - import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; @@ -41,13 +18,19 @@ import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum; import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent; import org.openecomp.sdc.be.resources.data.auditing.ConsumerEvent; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; -import org.openecomp.sdc.common.datastructure.AuditingFieldsKeysEnum; import org.openecomp.sdc.common.util.ThreadLocalsHolder; +import static org.assertj.core.api.Assertions.assertThat; +import static org.junit.Assert.assertEquals; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.ArgumentMatchers.eq; +import static org.mockito.Mockito.verify; +import static org.mockito.Mockito.when; +import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.*; + @RunWith(MockitoJUnitRunner.class) public class AuditConsumerEventFuncTest { private AuditingManager auditingManager; - private ConsumerDefinition consumer; @Mock @@ -58,7 +41,7 @@ public class AuditConsumerEventFuncTest { private static Configuration.ElasticSearchConfig esConfig; @Captor - private ArgumentCaptor<AuditingGenericEvent> eventCaptor; + private ArgumentCaptor<ConsumerEvent> eventCaptor; @Before public void setUp() { @@ -90,17 +73,6 @@ public class AuditConsumerEventFuncTest { } @Test - public void testOldAddEcompUserCredEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.ADD_ECOMP_USER_CREDENTIALS.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.ADD_ECOMP_USER_CREDENTIALS))).isEqualTo(EXPECTED_ADD_ECOMP_USER_CRED_LOG_STR); - verifyConsumerEvent(AuditingActionEnum.ADD_ECOMP_USER_CREDENTIALS.getName()); - - } - - @Test public void testNewGetEcompUserCredEvent() { AuditEventFactory factory = new AuditConsumerEventFactory( AuditingActionEnum.GET_ECOMP_USER_CREDENTIALS, @@ -121,17 +93,6 @@ public class AuditConsumerEventFuncTest { } @Test - public void testOldGetEcompUserCredEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.GET_ECOMP_USER_CREDENTIALS.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.GET_ECOMP_USER_CREDENTIALS))).isEqualTo(EXPECTED_GET_ECOMP_USER_CRED_LOG_STR); - verifyConsumerEvent(AuditingActionEnum.GET_ECOMP_USER_CREDENTIALS.getName()); - - } - - @Test public void buildConsumerNameWhenAllFieldsAreProvided() { consumer.setConsumerName(CONSUMER_NAME); consumer.setConsumerSalt(CONSUMER_SALT); @@ -173,22 +134,9 @@ public class AuditConsumerEventFuncTest { assertEquals("", AuditConsumerEventFactory.buildConsumerName(null)); } - - private EnumMap<AuditingFieldsKeysEnum, Object> fillMap(AuditingActionEnum action) { - EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, action.getName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_NAME, modifier.getFirstName() + " " + modifier.getLastName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_UID, modifier.getUserId()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ECOMP_USER, USER_ID); - - return auditingFields; - } - private void verifyConsumerEvent(String action) { verify(cassandraDao).saveRecord(eventCaptor.capture()); - ConsumerEvent storedEvent = (ConsumerEvent) eventCaptor.getValue(); + ConsumerEvent storedEvent = eventCaptor.getValue(); assertThat(storedEvent.getModifier()).isEqualTo(MODIFIER_UID); assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditResourceEventFactoryManangerTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditResourceEventFactoryManangerTest.java index bad63c7e01..1fc1444e34 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditResourceEventFactoryManangerTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditResourceEventFactoryManangerTest.java @@ -1,37 +1,39 @@ package org.openecomp.sdc.be.auditing.impl; import org.junit.Test; +import org.openecomp.sdc.be.auditing.api.AuditEventFactory; +import org.openecomp.sdc.be.auditing.impl.resourceadmin.AuditResourceEventFactoryManager; import org.openecomp.sdc.be.model.User; import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; -import org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceCommonInfo; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceVersionInfo; + public class AuditResourceEventFactoryManangerTest { - private AuditResourceEventFactoryMananger createTestSubject() { - return new AuditResourceEventFactoryMananger(); + private AuditResourceEventFactoryManager createTestSubject() { + return new AuditResourceEventFactoryManager(); } @Test public void testCreateResourceEventFactory() throws Exception { AuditingActionEnum action = null; CommonAuditData commonFields = null; - ResourceAuditData prevParams = null; - ResourceAuditData currParams = null; + ResourceVersionInfo prevParams = null; + ResourceVersionInfo currParams = null; String resourceType = ""; - String resourceName = ""; - String invariantUuid = ""; User modifier = null; String artifactData = ""; String comment = ""; String did = ""; String toscaNodeType = ""; - AuditBaseEventFactory result; + AuditEventFactory result; for (AuditingActionEnum iterable_element : AuditingActionEnum.values()) { try { - result = AuditResourceEventFactoryMananger.createResourceEventFactory(iterable_element, commonFields, prevParams, - currParams, resourceType, resourceName, invariantUuid, modifier, artifactData, comment, did, + result = AuditResourceEventFactoryManager.createResourceEventFactory(iterable_element, commonFields,new ResourceCommonInfo(), prevParams, + currParams, resourceType,modifier, artifactData, comment,did, toscaNodeType); } catch (Exception UnsupportedOperationException) { continue; diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditTestUtils.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditTestUtils.java index 04bd34f289..6fd59f63fb 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditTestUtils.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditTestUtils.java @@ -40,9 +40,9 @@ public class AuditTestUtils { public final static String DPREV_STATUS = "DPREV_STATUS"; public final static String DCURR_STATUS = "DCURR_STATUS"; - public final static String CONSUMER_NAME = "consumer"; - public final static String CONSUMER_SALT = "2a1f887d607d4515d4066fe0f5452a50"; - public final static String CONSUMER_PASSWORD = "0a0dc557c3bf594b1a48030e3e99227580168b21f44e285c69740b8d5b13e33b"; + final static String CONSUMER_NAME = "consumer"; + final static String CONSUMER_SALT = "2a1f887d607d4515d4066fe0f5452a50"; + final static String CONSUMER_PASSWORD = "0a0dc557c3bf594b1a48030e3e99227580168b21f44e285c69740b8d5b13e33b"; public final static String PREV_RESOURCE_VERSION = "1.0"; public final static String PREV_RESOURCE_STATE = "READY_FOR_CERTIFICATION"; @@ -55,8 +55,6 @@ public class AuditTestUtils { public final static String STATUS_500 = "500"; public final static String DESC_ERROR = "Error"; - public final static String MSG_ERROR = "Error: "; - public final static String MSG_OK = "OK: "; public final static String DIST_CONSUMER_ID = "ABC-123445678"; public final static String DIST_RESOURCE_URL = "http://abc.com/res"; @@ -139,7 +137,8 @@ public class AuditTestUtils { MODIFIER_UID + "\" STATUS = \"" + STATUS_OK + "\" SERVICE_INSTANCE_ID = \"" + SERVICE_INSTANCE_ID + "\" INVARIANT_UUID = \"" + INVARIANT_UUID + "\" DESC = \"" + DESCRIPTION + "\""; - public final static String EXPECTED_DOWNLOAD_ARTIFACT_EXTERNAL_API_LOG_STR = "CONSUMER_ID = \"" + DIST_CONSUMER_ID + "\" RESOURCE_URL = \"" + + //TODO: remove with the old API and tests + public final static String EXPECTED_DOWNLOAD_ARTIFACT_EXTERNAL_API_LOG_STR = "ACTION = \"" + AuditingActionEnum.DOWNLOAD_ARTIFACT.getName() + "\" CONSUMER_ID = \"" + DIST_CONSUMER_ID + "\" RESOURCE_URL = \"" + DIST_RESOURCE_URL + "\" STATUS = \"" + STATUS_OK + "\" DESC = \"" + DESCRIPTION + "\""; public final static String EXPECTED_CHANGE_LIFECYCLE_EXTERNAL_API_LOG_STR = "ACTION = \"" + AuditingActionEnum.CHANGE_LIFECYCLE_BY_API.getName() + "\" RESOURCE_NAME = \"" + RESOURCE_NAME + @@ -163,10 +162,10 @@ public class AuditTestUtils { public final static String EXPECTED_AUTH_REQUEST_LOG_STR = "ACTION = \"" + AuditingActionEnum.AUTH_REQUEST.getName() + "\" URL = \"" + AUTH_URL + "\" USER = \"" + USER_ID + "\" AUTH_STATUS = \"" + AUTH_STATUS + "\" REALM = \"" + REALM + "\""; - public final static String EXPECTED_ADD_ECOMP_USER_CRED_LOG_STR = "ACTION = \"" + AuditingActionEnum.ADD_ECOMP_USER_CREDENTIALS.getName() + + final static String EXPECTED_ADD_ECOMP_USER_CRED_LOG_STR = "ACTION = \"" + AuditingActionEnum.ADD_ECOMP_USER_CREDENTIALS.getName() + "\" MODIFIER = \"" + MODIFIER_UID + "\" ECOMP_USER = \"" + USER_ID + "\" STATUS = \"" + STATUS_OK + "\" DESC = \"" + DESCRIPTION + "\""; - public final static String EXPECTED_GET_ECOMP_USER_CRED_LOG_STR = "ACTION = \"" + AuditingActionEnum.GET_ECOMP_USER_CREDENTIALS.getName() + + final static String EXPECTED_GET_ECOMP_USER_CRED_LOG_STR = "ACTION = \"" + AuditingActionEnum.GET_ECOMP_USER_CREDENTIALS.getName() + "\" MODIFIER = \"" + MODIFIER_UID + "\" ECOMP_USER = \"" + USER_ID + "\" STATUS = \"" + STATUS_OK + "\" DESC = \"" + DESCRIPTION + "\""; public final static String EXPECTED_ADD_CATEGORY_LOG_STR = "ACTION = \"" + AuditingActionEnum.ADD_CATEGORY.getName() + @@ -207,8 +206,21 @@ public class AuditTestUtils { "\" STATUS = \"" + STATUS_OK + "\" DESC = \"" + DESCRIPTION + "\""; public final static String EXPECTED_GET_UEB_CLUSTER_LOG_STR = "ACTION = \"" + AuditingActionEnum.GET_UEB_CLUSTER.getName() + - "\" CONSUMER_ID = \"" + DIST_CONSUMER_ID + "\" STATUS = \"" + STATUS_OK + "\" STATUS_DESC = \"" + DESCRIPTION + "\""; + "\" CONSUMER_ID = \"" + DIST_CONSUMER_ID + "\" STATUS_TIME = "; //STATUS_TIME value is calculated at run time + public final static String EXPECTED_GET_CATEGORY_HIERARCHY_LOG_STR = "ACTION = \"" + AuditingActionEnum.GET_CATEGORY_HIERARCHY.getName() + "\" MODIFIER = \"" + USER_UID + + "\" DETAILS = \"" + USER_DETAILS + "\" STATUS = \"" + STATUS_OK + "\" DESC = \"" + DESCRIPTION + "\""; + + public final static String EXPECTED_EXTERNAL_ASSET_LOG_STR = "ACTION = \"" + AuditingActionEnum.GET_ASSET_METADATA.getName() + + "\" CONSUMER_ID = \"" + DIST_CONSUMER_ID + "\" RESOURCE_URL = \"" + DIST_RESOURCE_URL + "\" RESOURCE_NAME = \"" + RESOURCE_NAME + + "\" RESOURCE_TYPE = \"" + RESOURCE_TYPE +"\" SERVICE_INSTANCE_ID = \"" + SERVICE_INSTANCE_ID + "\" STATUS = \"" + STATUS_OK + + "\" DESC = \"" + DESCRIPTION + "\""; + + public final static String EXPECTED_EXTERNAL_CREATE_RESOURCE_LOG_STR = "ACTION = \"" + AuditingActionEnum.CREATE_RESOURCE_BY_API.getName() + + "\" RESOURCE_NAME = \"" + RESOURCE_NAME + "\" RESOURCE_TYPE = \"" + RESOURCE_TYPE + "\" CONSUMER_ID = \"" + DIST_CONSUMER_ID + + "\" RESOURCE_URL = \"" + DIST_RESOURCE_URL + "\" MODIFIER = \"" + MODIFIER_UID + "\" CURR_VERSION = \"" + CURRENT_VERSION + + "\" CURR_STATE = \"" + CURRENT_STATE + "\" CURR_ARTIFACT_UUID = \"" + ARTIFACT_UUID + "\" STATUS = \"" + STATUS_OK + + "\" SERVICE_INSTANCE_ID = \"" + SERVICE_INSTANCE_ID + "\" INVARIANT_UUID = \"" + INVARIANT_UUID + "\" DESC = \"" + DESCRIPTION + "\""; public static User user; public static User modifier; @@ -232,5 +244,4 @@ public class AuditTestUtils { } - } diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditingLogFormatUtilTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditingLogFormatUtilTest.java deleted file mode 100644 index 37f810699b..0000000000 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditingLogFormatUtilTest.java +++ /dev/null @@ -1,96 +0,0 @@ -package org.openecomp.sdc.be.auditing.impl; - -import java.util.HashMap; -import java.util.Map; - -import org.junit.Assert; -import org.junit.Test; -import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum; -import org.openecomp.sdc.common.datastructure.AuditingFieldsKeysEnum; - -import mockit.Deencapsulation; - -public class AuditingLogFormatUtilTest { - - private AuditingLogFormatUtil createTestSubject() { - return new AuditingLogFormatUtil(); - } - - @Test - public void testGetModifier() throws Exception { - String modifierName = "mock"; - String modifierUid = "mock"; - String result; - - // test 0 - result = Deencapsulation.invoke(AuditingLogFormatUtil.class, "getModifier", - new Object[] { modifierName, modifierUid }); - Assert.assertEquals("mock(mock)", result); - - // test 1 - result = Deencapsulation.invoke(AuditingLogFormatUtil.class, "getModifier", - new Object[] { modifierName, String.class }); - Assert.assertEquals("", result); - - // test 2 - modifierUid = ""; - result = Deencapsulation.invoke(AuditingLogFormatUtil.class, "getModifier", - new Object[] { modifierName, modifierUid }); - Assert.assertEquals("", result); - - // test 3 - result = Deencapsulation.invoke(AuditingLogFormatUtil.class, "getModifier", - new Object[] { String.class, modifierUid }); - Assert.assertEquals("", result); - - // test 4 - modifierName = ""; - result = Deencapsulation.invoke(AuditingLogFormatUtil.class, "getModifier", - new Object[] { modifierName, modifierUid }); - Assert.assertEquals("", result); - } - - @Test - public void testGetUser() throws Exception { - String userData = ""; - String result; - - // default test - result = Deencapsulation.invoke(AuditingLogFormatUtil.class, "getUser", new Object[] { userData }); - } - - @Test - public void testLogAuditEvent() throws Exception { - Map<AuditingFieldsKeysEnum, Object> auditingFields = null; - String result; - - // default test - HashMap<AuditingFieldsKeysEnum, Object> hashMap = new HashMap<AuditingFieldsKeysEnum, Object>(); - result = Deencapsulation.invoke(AuditingLogFormatUtil.class, "logAuditEvent", - new Object[] { hashMap.getClass() }); - } - - @Test - public void testLogAuditEvent_1() throws Exception { - String formattedString = ""; - Map<AuditingFieldsKeysEnum, Object> auditingFields = new HashMap<>(); - - // default test - Deencapsulation.invoke(AuditingLogFormatUtil.class, "logAuditEvent", new Object[] { formattedString }); - - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_NAME, "mock"); - Deencapsulation.invoke(AuditingLogFormatUtil.class, "logAuditEvent", auditingFields); - - for ( AuditingFieldsKeysEnum enumValue : AuditingFieldsKeysEnum.values()) { - auditingFields.put(enumValue, "mock"); - } - - Deencapsulation.invoke(AuditingLogFormatUtil.class, "logAuditEvent", auditingFields); - - auditingFields = new HashMap<>(); - for (AuditingActionEnum iterable_element : AuditingActionEnum.values()) { - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, iterable_element.getName()); - Deencapsulation.invoke(AuditingLogFormatUtil.class, "logAuditEvent", auditingFields); - } - } -}
\ No newline at end of file diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/category/AuditCategoryEventFuncTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/category/AuditCategoryEventFuncTest.java index e41e34bb35..9f08bbb72b 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/category/AuditCategoryEventFuncTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/category/AuditCategoryEventFuncTest.java @@ -1,26 +1,5 @@ package org.openecomp.sdc.be.auditing.impl.category; -import static org.assertj.core.api.Assertions.assertThat; -import static org.mockito.ArgumentMatchers.any; -import static org.mockito.ArgumentMatchers.anyMap; -import static org.mockito.ArgumentMatchers.eq; -import static org.mockito.Mockito.verify; -import static org.mockito.Mockito.when; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.CATEGORY; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DESCRIPTION; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_ADD_CATEGORY_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.GROUPING_NAME; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.MODIFIER_UID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.REQUEST_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.RESOURCE_TYPE; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.SERVICE_INSTANCE_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.STATUS_OK; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.SUB_CATEGORY; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.init; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.modifier; - -import java.util.EnumMap; - import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; @@ -39,9 +18,15 @@ import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum; import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent; import org.openecomp.sdc.be.resources.data.auditing.CategoryEvent; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; -import org.openecomp.sdc.common.datastructure.AuditingFieldsKeysEnum; import org.openecomp.sdc.common.util.ThreadLocalsHolder; +import static org.assertj.core.api.Assertions.assertThat; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.ArgumentMatchers.eq; +import static org.mockito.Mockito.verify; +import static org.mockito.Mockito.when; +import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.*; + @RunWith(MockitoJUnitRunner.class) public class AuditCategoryEventFuncTest { private AuditingManager auditingManager; @@ -54,7 +39,7 @@ public class AuditCategoryEventFuncTest { private static Configuration.ElasticSearchConfig esConfig; @Captor - private ArgumentCaptor<AuditingGenericEvent> eventCaptor; + private ArgumentCaptor<CategoryEvent> eventCaptor; @Before public void setUp() { @@ -64,8 +49,9 @@ public class AuditCategoryEventFuncTest { } @Test - public void testNewAddCategoryEvent() { - AuditEventFactory builder = new AuditAddCategoryEventFactory( + public void testAddCategoryEvent() { + AuditEventFactory builder = new AuditCategoryEventFactory( + AuditingActionEnum.ADD_CATEGORY, CommonAuditData.newBuilder() .description(DESCRIPTION) .status(STATUS_OK) @@ -82,40 +68,13 @@ public class AuditCategoryEventFuncTest { verifyCategoryEvent(AuditingActionEnum.ADD_CATEGORY.getName()); } - @Test - public void testOldAddEcompUserCredEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.ADD_CATEGORY.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.ADD_CATEGORY))).isEqualTo(EXPECTED_ADD_CATEGORY_LOG_STR); - verifyCategoryEvent(AuditingActionEnum.ADD_CATEGORY.getName()); - - } - - private EnumMap<AuditingFieldsKeysEnum, Object> fillMap(AuditingActionEnum action) { - EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, action.getName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_NAME, modifier.getFirstName() + " " + modifier.getLastName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_UID, modifier.getUserId()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_CATEGORY_NAME, CATEGORY); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_SUB_CATEGORY_NAME, SUB_CATEGORY); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_GROUPING_NAME, GROUPING_NAME); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_TYPE, RESOURCE_TYPE); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_SERVICE_INSTANCE_ID, SERVICE_INSTANCE_ID); - - return auditingFields; - } - private void verifyCategoryEvent(String action) { verify(cassandraDao).saveRecord(eventCaptor.capture()); - CategoryEvent storedEvent = (CategoryEvent) eventCaptor.getValue(); + CategoryEvent storedEvent = eventCaptor.getValue(); assertThat(storedEvent.getModifier()).isEqualTo(MODIFIER_UID); assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); -// assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID); + assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID); assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID); assertThat(storedEvent.getAction()).isEqualTo(action); assertThat(storedEvent.getCategoryName()).isEqualTo(CATEGORY); diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/category/AuditGetCategoryHierarchyEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/category/AuditGetCategoryHierarchyEventFactoryTest.java index f5f6dde66a..44dacb9b83 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/category/AuditGetCategoryHierarchyEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/category/AuditGetCategoryHierarchyEventFactoryTest.java @@ -2,7 +2,6 @@ package org.openecomp.sdc.be.auditing.impl.category; import org.junit.Test; import org.openecomp.sdc.be.model.User; -import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum; import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder; @@ -12,7 +11,7 @@ public class AuditGetCategoryHierarchyEventFactoryTest { private AuditGetCategoryHierarchyEventFactory createTestSubject() { Builder newBuilder = CommonAuditData.newBuilder(); CommonAuditData build = newBuilder.build(); - return new AuditGetCategoryHierarchyEventFactory(AuditingActionEnum.ACTIVATE_SERVICE_BY_API, build, + return new AuditGetCategoryHierarchyEventFactory( build, new User(), ""); } diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/category/AuditGetCategoryHierarchyEventTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/category/AuditGetCategoryHierarchyEventTest.java new file mode 100644 index 0000000000..7f0f3f5a2f --- /dev/null +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/category/AuditGetCategoryHierarchyEventTest.java @@ -0,0 +1,77 @@ +package org.openecomp.sdc.be.auditing.impl.category; + +import org.junit.Before; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.mockito.ArgumentCaptor; +import org.mockito.Captor; +import org.mockito.Mock; +import org.mockito.junit.MockitoJUnitRunner; +import org.openecomp.sdc.be.auditing.api.AuditEventFactory; +import org.openecomp.sdc.be.auditing.impl.AuditingManager; +import org.openecomp.sdc.be.config.Configuration; +import org.openecomp.sdc.be.dao.api.ActionStatus; +import org.openecomp.sdc.be.dao.cassandra.AuditCassandraDao; +import org.openecomp.sdc.be.dao.cassandra.CassandraOperationStatus; +import org.openecomp.sdc.be.dao.impl.AuditingDao; +import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum; +import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent; +import org.openecomp.sdc.be.resources.data.auditing.GetCategoryHierarchyEvent; +import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; + +import static org.assertj.core.api.Assertions.assertThat; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.ArgumentMatchers.eq; +import static org.mockito.Mockito.verify; +import static org.mockito.Mockito.when; +import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.*; + +@RunWith(MockitoJUnitRunner.class) +public class AuditGetCategoryHierarchyEventTest { + @Mock + private static AuditCassandraDao cassandraDao; + @Captor + private ArgumentCaptor<GetCategoryHierarchyEvent> eventCaptor; + @Mock + private static AuditingDao auditingDao; + @Mock + private Configuration.ElasticSearchConfig esConfig; + + private AuditingManager auditingManager; + + @Before + public void setUp() { + init(esConfig); + auditingManager = new AuditingManager(auditingDao, cassandraDao); + } + + @Test + public void testNewGetCategoryHierarchyEvent() { + AuditEventFactory factory = new AuditGetCategoryHierarchyEventFactory( + CommonAuditData.newBuilder() + .description(DESCRIPTION) + .status(STATUS_OK) + .requestId(REQUEST_ID) + .build(), + user, USER_DETAILS); + when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.GET_CATEGORY_HIERARCHY.getAuditingEsType()))) + .thenReturn(ActionStatus.OK); + when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); + + assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_GET_CATEGORY_HIERARCHY_LOG_STR); + verifyEvent(); + } + + private void verifyEvent() { + verify(cassandraDao).saveRecord(eventCaptor.capture()); + GetCategoryHierarchyEvent storedEvent = eventCaptor.getValue(); + assertThat(storedEvent.getModifier()).isEqualTo(USER_UID); + assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); + assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); + assertThat(storedEvent.getDetails()).isEqualTo(USER_DETAILS); + assertThat(storedEvent.getRequestId()).isNotBlank(); + assertThat(storedEvent.getServiceInstanceId()).isNull(); + assertThat(storedEvent.getAction()).isEqualTo(AuditingActionEnum.GET_CATEGORY_HIERARCHY.getName()); + } + +} diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditCreateTopicDistribEngineEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditCreateTopicDistribEngineEventFactoryTest.java index c50ea24fb4..e97fb8e4a8 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditCreateTopicDistribEngineEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditCreateTopicDistribEngineEventFactoryTest.java @@ -3,18 +3,19 @@ package org.openecomp.sdc.be.auditing.impl.distribution; import org.junit.Test; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder; +import org.openecomp.sdc.be.resources.data.auditing.model.DistributionTopicData; public class AuditCreateTopicDistribEngineEventFactoryTest { - private AuditCreateTopicDistribEngineEventFactory createTestSubject() { + private AuditCreateTopicDistributionEngineEventFactory createTestSubject() { Builder newBuilder = CommonAuditData.newBuilder(); CommonAuditData build = newBuilder.build(); - return new AuditCreateTopicDistribEngineEventFactory(build, "", "", "", "", "", ""); + return new AuditCreateTopicDistributionEngineEventFactory(build,DistributionTopicData.newBuilder().build(),"", "", ""); } @Test public void testGetLogMessage() throws Exception { - AuditCreateTopicDistribEngineEventFactory testSubject; + AuditCreateTopicDistributionEngineEventFactory testSubject; String result; // default test diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistrEngineFuncTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistrEngineFuncTest.java deleted file mode 100644 index 29285e7aa0..0000000000 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistrEngineFuncTest.java +++ /dev/null @@ -1,191 +0,0 @@ -package org.openecomp.sdc.be.auditing.impl.distribution; - -import static org.assertj.core.api.Assertions.assertThat; -import static org.mockito.ArgumentMatchers.any; -import static org.mockito.ArgumentMatchers.anyMap; -import static org.mockito.ArgumentMatchers.eq; -import static org.mockito.Mockito.verify; -import static org.mockito.Mockito.when; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DESCRIPTION; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DIST_API_KEY; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DIST_CONSUMER_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DIST_ENV_NAME; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DIST_NOTIFY_TOPIC; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DIST_ROLE; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DIST_STATUS_TOPIC; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_DIST_ADD_KEY_ENGINE_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_DIST_CREATE_TOPIC_ENGINE_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_DIST_REG_ENGINE_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.REQUEST_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.SERVICE_INSTANCE_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.STATUS_OK; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.init; - -import java.util.EnumMap; - -import org.junit.Before; -import org.junit.Test; -import org.junit.runner.RunWith; -import org.mockito.ArgumentCaptor; -import org.mockito.Captor; -import org.mockito.Mock; -import org.mockito.junit.MockitoJUnitRunner; -import org.openecomp.sdc.be.auditing.api.AuditEventFactory; -import org.openecomp.sdc.be.auditing.impl.AuditingManager; -import org.openecomp.sdc.be.config.Configuration; -import org.openecomp.sdc.be.dao.api.ActionStatus; -import org.openecomp.sdc.be.dao.cassandra.AuditCassandraDao; -import org.openecomp.sdc.be.dao.cassandra.CassandraOperationStatus; -import org.openecomp.sdc.be.dao.impl.AuditingDao; -import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum; -import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent; -import org.openecomp.sdc.be.resources.data.auditing.DistributionEngineEvent; -import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; -import org.openecomp.sdc.common.datastructure.AuditingFieldsKeysEnum; -import org.openecomp.sdc.common.util.ThreadLocalsHolder; - -@RunWith(MockitoJUnitRunner.class) -public class AuditDistrEngineFuncTest { - private AuditingManager auditingManager; - - @Mock - private static AuditCassandraDao cassandraDao; - @Mock - private static AuditingDao auditingDao; - @Mock - private static Configuration.ElasticSearchConfig esConfig; - - @Captor - private ArgumentCaptor<AuditingGenericEvent> eventCaptor; - - @Before - public void setUp() { - init(esConfig); - auditingManager = new AuditingManager(auditingDao, cassandraDao); - ThreadLocalsHolder.setUuid(REQUEST_ID); - } - - @Test - public void testNewAddKeyEvent() { - AuditEventFactory factory = new AuditAddKeyDistribEngineEventFactory( - CommonAuditData.newBuilder() - .description(DESCRIPTION) - .status(STATUS_OK) - .requestId(REQUEST_ID) - .serviceInstanceId(SERVICE_INSTANCE_ID) - .build(), - DIST_CONSUMER_ID, DIST_STATUS_TOPIC, DIST_NOTIFY_TOPIC, DIST_API_KEY, DIST_ENV_NAME, DIST_ROLE); - - when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.ADD_KEY_TO_TOPIC_ACL.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DIST_ADD_KEY_ENGINE_LOG_STR); - verifyEvent(AuditingActionEnum.ADD_KEY_TO_TOPIC_ACL.getName()); - } - - @Test - public void testOldAddKeyEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.ADD_KEY_TO_TOPIC_ACL.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.ADD_KEY_TO_TOPIC_ACL))).isEqualTo(EXPECTED_DIST_ADD_KEY_ENGINE_LOG_STR); - verifyEvent(AuditingActionEnum.ADD_KEY_TO_TOPIC_ACL.getName()); - - } - - @Test - public void testNewCreateTopicEvent() { - AuditEventFactory factory = new AuditCreateTopicDistribEngineEventFactory( - CommonAuditData.newBuilder() - .description(DESCRIPTION) - .status(STATUS_OK) - .requestId(REQUEST_ID) - .serviceInstanceId(SERVICE_INSTANCE_ID) - .build(), - DIST_CONSUMER_ID, DIST_STATUS_TOPIC, DIST_NOTIFY_TOPIC, DIST_API_KEY, DIST_ENV_NAME, DIST_ROLE); - - when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.CREATE_DISTRIBUTION_TOPIC.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DIST_CREATE_TOPIC_ENGINE_LOG_STR); - verifyEvent(AuditingActionEnum.CREATE_DISTRIBUTION_TOPIC.getName()); - } - - @Test - public void testOldCreateTopicEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.CREATE_DISTRIBUTION_TOPIC.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.CREATE_DISTRIBUTION_TOPIC))).isEqualTo(EXPECTED_DIST_CREATE_TOPIC_ENGINE_LOG_STR); - verifyEvent(AuditingActionEnum.CREATE_DISTRIBUTION_TOPIC.getName()); - } - - @Test - public void testNewRegisterEvent() { - AuditEventFactory factory = new AuditRegisterDistribEngineEventFactory( - CommonAuditData.newBuilder() - .description(DESCRIPTION) - .status(STATUS_OK) - .requestId(REQUEST_ID) - .serviceInstanceId(SERVICE_INSTANCE_ID) - .build(), - DIST_CONSUMER_ID, DIST_STATUS_TOPIC, DIST_NOTIFY_TOPIC, DIST_API_KEY, DIST_ENV_NAME, DIST_ROLE); - - when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.DISTRIBUTION_REGISTER.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DIST_REG_ENGINE_LOG_STR); - verifyEvent(AuditingActionEnum.DISTRIBUTION_REGISTER.getName()); - } - - @Test - public void testOldRegisterEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.DISTRIBUTION_REGISTER.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.DISTRIBUTION_REGISTER))).isEqualTo(EXPECTED_DIST_REG_ENGINE_LOG_STR); - verifyEvent(AuditingActionEnum.DISTRIBUTION_REGISTER.getName()); - } - - private void verifyEvent(String action) { - verify(cassandraDao).saveRecord(eventCaptor.capture()); - DistributionEngineEvent storedEvent = (DistributionEngineEvent) eventCaptor.getValue(); - assertThat(storedEvent.getDnotifTopic()).isEqualTo(DIST_NOTIFY_TOPIC); - assertThat(storedEvent.getDstatusTopic()).isEqualTo(DIST_STATUS_TOPIC); - assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); - assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); - assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID); - assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID); - assertThat(storedEvent.getAction()).isEqualTo(action); - assertThat(storedEvent.getEnvironmentName()).isEqualTo(DIST_ENV_NAME); - assertThat(storedEvent.getApiKey()).isEqualTo(DIST_API_KEY); - assertThat(storedEvent.getConsumerId()).isEqualTo(DIST_CONSUMER_ID); - assertThat(storedEvent.getRole()).isEqualTo(DIST_ROLE); - } - - private EnumMap<AuditingFieldsKeysEnum, Object> fillMap(AuditingActionEnum action) { - EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, action.getName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_CONSUMER_ID, DIST_CONSUMER_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_ENVRIONMENT_NAME, DIST_ENV_NAME); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_STATUS_TOPIC_NAME, DIST_STATUS_TOPIC); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_NOTIFICATION_TOPIC_NAME, DIST_NOTIFY_TOPIC); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_TOPIC_NAME, DIST_NOTIFY_TOPIC); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_API_KEY, DIST_API_KEY); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_REQUEST_ID, REQUEST_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_ROLE, DIST_ROLE); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_SERVICE_INSTANCE_ID, SERVICE_INSTANCE_ID); - - return auditingFields; - } - - -} diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistrEventFuncTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistrEventFuncTest.java deleted file mode 100644 index ceb25e44b7..0000000000 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistrEventFuncTest.java +++ /dev/null @@ -1,387 +0,0 @@ -package org.openecomp.sdc.be.auditing.impl.distribution; - -import static org.assertj.core.api.Assertions.assertThat; -import static org.mockito.ArgumentMatchers.any; -import static org.mockito.ArgumentMatchers.anyMap; -import static org.mockito.ArgumentMatchers.eq; -import static org.mockito.Mockito.verify; -import static org.mockito.Mockito.when; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.CURRENT_STATE; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.CURRENT_VERSION; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DESCRIPTION; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DIST_CONSUMER_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DIST_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DIST_RESOURCE_URL; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DIST_STATUS_TIME; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_DISTRIB_DEPLOY_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_DISTRIB_NOTIFICATION_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_DIST_DOWNLOAD_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_DIST_STATUS_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_GET_UEB_CLUSTER_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.OP_ENV_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.REQUEST_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.RESOURCE_NAME; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.RESOURCE_TYPE; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.SERVICE_INSTANCE_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.STATUS_OK; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.TENANT_CONTEXT; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.TOPIC_NAME; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_FIRST_NAME; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_LAST_NAME; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_UID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.VNF_WORKLOAD_CONTEXT; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.init; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.user; - -import java.util.EnumMap; - -import org.junit.Before; -import org.junit.Test; -import org.junit.runner.RunWith; -import org.mockito.ArgumentCaptor; -import org.mockito.Captor; -import org.mockito.Mock; -import org.mockito.junit.MockitoJUnitRunner; -import org.openecomp.sdc.be.auditing.api.AuditEventFactory; -import org.openecomp.sdc.be.auditing.impl.AuditingManager; -import org.openecomp.sdc.be.config.Configuration; -import org.openecomp.sdc.be.dao.api.ActionStatus; -import org.openecomp.sdc.be.dao.cassandra.AuditCassandraDao; -import org.openecomp.sdc.be.dao.cassandra.CassandraOperationStatus; -import org.openecomp.sdc.be.dao.impl.AuditingDao; -import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum; -import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent; -import org.openecomp.sdc.be.resources.data.auditing.AuditingGetUebClusterEvent; -import org.openecomp.sdc.be.resources.data.auditing.DistributionDeployEvent; -import org.openecomp.sdc.be.resources.data.auditing.DistributionDownloadEvent; -import org.openecomp.sdc.be.resources.data.auditing.DistributionNotificationEvent; -import org.openecomp.sdc.be.resources.data.auditing.DistributionStatusEvent; -import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; -import org.openecomp.sdc.be.resources.data.auditing.model.DistributionData; -import org.openecomp.sdc.be.resources.data.auditing.model.OperationalEnvAuditData; -import org.openecomp.sdc.common.datastructure.AuditingFieldsKeysEnum; -import org.openecomp.sdc.common.util.ThreadLocalsHolder; - -@RunWith(MockitoJUnitRunner.class) -public class AuditDistrEventFuncTest { - - private AuditingManager auditingManager; - - @Mock - private static AuditCassandraDao cassandraDao; - @Mock - private static AuditingDao auditingDao; - @Mock - private static Configuration.ElasticSearchConfig esConfig; - - @Captor - private ArgumentCaptor<AuditingGenericEvent> eventCaptor; - - @Before - public void setUp() { - init(esConfig); - auditingManager = new AuditingManager(auditingDao, cassandraDao); - ThreadLocalsHolder.setUuid(REQUEST_ID); - } - - @Test - public void testNewNotifyEvent() { - AuditEventFactory factory = new AuditDistribNotificationEventFactory( - CommonAuditData.newBuilder() - .description(DESCRIPTION) - .status(STATUS_OK) - .requestId(REQUEST_ID) - .serviceInstanceId(SERVICE_INSTANCE_ID) - .build(), - CURRENT_STATE, CURRENT_VERSION, DIST_ID, user, - RESOURCE_NAME, RESOURCE_TYPE, TOPIC_NAME, - new OperationalEnvAuditData(OP_ENV_ID, VNF_WORKLOAD_CONTEXT, TENANT_CONTEXT)); - - when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.DISTRIBUTION_NOTIFY.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DISTRIB_NOTIFICATION_LOG_STR); - verifyNotifyEvent(); - } - - @Test - public void testOldNotifyEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.DISTRIBUTION_NOTIFY.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillNotifyMap())).isEqualTo(EXPECTED_DISTRIB_NOTIFICATION_LOG_STR); - verifyNotifyEvent(); - - } - - @Test - public void testNewStatusEvent() { - AuditEventFactory factory = new AuditDistribStatusEventFactory( - CommonAuditData.newBuilder() - .description(DESCRIPTION) - .status(STATUS_OK) - .requestId(REQUEST_ID) - .serviceInstanceId(SERVICE_INSTANCE_ID) - .build(), - DIST_ID, DIST_CONSUMER_ID, TOPIC_NAME, DIST_RESOURCE_URL, DIST_STATUS_TIME); - - when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.DISTRIBUTION_STATUS.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DIST_STATUS_LOG_STR); - verifyStatusEvent(); - } - - @Test - public void testOldStatusEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.DISTRIBUTION_STATUS.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillStatusMap())).isEqualTo(EXPECTED_DIST_STATUS_LOG_STR); - verifyStatusEvent(); - } - - @Test - public void testNewDownloadEvent() { - AuditEventFactory factory = new AuditDistribDownloadEventFactory( - CommonAuditData.newBuilder() - .description(DESCRIPTION) - .status(STATUS_OK) - .requestId(REQUEST_ID) - .serviceInstanceId(SERVICE_INSTANCE_ID) - .build(), - new DistributionData(DIST_CONSUMER_ID, DIST_RESOURCE_URL)); - - when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.DISTRIBUTION_ARTIFACT_DOWNLOAD.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DIST_DOWNLOAD_LOG_STR); - verifyDownloadsEvent(); - } - - @Test - public void testOldDownloadEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.DISTRIBUTION_ARTIFACT_DOWNLOAD.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillDownloadMap())).isEqualTo(EXPECTED_DIST_DOWNLOAD_LOG_STR); - verifyDownloadsEvent(); - } - - @Test - public void testNewDeployEvent() { - AuditEventFactory factory = new AuditDistribDeployEventFactory( - CommonAuditData.newBuilder() - .description(DESCRIPTION) - .status(STATUS_OK) - .requestId(REQUEST_ID) - .serviceInstanceId(SERVICE_INSTANCE_ID) - .build(), - CURRENT_VERSION, - DIST_ID, user, RESOURCE_NAME, RESOURCE_TYPE); - - when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.DISTRIBUTION_DEPLOY.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DISTRIB_DEPLOY_LOG_STR); - verifyDeployEvent(); - } - - @Test - public void testOldDeployEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.DISTRIBUTION_DEPLOY.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillDeployMap())).isEqualTo(EXPECTED_DISTRIB_DEPLOY_LOG_STR); - verifyDeployEvent(); - } - - @Test - public void testNewGetUebClusterEvent() { - AuditEventFactory factory = new AuditGetUebClusterEventFactory( - CommonAuditData.newBuilder() - .description(DESCRIPTION) - .status(STATUS_OK) - .requestId(REQUEST_ID) - .serviceInstanceId(SERVICE_INSTANCE_ID) - .build(), - DIST_CONSUMER_ID); - - when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.GET_UEB_CLUSTER.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_GET_UEB_CLUSTER_LOG_STR); - verifyGetUebClusterEvent(); - } - - @Test - public void testOldGetUebClusterEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.GET_UEB_CLUSTER.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillGetUebClusterMap())).isEqualTo(EXPECTED_GET_UEB_CLUSTER_LOG_STR); - verifyGetUebClusterEvent(); - } - - private void verifyNotifyEvent() { - verify(cassandraDao).saveRecord(eventCaptor.capture()); - DistributionNotificationEvent storedEvent = (DistributionNotificationEvent) eventCaptor.getValue(); - assertThat(storedEvent.getCurrState()).isEqualTo(CURRENT_STATE); - assertThat(storedEvent.getCurrVersion()).isEqualTo(CURRENT_VERSION); - assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); - assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); - assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID); - assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID); - assertThat(storedEvent.getAction()).isEqualTo(AuditingActionEnum.DISTRIBUTION_NOTIFY.getName()); - assertThat(storedEvent.getDid()).isEqualTo(DIST_ID); - assertThat(storedEvent.getModifier()).isEqualTo(USER_UID); - assertThat(storedEvent.getResourceName()).isEqualTo(RESOURCE_NAME); - assertThat(storedEvent.getResourceType()).isEqualTo(RESOURCE_TYPE); - assertThat(storedEvent.getTopicName()).isEqualTo(TOPIC_NAME); - assertThat(storedEvent.getVnfWorkloadContext()).isEqualTo(VNF_WORKLOAD_CONTEXT); - assertThat(storedEvent.getEnvId()).isEqualTo(OP_ENV_ID); - assertThat(storedEvent.getTenant()).isEqualTo(TENANT_CONTEXT); - } - - private void verifyStatusEvent() { - verify(cassandraDao).saveRecord(eventCaptor.capture()); - DistributionStatusEvent storedEvent = (DistributionStatusEvent) eventCaptor.getValue(); - assertThat(storedEvent.getConsumerId()).isEqualTo(DIST_CONSUMER_ID); - assertThat(storedEvent.getDid()).isEqualTo(DIST_ID); - assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); - assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); - assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID); - assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID); - assertThat(storedEvent.getAction()).isEqualTo(AuditingActionEnum.DISTRIBUTION_STATUS.getName()); - assertThat(storedEvent.getStatusTime()).isEqualTo(DIST_STATUS_TIME); - assertThat(storedEvent.getResoureURL()).isEqualTo(DIST_RESOURCE_URL); - assertThat(storedEvent.getTopicName()).isEqualTo(TOPIC_NAME); - } - - private void verifyDownloadsEvent() { - verify(cassandraDao).saveRecord(eventCaptor.capture()); - DistributionDownloadEvent storedEvent = (DistributionDownloadEvent) eventCaptor.getValue(); - assertThat(storedEvent.getConsumerId()).isEqualTo(DIST_CONSUMER_ID); - assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); - assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); - assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID); - assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID); - assertThat(storedEvent.getResourceUrl()).isEqualTo(DIST_RESOURCE_URL); - } - - private void verifyDeployEvent() { - verify(cassandraDao).saveRecord(eventCaptor.capture()); - DistributionDeployEvent storedEvent = (DistributionDeployEvent) eventCaptor.getValue(); - assertThat(storedEvent.getCurrVersion()).isEqualTo(CURRENT_VERSION); - assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); - assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); - assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID); - assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID); - assertThat(storedEvent.getDid()).isEqualTo(DIST_ID); - assertThat(storedEvent.getModifier()).isEqualTo(USER_UID); - assertThat(storedEvent.getResourceName()).isEqualTo(RESOURCE_NAME); - assertThat(storedEvent.getResourceType()).isEqualTo(RESOURCE_TYPE); - } - - private void verifyGetUebClusterEvent() { - verify(cassandraDao).saveRecord(eventCaptor.capture()); - AuditingGetUebClusterEvent storedEvent = (AuditingGetUebClusterEvent) eventCaptor.getValue(); - assertThat(storedEvent.getConsumerId()).isEqualTo(DIST_CONSUMER_ID); - assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); - assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); - assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID); - assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID); - } - - private EnumMap<AuditingFieldsKeysEnum, Object> fillNotifyMap() { - EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, AuditingActionEnum.DISTRIBUTION_NOTIFY.getName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_ID, DIST_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_TYPE, RESOURCE_TYPE); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_SERVICE_INSTANCE_ID, SERVICE_INSTANCE_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_NAME, RESOURCE_NAME); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_CURR_STATE, CURRENT_STATE); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_CURR_VERSION, CURRENT_VERSION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_UID, USER_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_NAME, USER_FIRST_NAME + " " + USER_LAST_NAME); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_TOPIC_NAME, TOPIC_NAME); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_VNF_WORKLOAD_CONTEXT, VNF_WORKLOAD_CONTEXT); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_TENANT, TENANT_CONTEXT); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_ENVIRONMENT_ID, OP_ENV_ID); - - return auditingFields; - } - - private EnumMap<AuditingFieldsKeysEnum, Object> fillStatusMap() { - EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, AuditingActionEnum.DISTRIBUTION_STATUS.getName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_TOPIC_NAME, TOPIC_NAME); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_ID, DIST_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_SERVICE_INSTANCE_ID, SERVICE_INSTANCE_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_RESOURCE_URL, DIST_RESOURCE_URL); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_STATUS_TIME, DIST_STATUS_TIME); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_CONSUMER_ID, DIST_CONSUMER_ID); - - return auditingFields; - } - - private EnumMap<AuditingFieldsKeysEnum, Object> fillDownloadMap() { - EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, AuditingActionEnum.DISTRIBUTION_ARTIFACT_DOWNLOAD.getName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_CONSUMER_ID, DIST_CONSUMER_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_REQUEST_ID, REQUEST_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_RESOURCE_URL, DIST_RESOURCE_URL); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_SERVICE_INSTANCE_ID, SERVICE_INSTANCE_ID); - - return auditingFields; - } - - private EnumMap<AuditingFieldsKeysEnum, Object> fillDeployMap() { - EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, AuditingActionEnum.DISTRIBUTION_DEPLOY.getName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_ID, DIST_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_TYPE, RESOURCE_TYPE); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_SERVICE_INSTANCE_ID, SERVICE_INSTANCE_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_NAME, RESOURCE_NAME); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_CURR_VERSION, CURRENT_VERSION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_UID, USER_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_NAME, USER_FIRST_NAME + " " + USER_LAST_NAME); - - return auditingFields; - } - - private EnumMap<AuditingFieldsKeysEnum, Object> fillGetUebClusterMap() { - EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, AuditingActionEnum.GET_UEB_CLUSTER.getName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_CONSUMER_ID, DIST_CONSUMER_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_STATUS_DESC, DESCRIPTION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_REQUEST_ID, REQUEST_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_SERVICE_INSTANCE_ID, SERVICE_INSTANCE_ID); - - return auditingFields; - } - - - - -} diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistribDeployEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistribDeployEventFactoryTest.java index 6a314da699..9aa8c5dbbe 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistribDeployEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistribDeployEventFactoryTest.java @@ -5,18 +5,19 @@ import org.openecomp.sdc.be.model.User; import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceCommonInfo; public class AuditDistribDeployEventFactoryTest { - private AuditDistribDeployEventFactory createTestSubject() { + private AuditDistributionDeployEventFactory createTestSubject() { Builder newBuilder = CommonAuditData.newBuilder(); CommonAuditData build = newBuilder.build(); - return new AuditDistribDeployEventFactory(build, "", "", new User(), "", ""); + return new AuditDistributionDeployEventFactory(build,new ResourceCommonInfo(),"", new User(), "1.0"); } @Test public void testGetLogMessage() throws Exception { - AuditDistribDeployEventFactory testSubject; + AuditDistributionDeployEventFactory testSubject; String result; // default test @@ -26,7 +27,7 @@ public class AuditDistribDeployEventFactoryTest { @Test public void testGetDbEvent() throws Exception { - AuditDistribDeployEventFactory testSubject; + AuditDistributionDeployEventFactory testSubject; AuditingGenericEvent result; // default test diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistribDownloadEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistribDownloadEventFactoryTest.java index 3aaeb6fddd..5027940d1b 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistribDownloadEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistribDownloadEventFactoryTest.java @@ -1,22 +1,23 @@ package org.openecomp.sdc.be.auditing.impl.distribution; import org.junit.Test; +import org.openecomp.sdc.be.model.User; import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder; -import org.openecomp.sdc.be.resources.data.auditing.model.DistributionData; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceCommonInfo; public class AuditDistribDownloadEventFactoryTest { - private AuditDistribDownloadEventFactory createTestSubject() { + private AuditDistributionDeployEventFactory createTestSubject() { Builder newBuilder = CommonAuditData.newBuilder(); CommonAuditData build = newBuilder.build(); - return new AuditDistribDownloadEventFactory(build, new DistributionData("", "")); + return new AuditDistributionDeployEventFactory(build,new ResourceCommonInfo(),"",new User(),"1.0"); } @Test public void testGetLogMessage() throws Exception { - AuditDistribDownloadEventFactory testSubject; + AuditDistributionDeployEventFactory testSubject; String result; // default test @@ -26,7 +27,7 @@ public class AuditDistribDownloadEventFactoryTest { @Test public void testGetDbEvent() throws Exception { - AuditDistribDownloadEventFactory testSubject; + AuditDistributionDeployEventFactory testSubject; AuditingGenericEvent result; // default test diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistribNotificationEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistribNotificationEventFactoryTest.java index 06b45a4736..5dd351ff7d 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistribNotificationEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistribNotificationEventFactoryTest.java @@ -6,19 +6,21 @@ import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder; import org.openecomp.sdc.be.resources.data.auditing.model.OperationalEnvAuditData; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceCommonInfo; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceVersionInfo; public class AuditDistribNotificationEventFactoryTest { - private AuditDistribNotificationEventFactory createTestSubject() { + private AuditDistributionNotificationEventFactory createTestSubject() { Builder newBuilder = CommonAuditData.newBuilder(); CommonAuditData build = newBuilder.build(); - return new AuditDistribNotificationEventFactory(build, "", "", "", new User(), "", "", "", + return new AuditDistributionNotificationEventFactory(build,new ResourceCommonInfo(), ResourceVersionInfo.newBuilder().build(), "",new User(),"", new OperationalEnvAuditData("", "", "")); } @Test public void testGetLogMessage() throws Exception { - AuditDistribNotificationEventFactory testSubject; + AuditDistributionNotificationEventFactory testSubject; String result; // default test @@ -28,7 +30,7 @@ public class AuditDistribNotificationEventFactoryTest { @Test public void testGetDbEvent() throws Exception { - AuditDistribNotificationEventFactory testSubject; + AuditDistributionNotificationEventFactory testSubject; AuditingGenericEvent result; // default test diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistribStatusEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistribStatusEventFactoryTest.java index a9b5e68394..3f6ec5dbd2 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistribStatusEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistribStatusEventFactoryTest.java @@ -4,18 +4,19 @@ import org.junit.Test; import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder; +import org.openecomp.sdc.be.resources.data.auditing.model.DistributionData; public class AuditDistribStatusEventFactoryTest { - private AuditDistribStatusEventFactory createTestSubject() { + private AuditDistributionStatusEventFactory createTestSubject() { Builder newBuilder = CommonAuditData.newBuilder(); CommonAuditData build = newBuilder.build(); - return new AuditDistribStatusEventFactory(build, "", "", "", "", ""); + return new AuditDistributionStatusEventFactory(build,new DistributionData("",""), "", "", ""); } @Test public void testGetLogMessage() throws Exception { - AuditDistribStatusEventFactory testSubject; + AuditDistributionStatusEventFactory testSubject; String result; // default test @@ -25,7 +26,7 @@ public class AuditDistribStatusEventFactoryTest { @Test public void testGetDbEvent() throws Exception { - AuditDistribStatusEventFactory testSubject; + AuditDistributionStatusEventFactory testSubject; AuditingGenericEvent result; // default test diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistributionEngineFuncTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistributionEngineFuncTest.java new file mode 100644 index 0000000000..25cf1fbf11 --- /dev/null +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistributionEngineFuncTest.java @@ -0,0 +1,146 @@ +package org.openecomp.sdc.be.auditing.impl.distribution; + +import org.junit.Before; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.mockito.ArgumentCaptor; +import org.mockito.Captor; +import org.mockito.Mock; +import org.mockito.junit.MockitoJUnitRunner; +import org.openecomp.sdc.be.auditing.api.AuditEventFactory; +import org.openecomp.sdc.be.auditing.impl.AuditingManager; +import org.openecomp.sdc.be.config.Configuration; +import org.openecomp.sdc.be.dao.api.ActionStatus; +import org.openecomp.sdc.be.dao.cassandra.AuditCassandraDao; +import org.openecomp.sdc.be.dao.cassandra.CassandraOperationStatus; +import org.openecomp.sdc.be.dao.impl.AuditingDao; +import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum; +import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent; +import org.openecomp.sdc.be.resources.data.auditing.DistributionEngineEvent; +import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; +import org.openecomp.sdc.be.resources.data.auditing.model.DistributionTopicData; +import org.openecomp.sdc.common.util.ThreadLocalsHolder; + +import static org.assertj.core.api.Assertions.assertThat; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.ArgumentMatchers.eq; +import static org.mockito.Mockito.verify; +import static org.mockito.Mockito.when; +import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.*; + +@RunWith(MockitoJUnitRunner.class) +public class AuditDistributionEngineFuncTest { + private AuditingManager auditingManager; + + @Mock + private static AuditCassandraDao cassandraDao; + @Mock + private static AuditingDao auditingDao; + @Mock + private static Configuration.ElasticSearchConfig esConfig; + + @Captor + private ArgumentCaptor<DistributionEngineEvent> eventCaptor; + + @Before + public void setUp() { + init(esConfig); + auditingManager = new AuditingManager(auditingDao, cassandraDao); + ThreadLocalsHolder.setUuid(REQUEST_ID); + } + + @Test + public void testAddKeyEvent() { + AuditEventFactory factory = new AuditAddRemoveKeyDistributionEngineEventFactory( + AuditingActionEnum.ADD_KEY_TO_TOPIC_ACL, + CommonAuditData.newBuilder() + .description(DESCRIPTION) + .status(STATUS_OK) + .requestId(REQUEST_ID) + .serviceInstanceId(SERVICE_INSTANCE_ID) + .build(), + DistributionTopicData.newBuilder() + .statusTopic(DIST_STATUS_TOPIC) + .notificationTopic(DIST_NOTIFY_TOPIC) + .build(), + DIST_API_KEY, DIST_ENV_NAME, DIST_ROLE); + + when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.ADD_KEY_TO_TOPIC_ACL.getAuditingEsType()))) + .thenReturn(ActionStatus.OK); + when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); + + assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DIST_ADD_KEY_ENGINE_LOG_STR); + verifyEvent(AuditingActionEnum.ADD_KEY_TO_TOPIC_ACL.getName()); + } + + @Test + public void testCreateTopicEvent() { + AuditEventFactory factory = new AuditCreateTopicDistributionEngineEventFactory( + CommonAuditData.newBuilder() + .description(DESCRIPTION) + .status(STATUS_OK) + .requestId(REQUEST_ID) + .serviceInstanceId(SERVICE_INSTANCE_ID) + .build(), + DistributionTopicData.newBuilder() + .statusTopic(DIST_STATUS_TOPIC) + .notificationTopic(DIST_NOTIFY_TOPIC) + .build(), + DIST_API_KEY, DIST_ENV_NAME, DIST_ROLE); + + when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.CREATE_DISTRIBUTION_TOPIC.getAuditingEsType()))) + .thenReturn(ActionStatus.OK); + when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); + + assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DIST_CREATE_TOPIC_ENGINE_LOG_STR); + verifyEvent(AuditingActionEnum.CREATE_DISTRIBUTION_TOPIC.getName()); + } + + @Test + public void testRegisterEvent() { + AuditEventFactory factory = new AuditRegUnregDistributionEngineEventFactory( + AuditingActionEnum.DISTRIBUTION_REGISTER, + CommonAuditData.newBuilder() + .description(DESCRIPTION) + .status(STATUS_OK) + .requestId(REQUEST_ID) + .serviceInstanceId(SERVICE_INSTANCE_ID) + .build(), + DistributionTopicData.newBuilder() + .statusTopic(DIST_STATUS_TOPIC) + .notificationTopic(DIST_NOTIFY_TOPIC) + .build(), + DIST_CONSUMER_ID, DIST_API_KEY, DIST_ENV_NAME); + + when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.DISTRIBUTION_REGISTER.getAuditingEsType()))) + .thenReturn(ActionStatus.OK); + when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); + + assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DIST_REG_ENGINE_LOG_STR); + verifyEvent(AuditingActionEnum.DISTRIBUTION_REGISTER.getName()); + } + + private void verifyEvent(String action) { + verify(cassandraDao).saveRecord(eventCaptor.capture()); + DistributionEngineEvent storedEvent = eventCaptor.getValue(); + assertThat(storedEvent.getDnotifTopic()).isEqualTo(DIST_NOTIFY_TOPIC); + assertThat(storedEvent.getDstatusTopic()).isEqualTo(DIST_STATUS_TOPIC); + assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); + assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); + assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID); + assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID); + assertThat(storedEvent.getAction()).isEqualTo(action); + assertThat(storedEvent.getEnvironmentName()).isEqualTo(DIST_ENV_NAME); + assertThat(storedEvent.getApiKey()).isEqualTo(DIST_API_KEY); + if (!action.equals(AuditingActionEnum.CREATE_DISTRIBUTION_TOPIC.getName()) && + !action.equals(AuditingActionEnum.ADD_KEY_TO_TOPIC_ACL.getName()) && + !action.equals(AuditingActionEnum.REMOVE_KEY_FROM_TOPIC_ACL.getName())) { + assertThat(storedEvent.getConsumerId()).isEqualTo(DIST_CONSUMER_ID); + } + if (!action.equals(AuditingActionEnum.DISTRIBUTION_REGISTER.getName()) && + !action.equals(AuditingActionEnum.DISTRIBUTION_UN_REGISTER.getName())) { + assertThat(storedEvent.getRole()).isEqualTo(DIST_ROLE); + } + } + +} diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistributionEventFuncTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistributionEventFuncTest.java new file mode 100644 index 0000000000..4c9c63343f --- /dev/null +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistributionEventFuncTest.java @@ -0,0 +1,224 @@ +package org.openecomp.sdc.be.auditing.impl.distribution; + +import org.junit.Before; +import org.junit.Test; +import org.junit.runner.RunWith; +import org.mockito.ArgumentCaptor; +import org.mockito.Captor; +import org.mockito.Mock; +import org.mockito.junit.MockitoJUnitRunner; +import org.openecomp.sdc.be.auditing.api.AuditEventFactory; +import org.openecomp.sdc.be.auditing.impl.AuditGetUebClusterEventFactory; +import org.openecomp.sdc.be.auditing.impl.AuditingManager; +import org.openecomp.sdc.be.config.Configuration; +import org.openecomp.sdc.be.dao.api.ActionStatus; +import org.openecomp.sdc.be.dao.cassandra.AuditCassandraDao; +import org.openecomp.sdc.be.dao.cassandra.CassandraOperationStatus; +import org.openecomp.sdc.be.dao.impl.AuditingDao; +import org.openecomp.sdc.be.resources.data.auditing.*; +import org.openecomp.sdc.be.resources.data.auditing.model.*; +import org.openecomp.sdc.common.util.ThreadLocalsHolder; + +import static org.assertj.core.api.Assertions.assertThat; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.ArgumentMatchers.eq; +import static org.mockito.Mockito.verify; +import static org.mockito.Mockito.when; +import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.*; + +@RunWith(MockitoJUnitRunner.class) +public class AuditDistributionEventFuncTest { + + private AuditingManager auditingManager; + + @Mock + private static AuditCassandraDao cassandraDao; + @Mock + private static AuditingDao auditingDao; + @Mock + private static Configuration.ElasticSearchConfig esConfig; + + @Captor + private ArgumentCaptor<AuditingGenericEvent> eventCaptor; + + @Before + public void setUp() { + init(esConfig); + auditingManager = new AuditingManager(auditingDao, cassandraDao); + ThreadLocalsHolder.setUuid(REQUEST_ID); + } + + @Test + public void testNotifyEvent() { + AuditEventFactory factory = new AuditDistributionNotificationEventFactory( + CommonAuditData.newBuilder() + .description(DESCRIPTION) + .status(STATUS_OK) + .requestId(REQUEST_ID) + .serviceInstanceId(SERVICE_INSTANCE_ID) + .build(), + new ResourceCommonInfo(RESOURCE_NAME,RESOURCE_TYPE), + ResourceVersionInfo.newBuilder() + .state(CURRENT_STATE) + .version(CURRENT_VERSION) + .build(), + DIST_ID, user, TOPIC_NAME, + new OperationalEnvAuditData(OP_ENV_ID, VNF_WORKLOAD_CONTEXT, TENANT_CONTEXT)); + + when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.DISTRIBUTION_NOTIFY.getAuditingEsType()))) + .thenReturn(ActionStatus.OK); + when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); + + assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DISTRIB_NOTIFICATION_LOG_STR); + verifyNotifyEvent(); + } + + @Test + public void testStatusEvent() { + AuditEventFactory factory = new AuditDistributionStatusEventFactory( + CommonAuditData.newBuilder() + .description(DESCRIPTION) + .status(STATUS_OK) + .requestId(REQUEST_ID) + .serviceInstanceId(SERVICE_INSTANCE_ID) + .build(), + new DistributionData(DIST_CONSUMER_ID, DIST_RESOURCE_URL), + DIST_ID, TOPIC_NAME, DIST_STATUS_TIME); + + when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.DISTRIBUTION_STATUS.getAuditingEsType()))) + .thenReturn(ActionStatus.OK); + when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); + + assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DIST_STATUS_LOG_STR); + verifyStatusEvent(); + } + + @Test + public void testDownloadEvent() { + AuditEventFactory factory = new AuditDistributionDownloadEventFactory( + CommonAuditData.newBuilder() + .description(DESCRIPTION) + .status(STATUS_OK) + .requestId(REQUEST_ID) + .serviceInstanceId(SERVICE_INSTANCE_ID) + .build(), + new DistributionData(DIST_CONSUMER_ID, DIST_RESOURCE_URL)); + + when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.DISTRIBUTION_ARTIFACT_DOWNLOAD.getAuditingEsType()))) + .thenReturn(ActionStatus.OK); + when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); + + assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DIST_DOWNLOAD_LOG_STR); + verifyDownloadsEvent(); + } + + @Test + public void testDeployEvent() { + AuditEventFactory factory = new AuditDistributionDeployEventFactory( + CommonAuditData.newBuilder() + .description(DESCRIPTION) + .status(STATUS_OK) + .requestId(REQUEST_ID) + .serviceInstanceId(SERVICE_INSTANCE_ID) + .build(), + new ResourceCommonInfo(RESOURCE_NAME,RESOURCE_TYPE), + DIST_ID, user, CURRENT_VERSION); + + when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.DISTRIBUTION_DEPLOY.getAuditingEsType()))) + .thenReturn(ActionStatus.OK); + when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); + + assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DISTRIB_DEPLOY_LOG_STR); + verifyDeployEvent(); + } + + @Test + public void testGetUebClusterEvent() { + AuditEventFactory factory = new AuditGetUebClusterEventFactory( + CommonAuditData.newBuilder() + .description(DESCRIPTION) + .status(STATUS_OK) + .requestId(REQUEST_ID) + .serviceInstanceId(SERVICE_INSTANCE_ID) + .build(), + DIST_CONSUMER_ID); + + when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.GET_UEB_CLUSTER.getAuditingEsType()))) + .thenReturn(ActionStatus.OK); + when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); + + assertThat(auditingManager.auditEvent(factory)).contains(EXPECTED_GET_UEB_CLUSTER_LOG_STR); + verifyGetUebClusterEvent(); + } + + private void verifyNotifyEvent() { + verify(cassandraDao).saveRecord(eventCaptor.capture()); + DistributionNotificationEvent storedEvent = (DistributionNotificationEvent) eventCaptor.getValue(); + assertThat(storedEvent.getCurrState()).isEqualTo(CURRENT_STATE); + assertThat(storedEvent.getCurrVersion()).isEqualTo(CURRENT_VERSION); + assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); + assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); + assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID); + assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID); + assertThat(storedEvent.getAction()).isEqualTo(AuditingActionEnum.DISTRIBUTION_NOTIFY.getName()); + assertThat(storedEvent.getDid()).isEqualTo(DIST_ID); + assertThat(storedEvent.getModifier()).isEqualTo(USER_UID); + assertThat(storedEvent.getResourceName()).isEqualTo(RESOURCE_NAME); + assertThat(storedEvent.getResourceType()).isEqualTo(RESOURCE_TYPE); + assertThat(storedEvent.getTopicName()).isEqualTo(TOPIC_NAME); + assertThat(storedEvent.getVnfWorkloadContext()).isEqualTo(VNF_WORKLOAD_CONTEXT); + assertThat(storedEvent.getEnvId()).isEqualTo(OP_ENV_ID); + assertThat(storedEvent.getTenant()).isEqualTo(TENANT_CONTEXT); + } + + private void verifyStatusEvent() { + verify(cassandraDao).saveRecord(eventCaptor.capture()); + DistributionStatusEvent storedEvent = (DistributionStatusEvent) eventCaptor.getValue(); + assertThat(storedEvent.getConsumerId()).isEqualTo(DIST_CONSUMER_ID); + assertThat(storedEvent.getDid()).isEqualTo(DIST_ID); + assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); + assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); + assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID); + assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID); + assertThat(storedEvent.getAction()).isEqualTo(AuditingActionEnum.DISTRIBUTION_STATUS.getName()); + assertThat(storedEvent.getStatusTime()).isEqualTo(DIST_STATUS_TIME); + assertThat(storedEvent.getResoureURL()).isEqualTo(DIST_RESOURCE_URL); + assertThat(storedEvent.getTopicName()).isEqualTo(TOPIC_NAME); + } + + private void verifyDownloadsEvent() { + verify(cassandraDao).saveRecord(eventCaptor.capture()); + DistributionDownloadEvent storedEvent = (DistributionDownloadEvent) eventCaptor.getValue(); + assertThat(storedEvent.getConsumerId()).isEqualTo(DIST_CONSUMER_ID); + assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); + assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); + assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID); + assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID); + assertThat(storedEvent.getResourceUrl()).isEqualTo(DIST_RESOURCE_URL); + } + + private void verifyDeployEvent() { + verify(cassandraDao).saveRecord(eventCaptor.capture()); + DistributionDeployEvent storedEvent = (DistributionDeployEvent) eventCaptor.getValue(); + assertThat(storedEvent.getCurrVersion()).isEqualTo(CURRENT_VERSION); + assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); + assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); + assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID); + assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID); + assertThat(storedEvent.getDid()).isEqualTo(DIST_ID); + assertThat(storedEvent.getModifier()).isEqualTo(USER_UID); + assertThat(storedEvent.getResourceName()).isEqualTo(RESOURCE_NAME); + assertThat(storedEvent.getResourceType()).isEqualTo(RESOURCE_TYPE); + } + + private void verifyGetUebClusterEvent() { + verify(cassandraDao).saveRecord(eventCaptor.capture()); + AuditingGetUebClusterEvent storedEvent = (AuditingGetUebClusterEvent) eventCaptor.getValue(); + assertThat(storedEvent.getConsumerId()).isEqualTo(DIST_CONSUMER_ID); + assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); + assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); + assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID); + assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID); + } + +} diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditGetUebClusterEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditGetUebClusterEventFactoryTest.java index 10608ab651..ee8100ef6a 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditGetUebClusterEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditGetUebClusterEventFactoryTest.java @@ -1,6 +1,7 @@ package org.openecomp.sdc.be.auditing.impl.distribution; import org.junit.Test; +import org.openecomp.sdc.be.auditing.impl.AuditGetUebClusterEventFactory; import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder; diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/ecompopenv/AuditEcompOpEnvEventTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/ecompopenv/AuditEcompOpEnvEventTest.java index 8dd66800e2..95beb9cb5b 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/ecompopenv/AuditEcompOpEnvEventTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/ecompopenv/AuditEcompOpEnvEventTest.java @@ -1,23 +1,5 @@ package org.openecomp.sdc.be.auditing.impl.ecompopenv; -import static org.assertj.core.api.Assertions.assertThat; -import static org.mockito.ArgumentMatchers.any; -import static org.mockito.ArgumentMatchers.anyMap; -import static org.mockito.ArgumentMatchers.eq; -import static org.mockito.Mockito.verify; -import static org.mockito.Mockito.when; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_CREATE_OP_ENV_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_UNKNOWN_NOTIFICATION_OP_ENV_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_UNSUPPORTED_TYPE_OP_ENV_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.OP_ENV_ACTION; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.OP_ENV_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.OP_ENV_NAME; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.OP_ENV_TYPE; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.TENANT_CONTEXT; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.init; - -import java.util.EnumMap; - import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; @@ -36,7 +18,13 @@ import org.openecomp.sdc.be.dao.impl.AuditingDao; import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum; import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent; import org.openecomp.sdc.be.resources.data.auditing.EcompOperationalEnvironmentEvent; -import org.openecomp.sdc.common.datastructure.AuditingFieldsKeysEnum; + +import static org.assertj.core.api.Assertions.assertThat; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.ArgumentMatchers.eq; +import static org.mockito.Mockito.verify; +import static org.mockito.Mockito.when; +import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.*; @RunWith(MockitoJUnitRunner.class) public class AuditEcompOpEnvEventTest { @@ -51,7 +39,7 @@ public class AuditEcompOpEnvEventTest { private static Configuration.ElasticSearchConfig esConfig; @Captor - private ArgumentCaptor<AuditingGenericEvent> eventCaptor; + private ArgumentCaptor<EcompOperationalEnvironmentEvent> eventCaptor; @Before public void setUp() { @@ -60,7 +48,7 @@ public class AuditEcompOpEnvEventTest { } @Test - public void testNewCreateOpEnvEvent() { + public void testCreateOpEnvEvent() { AuditEventFactory factory = new AuditEcompOpEnvEventFactory(AuditingActionEnum.CREATE_ENVIRONMENT, OP_ENV_ID, OP_ENV_NAME, OP_ENV_TYPE, OP_ENV_ACTION, TENANT_CONTEXT); @@ -73,18 +61,7 @@ public class AuditEcompOpEnvEventTest { } @Test - public void testOldCreateOpEnvEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.CREATE_ENVIRONMENT.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.CREATE_ENVIRONMENT))).isEqualTo(EXPECTED_CREATE_OP_ENV_LOG_STR); - verifyEvent(AuditingActionEnum.CREATE_ENVIRONMENT.getName()); - - } - - @Test - public void testNewUnsupportedTypeOpEnvEvent() { + public void testUnsupportedTypeOpEnvEvent() { AuditEventFactory factory = new AuditEcompOpEnvEventFactory(AuditingActionEnum.UNSUPPORTED_ENVIRONMENT_TYPE, OP_ENV_ID, OP_ENV_NAME, OP_ENV_TYPE, OP_ENV_ACTION, TENANT_CONTEXT); @@ -97,17 +74,7 @@ public class AuditEcompOpEnvEventTest { } @Test - public void testOldUnsupportedTypeOpEnvEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.UNSUPPORTED_ENVIRONMENT_TYPE.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.UNSUPPORTED_ENVIRONMENT_TYPE))).isEqualTo(EXPECTED_UNSUPPORTED_TYPE_OP_ENV_LOG_STR); - verifyEvent(AuditingActionEnum.UNSUPPORTED_ENVIRONMENT_TYPE.getName()); - } - - @Test - public void testNewUnknownNotificationOpEnvEvent() { + public void testUnknownNotificationOpEnvEvent() { AuditEventFactory factory = new AuditEcompOpEnvEventFactory(AuditingActionEnum.UNKNOWN_ENVIRONMENT_NOTIFICATION, OP_ENV_ID, OP_ENV_NAME, OP_ENV_TYPE, OP_ENV_ACTION, TENANT_CONTEXT); @@ -119,38 +86,14 @@ public class AuditEcompOpEnvEventTest { verifyEvent(AuditingActionEnum.UNKNOWN_ENVIRONMENT_NOTIFICATION.getName()); } - @Test - public void testOldUnknownNotificationOpEnvEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.UNSUPPORTED_ENVIRONMENT_TYPE.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.UNKNOWN_ENVIRONMENT_NOTIFICATION))).isEqualTo(EXPECTED_UNKNOWN_NOTIFICATION_OP_ENV_LOG_STR); - verifyEvent(AuditingActionEnum.UNKNOWN_ENVIRONMENT_NOTIFICATION.getName()); - } - - private EnumMap<AuditingFieldsKeysEnum, Object> fillMap(AuditingActionEnum action) { - EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, action.getName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_OPERATIONAL_ENVIRONMENT_ID, OP_ENV_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_OPERATIONAL_ENVIRONMENT_TYPE, OP_ENV_TYPE); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_OPERATIONAL_ENVIRONMENT_NAME, OP_ENV_NAME); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_OPERATIONAL_ENVIRONMENT_ACTION, OP_ENV_ACTION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_TENANT_CONTEXT, TENANT_CONTEXT); - - return auditingFields; - } - private void verifyEvent(String action) { verify(cassandraDao).saveRecord(eventCaptor.capture()); - EcompOperationalEnvironmentEvent storedEvent = (EcompOperationalEnvironmentEvent) eventCaptor.getValue(); + EcompOperationalEnvironmentEvent storedEvent = eventCaptor.getValue(); assertThat(storedEvent.getAction()).isEqualTo(action); assertThat(storedEvent.getOperationalEnvironmentId()).isEqualTo(OP_ENV_ID); assertThat(storedEvent.getOperationalEnvironmentName()).isEqualTo(OP_ENV_NAME); assertThat(storedEvent.getOperationalEnvironmentType()).isEqualTo(OP_ENV_TYPE); assertThat(storedEvent.getTenantContext()).isEqualTo(TENANT_CONTEXT); - - } } diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditActivateServiceExternalApiEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditActivateServiceExternalApiEventFactoryTest.java index 908399aa50..364e8272fe 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditActivateServiceExternalApiEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditActivateServiceExternalApiEventFactoryTest.java @@ -4,17 +4,18 @@ import org.junit.Test; import org.openecomp.sdc.be.model.User; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder; -import org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData; +import org.openecomp.sdc.be.resources.data.auditing.model.DistributionData; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceCommonInfo; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceVersionInfo; + public class AuditActivateServiceExternalApiEventFactoryTest { private AuditActivateServiceExternalApiEventFactory createTestSubject() { Builder newBuilder = CommonAuditData.newBuilder(); CommonAuditData commonAuData = newBuilder.build(); - org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData.Builder newBuilder2 = ResourceAuditData.newBuilder(); - ResourceAuditData resAuData = newBuilder2.build(); - return new AuditActivateServiceExternalApiEventFactory(commonAuData, "", "", "", "", - resAuData, resAuData, "", new User(), ""); + ResourceVersionInfo.Builder newBuilder2 = ResourceVersionInfo.newBuilder(); + return new AuditActivateServiceExternalApiEventFactory(commonAuData,new ResourceCommonInfo(),new DistributionData("",""),"", new User()); } @Test diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditChangeLifecycleExternalApiEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditChangeLifecycleExternalApiEventFactoryTest.java index d639471c77..2fba9b92fb 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditChangeLifecycleExternalApiEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditChangeLifecycleExternalApiEventFactoryTest.java @@ -3,17 +3,20 @@ package org.openecomp.sdc.be.auditing.impl.externalapi; import org.junit.Test; import org.openecomp.sdc.be.model.User; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; -import org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData; +import org.openecomp.sdc.be.resources.data.auditing.model.DistributionData; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceCommonInfo; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceVersionInfo; + public class AuditChangeLifecycleExternalApiEventFactoryTest { private AuditChangeLifecycleExternalApiEventFactory createTestSubject() { org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder newBuilder = CommonAuditData.newBuilder(); CommonAuditData commonAuData = newBuilder.build(); - org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData.Builder newBuilder2 = ResourceAuditData.newBuilder(); - ResourceAuditData resAuData = newBuilder2.build(); - return new AuditChangeLifecycleExternalApiEventFactory(commonAuData, "", "", "", "", - resAuData, resAuData, "", new User(), ""); + ResourceVersionInfo.Builder newBuilder2 = ResourceVersionInfo.newBuilder(); + ResourceVersionInfo resAuData = newBuilder2.build(); + return new AuditChangeLifecycleExternalApiEventFactory(commonAuData,new ResourceCommonInfo(), new DistributionData("",""), + resAuData, resAuData, "", new User()); } @Test diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditCreateResourceExternalApiEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditCreateResourceExternalApiEventFactoryTest.java index 414920ea4b..91a5e68fdc 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditCreateResourceExternalApiEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditCreateResourceExternalApiEventFactoryTest.java @@ -3,17 +3,18 @@ package org.openecomp.sdc.be.auditing.impl.externalapi; import org.junit.Test; import org.openecomp.sdc.be.model.User; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; -import org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData; +import org.openecomp.sdc.be.resources.data.auditing.model.DistributionData; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceCommonInfo; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceVersionInfo; public class AuditCreateResourceExternalApiEventFactoryTest { private AuditCreateResourceExternalApiEventFactory createTestSubject() { - org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder newBuilder = CommonAuditData.newBuilder(); + CommonAuditData.Builder newBuilder = CommonAuditData.newBuilder(); CommonAuditData commonAuData = newBuilder.build(); - org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData.Builder newBuilder2 = ResourceAuditData.newBuilder(); - ResourceAuditData resAuData = newBuilder2.build(); - return new AuditCreateResourceExternalApiEventFactory(commonAuData, "", "", "", "", - resAuData, resAuData, "", new User(), ""); + ResourceVersionInfo.Builder newBuilder2 = ResourceVersionInfo.newBuilder(); + ResourceVersionInfo resAuData = newBuilder2.build(); + return new AuditCreateResourceExternalApiEventFactory(commonAuData,new ResourceCommonInfo(),new DistributionData("",""),resAuData,"", new User()); } @Test diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditDownloadArtifactExternalApiEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditDownloadArtifactExternalApiEventFactoryTest.java index bf5f03c9ea..8aad4a78b1 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditDownloadArtifactExternalApiEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditDownloadArtifactExternalApiEventFactoryTest.java @@ -3,17 +3,19 @@ package org.openecomp.sdc.be.auditing.impl.externalapi; import org.junit.Test; import org.openecomp.sdc.be.model.User; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; -import org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData; +import org.openecomp.sdc.be.resources.data.auditing.model.DistributionData; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceCommonInfo; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceVersionInfo; + public class AuditDownloadArtifactExternalApiEventFactoryTest { private AuditDownloadArtifactExternalApiEventFactory createTestSubject() { - org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder newBuilder = CommonAuditData.newBuilder(); + CommonAuditData.Builder newBuilder = CommonAuditData.newBuilder(); CommonAuditData commonAuData = newBuilder.build(); - org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData.Builder newBuilder2 = ResourceAuditData.newBuilder(); - ResourceAuditData resAuData = newBuilder2.build(); - return new AuditDownloadArtifactExternalApiEventFactory(commonAuData, "", "", "", "", - resAuData, resAuData, "", new User(), ""); + ResourceVersionInfo.Builder newBuilder2 = ResourceVersionInfo.newBuilder(); + ResourceVersionInfo resAuData = newBuilder2.build(); + return new AuditDownloadArtifactExternalApiEventFactory(commonAuData,new ResourceCommonInfo(),new DistributionData("", ""),resAuData, new User()); } @Test diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditExternalApiEventFuncTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditExternalApiEventFuncTest.java index 1ddda9ea5f..a247d61d5c 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditExternalApiEventFuncTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/externalapi/AuditExternalApiEventFuncTest.java @@ -1,38 +1,5 @@ package org.openecomp.sdc.be.auditing.impl.externalapi; -import static org.assertj.core.api.Assertions.assertThat; -import static org.mockito.ArgumentMatchers.any; -import static org.mockito.ArgumentMatchers.anyMap; -import static org.mockito.ArgumentMatchers.eq; -import static org.mockito.Mockito.verify; -import static org.mockito.Mockito.when; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.ARTIFACT_DATA; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.ARTIFACT_UUID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.CURRENT_STATE; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.CURRENT_VERSION; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DESCRIPTION; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DIST_CONSUMER_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DIST_RESOURCE_URL; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_ACTIVATE_SERVICE_API_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_CHANGE_LIFECYCLE_EXTERNAL_API_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_DELETE_ARTIFACT_EXTERNAL_API_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_DOWNLOAD_ARTIFACT_EXTERNAL_API_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_GET_ASSET_LIST_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_GET_TOSCA_MODEL_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.INVARIANT_UUID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.MODIFIER_UID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.PREV_RESOURCE_STATE; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.PREV_RESOURCE_VERSION; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.REQUEST_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.RESOURCE_NAME; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.RESOURCE_TYPE; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.SERVICE_INSTANCE_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.STATUS_OK; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.init; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.modifier; - -import java.util.EnumMap; - import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; @@ -51,8 +18,17 @@ import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum; import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent; import org.openecomp.sdc.be.resources.data.auditing.ExternalApiEvent; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; -import org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData; -import org.openecomp.sdc.common.datastructure.AuditingFieldsKeysEnum; +import org.openecomp.sdc.be.resources.data.auditing.model.DistributionData; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceCommonInfo; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceVersionInfo; + +import static org.assertj.core.api.Assertions.assertThat; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.ArgumentMatchers.eq; +import static org.mockito.Mockito.verify; +import static org.mockito.Mockito.when; +import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.*; + @RunWith(MockitoJUnitRunner.class) public class AuditExternalApiEventFuncTest { @@ -67,7 +43,7 @@ public class AuditExternalApiEventFuncTest { private static Configuration.ElasticSearchConfig esConfig; @Captor - private ArgumentCaptor<AuditingGenericEvent> eventCaptor; + private ArgumentCaptor<ExternalApiEvent> eventCaptor; @Before public void setUp() { @@ -76,7 +52,7 @@ public class AuditExternalApiEventFuncTest { } @Test - public void testNewActivateServiceEvent() { + public void testActivateServiceEvent() { AuditEventFactory builder = new AuditActivateServiceExternalApiEventFactory( CommonAuditData.newBuilder() .description(DESCRIPTION) @@ -84,40 +60,21 @@ public class AuditExternalApiEventFuncTest { .requestId(REQUEST_ID) .serviceInstanceId(SERVICE_INSTANCE_ID) .build(), - RESOURCE_TYPE, RESOURCE_NAME, DIST_CONSUMER_ID, DIST_RESOURCE_URL, - ResourceAuditData.newBuilder() - .artifactUuid(ARTIFACT_UUID) - .state(PREV_RESOURCE_STATE) - .version(PREV_RESOURCE_VERSION) - .build(), - ResourceAuditData.newBuilder() - .artifactUuid(ARTIFACT_UUID) - .state(CURRENT_STATE) - .version(CURRENT_VERSION) - .build(), - INVARIANT_UUID, modifier, ARTIFACT_DATA); + new ResourceCommonInfo(RESOURCE_NAME, RESOURCE_TYPE), + new DistributionData(DIST_CONSUMER_ID, DIST_RESOURCE_URL), + INVARIANT_UUID, modifier); when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.ACTIVATE_SERVICE_BY_API.getAuditingEsType()))) .thenReturn(ActionStatus.OK); when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); assertThat(auditingManager.auditEvent(builder)).isEqualTo(EXPECTED_ACTIVATE_SERVICE_API_LOG_STR); - verifyExternalApiEvent(AuditingActionEnum.ACTIVATE_SERVICE_BY_API.getName()); - } - - @Test - public void testOldActivateServiceEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.ACTIVATE_SERVICE_BY_API.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.ACTIVATE_SERVICE_BY_API))).isEqualTo(EXPECTED_ACTIVATE_SERVICE_API_LOG_STR); - verifyExternalApiEvent(AuditingActionEnum.ACTIVATE_SERVICE_BY_API.getName()); + verifyExternalApiEventWithoutVersionInfo(AuditingActionEnum.ACTIVATE_SERVICE_BY_API.getName()); } @Test - public void testNewDownloadArtifactEvent() { + public void testDownloadArtifactEvent() { AuditEventFactory builder = new AuditDownloadArtifactExternalApiEventFactory( CommonAuditData.newBuilder() .description(DESCRIPTION) @@ -125,18 +82,14 @@ public class AuditExternalApiEventFuncTest { .requestId(REQUEST_ID) .serviceInstanceId(SERVICE_INSTANCE_ID) .build(), - RESOURCE_TYPE, RESOURCE_NAME, DIST_CONSUMER_ID, DIST_RESOURCE_URL, - ResourceAuditData.newBuilder() - .artifactUuid(ARTIFACT_UUID) - .state(PREV_RESOURCE_STATE) - .version(PREV_RESOURCE_VERSION) - .build(), - ResourceAuditData.newBuilder() - .artifactUuid(ARTIFACT_UUID) - .state(CURRENT_STATE) + new ResourceCommonInfo(RESOURCE_NAME, RESOURCE_TYPE), + new DistributionData(DIST_CONSUMER_ID, DIST_RESOURCE_URL), + ResourceVersionInfo.newBuilder() .version(CURRENT_VERSION) + .state(CURRENT_STATE) + .artifactUuid(ARTIFACT_UUID) .build(), - INVARIANT_UUID, modifier, ARTIFACT_DATA); + modifier); when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.DOWNLOAD_ARTIFACT.getAuditingEsType()))) .thenReturn(ActionStatus.OK); @@ -147,17 +100,7 @@ public class AuditExternalApiEventFuncTest { } @Test - public void testOldDownloadArtifactEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.DOWNLOAD_ARTIFACT.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.DOWNLOAD_ARTIFACT))).isEqualTo(EXPECTED_DOWNLOAD_ARTIFACT_EXTERNAL_API_LOG_STR + " "); - verifyExternalApiEvent(AuditingActionEnum.DOWNLOAD_ARTIFACT.getName()); - } - - @Test - public void testNewChangeLifecycleEvent() { + public void testChangeLifecycleEvent() { AuditEventFactory factory = new AuditChangeLifecycleExternalApiEventFactory( CommonAuditData.newBuilder() .description(DESCRIPTION) @@ -165,18 +108,19 @@ public class AuditExternalApiEventFuncTest { .requestId(REQUEST_ID) .serviceInstanceId(SERVICE_INSTANCE_ID) .build(), - RESOURCE_TYPE, RESOURCE_NAME, DIST_CONSUMER_ID, DIST_RESOURCE_URL, - ResourceAuditData.newBuilder() + new ResourceCommonInfo(RESOURCE_NAME, RESOURCE_TYPE), + new DistributionData(DIST_CONSUMER_ID, DIST_RESOURCE_URL), + ResourceVersionInfo.newBuilder() .artifactUuid(ARTIFACT_UUID) .state(PREV_RESOURCE_STATE) .version(PREV_RESOURCE_VERSION) .build(), - ResourceAuditData.newBuilder() + ResourceVersionInfo.newBuilder() .artifactUuid(ARTIFACT_UUID) .state(CURRENT_STATE) .version(CURRENT_VERSION) .build(), - INVARIANT_UUID, modifier, ARTIFACT_DATA); + INVARIANT_UUID, modifier); when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.CHANGE_LIFECYCLE_BY_API.getAuditingEsType()))) .thenReturn(ActionStatus.OK); @@ -187,32 +131,23 @@ public class AuditExternalApiEventFuncTest { } @Test - public void testOldChangeLifecycleEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.CHANGE_LIFECYCLE_BY_API.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.CHANGE_LIFECYCLE_BY_API))).isEqualTo(EXPECTED_CHANGE_LIFECYCLE_EXTERNAL_API_LOG_STR); - verifyExternalApiEvent(AuditingActionEnum.CHANGE_LIFECYCLE_BY_API.getName()); - - } - - @Test - public void testNewDeleteArtifactEvent() { - AuditEventFactory factory = new AuditDeleteArtByApiCrudExternalApiEventFactory( + public void testDeleteArtifactEvent() { + AuditEventFactory factory = new AuditCrudExternalApiArtifactEventFactory( + AuditingActionEnum.ARTIFACT_DELETE_BY_API, CommonAuditData.newBuilder() .description(DESCRIPTION) .status(STATUS_OK) .requestId(REQUEST_ID) .serviceInstanceId(SERVICE_INSTANCE_ID) .build(), - RESOURCE_TYPE, RESOURCE_NAME, DIST_CONSUMER_ID, DIST_RESOURCE_URL, - ResourceAuditData.newBuilder() + new ResourceCommonInfo(RESOURCE_NAME, RESOURCE_TYPE), + new DistributionData(DIST_CONSUMER_ID, DIST_RESOURCE_URL), + ResourceVersionInfo.newBuilder() .artifactUuid(ARTIFACT_UUID) .state(PREV_RESOURCE_STATE) .version(PREV_RESOURCE_VERSION) .build(), - ResourceAuditData.newBuilder() + ResourceVersionInfo.newBuilder() .artifactUuid(ARTIFACT_UUID) .state(CURRENT_STATE) .version(CURRENT_VERSION) @@ -228,141 +163,183 @@ public class AuditExternalApiEventFuncTest { } @Test - public void testOldDeleteArtifactEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.ARTIFACT_DELETE_BY_API.getAuditingEsType()))) + public void testGetAssetEvent() { + AuditEventFactory factory = new AuditAssetExternalApiEventFactory(AuditingActionEnum.GET_ASSET_METADATA, + CommonAuditData.newBuilder() + .status(STATUS_OK) + .description(DESCRIPTION) + .requestId(REQUEST_ID) + .serviceInstanceId(SERVICE_INSTANCE_ID) + .build(), + new ResourceCommonInfo(RESOURCE_NAME, RESOURCE_TYPE), + new DistributionData(DIST_CONSUMER_ID, DIST_RESOURCE_URL)); + when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.GET_ASSET_METADATA.getAuditingEsType()))) .thenReturn(ActionStatus.OK); when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.ARTIFACT_DELETE_BY_API))).isEqualTo(EXPECTED_DELETE_ARTIFACT_EXTERNAL_API_LOG_STR + " "); - verifyExternalApiEvent(AuditingActionEnum.ARTIFACT_DELETE_BY_API.getName()); + assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_EXTERNAL_ASSET_LOG_STR); + verifyExternalApiEventWithoutVersionInfo(AuditingActionEnum.GET_ASSET_METADATA.getName()); } @Test - public void testNewGetAssetsListEvent() { - AuditEventFactory factory = new AuditGetAssetListExternalApiEventFactory( + public void testGetAssetsListEvent() { + AuditEventFactory factory = new AuditAssetListExternalApiEventFactory( + AuditingActionEnum.GET_ASSET_LIST, CommonAuditData.newBuilder() .description(DESCRIPTION) .status(STATUS_OK) .requestId(REQUEST_ID) .serviceInstanceId(SERVICE_INSTANCE_ID) .build(), - RESOURCE_TYPE, RESOURCE_NAME, DIST_CONSUMER_ID, DIST_RESOURCE_URL, - ResourceAuditData.newBuilder() - .artifactUuid(ARTIFACT_UUID) - .state(PREV_RESOURCE_STATE) - .version(PREV_RESOURCE_VERSION) - .build(), - ResourceAuditData.newBuilder() - .artifactUuid(ARTIFACT_UUID) - .state(CURRENT_STATE) - .version(CURRENT_VERSION) - .build(), - INVARIANT_UUID, modifier, ARTIFACT_DATA); + new DistributionData(DIST_CONSUMER_ID, DIST_RESOURCE_URL)); when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.GET_ASSET_LIST.getAuditingEsType()))) .thenReturn(ActionStatus.OK); when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_GET_ASSET_LIST_LOG_STR); - verifyExternalApiEvent(AuditingActionEnum.GET_ASSET_LIST.getName()); + verifyExternalApiEventWithoutResourceInfo(AuditingActionEnum.GET_ASSET_LIST.getName()); } @Test - public void testOldGetAssetsListEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.GET_ASSET_LIST.getAuditingEsType()))) + public void testGetToscaModelEvent() { + AuditEventFactory factory = new AuditAssetExternalApiEventFactory( + AuditingActionEnum.GET_TOSCA_MODEL, + CommonAuditData.newBuilder() + .description(DESCRIPTION) + .status(STATUS_OK) + .requestId(REQUEST_ID) + .serviceInstanceId(SERVICE_INSTANCE_ID) + .build(), + new ResourceCommonInfo(RESOURCE_NAME, RESOURCE_TYPE), + new DistributionData(DIST_CONSUMER_ID, DIST_RESOURCE_URL)); + + when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.GET_TOSCA_MODEL.getAuditingEsType()))) .thenReturn(ActionStatus.OK); when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.GET_ASSET_LIST))).isEqualTo(EXPECTED_GET_ASSET_LIST_LOG_STR); - verifyExternalApiEvent(AuditingActionEnum.GET_ASSET_LIST.getName()); + assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_GET_TOSCA_MODEL_LOG_STR); + verifyExternalApiEventWithoutVersionInfo(AuditingActionEnum.GET_TOSCA_MODEL.getName()); } @Test - public void testNewGetToscaModelEvent() { - AuditEventFactory factory = new AuditGetToscaModelExternalApiEventFactory( + public void testCreateResourceEvent() { + AuditEventFactory factory = new AuditCreateResourceExternalApiEventFactory( CommonAuditData.newBuilder() .description(DESCRIPTION) .status(STATUS_OK) .requestId(REQUEST_ID) .serviceInstanceId(SERVICE_INSTANCE_ID) .build(), - RESOURCE_TYPE, RESOURCE_NAME, DIST_CONSUMER_ID, DIST_RESOURCE_URL, - ResourceAuditData.newBuilder() - .artifactUuid(ARTIFACT_UUID) - .state(PREV_RESOURCE_STATE) - .version(PREV_RESOURCE_VERSION) - .build(), - ResourceAuditData.newBuilder() + new ResourceCommonInfo(RESOURCE_NAME, RESOURCE_TYPE), + new DistributionData(DIST_CONSUMER_ID, DIST_RESOURCE_URL), + ResourceVersionInfo.newBuilder() .artifactUuid(ARTIFACT_UUID) .state(CURRENT_STATE) .version(CURRENT_VERSION) .build(), - INVARIANT_UUID, modifier, ARTIFACT_DATA); + INVARIANT_UUID, modifier); - when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.GET_TOSCA_MODEL.getAuditingEsType()))) + when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.CREATE_RESOURCE_BY_API.getAuditingEsType()))) .thenReturn(ActionStatus.OK); when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_GET_TOSCA_MODEL_LOG_STR); - verifyExternalApiEvent(AuditingActionEnum.GET_TOSCA_MODEL.getName()); - } - - @Test - public void testOldGetToscaModelEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.GET_TOSCA_MODEL.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.GET_TOSCA_MODEL))).isEqualTo(EXPECTED_GET_TOSCA_MODEL_LOG_STR); - verifyExternalApiEvent(AuditingActionEnum.GET_TOSCA_MODEL.getName()); + assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_EXTERNAL_CREATE_RESOURCE_LOG_STR); + verifyExternalApiEvent(AuditingActionEnum.CREATE_RESOURCE_BY_API.getName()); } private void verifyExternalApiEvent(String action) { verify(cassandraDao).saveRecord(eventCaptor.capture()); - ExternalApiEvent storedEvent = (ExternalApiEvent) eventCaptor.getValue(); + ExternalApiEvent storedEvent = eventCaptor.getValue(); assertThat(storedEvent.getModifier()).isEqualTo(MODIFIER_UID); assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID); assertThat(storedEvent.getAction()).isEqualTo(action); - assertThat(storedEvent.getArtifactData()).isEqualTo(ARTIFACT_DATA); - assertThat(storedEvent.getCurrArtifactUuid()).isEqualTo(ARTIFACT_UUID); - assertThat(storedEvent.getPrevArtifactUuid()).isEqualTo(ARTIFACT_UUID); - assertThat(storedEvent.getPrevState()).isEqualTo(PREV_RESOURCE_STATE); - assertThat(storedEvent.getCurrState()).isEqualTo(CURRENT_STATE); - assertThat(storedEvent.getPrevVersion()).isEqualTo(PREV_RESOURCE_VERSION); - assertThat(storedEvent.getCurrVersion()).isEqualTo(CURRENT_VERSION); - assertThat(storedEvent.getInvariantUuid()).isEqualTo(INVARIANT_UUID); + assertThat(storedEvent.getResourceName()).isEqualTo(RESOURCE_NAME); assertThat(storedEvent.getResourceType()).isEqualTo(RESOURCE_TYPE); + assertThat(storedEvent.getCurrArtifactUuid()).isEqualTo(ARTIFACT_UUID); - } + if (!action.equals(AuditingActionEnum.DOWNLOAD_ARTIFACT.getName()) + && !action.equals(AuditingActionEnum.CREATE_RESOURCE_BY_API.getName())) { + assertThat(storedEvent.getPrevArtifactUuid()).isEqualTo(ARTIFACT_UUID); + assertThat(storedEvent.getCurrVersion()).isEqualTo(CURRENT_VERSION); + assertThat(storedEvent.getCurrState()).isEqualTo(CURRENT_STATE); + assertThat(storedEvent.getPrevState()).isEqualTo(PREV_RESOURCE_STATE); + assertThat(storedEvent.getPrevVersion()).isEqualTo(PREV_RESOURCE_VERSION); + } + else { + assertThat(storedEvent.getPrevArtifactUuid()).isNull(); + assertThat(storedEvent.getCurrVersion()).isEqualTo(CURRENT_VERSION); + assertThat(storedEvent.getCurrState()).isEqualTo(CURRENT_STATE); + assertThat(storedEvent.getPrevState()).isNull(); + assertThat(storedEvent.getPrevVersion()).isNull(); + if (action.equals(AuditingActionEnum.DOWNLOAD_ARTIFACT.getName())) { + assertThat(storedEvent.getInvariantUuid()).isNull(); + } + else { + assertThat(storedEvent.getInvariantUuid()).isEqualTo(INVARIANT_UUID); + } + } + if (!action.equals(AuditingActionEnum.CHANGE_LIFECYCLE_BY_API.getName()) + && !action.equals(AuditingActionEnum.DOWNLOAD_ARTIFACT.getName()) + && !action.equals(AuditingActionEnum.CREATE_RESOURCE_BY_API.getName())) { + assertThat(storedEvent.getArtifactData()).isEqualTo(ARTIFACT_DATA); + } + else { + assertThat(storedEvent.getArtifactData()).isNull(); + } - private EnumMap<AuditingFieldsKeysEnum, Object> fillMap(AuditingActionEnum action) { - EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, action.getName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_NAME, modifier.getFirstName() + " " + modifier.getLastName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_UID, modifier.getUserId()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION); - - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_TYPE, RESOURCE_TYPE); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_PREV_VERSION, PREV_RESOURCE_VERSION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_PREV_STATE, PREV_RESOURCE_STATE); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_NAME, RESOURCE_NAME); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_CURR_VERSION, CURRENT_VERSION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_CURR_STATE, CURRENT_STATE); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_SERVICE_INSTANCE_ID, SERVICE_INSTANCE_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_INVARIANT_UUID, INVARIANT_UUID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ARTIFACT_DATA, ARTIFACT_DATA); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_CURR_ARTIFACT_UUID, ARTIFACT_UUID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_PREV_ARTIFACT_UUID, ARTIFACT_UUID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_CONSUMER_ID, DIST_CONSUMER_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_RESOURCE_URL, DIST_RESOURCE_URL); - return auditingFields; } + private void verifyExternalApiEventWithoutVersionInfo(String action) { + verify(cassandraDao).saveRecord(eventCaptor.capture()); + ExternalApiEvent storedEvent = eventCaptor.getValue(); + if (action.equals(AuditingActionEnum.ACTIVATE_SERVICE_BY_API.getName())) { + assertThat(storedEvent.getModifier()).isEqualTo(MODIFIER_UID); + assertThat(storedEvent.getInvariantUuid()).isEqualTo(INVARIANT_UUID); + } + else { + assertThat(storedEvent.getModifier()).isEmpty(); + assertThat(storedEvent.getInvariantUuid()).isNull(); + } + assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); + assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); + assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID); + assertThat(storedEvent.getAction()).isEqualTo(action); + assertThat(storedEvent.getArtifactData()).isNull(); + assertThat(storedEvent.getCurrArtifactUuid()).isNull(); + assertThat(storedEvent.getPrevArtifactUuid()).isNull(); + assertThat(storedEvent.getPrevState()).isNull(); + assertThat(storedEvent.getCurrState()).isNull(); + assertThat(storedEvent.getPrevVersion()).isNull(); + assertThat(storedEvent.getCurrVersion()).isNull(); + + assertThat(storedEvent.getResourceName()).isEqualTo(RESOURCE_NAME); + assertThat(storedEvent.getResourceType()).isEqualTo(RESOURCE_TYPE); + + } + private void verifyExternalApiEventWithoutResourceInfo(String action) { + verify(cassandraDao).saveRecord(eventCaptor.capture()); + ExternalApiEvent storedEvent = eventCaptor.getValue(); + assertThat(storedEvent.getModifier()).isEmpty(); + assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); + assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK); + assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID); + assertThat(storedEvent.getAction()).isEqualTo(action); + assertThat(storedEvent.getArtifactData()).isNull(); + assertThat(storedEvent.getCurrArtifactUuid()).isNull(); + assertThat(storedEvent.getPrevArtifactUuid()).isNull(); + assertThat(storedEvent.getPrevState()).isNull(); + assertThat(storedEvent.getCurrState()).isNull(); + assertThat(storedEvent.getPrevVersion()).isNull(); + assertThat(storedEvent.getCurrVersion()).isNull(); + assertThat(storedEvent.getInvariantUuid()).isNull(); + assertThat(storedEvent.getResourceName()).isNull(); + assertThat(storedEvent.getResourceType()).isNull(); + } -} +}
\ No newline at end of file diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditArtifactResourceAdminEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditArtifactResourceAdminEventFactoryTest.java index 51c9553b93..c0d026a8ab 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditArtifactResourceAdminEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditArtifactResourceAdminEventFactoryTest.java @@ -4,17 +4,18 @@ import org.junit.Test; import org.openecomp.sdc.be.model.User; import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; -import org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceCommonInfo; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceVersionInfo; public class AuditArtifactResourceAdminEventFactoryTest { private AuditArtifactResourceAdminEventFactory createTestSubject() { - org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder newBuilder = CommonAuditData.newBuilder(); + CommonAuditData.Builder newBuilder = CommonAuditData.newBuilder(); CommonAuditData commonAuData = newBuilder.build(); - org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData.Builder newBuilder2 = ResourceAuditData.newBuilder(); - ResourceAuditData resAuData = newBuilder2.build(); - return new AuditArtifactResourceAdminEventFactory(AuditingActionEnum.ACTIVATE_SERVICE_BY_API, commonAuData, - resAuData, resAuData, "", "", "", new User(), "", "", ""); + ResourceVersionInfo.Builder newBuilder2 = ResourceVersionInfo.newBuilder(); + ResourceVersionInfo resAuData = newBuilder2.build(); + return new AuditArtifactResourceAdminEventFactory(AuditingActionEnum.ACTIVATE_SERVICE_BY_API, commonAuData,new ResourceCommonInfo(), + resAuData, resAuData, "", new User(), "", "", ""); } @Test diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditCertificationResourceAdminEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditCertificationResourceAdminEventFactoryTest.java index a9de5b01ab..25305d5276 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditCertificationResourceAdminEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditCertificationResourceAdminEventFactoryTest.java @@ -4,17 +4,18 @@ import org.junit.Test; import org.openecomp.sdc.be.model.User; import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; -import org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceCommonInfo; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceVersionInfo; public class AuditCertificationResourceAdminEventFactoryTest { private AuditCertificationResourceAdminEventFactory createTestSubject() { - org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder newBuilder = CommonAuditData.newBuilder(); + CommonAuditData.Builder newBuilder = CommonAuditData.newBuilder(); CommonAuditData commonAuData = newBuilder.build(); - org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData.Builder newBuilder2 = ResourceAuditData.newBuilder(); - ResourceAuditData resAuData = newBuilder2.build(); - return new AuditCertificationResourceAdminEventFactory(AuditingActionEnum.ACTIVATE_SERVICE_BY_API, commonAuData, - resAuData, resAuData, "", "", "", new User(), "", "", ""); + ResourceVersionInfo.Builder newBuilder2 = ResourceVersionInfo.newBuilder(); + ResourceVersionInfo resAuData = newBuilder2.build(); + return new AuditCertificationResourceAdminEventFactory(AuditingActionEnum.ACTIVATE_SERVICE_BY_API, commonAuData,new ResourceCommonInfo(), + resAuData, resAuData, "", new User(), "", "", ""); } @Test diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditCreateUpdateResourceAdminEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditCreateUpdateResourceAdminEventFactoryTest.java index 357d2e2694..c2c6367c59 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditCreateUpdateResourceAdminEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditCreateUpdateResourceAdminEventFactoryTest.java @@ -4,17 +4,19 @@ import org.junit.Test; import org.openecomp.sdc.be.model.User; import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; -import org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceCommonInfo; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceVersionInfo; + public class AuditCreateUpdateResourceAdminEventFactoryTest { private AuditCreateUpdateResourceAdminEventFactory createTestSubject() { - org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder newBuilder = CommonAuditData.newBuilder(); + CommonAuditData.Builder newBuilder = CommonAuditData.newBuilder(); CommonAuditData commonAuData = newBuilder.build(); - org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData.Builder newBuilder2 = ResourceAuditData.newBuilder(); - ResourceAuditData resAuData = newBuilder2.build(); - return new AuditCreateUpdateResourceAdminEventFactory(AuditingActionEnum.ACTIVATE_SERVICE_BY_API, commonAuData, - resAuData, resAuData, "", "", "", new User(), "", "", "", ""); + ResourceVersionInfo.Builder newBuilder2 = ResourceVersionInfo.newBuilder(); + ResourceVersionInfo resAuData = newBuilder2.build(); + return new AuditCreateUpdateResourceAdminEventFactory(AuditingActionEnum.ACTIVATE_SERVICE_BY_API, commonAuData,new ResourceCommonInfo(), + resAuData, resAuData, "", new User(), "", "","",""); } @Test diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditDistStateChangeRequestResourceAdminEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditDistStateChangeRequestResourceAdminEventFactoryTest.java index 20b65c5b6c..5f5aeb001f 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditDistStateChangeRequestResourceAdminEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditDistStateChangeRequestResourceAdminEventFactoryTest.java @@ -3,17 +3,18 @@ package org.openecomp.sdc.be.auditing.impl.resourceadmin; import org.junit.Test; import org.openecomp.sdc.be.model.User; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; -import org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceCommonInfo; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceVersionInfo; public class AuditDistStateChangeRequestResourceAdminEventFactoryTest { private AuditDistStateChangeRequestResourceAdminEventFactory createTestSubject() { org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder newBuilder = CommonAuditData.newBuilder(); CommonAuditData commonAuData = newBuilder.build(); - org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData.Builder newBuilder2 = ResourceAuditData.newBuilder(); - ResourceAuditData resAuData = newBuilder2.build(); - return new AuditDistStateChangeRequestResourceAdminEventFactory(commonAuData, resAuData, - resAuData, "", "", "", new User(), "", "", ""); + ResourceVersionInfo.Builder newBuilder2 = ResourceVersionInfo.newBuilder(); + ResourceVersionInfo resAuData = newBuilder2.build(); + return new AuditDistStateChangeRequestResourceAdminEventFactory(commonAuData,new ResourceCommonInfo(), resAuData, + resAuData, "", new User(), "", "", ""); } @Test diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditDistStateChangeResourceAdminEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditDistStateChangeResourceAdminEventFactoryTest.java index d3900ee9c9..721a29a2c0 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditDistStateChangeResourceAdminEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditDistStateChangeResourceAdminEventFactoryTest.java @@ -4,17 +4,18 @@ import org.junit.Test; import org.openecomp.sdc.be.model.User; import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; -import org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceCommonInfo; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceVersionInfo; public class AuditDistStateChangeResourceAdminEventFactoryTest { private AuditDistStateChangeResourceAdminEventFactory createTestSubject() { - org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder newBuilder = CommonAuditData.newBuilder(); + CommonAuditData.Builder newBuilder = CommonAuditData.newBuilder(); CommonAuditData commonAuData = newBuilder.build(); - org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData.Builder newBuilder2 = ResourceAuditData.newBuilder(); - ResourceAuditData resAuData = newBuilder2.build(); - return new AuditDistStateChangeResourceAdminEventFactory(AuditingActionEnum.ACTIVATE_SERVICE_BY_API, commonAuData, - resAuData, resAuData, "", "", "", new User(), "", "", ""); + ResourceVersionInfo.Builder newBuilder2 = ResourceVersionInfo.newBuilder(); + ResourceVersionInfo resAuData = newBuilder2.build(); + return new AuditDistStateChangeResourceAdminEventFactory(AuditingActionEnum.ACTIVATE_SERVICE_BY_API, commonAuData,new ResourceCommonInfo(), + resAuData, resAuData, "", new User(), "", "",""); } @Test diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditImportResourceAdminEventFactoryTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditImportResourceAdminEventFactoryTest.java index ff033dabaf..bd7b01d103 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditImportResourceAdminEventFactoryTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditImportResourceAdminEventFactoryTest.java @@ -3,18 +3,17 @@ package org.openecomp.sdc.be.auditing.impl.resourceadmin; import org.junit.Test; import org.openecomp.sdc.be.model.User; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; -import org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceCommonInfo; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceVersionInfo; public class AuditImportResourceAdminEventFactoryTest { private AuditImportResourceAdminEventFactory createTestSubject() { - org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData.Builder newBuilder = CommonAuditData.newBuilder(); + CommonAuditData.Builder newBuilder = CommonAuditData.newBuilder(); CommonAuditData commonAuData = newBuilder.build(); - org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData.Builder newBuilder2 = ResourceAuditData.newBuilder(); - ResourceAuditData resAuData = newBuilder2.build(); - new AuditImportResourceAdminEventFactory(commonAuData, resAuData, resAuData, "", "", "", new User(), ""); - return new AuditImportResourceAdminEventFactory(commonAuData, resAuData, - resAuData, "", "", "", new User(), "", "", "", ""); + ResourceVersionInfo.Builder newBuilder2 = ResourceVersionInfo.newBuilder(); + ResourceVersionInfo resAuData = newBuilder2.build(); + return new AuditImportResourceAdminEventFactory(commonAuData,new ResourceCommonInfo(), resAuData,resAuData,"", new User(),""); } @Test diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditResourceAdminEventFuncTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditResourceAdminEventFuncTest.java index 8478803f16..781702c4a4 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditResourceAdminEventFuncTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/resourceadmin/AuditResourceAdminEventFuncTest.java @@ -1,41 +1,5 @@ package org.openecomp.sdc.be.auditing.impl.resourceadmin; -import static org.assertj.core.api.Assertions.assertThat; -import static org.mockito.ArgumentMatchers.any; -import static org.mockito.ArgumentMatchers.anyMap; -import static org.mockito.ArgumentMatchers.eq; -import static org.mockito.Mockito.verify; -import static org.mockito.Mockito.when; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.ARTIFACT_DATA; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.ARTIFACT_UUID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.COMMENT; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.CURRENT_STATE; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.CURRENT_VERSION; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DCURR_STATUS; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DESCRIPTION; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DIST_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DPREV_STATUS; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_ARTIFACT_UPLOAD_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_CHECK_IN_RESOURCE_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_CREATE_RESOURCE_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_DIST_STATE_CHANGE_APPROV; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_DIST_STATE_CHANGE_REQUEST; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_IMPORT_RESOURCE_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.INVARIANT_UUID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.MODIFIER_UID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.PREV_RESOURCE_STATE; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.PREV_RESOURCE_VERSION; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.REQUEST_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.RESOURCE_NAME; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.RESOURCE_TYPE_VFC; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.SERVICE_INSTANCE_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.STATUS_OK; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.TOSCA_NODE_TYPE; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.init; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.modifier; - -import java.util.EnumMap; - import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; @@ -56,12 +20,18 @@ import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum; import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent; import org.openecomp.sdc.be.resources.data.auditing.ResourceAdminEvent; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; -import org.openecomp.sdc.be.resources.data.auditing.model.ResourceAuditData; -import org.openecomp.sdc.common.api.ConfigurationSource; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceCommonInfo; +import org.openecomp.sdc.be.resources.data.auditing.model.ResourceVersionInfo; import org.openecomp.sdc.common.api.Constants; -import org.openecomp.sdc.common.datastructure.AuditingFieldsKeysEnum; import org.openecomp.sdc.common.util.ThreadLocalsHolder; +import static org.assertj.core.api.Assertions.assertThat; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.ArgumentMatchers.eq; +import static org.mockito.Mockito.verify; +import static org.mockito.Mockito.when; +import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.*; + @RunWith(MockitoJUnitRunner.class) public class AuditResourceAdminEventFuncTest { private AuditingManager auditingManager; @@ -69,14 +39,12 @@ public class AuditResourceAdminEventFuncTest { @Mock private static AuditCassandraDao cassandraDao; @Mock - private static ConfigurationSource configurationSource; - @Mock private static AuditingDao auditingDao; @Mock private static Configuration.ElasticSearchConfig esConfig; @Captor - private ArgumentCaptor<AuditingGenericEvent> eventCaptor; + private ArgumentCaptor<ResourceAdminEvent> eventCaptor; @Before public void setUp() { @@ -86,7 +54,7 @@ public class AuditResourceAdminEventFuncTest { } @Test - public void testNewCheckInResourceAdminEvent() { + public void testCheckInResourceAdminEvent() { Resource resource = new Resource(); resource.setName(RESOURCE_NAME); resource.setUUID(SERVICE_INSTANCE_ID); @@ -102,19 +70,20 @@ public class AuditResourceAdminEventFuncTest { .requestId(REQUEST_ID) .serviceInstanceId(SERVICE_INSTANCE_ID) .build(), - ResourceAuditData.newBuilder() + new ResourceCommonInfo(RESOURCE_NAME, RESOURCE_TYPE_VFC), + ResourceVersionInfo.newBuilder() .artifactUuid(ARTIFACT_UUID) .state(PREV_RESOURCE_STATE) .version(PREV_RESOURCE_VERSION) .distributionStatus(DPREV_STATUS) .build(), - ResourceAuditData.newBuilder() + ResourceVersionInfo.newBuilder() .artifactUuid(ARTIFACT_UUID) .state(CURRENT_STATE) .version(CURRENT_VERSION) .distributionStatus(DCURR_STATUS) .build(), - RESOURCE_TYPE_VFC, RESOURCE_NAME, INVARIANT_UUID, modifier, + INVARIANT_UUID, modifier, ARTIFACT_DATA, COMMENT, DIST_ID); when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.CHECKIN_RESOURCE.getAuditingEsType()))) @@ -126,52 +95,7 @@ public class AuditResourceAdminEventFuncTest { } @Test - public void testOldCheckInResourceAdminEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.CHECKIN_RESOURCE.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.CHECKIN_RESOURCE))).isEqualTo(EXPECTED_CHECK_IN_RESOURCE_LOG_STR + " "); - verifyResourceAdminEvent(AuditingActionEnum.CHECKIN_RESOURCE.getName()); - - } - - private EnumMap<AuditingFieldsKeysEnum, Object> fillMap(AuditingActionEnum action) { - EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, action.getName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_NAME, modifier.getFirstName() + " " + modifier.getLastName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_UID, modifier.getUserId()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION); - - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_TYPE, RESOURCE_TYPE_VFC); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_PREV_VERSION, PREV_RESOURCE_VERSION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_PREV_STATE, PREV_RESOURCE_STATE); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_NAME, RESOURCE_NAME); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_CURR_VERSION, CURRENT_VERSION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_CURR_STATE, CURRENT_STATE); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_SERVICE_INSTANCE_ID, SERVICE_INSTANCE_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_INVARIANT_UUID, INVARIANT_UUID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ARTIFACT_DATA, ARTIFACT_DATA); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_CURR_ARTIFACT_UUID, ARTIFACT_UUID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_PREV_ARTIFACT_UUID, ARTIFACT_UUID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_ID, DIST_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_COMMENT, COMMENT); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_DCURR_STATUS, DCURR_STATUS); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_DPREV_STATUS, DPREV_STATUS); - - if (action == AuditingActionEnum.IMPORT_RESOURCE) { - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_TOSCA_NODE_TYPE, TOSCA_NODE_TYPE); - } - else { - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_TOSCA_NODE_TYPE, Constants.EMPTY_STRING); - } - - return auditingFields; - } - - @Test - public void testNewCreateResourceAdminEvent() { + public void testCreateResourceAdminEvent() { AuditEventFactory factory = new AuditCreateUpdateResourceAdminEventFactory( AuditingActionEnum.CREATE_RESOURCE, @@ -181,19 +105,20 @@ public class AuditResourceAdminEventFuncTest { .requestId(REQUEST_ID) .serviceInstanceId(SERVICE_INSTANCE_ID) .build(), - ResourceAuditData.newBuilder() + new ResourceCommonInfo(RESOURCE_NAME, RESOURCE_TYPE_VFC), + ResourceVersionInfo.newBuilder() .artifactUuid(ARTIFACT_UUID) .state(PREV_RESOURCE_STATE) .version(PREV_RESOURCE_VERSION) .distributionStatus(DPREV_STATUS) .build(), - ResourceAuditData.newBuilder() + ResourceVersionInfo.newBuilder() .artifactUuid(ARTIFACT_UUID) .state(CURRENT_STATE) .version(CURRENT_VERSION) .distributionStatus(DCURR_STATUS) .build(), - RESOURCE_TYPE_VFC, RESOURCE_NAME, INVARIANT_UUID, modifier, + INVARIANT_UUID, modifier, ARTIFACT_DATA, COMMENT, DIST_ID, Constants.EMPTY_STRING); when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.CREATE_RESOURCE.getAuditingEsType()))) @@ -205,18 +130,7 @@ public class AuditResourceAdminEventFuncTest { } @Test - public void testOldCreateResourceAdminEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.CREATE_RESOURCE.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.CREATE_RESOURCE))).isEqualTo(EXPECTED_CREATE_RESOURCE_LOG_STR + " "); - verifyResourceAdminEvent(AuditingActionEnum.CREATE_RESOURCE.getName()); - - } - - @Test - public void testNewImportResourceAdminEvent() { + public void testImportResourceAdminEvent() { Resource resource = new Resource(); resource.setName(RESOURCE_NAME); @@ -233,19 +147,20 @@ public class AuditResourceAdminEventFuncTest { .requestId(REQUEST_ID) .serviceInstanceId(SERVICE_INSTANCE_ID) .build(), - ResourceAuditData.newBuilder() + new ResourceCommonInfo(RESOURCE_NAME, RESOURCE_TYPE_VFC), + ResourceVersionInfo.newBuilder() .artifactUuid(ARTIFACT_UUID) .state(PREV_RESOURCE_STATE) .version(PREV_RESOURCE_VERSION) .distributionStatus(DPREV_STATUS) .build(), - ResourceAuditData.newBuilder() + ResourceVersionInfo.newBuilder() .artifactUuid(ARTIFACT_UUID) .state(CURRENT_STATE) .version(CURRENT_VERSION) .distributionStatus(DCURR_STATUS) .build(), - RESOURCE_TYPE_VFC, RESOURCE_NAME, INVARIANT_UUID, modifier, + INVARIANT_UUID, modifier, ARTIFACT_DATA, COMMENT, DIST_ID, TOSCA_NODE_TYPE); when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.IMPORT_RESOURCE.getAuditingEsType()))) @@ -257,18 +172,7 @@ public class AuditResourceAdminEventFuncTest { } @Test - public void testOldImportResourceAdminEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.IMPORT_RESOURCE.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.IMPORT_RESOURCE))).isEqualTo(EXPECTED_IMPORT_RESOURCE_LOG_STR + " "); - verifyResourceAdminEvent(AuditingActionEnum.IMPORT_RESOURCE.getName()); - - } - - @Test - public void testNewArtifactUploadResourceAdminEvent() { + public void testArtifactUploadResourceAdminEvent() { AuditEventFactory factory = new AuditArtifactResourceAdminEventFactory( AuditingActionEnum.ARTIFACT_UPLOAD, @@ -278,19 +182,20 @@ public class AuditResourceAdminEventFuncTest { .requestId(REQUEST_ID) .serviceInstanceId(SERVICE_INSTANCE_ID) .build(), - ResourceAuditData.newBuilder() + new ResourceCommonInfo(RESOURCE_NAME, RESOURCE_TYPE_VFC), + ResourceVersionInfo.newBuilder() .artifactUuid(ARTIFACT_UUID) .state(PREV_RESOURCE_STATE) .version(PREV_RESOURCE_VERSION) .distributionStatus(DPREV_STATUS) .build(), - ResourceAuditData.newBuilder() + ResourceVersionInfo.newBuilder() .artifactUuid(ARTIFACT_UUID) .state(CURRENT_STATE) .version(CURRENT_VERSION) .distributionStatus(DCURR_STATUS) .build(), - RESOURCE_TYPE_VFC, RESOURCE_NAME, INVARIANT_UUID, modifier, + INVARIANT_UUID, modifier, ARTIFACT_DATA, COMMENT, DIST_ID); when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.ARTIFACT_UPLOAD.getAuditingEsType()))) @@ -302,18 +207,7 @@ public class AuditResourceAdminEventFuncTest { } @Test - public void testOldArtifactUploadResourceAdminEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.IMPORT_RESOURCE.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.ARTIFACT_UPLOAD))).isEqualTo(EXPECTED_ARTIFACT_UPLOAD_LOG_STR + " "); - verifyResourceAdminEvent(AuditingActionEnum.ARTIFACT_UPLOAD.getName()); - - } - - @Test - public void testNewDistStateChangeRequestResourceAdminEvent() { + public void testDistStateChangeRequestResourceAdminEvent() { AuditEventFactory factory = new AuditDistStateChangeRequestResourceAdminEventFactory( CommonAuditData.newBuilder() @@ -322,19 +216,20 @@ public class AuditResourceAdminEventFuncTest { .requestId(REQUEST_ID) .serviceInstanceId(SERVICE_INSTANCE_ID) .build(), - ResourceAuditData.newBuilder() + new ResourceCommonInfo(RESOURCE_NAME, RESOURCE_TYPE_VFC), + ResourceVersionInfo.newBuilder() .artifactUuid(ARTIFACT_UUID) .state(PREV_RESOURCE_STATE) .version(PREV_RESOURCE_VERSION) .distributionStatus(DPREV_STATUS) .build(), - ResourceAuditData.newBuilder() + ResourceVersionInfo.newBuilder() .artifactUuid(ARTIFACT_UUID) .state(CURRENT_STATE) .version(CURRENT_VERSION) .distributionStatus(DCURR_STATUS) .build(), - RESOURCE_TYPE_VFC, RESOURCE_NAME, INVARIANT_UUID, modifier, + INVARIANT_UUID, modifier, ARTIFACT_DATA, COMMENT, DIST_ID); when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.DISTRIBUTION_STATE_CHANGE_REQUEST.getAuditingEsType()))) @@ -346,17 +241,7 @@ public class AuditResourceAdminEventFuncTest { } @Test - public void testOldDistStateChangeRequestResourceAdminEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.DISTRIBUTION_STATE_CHANGE_REQUEST.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.DISTRIBUTION_STATE_CHANGE_REQUEST))).isEqualTo(EXPECTED_DIST_STATE_CHANGE_REQUEST); - verifyResourceAdminEvent(AuditingActionEnum.DISTRIBUTION_STATE_CHANGE_REQUEST.getName()); - } - - @Test - public void testNewDistStateChangeApprovResourceAdminEvent() { + public void testDistStateChangeApprovResourceAdminEvent() { AuditEventFactory factory = new AuditDistStateChangeResourceAdminEventFactory( AuditingActionEnum.DISTRIBUTION_STATE_CHANGE_APPROV, @@ -366,19 +251,20 @@ public class AuditResourceAdminEventFuncTest { .requestId(REQUEST_ID) .serviceInstanceId(SERVICE_INSTANCE_ID) .build(), - ResourceAuditData.newBuilder() + new ResourceCommonInfo(RESOURCE_NAME, RESOURCE_TYPE_VFC), + ResourceVersionInfo.newBuilder() .artifactUuid(ARTIFACT_UUID) .state(PREV_RESOURCE_STATE) .version(PREV_RESOURCE_VERSION) .distributionStatus(DPREV_STATUS) .build(), - ResourceAuditData.newBuilder() + ResourceVersionInfo.newBuilder() .artifactUuid(ARTIFACT_UUID) .state(CURRENT_STATE) .version(CURRENT_VERSION) .distributionStatus(DCURR_STATUS) .build(), - RESOURCE_TYPE_VFC, RESOURCE_NAME, INVARIANT_UUID, modifier, + INVARIANT_UUID, modifier, ARTIFACT_DATA, COMMENT, DIST_ID); when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.DISTRIBUTION_STATE_CHANGE_REQUEST.getAuditingEsType()))) @@ -389,20 +275,9 @@ public class AuditResourceAdminEventFuncTest { verifyResourceAdminEvent(AuditingActionEnum.DISTRIBUTION_STATE_CHANGE_APPROV.getName()); } - @Test - public void testOldDistStateChangeApprovResourceAdminEvent() { - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.DISTRIBUTION_STATE_CHANGE_APPROV.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(fillMap(AuditingActionEnum.DISTRIBUTION_STATE_CHANGE_APPROV))).isEqualTo(EXPECTED_DIST_STATE_CHANGE_APPROV); - verifyResourceAdminEvent(AuditingActionEnum.DISTRIBUTION_STATE_CHANGE_APPROV.getName()); - } - - private void verifyResourceAdminEvent(String action) { verify(cassandraDao).saveRecord(eventCaptor.capture()); - ResourceAdminEvent storedEvent = (ResourceAdminEvent) eventCaptor.getValue(); + ResourceAdminEvent storedEvent = eventCaptor.getValue(); assertThat(storedEvent.getModifier()).isEqualTo(MODIFIER_UID); assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION); assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID); diff --git a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/usersadmin/AuditUserEventFuncTest.java b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/usersadmin/AuditUserEventFuncTest.java index f454a4b164..9652e884b4 100644 --- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/usersadmin/AuditUserEventFuncTest.java +++ b/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/usersadmin/AuditUserEventFuncTest.java @@ -1,39 +1,5 @@ package org.openecomp.sdc.be.auditing.impl.usersadmin; -import static org.assertj.core.api.Assertions.assertThat; -import static org.mockito.ArgumentMatchers.any; -import static org.mockito.ArgumentMatchers.anyMap; -import static org.mockito.ArgumentMatchers.eq; -import static org.mockito.Mockito.verify; -import static org.mockito.Mockito.when; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.AUTH_STATUS; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.AUTH_URL; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DESCRIPTION; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DESIGNER_USER_ROLE; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_ADD_USER_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_AUTH_REQUEST_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_DELETE_USER_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_GET_USER_LIST_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_UPDATE_USER_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_USER_ACCESS_LOG_STR; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.MODIFIER_UID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.REALM; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.REQUEST_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.STATUS_CREATED; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.STATUS_OK; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.TESTER_USER_ROLE; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.UPDATED_USER_EXTENDED_NAME; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_DETAILS; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_EMAIL; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_EXTENDED_NAME; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_ID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_UID; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.init; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.modifier; -import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.user; - -import java.util.EnumMap; - import org.junit.Before; import org.junit.Test; import org.junit.runner.RunWith; @@ -50,14 +16,16 @@ import org.openecomp.sdc.be.dao.cassandra.AuditCassandraDao; import org.openecomp.sdc.be.dao.cassandra.CassandraOperationStatus; import org.openecomp.sdc.be.dao.impl.AuditingDao; import org.openecomp.sdc.be.model.User; -import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum; -import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent; -import org.openecomp.sdc.be.resources.data.auditing.AuthEvent; -import org.openecomp.sdc.be.resources.data.auditing.GetUsersListEvent; -import org.openecomp.sdc.be.resources.data.auditing.UserAccessEvent; -import org.openecomp.sdc.be.resources.data.auditing.UserAdminEvent; +import org.openecomp.sdc.be.resources.data.auditing.*; import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData; -import org.openecomp.sdc.common.datastructure.AuditingFieldsKeysEnum; + +import static org.assertj.core.api.Assertions.assertThat; +import static org.mockito.ArgumentMatchers.any; +import static org.mockito.ArgumentMatchers.eq; +import static org.mockito.Mockito.verify; +import static org.mockito.Mockito.when; +import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.*; + @RunWith(MockitoJUnitRunner.class) public class AuditUserEventFuncTest { @@ -79,7 +47,7 @@ public class AuditUserEventFuncTest { } @Test - public void testNewUserAccessEvent() { + public void testUserAccessEvent() { AuditEventFactory factory = new AuditUserAccessEventFactory( CommonAuditData.newBuilder() .description(DESCRIPTION) @@ -96,24 +64,7 @@ public class AuditUserEventFuncTest { } @Test - public void testOldUserAccessEvent() { - EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, AuditingActionEnum.USER_ACCESS.getName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_USER_UID, user.getFirstName() + " " + user.getLastName() + '(' + user.getUserId() + ')'); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_REQUEST_ID, REQUEST_ID); - - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.USER_ACCESS.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(auditingFields)).isEqualTo(EXPECTED_USER_ACCESS_LOG_STR); - verifyUserAccessEvent(); - } - - @Test - public void testNewUserAdminEventForAddUser() { + public void testUserAdminEventForAddUser() { user.setRole(DESIGNER_USER_ROLE); user.setEmail(USER_EMAIL); @@ -135,30 +86,7 @@ public class AuditUserEventFuncTest { } @Test - public void testOldUserAdminEventForAddUser() { - user.setRole(TESTER_USER_ROLE); - user.setEmail(USER_EMAIL); - - EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, AuditingActionEnum.ADD_USER.getName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_NAME, modifier.getFirstName() + " " + modifier.getLastName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_UID, modifier.getUserId()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_CREATED); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_REQUEST_ID, REQUEST_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_USER_BEFORE, null); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_USER_AFTER, USER_EXTENDED_NAME); - - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.ADD_USER.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(auditingFields)).isEqualTo(EXPECTED_ADD_USER_LOG_STR); - verifyUserEvent(AuditingActionEnum.ADD_USER.getName()); - } - - @Test - public void testNewUserAdminEventForUpdateUser() { + public void testUserAdminEventForUpdateUser() { user.setRole(DESIGNER_USER_ROLE); user.setEmail(USER_EMAIL); @@ -183,33 +111,7 @@ public class AuditUserEventFuncTest { } @Test - public void testOldUserAdminEventForUpdateUser() { - user.setRole(DESIGNER_USER_ROLE); - user.setEmail(USER_EMAIL); - - User updated = new User(user); - updated.setRole(TESTER_USER_ROLE); - - EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, AuditingActionEnum.UPDATE_USER.getName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_NAME, modifier.getFirstName() + " " + modifier.getLastName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_UID, modifier.getUserId()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_REQUEST_ID, REQUEST_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_USER_BEFORE, USER_EXTENDED_NAME); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_USER_AFTER, UPDATED_USER_EXTENDED_NAME); - - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.UPDATE_USER.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(auditingFields)).isEqualTo(EXPECTED_UPDATE_USER_LOG_STR); - verifyUserEvent(AuditingActionEnum.UPDATE_USER.getName()); - } - - @Test - public void testNewUserAdminEventForDeleteUser() { + public void testUserAdminEventForDeleteUser() { user.setRole(DESIGNER_USER_ROLE); user.setEmail(USER_EMAIL); @@ -231,30 +133,7 @@ public class AuditUserEventFuncTest { } @Test - public void testOldUserAdminEventForDeleteUser() { - user.setRole(TESTER_USER_ROLE); - user.setEmail(USER_EMAIL); - - EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, AuditingActionEnum.DELETE_USER.getName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_NAME, modifier.getFirstName() + " " + modifier.getLastName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_UID, modifier.getUserId()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_REQUEST_ID, REQUEST_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_USER_BEFORE, USER_EXTENDED_NAME); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_USER_AFTER, null); - - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.DELETE_USER.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(auditingFields)).isEqualTo(EXPECTED_DELETE_USER_LOG_STR); - verifyUserEvent(AuditingActionEnum.DELETE_USER.getName()); - } - - @Test - public void testNewGetUserListEvent() { + public void testGetUserListEvent() { AuditEventFactory factory = new AuditGetUsersListEventFactory( CommonAuditData.newBuilder() @@ -273,26 +152,7 @@ public class AuditUserEventFuncTest { } @Test - public void testOldGetUserListEvent() { - EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, AuditingActionEnum.GET_USERS_LIST.getName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_NAME, user.getFirstName() + " " + user.getLastName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_UID, user.getUserId()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_REQUEST_ID, REQUEST_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_USER_DETAILS, USER_DETAILS); - - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.GET_USERS_LIST.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(auditingFields)).isEqualTo(EXPECTED_GET_USER_LIST_LOG_STR); - verifyGetUserListEvent(); - } - - @Test - public void testNewAuthRequestEvent() { + public void testAuthRequestEvent() { AuditEventFactory factory = new AuditAuthRequestEventFactory( CommonAuditData.newBuilder() @@ -310,27 +170,6 @@ public class AuditUserEventFuncTest { verifyAuthRequestEvent(); } - @Test - public void testOldAuthRequestEvent() { - EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, AuditingActionEnum.AUTH_REQUEST.getName()); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_AUTH_USER, USER_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_REQUEST_ID, REQUEST_ID); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_AUTH_REALM, REALM); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_AUTH_URL, AUTH_URL); - auditingFields.put(AuditingFieldsKeysEnum.AUDIT_AUTH_STATUS, AUTH_STATUS); - - when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.AUTH_REQUEST.getAuditingEsType()))) - .thenReturn(ActionStatus.OK); - when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK); - - assertThat(auditingManager.auditEvent(auditingFields)).isEqualTo(EXPECTED_AUTH_REQUEST_LOG_STR); - verifyAuthRequestEvent(); - } - - private void verifyUserEvent(String action) { verify(cassandraDao).saveRecord(eventCaptor.capture()); UserAdminEvent storedEvent = (UserAdminEvent) eventCaptor.getValue(); |