2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2020 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
21 package org.openecomp.sdc.be.catalog.impl;
23 import static org.assertj.core.api.Assertions.assertThat;
24 import static org.assertj.core.api.Assertions.fail;
25 import static org.mockito.Mockito.mock;
26 import static org.openecomp.sdc.be.catalog.enums.ResultStatusEnum.FAIL;
27 import static org.openecomp.sdc.be.catalog.enums.ResultStatusEnum.SERVICE_DISABLED;
29 import com.fasterxml.jackson.core.JsonProcessingException;
30 import com.fasterxml.jackson.databind.ObjectMapper;
31 import java.util.ArrayList;
32 import java.util.List;
33 import org.junit.jupiter.api.BeforeEach;
34 import org.junit.jupiter.api.Test;
35 import org.openecomp.sdc.be.catalog.api.IComponentMessage;
36 import org.openecomp.sdc.be.catalog.api.IStatus;
37 import org.openecomp.sdc.be.catalog.enums.ChangeTypeEnum;
38 import org.openecomp.sdc.be.components.distribution.engine.DmaapClientFactory;
39 import org.openecomp.sdc.be.config.Configuration;
40 import org.openecomp.sdc.be.config.ConfigurationManager;
41 import org.openecomp.sdc.be.config.DmaapProducerConfiguration;
42 import org.openecomp.sdc.be.datatypes.enums.ComponentTypeEnum;
43 import org.openecomp.sdc.be.datatypes.enums.ResourceTypeEnum;
44 import org.openecomp.sdc.be.model.CatalogUpdateTimestamp;
45 import org.openecomp.sdc.be.model.LifecycleStateEnum;
46 import org.openecomp.sdc.be.model.Resource;
47 import org.openecomp.sdc.be.model.category.CategoryDefinition;
48 import org.openecomp.sdc.be.model.category.SubCategoryDefinition;
49 import org.openecomp.sdc.common.api.ConfigurationSource;
50 import org.openecomp.sdc.common.impl.ExternalConfiguration;
51 import org.openecomp.sdc.common.impl.FSConfigurationSource;
52 import org.slf4j.Logger;
53 import org.slf4j.LoggerFactory;
54 import org.springframework.test.context.ContextConfiguration;
56 @ContextConfiguration("classpath:application-context-test.xml")
57 class DmaapProducerTest {
59 private static final Logger LOG = LoggerFactory.getLogger(DmaapProducerTest.class);
61 private ConfigurationManager configurationManager;
62 private DmaapProducer dmaapProducer;
63 private DmaapClientFactory dmaapClientFactory;
67 final ConfigurationSource configurationSource = new FSConfigurationSource(
68 ExternalConfiguration.getChangeListener(),
69 "src/test/resources/config/catalog-be");
70 configurationManager = new ConfigurationManager(configurationSource);
71 final Configuration configuration = new Configuration();
72 final DmaapProducerConfiguration dmaapProducerConfiguration = new DmaapProducerConfiguration();
73 dmaapProducerConfiguration.setActive(true);
74 configuration.setJanusGraphInMemoryGraph(true);
75 configurationManager.setConfiguration(configuration);
76 configurationManager.getConfiguration().setDmaapProducerConfiguration(dmaapProducerConfiguration);
77 ExternalConfiguration.setAppName("catalog-be");
78 dmaapProducer = new DmaapProducer(mock(DmaapClientFactory.class), mock(DmaapProducerHealth.class));
82 void pushComponentMessageTest() {
83 boolean oldVal = isActive();
84 final Resource resource = new Resource();
85 resource.setUniqueId("mockUniqueId");
86 resource.setUUID("mockNameUUID");
87 resource.setResourceType(ResourceTypeEnum.VF);
88 resource.setComponentType(ComponentTypeEnum.RESOURCE);
89 resource.setName("mockName");
90 resource.setSystemName("mockSystemName");
91 resource.setVersion("1.0");
92 resource.setLifecycleState(LifecycleStateEnum.NOT_CERTIFIED_CHECKOUT);
93 resource.setLastUpdateDate(System.currentTimeMillis());
94 resource.setInvariantUUID("mockInvariantUUID");
95 resource.setDescription("mockDescription");
96 resource.setHighestVersion(true);
97 resource.setArchived(false);
99 final List<CategoryDefinition> categories = new ArrayList<>();
100 final CategoryDefinition categoryDefinition = new CategoryDefinition();
101 categoryDefinition.setName("mockCategory");
102 categoryDefinition.setNormalizedName("mockCategory");
103 categoryDefinition.setUniqueId("uniqueId");
104 final SubCategoryDefinition subCategoryDefinition = new SubCategoryDefinition();
105 subCategoryDefinition.setName("mockSubCategory");
106 subCategoryDefinition.setNormalizedName("mockSubCategory");
107 subCategoryDefinition.setUniqueId("mockSubCategoryUniqueId");
108 categoryDefinition.addSubCategory(subCategoryDefinition);
109 categories.add(categoryDefinition);
110 resource.setCategories(categories);
112 final IComponentMessage message = new ComponentMessage(resource, ChangeTypeEnum.LIFECYCLE,
113 new CatalogUpdateTimestamp(123, 1234));
115 LOG.info("[DmaapProducer] pushing message =>{}", new ObjectMapper().writeValueAsString(message));
116 //push message by configuration => will send the message if configuration enables
117 //will not test network connectivity to avoid build server automation fail
119 IStatus status = dmaapProducer.pushMessage(message);
120 assertThat(status.getResultStatus()).isEqualTo(SERVICE_DISABLED);
122 dmaapProducer.shutdown();
123 status = dmaapProducer.pushMessage(message);
124 assertThat(status.getResultStatus()).isEqualTo(FAIL);
125 } catch (final JsonProcessingException e) {
126 fail("'JsonProcessingException' detected!", e);
127 } catch (final Exception e) {
128 fail("Unknown exception detected", e);
130 configurationManager.getConfiguration().getDmaapProducerConfiguration().setActive(oldVal);
134 private boolean isActive() {
135 return configurationManager.getConfiguration().getDmaapProducerConfiguration().getActive();
138 private void toggleInactive() {
139 configurationManager.getConfiguration().getDmaapProducerConfiguration().setActive(false);
142 private void toggleActive() {
143 configurationManager.getConfiguration().getDmaapProducerConfiguration().setActive(true);