catalog-be/src/test/java/org/openecomp/sdc/be/auditing/impl/distribution/AuditDistrEventFuncTest.java

   1 package org.openecomp.sdc.be.auditing.impl.distribution;
   2
   3 import static org.assertj.core.api.Assertions.assertThat;
   4 import static org.mockito.ArgumentMatchers.any;
   5 import static org.mockito.ArgumentMatchers.anyMap;
   6 import static org.mockito.ArgumentMatchers.eq;
   7 import static org.mockito.Mockito.verify;
   8 import static org.mockito.Mockito.when;
   9 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.CURRENT_STATE;
  10 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.CURRENT_VERSION;
  11 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DESCRIPTION;
  12 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DIST_CONSUMER_ID;
  13 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DIST_ID;
  14 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DIST_RESOURCE_URL;
  15 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.DIST_STATUS_TIME;
  16 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_DISTRIB_DEPLOY_LOG_STR;
  17 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_DISTRIB_NOTIFICATION_LOG_STR;
  18 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_DIST_DOWNLOAD_LOG_STR;
  19 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_DIST_STATUS_LOG_STR;
  20 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.EXPECTED_GET_UEB_CLUSTER_LOG_STR;
  21 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.OP_ENV_ID;
  22 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.REQUEST_ID;
  23 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.RESOURCE_NAME;
  24 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.RESOURCE_TYPE;
  25 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.SERVICE_INSTANCE_ID;
  26 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.STATUS_OK;
  27 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.TENANT_CONTEXT;
  28 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.TOPIC_NAME;
  29 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_FIRST_NAME;
  30 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_ID;
  31 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_LAST_NAME;
  32 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.USER_UID;
  33 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.VNF_WORKLOAD_CONTEXT;
  34 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.init;
  35 import static org.openecomp.sdc.be.auditing.impl.AuditTestUtils.user;
  36
  37 import java.util.EnumMap;
  38
  39 import org.junit.Before;
  40 import org.junit.Test;
  41 import org.junit.runner.RunWith;
  42 import org.mockito.ArgumentCaptor;
  43 import org.mockito.Captor;
  44 import org.mockito.Mock;
  45 import org.mockito.junit.MockitoJUnitRunner;
  46 import org.openecomp.sdc.be.auditing.api.AuditEventFactory;
  47 import org.openecomp.sdc.be.auditing.impl.AuditingManager;
  48 import org.openecomp.sdc.be.config.Configuration;
  49 import org.openecomp.sdc.be.dao.api.ActionStatus;
  50 import org.openecomp.sdc.be.dao.cassandra.AuditCassandraDao;
  51 import org.openecomp.sdc.be.dao.cassandra.CassandraOperationStatus;
  52 import org.openecomp.sdc.be.dao.impl.AuditingDao;
  53 import org.openecomp.sdc.be.resources.data.auditing.AuditingActionEnum;
  54 import org.openecomp.sdc.be.resources.data.auditing.AuditingGenericEvent;
  55 import org.openecomp.sdc.be.resources.data.auditing.AuditingGetUebClusterEvent;
  56 import org.openecomp.sdc.be.resources.data.auditing.DistributionDeployEvent;
  57 import org.openecomp.sdc.be.resources.data.auditing.DistributionDownloadEvent;
  58 import org.openecomp.sdc.be.resources.data.auditing.DistributionNotificationEvent;
  59 import org.openecomp.sdc.be.resources.data.auditing.DistributionStatusEvent;
  60 import org.openecomp.sdc.be.resources.data.auditing.model.CommonAuditData;
  61 import org.openecomp.sdc.be.resources.data.auditing.model.DistributionData;
  62 import org.openecomp.sdc.be.resources.data.auditing.model.OperationalEnvAuditData;
  63 import org.openecomp.sdc.common.datastructure.AuditingFieldsKeysEnum;
  64 import org.openecomp.sdc.common.util.ThreadLocalsHolder;
  65
  66 @RunWith(MockitoJUnitRunner.class)
  67 public class AuditDistrEventFuncTest {
  68
  69     private AuditingManager auditingManager;
  70
  71     @Mock
  72     private static AuditCassandraDao cassandraDao;
  73     @Mock
  74     private static AuditingDao auditingDao;
  75     @Mock
  76     private static Configuration.ElasticSearchConfig esConfig;
  77
  78     @Captor
  79     private ArgumentCaptor<AuditingGenericEvent> eventCaptor;
  80
  81     @Before
  82     public void setUp() {
  83         init(esConfig);
  84         auditingManager = new AuditingManager(auditingDao, cassandraDao);
  85         ThreadLocalsHolder.setUuid(REQUEST_ID);
  86     }
  87
  88     @Test
  89     public void testNewNotifyEvent() {
  90         AuditEventFactory factory = new AuditDistribNotificationEventFactory(
  91                 CommonAuditData.newBuilder()
  92                         .description(DESCRIPTION)
  93                         .status(STATUS_OK)
  94                         .requestId(REQUEST_ID)
  95                         .serviceInstanceId(SERVICE_INSTANCE_ID)
  96                         .build(),
  97                 CURRENT_STATE, CURRENT_VERSION, DIST_ID, user,
  98                 RESOURCE_NAME, RESOURCE_TYPE, TOPIC_NAME,
  99                 new OperationalEnvAuditData(OP_ENV_ID, VNF_WORKLOAD_CONTEXT, TENANT_CONTEXT));
 100
 101         when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.DISTRIBUTION_NOTIFY.getAuditingEsType())))
 102                 .thenReturn(ActionStatus.OK);
 103         when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK);
 104
 105         assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DISTRIB_NOTIFICATION_LOG_STR);
 106         verifyNotifyEvent();
 107     }
 108
 109     @Test
 110     public void testOldNotifyEvent() {
 111         when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.DISTRIBUTION_NOTIFY.getAuditingEsType())))
 112                 .thenReturn(ActionStatus.OK);
 113         when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK);
 114
 115         assertThat(auditingManager.auditEvent(fillNotifyMap())).isEqualTo(EXPECTED_DISTRIB_NOTIFICATION_LOG_STR);
 116         verifyNotifyEvent();
 117
 118     }
 119
 120     @Test
 121     public void testNewStatusEvent() {
 122         AuditEventFactory factory = new AuditDistribStatusEventFactory(
 123                 CommonAuditData.newBuilder()
 124                         .description(DESCRIPTION)
 125                         .status(STATUS_OK)
 126                         .requestId(REQUEST_ID)
 127                         .serviceInstanceId(SERVICE_INSTANCE_ID)
 128                         .build(),
 129                 DIST_ID, DIST_CONSUMER_ID, TOPIC_NAME, DIST_RESOURCE_URL, DIST_STATUS_TIME);
 130
 131         when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.DISTRIBUTION_STATUS.getAuditingEsType())))
 132                 .thenReturn(ActionStatus.OK);
 133         when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK);
 134
 135         assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DIST_STATUS_LOG_STR);
 136         verifyStatusEvent();
 137     }
 138
 139     @Test
 140     public void testOldStatusEvent() {
 141         when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.DISTRIBUTION_STATUS.getAuditingEsType())))
 142                 .thenReturn(ActionStatus.OK);
 143         when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK);
 144
 145         assertThat(auditingManager.auditEvent(fillStatusMap())).isEqualTo(EXPECTED_DIST_STATUS_LOG_STR);
 146         verifyStatusEvent();
 147     }
 148
 149     @Test
 150     public void testNewDownloadEvent() {
 151         AuditEventFactory factory = new AuditDistribDownloadEventFactory(
 152                 CommonAuditData.newBuilder()
 153                         .description(DESCRIPTION)
 154                         .status(STATUS_OK)
 155                         .requestId(REQUEST_ID)
 156                         .serviceInstanceId(SERVICE_INSTANCE_ID)
 157                         .build(),
 158                 new DistributionData(DIST_CONSUMER_ID, DIST_RESOURCE_URL));
 159
 160         when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.DISTRIBUTION_ARTIFACT_DOWNLOAD.getAuditingEsType())))
 161                 .thenReturn(ActionStatus.OK);
 162         when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK);
 163
 164         assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DIST_DOWNLOAD_LOG_STR);
 165         verifyDownloadsEvent();
 166     }
 167
 168     @Test
 169     public void testOldDownloadEvent() {
 170         when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.DISTRIBUTION_ARTIFACT_DOWNLOAD.getAuditingEsType())))
 171                 .thenReturn(ActionStatus.OK);
 172         when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK);
 173
 174         assertThat(auditingManager.auditEvent(fillDownloadMap())).isEqualTo(EXPECTED_DIST_DOWNLOAD_LOG_STR);
 175         verifyDownloadsEvent();
 176     }
 177
 178     @Test
 179     public void testNewDeployEvent() {
 180         AuditEventFactory factory = new AuditDistribDeployEventFactory(
 181                 CommonAuditData.newBuilder()
 182                         .description(DESCRIPTION)
 183                         .status(STATUS_OK)
 184                         .requestId(REQUEST_ID)
 185                         .serviceInstanceId(SERVICE_INSTANCE_ID)
 186                         .build(),
 187                 CURRENT_VERSION,
 188                 DIST_ID, user, RESOURCE_NAME, RESOURCE_TYPE);
 189
 190         when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.DISTRIBUTION_DEPLOY.getAuditingEsType())))
 191                 .thenReturn(ActionStatus.OK);
 192         when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK);
 193
 194         assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_DISTRIB_DEPLOY_LOG_STR);
 195         verifyDeployEvent();
 196     }
 197
 198     @Test
 199     public void testOldDeployEvent() {
 200         when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.DISTRIBUTION_DEPLOY.getAuditingEsType())))
 201                 .thenReturn(ActionStatus.OK);
 202         when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK);
 203
 204         assertThat(auditingManager.auditEvent(fillDeployMap())).isEqualTo(EXPECTED_DISTRIB_DEPLOY_LOG_STR);
 205         verifyDeployEvent();
 206     }
 207
 208     @Test
 209     public void testNewGetUebClusterEvent() {
 210         AuditEventFactory factory = new AuditGetUebClusterEventFactory(
 211                 CommonAuditData.newBuilder()
 212                         .description(DESCRIPTION)
 213                         .status(STATUS_OK)
 214                         .requestId(REQUEST_ID)
 215                         .serviceInstanceId(SERVICE_INSTANCE_ID)
 216                         .build(),
 217                 DIST_CONSUMER_ID);
 218
 219         when(auditingDao.addRecord(any(AuditingGenericEvent.class), eq(AuditingActionEnum.GET_UEB_CLUSTER.getAuditingEsType())))
 220                 .thenReturn(ActionStatus.OK);
 221         when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK);
 222
 223         assertThat(auditingManager.auditEvent(factory)).isEqualTo(EXPECTED_GET_UEB_CLUSTER_LOG_STR);
 224         verifyGetUebClusterEvent();
 225     }
 226
 227     @Test
 228     public void testOldGetUebClusterEvent() {
 229         when(auditingDao.addRecord(anyMap(), eq(AuditingActionEnum.GET_UEB_CLUSTER.getAuditingEsType())))
 230                 .thenReturn(ActionStatus.OK);
 231         when(cassandraDao.saveRecord(any(AuditingGenericEvent.class))).thenReturn(CassandraOperationStatus.OK);
 232
 233         assertThat(auditingManager.auditEvent(fillGetUebClusterMap())).isEqualTo(EXPECTED_GET_UEB_CLUSTER_LOG_STR);
 234         verifyGetUebClusterEvent();
 235     }
 236
 237     private void verifyNotifyEvent() {
 238         verify(cassandraDao).saveRecord(eventCaptor.capture());
 239         DistributionNotificationEvent storedEvent = (DistributionNotificationEvent) eventCaptor.getValue();
 240         assertThat(storedEvent.getCurrState()).isEqualTo(CURRENT_STATE);
 241         assertThat(storedEvent.getCurrVersion()).isEqualTo(CURRENT_VERSION);
 242         assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION);
 243         assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK);
 244         assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID);
 245         assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID);
 246         assertThat(storedEvent.getAction()).isEqualTo(AuditingActionEnum.DISTRIBUTION_NOTIFY.getName());
 247         assertThat(storedEvent.getDid()).isEqualTo(DIST_ID);
 248         assertThat(storedEvent.getModifier()).isEqualTo(USER_UID);
 249         assertThat(storedEvent.getResourceName()).isEqualTo(RESOURCE_NAME);
 250         assertThat(storedEvent.getResourceType()).isEqualTo(RESOURCE_TYPE);
 251         assertThat(storedEvent.getTopicName()).isEqualTo(TOPIC_NAME);
 252         assertThat(storedEvent.getVnfWorkloadContext()).isEqualTo(VNF_WORKLOAD_CONTEXT);
 253         assertThat(storedEvent.getEnvId()).isEqualTo(OP_ENV_ID);
 254         assertThat(storedEvent.getTenant()).isEqualTo(TENANT_CONTEXT);
 255     }
 256
 257     private void verifyStatusEvent() {
 258         verify(cassandraDao).saveRecord(eventCaptor.capture());
 259         DistributionStatusEvent storedEvent = (DistributionStatusEvent) eventCaptor.getValue();
 260         assertThat(storedEvent.getConsumerId()).isEqualTo(DIST_CONSUMER_ID);
 261         assertThat(storedEvent.getDid()).isEqualTo(DIST_ID);
 262         assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION);
 263         assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK);
 264         assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID);
 265         assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID);
 266         assertThat(storedEvent.getAction()).isEqualTo(AuditingActionEnum.DISTRIBUTION_STATUS.getName());
 267         assertThat(storedEvent.getStatusTime()).isEqualTo(DIST_STATUS_TIME);
 268         assertThat(storedEvent.getResoureURL()).isEqualTo(DIST_RESOURCE_URL);
 269         assertThat(storedEvent.getTopicName()).isEqualTo(TOPIC_NAME);
 270     }
 271
 272     private void verifyDownloadsEvent() {
 273         verify(cassandraDao).saveRecord(eventCaptor.capture());
 274         DistributionDownloadEvent storedEvent = (DistributionDownloadEvent) eventCaptor.getValue();
 275         assertThat(storedEvent.getConsumerId()).isEqualTo(DIST_CONSUMER_ID);
 276         assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION);
 277         assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK);
 278         assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID);
 279         assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID);
 280         assertThat(storedEvent.getResourceUrl()).isEqualTo(DIST_RESOURCE_URL);
 281     }
 282
 283     private void verifyDeployEvent() {
 284         verify(cassandraDao).saveRecord(eventCaptor.capture());
 285         DistributionDeployEvent storedEvent = (DistributionDeployEvent) eventCaptor.getValue();
 286         assertThat(storedEvent.getCurrVersion()).isEqualTo(CURRENT_VERSION);
 287         assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION);
 288         assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK);
 289         assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID);
 290         assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID);
 291         assertThat(storedEvent.getDid()).isEqualTo(DIST_ID);
 292         assertThat(storedEvent.getModifier()).isEqualTo(USER_UID);
 293         assertThat(storedEvent.getResourceName()).isEqualTo(RESOURCE_NAME);
 294         assertThat(storedEvent.getResourceType()).isEqualTo(RESOURCE_TYPE);
 295     }
 296
 297     private void verifyGetUebClusterEvent() {
 298         verify(cassandraDao).saveRecord(eventCaptor.capture());
 299         AuditingGetUebClusterEvent storedEvent = (AuditingGetUebClusterEvent) eventCaptor.getValue();
 300         assertThat(storedEvent.getConsumerId()).isEqualTo(DIST_CONSUMER_ID);
 301         assertThat(storedEvent.getDesc()).isEqualTo(DESCRIPTION);
 302         assertThat(storedEvent.getStatus()).isEqualTo(STATUS_OK);
 303         assertThat(storedEvent.getRequestId()).isEqualTo(REQUEST_ID);
 304         assertThat(storedEvent.getServiceInstanceId()).isEqualTo(SERVICE_INSTANCE_ID);
 305      }
 306
 307     private EnumMap<AuditingFieldsKeysEnum, Object> fillNotifyMap() {
 308         EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class);
 309         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, AuditingActionEnum.DISTRIBUTION_NOTIFY.getName());
 310         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK);
 311         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION);
 312         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_ID, DIST_ID);
 313         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_TYPE, RESOURCE_TYPE);
 314         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_SERVICE_INSTANCE_ID, SERVICE_INSTANCE_ID);
 315         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_NAME, RESOURCE_NAME);
 316         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_CURR_STATE, CURRENT_STATE);
 317         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_CURR_VERSION, CURRENT_VERSION);
 318         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_UID, USER_ID);
 319         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_NAME, USER_FIRST_NAME + " " + USER_LAST_NAME);
 320         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_TOPIC_NAME, TOPIC_NAME);
 321         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_VNF_WORKLOAD_CONTEXT, VNF_WORKLOAD_CONTEXT);
 322         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_TENANT, TENANT_CONTEXT);
 323         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_ENVIRONMENT_ID, OP_ENV_ID);
 324
 325         return auditingFields;
 326     }
 327
 328     private EnumMap<AuditingFieldsKeysEnum, Object> fillStatusMap() {
 329        EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class);
 330         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, AuditingActionEnum.DISTRIBUTION_STATUS.getName());
 331         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_TOPIC_NAME, TOPIC_NAME);
 332         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK);
 333         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION);
 334         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_ID, DIST_ID);
 335         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_SERVICE_INSTANCE_ID, SERVICE_INSTANCE_ID);
 336         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_RESOURCE_URL, DIST_RESOURCE_URL);
 337         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_STATUS_TIME, DIST_STATUS_TIME);
 338         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_CONSUMER_ID, DIST_CONSUMER_ID);
 339
 340         return auditingFields;
 341     }
 342
 343     private EnumMap<AuditingFieldsKeysEnum, Object> fillDownloadMap() {
 344         EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class);
 345         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, AuditingActionEnum.DISTRIBUTION_ARTIFACT_DOWNLOAD.getName());
 346         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_CONSUMER_ID, DIST_CONSUMER_ID);
 347         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK);
 348         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION);
 349         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_REQUEST_ID, REQUEST_ID);
 350         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_RESOURCE_URL, DIST_RESOURCE_URL);
 351         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_SERVICE_INSTANCE_ID, SERVICE_INSTANCE_ID);
 352
 353         return auditingFields;
 354     }
 355
 356     private EnumMap<AuditingFieldsKeysEnum, Object> fillDeployMap() {
 357         EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class);
 358         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, AuditingActionEnum.DISTRIBUTION_DEPLOY.getName());
 359         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK);
 360         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DESC, DESCRIPTION);
 361         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_ID, DIST_ID);
 362         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_TYPE, RESOURCE_TYPE);
 363         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_SERVICE_INSTANCE_ID, SERVICE_INSTANCE_ID);
 364         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_NAME, RESOURCE_NAME);
 365         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_RESOURCE_CURR_VERSION, CURRENT_VERSION);
 366         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_UID, USER_ID);
 367         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_MODIFIER_NAME, USER_FIRST_NAME + " " + USER_LAST_NAME);
 368
 369         return auditingFields;
 370     }
 371
 372     private EnumMap<AuditingFieldsKeysEnum, Object> fillGetUebClusterMap() {
 373         EnumMap<AuditingFieldsKeysEnum, Object> auditingFields = new EnumMap<>(AuditingFieldsKeysEnum.class);
 374         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_ACTION, AuditingActionEnum.GET_UEB_CLUSTER.getName());
 375         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_CONSUMER_ID, DIST_CONSUMER_ID);
 376         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_STATUS, STATUS_OK);
 377         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_DISTRIBUTION_STATUS_DESC, DESCRIPTION);
 378         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_REQUEST_ID, REQUEST_ID);
 379         auditingFields.put(AuditingFieldsKeysEnum.AUDIT_SERVICE_INSTANCE_ID, SERVICE_INSTANCE_ID);
 380
 381         return auditingFields;
 382     }
 383
 384
 385
 386
 387 }