aboutsummaryrefslogtreecommitdiffstats
path: root/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditConsumerEventFuncTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditConsumerEventFuncTest.java')
-rw-r--r--catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditConsumerEventFuncTest.java170
1 files changed, 0 insertions, 170 deletions
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
deleted file mode 100644
index bfaccdd59e..0000000000
--- a/catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/AuditConsumerEventFuncTest.java
+++ /dev/null
@@ -1,170 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * SDC
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- * Modifications copyright (c) 2019 Nokia
- * ================================================================================
- */
-package org.openecomp.sdc.be.auditing.impl;
-
-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.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.model.ConsumerDefinition;
-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.util.ThreadLocalsHolder;
-import org.openecomp.sdc.test.utils.TestConfigurationProvider;
-
-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
- private static AuditCassandraDao cassandraDao;
- @Mock
- private static AuditingDao auditingDao;
- @Mock
- private static Configuration.ElasticSearchConfig esConfig;
-
- @Captor
- private ArgumentCaptor<ConsumerEvent> eventCaptor;
-
- @Before
- public void setUp() {
- init(esConfig);
- auditingManager = new AuditingManager(auditingDao, cassandraDao, new TestConfigurationProvider());
- consumer = new ConsumerDefinition();
- consumer.setConsumerName(USER_ID);
- ThreadLocalsHolder.setUuid(REQUEST_ID);
- }
-
- @Test
- public void testNewAddEcompUserCredEvent() {
- AuditEventFactory factory = new AuditConsumerEventFactory(
- AuditingActionEnum.ADD_ECOMP_USER_CREDENTIALS,
- CommonAuditData.newBuilder()
- .description(DESCRIPTION)
- .status(STATUS_OK)
- .requestId(REQUEST_ID)
- .serviceInstanceId(SERVICE_INSTANCE_ID)
- .build(),
- modifier, consumer);
-
- when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.ADD_ECOMP_USER_CREDENTIALS.getAuditingEsType())))
- .thenReturn(ActionStatus.OK);
- when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK);
-
- assertThat(auditingManager.auditEvent(factory)).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,
- CommonAuditData.newBuilder()
- .description(DESCRIPTION)
- .status(STATUS_OK)
- .requestId(REQUEST_ID)
- .serviceInstanceId(SERVICE_INSTANCE_ID)
- .build(),
- modifier, consumer);
-
- when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.GET_ECOMP_USER_CREDENTIALS.getAuditingEsType())))
- .thenReturn(ActionStatus.OK);
- when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK);
-
- assertThat(auditingManager.auditEvent(factory)).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);
- consumer.setConsumerPassword(CONSUMER_PASSWORD);
- assertEquals(CONSUMER_NAME + "," + CONSUMER_SALT + "," + CONSUMER_PASSWORD, AuditConsumerEventFactory.buildConsumerName(consumer));
- }
-
- @Test
- public void buildConsumerNameWhenSaltIsNull() {
- consumer.setConsumerName(CONSUMER_NAME);
- consumer.setConsumerPassword(CONSUMER_PASSWORD);
- assertEquals(CONSUMER_NAME + "," + CONSUMER_PASSWORD, AuditConsumerEventFactory.buildConsumerName(consumer));
- }
-
- @Test
- public void buildConsumerNameWhenNameIsNull() {
- consumer.setConsumerName(null);
- consumer.setConsumerSalt(CONSUMER_SALT);
- consumer.setConsumerPassword(CONSUMER_PASSWORD);
- assertEquals(CONSUMER_SALT + "," + CONSUMER_PASSWORD, AuditConsumerEventFactory.buildConsumerName(consumer));
- }
-
- @Test
- public void buildConsumerNameWhenNameAndPwAreNull() {
- consumer.setConsumerName(null);
- consumer.setConsumerSalt(CONSUMER_SALT);
- assertEquals(CONSUMER_SALT, AuditConsumerEventFactory.buildConsumerName(consumer));
- }
-
- @Test
- public void buildConsumerNameWhenNameAndSaltAreNull() {
- consumer.setConsumerName(null);
- consumer.setConsumerPassword(CONSUMER_PASSWORD);
- assertEquals(CONSUMER_PASSWORD, AuditConsumerEventFactory.buildConsumerName(consumer));
- }
-
- @Test
- public void buildConsumerNameWhenConsumerObjectIsNull() {
- assertEquals("", AuditConsumerEventFactory.buildConsumerName(null));
- }
-
- private void verifyConsumerEvent(String action) {
- verify(cassandraDao).saveRecord(eventCaptor.capture());
- ConsumerEvent 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.getServiceInstanceId()).isNull();
- assertThat(storedEvent.getAction()).isEqualTo(action);
- assertThat(storedEvent.getEcompUser()).isEqualTo(USER_ID);
- }
-}