package org.openecomp.sdc.be.components.impl;
-import static org.assertj.core.api.Assertions.assertThat;
-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.DESC_ERROR;
-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.DPREV_STATUS;
-import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.INVARIANT_UUID;
-import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.MODIFIER_FIRST_NAME;
-import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.MODIFIER_ID;
-import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.MODIFIER_LAST_NAME;
-import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.MODIFIER_UID;
-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.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.SERVICE_INSTANCE_ID;
-import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.STATUS_500;
-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.TESTER_USER_ROLE;
-import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.TOSCA_NODE_TYPE;
-import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.UPDATED_USER_EXTENDED_NAME;
-import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_EMAIL;
-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 org.junit.Before;
import org.junit.BeforeClass;
import org.junit.Test;
import org.mockito.Mock;
import org.mockito.junit.MockitoJUnitRunner;
import org.openecomp.sdc.be.auditing.api.AuditEventFactory;
-import org.openecomp.sdc.be.auditing.impl.AuditBaseEventFactory;
import org.openecomp.sdc.be.auditing.impl.AuditingManager;
+import org.openecomp.sdc.be.auditing.impl.externalapi.AuditChangeLifecycleExternalApiEventFactory;
+import org.openecomp.sdc.be.auditing.impl.externalapi.AuditCreateResourceExternalApiEventFactory;
import org.openecomp.sdc.be.datatypes.enums.ComponentTypeEnum;
-import org.openecomp.sdc.be.datatypes.enums.ResourceTypeEnum;
import org.openecomp.sdc.be.impl.ComponentsUtils;
-import org.openecomp.sdc.be.model.Component;
-import org.openecomp.sdc.be.model.LifecycleStateEnum;
-import org.openecomp.sdc.be.model.Resource;
-import org.openecomp.sdc.be.model.Service;
-import org.openecomp.sdc.be.model.User;
-import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum;
-import org.openecomp.sdc.be.resources.data.auditing.DistributionDownloadEvent;
-import org.openecomp.sdc.be.resources.data.auditing.EcompOperationalEnvironmentEvent;
-import org.openecomp.sdc.be.resources.data.auditing.ResourceAdminEvent;
-import org.openecomp.sdc.be.resources.data.auditing.UserAdminEvent;
+import org.openecomp.sdc.be.model.*;
+import org.openecomp.sdc.be.resources.data.auditing.*;
import org.openecomp.sdc.be.resources.data.auditing.model.DistributionData;
-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;
+import org.openecomp.sdc.common.api.Constants;
import org.openecomp.sdc.common.util.ThreadLocalsHolder;
import org.openecomp.sdc.exception.ResponseFormat;
+import javax.servlet.http.HttpServletRequest;
+
+import static org.assertj.core.api.Assertions.assertThat;
+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 ComponentsUtilsTest {
@Mock
private AuditingManager manager;
-
@Mock
private ResponseFormat responseFormat;
+ @Mock
+ private HttpServletRequest request;
+
+ private ArtifactDefinition artifactDefinition = null;
@Captor
- private ArgumentCaptor<AuditBaseEventFactory> factoryCaptor;
+ private ArgumentCaptor<AuditEventFactory> factoryCaptor;
@InjectMocks
private static ComponentsUtils utils;
service.setUUID(SERVICE_INSTANCE_ID);
service.setInvariantUUID(INVARIANT_UUID);
- utils.auditComponent(responseFormat, modifier, service, AuditingActionEnum.ARTIFACT_DELETE, service.getComponentType(),
- ResourceAuditData.newBuilder()
+ utils.auditComponent(responseFormat, modifier, service, AuditingActionEnum.ARTIFACT_DELETE,
+ new ResourceCommonInfo(RESOURCE_NAME, service.getComponentType().getValue()),
+ ResourceVersionInfo.newBuilder()
.state(PREV_RESOURCE_STATE)
.version(PREV_RESOURCE_VERSION)
.artifactUuid(ARTIFACT_UUID)
.distributionStatus(DPREV_STATUS).build(),
- ResourceAuditData.newBuilder()
+ ResourceVersionInfo.newBuilder()
.state(CURRENT_STATE)
.version(CURRENT_VERSION)
.artifactUuid(ARTIFACT_UUID)
.distributionStatus(DCURR_STATUS).build(),
- RESOURCE_NAME, COMMENT, ARTIFACT_DATA, DIST_ID);
+ COMMENT, artifactDefinition, DIST_ID);
verifyResourceAdminEvent(AuditingActionEnum.ARTIFACT_DELETE.getName(), STATUS_OK, DESCRIPTION, service.getComponentType().getValue(),
- false, true, true, true, true, true);
+ false, true, true, false, true, true, true);
}
@Test
service.setInvariantUUID(INVARIANT_UUID);
service.setState(LifecycleStateEnum.CERTIFIED);
service.setVersion(CURRENT_VERSION);
- utils.auditComponent(responseFormat, modifier, service, AuditingActionEnum.CREATE_RESOURCE, service.getComponentType(),
- ResourceAuditData.newBuilder()
+ utils.auditComponent(responseFormat, modifier, service, AuditingActionEnum.CREATE_RESOURCE,
+ new ResourceCommonInfo(RESOURCE_NAME, service.getComponentType().getValue()),
+ ResourceVersionInfo.newBuilder()
.state(PREV_RESOURCE_STATE)
.version(PREV_RESOURCE_VERSION)
.artifactUuid(ARTIFACT_UUID)
.distributionStatus(DPREV_STATUS).build(),
- ResourceAuditData.newBuilder()
+ ResourceVersionInfo.newBuilder()
.artifactUuid(ARTIFACT_UUID)
.distributionStatus(DCURR_STATUS).build(),
- RESOURCE_NAME, COMMENT, ARTIFACT_DATA, DIST_ID);
+ COMMENT, artifactDefinition, DIST_ID);
verifyResourceAdminEvent(AuditingActionEnum.CREATE_RESOURCE.getName(), STATUS_OK, DESCRIPTION, service.getComponentType().getValue(),
- false, true, true, true, true, true);
+ false, true, true, false, true, true, true);
}
service.setState(LifecycleStateEnum.CERTIFIED);
service.setName(RESOURCE_NAME);
service.setVersion(CURRENT_VERSION);
- utils.auditComponent(responseFormat, modifier, service, AuditingActionEnum.DISTRIBUTION_STATE_CHANGE_REQUEST, service.getComponentType(),
- ResourceAuditData.newBuilder()
+ utils.auditComponent(responseFormat, modifier, service, AuditingActionEnum.DISTRIBUTION_STATE_CHANGE_REQUEST,
+ new ResourceCommonInfo(service.getComponentType().getValue()),
+ ResourceVersionInfo.newBuilder()
.state(PREV_RESOURCE_STATE)
.version(PREV_RESOURCE_VERSION)
.artifactUuid(ARTIFACT_UUID)
.distributionStatus(DPREV_STATUS).build(),
- ResourceAuditData.newBuilder()
+ ResourceVersionInfo.newBuilder()
.artifactUuid(ARTIFACT_UUID)
.distributionStatus(DCURR_STATUS).build());
verifyResourceAdminEvent(AuditingActionEnum.DISTRIBUTION_STATE_CHANGE_REQUEST.getName(),
STATUS_OK, DESCRIPTION, service.getComponentType().getValue(),
- false, true, true, false, false, true);
+ false, true, true, false, false, true, false);
}
@Test
service.setVersion(CURRENT_VERSION);
utils.auditComponent(responseFormat, modifier, service, AuditingActionEnum.CERTIFICATION_REQUEST_RESOURCE,
- ComponentTypeEnum.SERVICE,
- ResourceAuditData.newBuilder().state(PREV_RESOURCE_STATE).version(PREV_RESOURCE_VERSION).artifactUuid(ARTIFACT_UUID).build());
+ new ResourceCommonInfo(ComponentTypeEnum.SERVICE.getValue()),
+ ResourceVersionInfo.newBuilder().state(PREV_RESOURCE_STATE).version(PREV_RESOURCE_VERSION).artifactUuid(ARTIFACT_UUID).build());
verifyResourceAdminEvent(AuditingActionEnum.CERTIFICATION_REQUEST_RESOURCE.getName(), STATUS_500, DESC_ERROR,
- service.getComponentType().getValue(), false, true, false, false, false, false);
+ service.getComponentType().getValue(), false, true, false, false, false, false, false);
}
@Test
when(responseFormat.getFormattedMessage()).thenReturn(DESC_ERROR);
utils.auditComponent(responseFormat, modifier, AuditingActionEnum.START_CERTIFICATION_RESOURCE,
- RESOURCE_NAME, ComponentTypeEnum.SERVICE, COMMENT);
+ new ResourceCommonInfo(RESOURCE_NAME, ComponentTypeEnum.SERVICE.getValue()), COMMENT);
verifyResourceAdminEvent(AuditingActionEnum.START_CERTIFICATION_RESOURCE.getName(), STATUS_500, DESC_ERROR, service.getComponentType().getValue(),
- true, false, false, false, true, false);
+ true, false, false, false, true, false, false);
}
@Test
service.setVersion(CURRENT_VERSION);
utils.auditComponentAdmin(responseFormat, modifier, service, AuditingActionEnum.CREATE_RESOURCE, service.getComponentType());
verifyResourceAdminEvent(AuditingActionEnum.CREATE_RESOURCE.getName(), STATUS_500, DESC_ERROR, service.getComponentType().getValue(),
- false, false, false, false, false, false);
+ false, false, false, false, false, false, false);
}
@Test
resource.setVersion(CURRENT_VERSION);
resource.setToscaResourceName(TOSCA_NODE_TYPE);
utils.auditResource(responseFormat, modifier, resource, null, AuditingActionEnum.IMPORT_RESOURCE,
- ResourceAuditData.newBuilder()
+ ResourceVersionInfo.newBuilder()
.state(PREV_RESOURCE_STATE)
.version(PREV_RESOURCE_VERSION)
.artifactUuid(ARTIFACT_UUID)
.build(),
- ARTIFACT_UUID, ARTIFACT_DATA);
+ ARTIFACT_UUID, artifactDefinition);
verifyResourceAdminEvent(AuditingActionEnum.IMPORT_RESOURCE.getName(), STATUS_OK, DESCRIPTION, resource.getResourceType().name(),
- false, true, true, true, false, false);
+ false, true, true, false, false, false, false);
}
@Test
utils.auditResource(responseFormat, modifier, resource, AuditingActionEnum.UPDATE_RESOURCE_METADATA);
verifyResourceAdminEvent(AuditingActionEnum.UPDATE_RESOURCE_METADATA.getName(), STATUS_500, DESC_ERROR, resource.getResourceType().name(),
- false, false, false, false, false, false);
+ false, false, false, false, false, false, false);
}
@Test
utils.auditResource(responseFormat, modifier, RESOURCE_NAME, AuditingActionEnum.CHECKOUT_RESOURCE);
verifyResourceAdminEvent(AuditingActionEnum.CHECKOUT_RESOURCE.getName(), STATUS_500, DESC_ERROR, ComponentTypeEnum.RESOURCE.getValue(),
- true, false, false, false, false, false);
+ true, false, false, false, false, false, false);
}
@Test
private void verifyResourceAdminEvent(String action, String status, String desc, String resourceType, boolean isComponentNull,
boolean isPrevStateAndVersionSet, boolean isCurrFieldsProvided, boolean isArtDataProvided, boolean isCommentProvided,
- boolean isDistStatusProvided) {
+ boolean isDistStatusProvided, boolean isDidProvided) {
verify(manager).auditEvent(factoryCaptor.capture());
AuditEventFactory factory = factoryCaptor.getValue();
ResourceAdminEvent event = (ResourceAdminEvent)factory.getDbEvent();
}
if (isArtDataProvided) {
assertThat(event.getArtifactData()).isEqualTo(ARTIFACT_DATA);
- if (resourceType.equals(ResourceTypeEnum.VFC.name())) {
- assertThat(event.getDid()).isNull();
- }
- else {
- assertThat(event.getDid()).isEqualTo(DIST_ID);
- }
}
else {
- assertThat(event.getArtifactData()).isNull();
+ assertThat(event.getArtifactData()).isEmpty();
+ }
+ if (isDidProvided) {
+ assertThat(event.getDid()).isEqualTo(DIST_ID);
+ }
+ else {
assertThat(event.getDid()).isNull();
}
if (isCommentProvided) {
assertThat(event.getDprevStatus()).isNull();
}
}
+
+ @Test
+ public void auditChangeLifeCycleExternalApiEventWhenComponentAndResponseObjectAreNull() {
+ when(responseFormat.getStatus()).thenReturn(Integer.valueOf(STATUS_500));
+ when(responseFormat.getFormattedMessage()).thenReturn(DESC_ERROR);
+
+ utils.auditChangeLifecycleAction(responseFormat, ComponentTypeEnum.RESOURCE, REQUEST_ID,
+ null, null, new DistributionData(DIST_CONSUMER_ID, DIST_RESOURCE_URL), modifier);
+
+ verify(manager).auditEvent(factoryCaptor.capture());
+ AuditChangeLifecycleExternalApiEventFactory factory = (AuditChangeLifecycleExternalApiEventFactory)factoryCaptor.getValue();
+
+ ExternalApiEvent event = (ExternalApiEvent)factory.getDbEvent();
+ assertThat(event.getAction()).isEqualTo(AuditingActionEnum.CHANGE_LIFECYCLE_BY_API.getName());
+ verifyCommonDataForExternalApiEvent(event, false);
+ verifyPreviousResourceVersionInfoForExternalApiEvent(event, true);
+ verifyCurrentResourceVersionInfoForExternalApiEvent(event, true);
+ verifyDistributionDataForExternalApiEvent(event);
+ assertThat(event.getModifier()).isEqualTo(MODIFIER_UID);
+ assertThat(event.getInvariantUuid()).isEmpty();
+ assertThat(event.getResourceName()).isNull();
+ assertThat(event.getResourceType()).isEqualTo(ComponentTypeEnum.RESOURCE.getValue());
+ }
+
+ @Test
+ public void auditChangeLifeCycleExternalApiEventWhenComponentIsNullAndResponseObjectIsNotNull() {
+ when(responseFormat.getStatus()).thenReturn(Integer.valueOf(STATUS_OK));
+ when(responseFormat.getFormattedMessage()).thenReturn(DESCRIPTION);
+ Component responseObject = new Resource();
+ responseObject.setVersion(CURRENT_VERSION);
+ responseObject.setState(LifecycleStateEnum.CERTIFIED);
+ responseObject.setInvariantUUID(INVARIANT_UUID);
+ responseObject.setUUID(SERVICE_INSTANCE_ID);
+
+ utils.auditChangeLifecycleAction(responseFormat, ComponentTypeEnum.RESOURCE, REQUEST_ID,
+ null, responseObject, new DistributionData(DIST_CONSUMER_ID, DIST_RESOURCE_URL), modifier);
+
+ verify(manager).auditEvent(factoryCaptor.capture());
+ AuditChangeLifecycleExternalApiEventFactory factory = (AuditChangeLifecycleExternalApiEventFactory)factoryCaptor.getValue();
+
+ ExternalApiEvent event = (ExternalApiEvent)factory.getDbEvent();
+ assertThat(event.getAction()).isEqualTo(AuditingActionEnum.CHANGE_LIFECYCLE_BY_API.getName());
+ verifyCommonDataForExternalApiEvent(event, true);
+ verifyPreviousResourceVersionInfoForExternalApiEvent(event, true);
+ verifyCurrentResourceVersionInfoForExternalApiEvent(event, false);
+ verifyDistributionDataForExternalApiEvent(event);
+ assertThat(event.getModifier()).isEqualTo(MODIFIER_UID);
+ assertThat(event.getInvariantUuid()).isEqualTo(INVARIANT_UUID);
+ assertThat(event.getResourceName()).isNull();
+ assertThat(event.getResourceType()).isEqualTo(ComponentTypeEnum.RESOURCE.getValue());
+ }
+
+ @Test
+ public void auditChangeLifeCycleExternalApiEventWhenComponentIsNotNullAndResponseObjectIsNull() {
+ when(responseFormat.getStatus()).thenReturn(Integer.valueOf(STATUS_500));
+ when(responseFormat.getFormattedMessage()).thenReturn(DESC_ERROR);
+ Component component = new Resource();
+ component.setVersion(PREV_RESOURCE_VERSION);
+ component.setState(LifecycleStateEnum.READY_FOR_CERTIFICATION);
+ component.setInvariantUUID(INVARIANT_UUID);
+ component.setName(RESOURCE_NAME);
+
+ utils.auditChangeLifecycleAction(responseFormat, ComponentTypeEnum.RESOURCE, REQUEST_ID,
+ component, null, new DistributionData(DIST_CONSUMER_ID, DIST_RESOURCE_URL), modifier);
+
+ verify(manager).auditEvent(factoryCaptor.capture());
+ AuditChangeLifecycleExternalApiEventFactory factory = (AuditChangeLifecycleExternalApiEventFactory)factoryCaptor.getValue();
+
+ ExternalApiEvent event = (ExternalApiEvent)factory.getDbEvent();
+ assertThat(event.getAction()).isEqualTo(AuditingActionEnum.CHANGE_LIFECYCLE_BY_API.getName());
+
+ verifyCommonDataForExternalApiEvent(event, false);
+ verifyPreviousResourceVersionInfoForExternalApiEvent(event, false);
+ verifyDistributionDataForExternalApiEvent(event);
+ assertThat(event.getModifier()).isEqualTo(MODIFIER_UID);
+ assertThat(event.getInvariantUuid()).isEqualTo(INVARIANT_UUID);
+ assertThat(event.getResourceName()).isEqualTo(RESOURCE_NAME);
+ assertThat(event.getResourceType()).isEqualTo(ComponentTypeEnum.RESOURCE.getValue());
+ }
+
+ @Test
+ public void auditChangeLifeCycleExternalApiEventWhenComponentAndResponseObjectAreNotNull() {
+ when(responseFormat.getStatus()).thenReturn(Integer.valueOf(STATUS_OK));
+ when(responseFormat.getFormattedMessage()).thenReturn(DESCRIPTION);
+ Component responseObject = new Resource();
+ responseObject.setVersion(CURRENT_VERSION);
+ responseObject.setState(LifecycleStateEnum.CERTIFIED);
+ responseObject.setInvariantUUID(INVARIANT_UUID);
+ responseObject.setUUID(SERVICE_INSTANCE_ID);
+
+ Component component = new Resource();
+ component.setVersion(PREV_RESOURCE_VERSION);
+ component.setState(LifecycleStateEnum.READY_FOR_CERTIFICATION);
+ component.setInvariantUUID(INVARIANT_UUID);
+ component.setUUID(SERVICE_INSTANCE_ID);
+ component.setName(RESOURCE_NAME);
+
+ utils.auditChangeLifecycleAction(responseFormat, ComponentTypeEnum.RESOURCE, REQUEST_ID,
+ null, responseObject, new DistributionData(DIST_CONSUMER_ID, DIST_RESOURCE_URL), modifier);
+
+ verify(manager).auditEvent(factoryCaptor.capture());
+ AuditChangeLifecycleExternalApiEventFactory factory = (AuditChangeLifecycleExternalApiEventFactory)factoryCaptor.getValue();
+
+ ExternalApiEvent event = (ExternalApiEvent)factory.getDbEvent();
+ assertThat(event.getAction()).isEqualTo(AuditingActionEnum.CHANGE_LIFECYCLE_BY_API.getName());
+ verifyCommonDataForExternalApiEvent(event, true);
+ verifyPreviousResourceVersionInfoForExternalApiEvent(event, true);
+ verifyCurrentResourceVersionInfoForExternalApiEvent(event, false);
+ verifyDistributionDataForExternalApiEvent(event);
+ assertThat(event.getModifier()).isEqualTo(MODIFIER_UID);
+ assertThat(event.getInvariantUuid()).isEqualTo(INVARIANT_UUID);
+ assertThat(event.getResourceName()).isNull();
+ assertThat(event.getResourceType()).isEqualTo(ComponentTypeEnum.RESOURCE.getValue());
+
+ }
+
+ private void verifyDistributionDataForExternalApiEvent(ExternalApiEvent event) {
+ assertThat(event.getConsumerId()).isEqualTo(DIST_CONSUMER_ID);
+ assertThat(event.getResourceURL()).isEqualTo(DIST_RESOURCE_URL);
+ }
+
+ private void verifyDistributionDataNotSetForExternalApiEvent(ExternalApiEvent event) {
+ assertThat(event.getConsumerId()).isNull();
+ assertThat(event.getResourceURL()).isNull();
+ }
+
+ private void verifyCommonDataForExternalApiEvent(ExternalApiEvent event, boolean isSucceeded) {
+ if (isSucceeded) {
+ assertThat(event.getDesc()).isEqualTo(DESCRIPTION);
+ assertThat(event.getStatus()).isEqualTo(STATUS_OK);
+ assertThat(event.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID);
+ }
+ else {
+ assertThat(event.getDesc()).isEqualTo(DESC_ERROR);
+ assertThat(event.getStatus()).isEqualTo(STATUS_500);
+ assertThat(event.getServiceInstanceId()).isNullOrEmpty();
+ }
+ assertThat(event.getRequestId()).isEqualTo(REQUEST_ID);
+ }
+
+ private void verifyCurrentResourceVersionInfoForExternalApiEvent(ExternalApiEvent event, boolean isNull) {
+ assertThat(event.getCurrArtifactUuid()).isNull();
+ if (isNull) {
+ assertThat(event.getCurrState()).isNull();
+ assertThat(event.getCurrVersion()).isNull();
+ }
+ else {
+ assertThat(event.getCurrState()).isEqualTo(LifecycleStateEnum.CERTIFIED.name());
+ assertThat(event.getCurrVersion()).isEqualTo(CURRENT_VERSION);
+ }
+ }
+
+ private void verifyPreviousResourceVersionInfoForExternalApiEvent(ExternalApiEvent event, boolean isNull) {
+ assertThat(event.getPrevArtifactUuid()).isNull();
+ if (isNull) {
+ assertThat(event.getPrevState()).isNull();
+ assertThat(event.getPrevVersion()).isNull();
+ }
+ else {
+ assertThat(event.getPrevState()).isEqualTo(LifecycleStateEnum.READY_FOR_CERTIFICATION.name());
+ assertThat(event.getPrevVersion()).isEqualTo(PREV_RESOURCE_VERSION);
+ }
+ }
+
+ @Test
+ public void auditExternalCreateResourceEventWhenResourceObjectIsNull() {
+ when(responseFormat.getStatus()).thenReturn(Integer.valueOf(STATUS_500));
+ when(responseFormat.getFormattedMessage()).thenReturn(DESC_ERROR);
+
+ when(request.getHeader(Constants.USER_ID_HEADER)).thenReturn(USER_ID);
+ when(request.getHeader(Constants.X_ECOMP_INSTANCE_ID_HEADER)).thenReturn(DIST_CONSUMER_ID);
+ when(request.getHeader(Constants.X_ECOMP_REQUEST_ID_HEADER)).thenReturn(REQUEST_ID);
+ when(request.getRequestURI()).thenReturn(DIST_RESOURCE_URL);
+
+ utils.auditCreateResourceExternalApi(responseFormat, new ResourceCommonInfo(RESOURCE_NAME, ComponentTypeEnum.RESOURCE.getValue()),
+ request, null);
+
+ verify(manager).auditEvent(factoryCaptor.capture());
+ AuditCreateResourceExternalApiEventFactory factory = (AuditCreateResourceExternalApiEventFactory)factoryCaptor.getValue();
+
+ ExternalApiEvent event = (ExternalApiEvent)factory.getDbEvent();
+ verifyCommonDataForExternalApiEvent(event, false);
+ verifyPreviousResourceVersionInfoForExternalApiEvent(event, true);
+ verifyCurrentResourceVersionInfoForExternalApiEvent(event, true);
+ verifyDistributionDataForExternalApiEvent(event);
+ assertThat(event.getModifier()).isEqualTo("(" + USER_ID + ")");
+ assertThat(event.getInvariantUuid()).isNull();
+ assertThat(event.getResourceName()).isEqualTo(RESOURCE_NAME);
+ assertThat(event.getResourceType()).isEqualTo(ComponentTypeEnum.RESOURCE.getValue());
+ }
+
+ @Test
+ public void auditExternalCreateResourceEventWhenResourceObjectIsNullAndRequestDataIsNotProvided() {
+ when(responseFormat.getStatus()).thenReturn(Integer.valueOf(STATUS_500));
+ when(responseFormat.getFormattedMessage()).thenReturn(DESC_ERROR);
+
+ when(request.getHeader(Constants.USER_ID_HEADER)).thenReturn(null);
+ when(request.getHeader(Constants.X_ECOMP_INSTANCE_ID_HEADER)).thenReturn(null);
+ when(request.getHeader(Constants.X_ECOMP_REQUEST_ID_HEADER)).thenReturn(REQUEST_ID);
+ when(request.getRequestURI()).thenReturn(null);
+
+ utils.auditCreateResourceExternalApi(responseFormat, new ResourceCommonInfo(ComponentTypeEnum.RESOURCE.getValue()),
+ request, null);
+
+ verify(manager).auditEvent(factoryCaptor.capture());
+ AuditCreateResourceExternalApiEventFactory factory = (AuditCreateResourceExternalApiEventFactory)factoryCaptor.getValue();
+
+ ExternalApiEvent event = (ExternalApiEvent)factory.getDbEvent();
+ verifyCommonDataForExternalApiEvent(event, false);
+ verifyPreviousResourceVersionInfoForExternalApiEvent(event, true);
+ verifyCurrentResourceVersionInfoForExternalApiEvent(event, true);
+ verifyDistributionDataNotSetForExternalApiEvent(event);
+ assertThat(event.getModifier()).isEmpty();
+ assertThat(event.getInvariantUuid()).isNull();
+ assertThat(event.getResourceName()).isNull();
+ assertThat(event.getResourceType()).isEqualTo(ComponentTypeEnum.RESOURCE.getValue());
+ }
+
+ @Test
+ public void auditExternalCreateResourceEventWhenResourceObjectAndRequestDataProvided() {
+ when(responseFormat.getStatus()).thenReturn(Integer.valueOf(STATUS_OK));
+ when(responseFormat.getFormattedMessage()).thenReturn(DESCRIPTION);
+
+ when(request.getHeader(Constants.USER_ID_HEADER)).thenReturn(USER_ID);
+ when(request.getHeader(Constants.X_ECOMP_INSTANCE_ID_HEADER)).thenReturn(DIST_CONSUMER_ID);
+ when(request.getHeader(Constants.X_ECOMP_REQUEST_ID_HEADER)).thenReturn(REQUEST_ID);
+ when(request.getRequestURI()).thenReturn(DIST_RESOURCE_URL);
+
+ Resource resource = new Resource();
+ resource.setName(RESOURCE_NAME);
+ resource.setInvariantUUID(INVARIANT_UUID);
+ resource.setUUID(SERVICE_INSTANCE_ID);
+
+ utils.auditCreateResourceExternalApi(responseFormat, new ResourceCommonInfo(ComponentTypeEnum.RESOURCE.getValue()),
+ request, resource);
+
+ verify(manager).auditEvent(factoryCaptor.capture());
+ AuditCreateResourceExternalApiEventFactory factory = (AuditCreateResourceExternalApiEventFactory)factoryCaptor.getValue();
+
+ ExternalApiEvent event = (ExternalApiEvent)factory.getDbEvent();
+ verifyCommonDataForExternalApiEvent(event, true);
+ verifyPreviousResourceVersionInfoForExternalApiEvent(event, true);
+ verifyDistributionDataForExternalApiEvent(event);
+ assertThat(event.getCurrArtifactUuid()).isNull();
+ assertThat(event.getCurrState()).isEqualTo(LifecycleStateEnum.NOT_CERTIFIED_CHECKOUT.name());
+ assertThat(event.getCurrVersion()).isEqualTo(ImportUtils.Constants.FIRST_NON_CERTIFIED_VERSION);
+ assertThat(event.getModifier()).isEqualTo("(" + USER_ID + ")");
+ assertThat(event.getInvariantUuid()).isEqualTo(INVARIANT_UUID);
+ assertThat(event.getResourceName()).isEqualTo(RESOURCE_NAME);
+ assertThat(event.getResourceType()).isEqualTo(ComponentTypeEnum.RESOURCE.getValue());
+ }
+
+ @Test
+ public void checkIfAuditEventIsExternal() {
+ assertThat(utils.isExternalApiEvent(AuditingActionEnum.ARTIFACT_UPLOAD_BY_API)).isTrue();
+ assertThat(utils.isExternalApiEvent(AuditingActionEnum.ARTIFACT_UPLOAD)).isFalse();
+ }
+
}
Code Review / sdc.git / blobdiff