diff options
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.java | 170 |
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); - } -} |