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 com.fasterxml.jackson.core.JsonProcessingException;
24 import com.fasterxml.jackson.databind.ObjectMapper;
25 import org.junit.Test;
26 import org.junit.runner.RunWith;
27 import org.openecomp.sdc.be.catalog.api.IComponentMessage;
28 import org.openecomp.sdc.be.catalog.api.IStatus;
29 import org.openecomp.sdc.be.catalog.enums.ChangeTypeEnum;
30 import org.openecomp.sdc.be.config.ConfigurationManager;
31 import org.openecomp.sdc.be.datatypes.enums.ComponentTypeEnum;
32 import org.openecomp.sdc.be.datatypes.enums.ResourceTypeEnum;
33 import org.openecomp.sdc.be.model.CatalogUpdateTimestamp;
34 import org.openecomp.sdc.be.model.LifecycleStateEnum;
35 import org.openecomp.sdc.be.model.Resource;
36 import org.openecomp.sdc.be.model.category.CategoryDefinition;
37 import org.openecomp.sdc.be.model.category.SubCategoryDefinition;
38 import org.slf4j.Logger;
39 import org.slf4j.LoggerFactory;
40 import org.springframework.beans.factory.annotation.Autowired;
41 import org.springframework.test.context.ContextConfiguration;
42 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
44 import java.util.ArrayList;
45 import java.util.List;
47 import static org.assertj.core.api.Assertions.assertThat;
48 import static org.openecomp.sdc.be.catalog.enums.ResultStatusEnum.FAIL;
49 import static org.openecomp.sdc.be.catalog.enums.ResultStatusEnum.SERVICE_DISABLED;
50 import static org.openecomp.sdc.be.config.ConfigurationManager.getConfigurationManager;
52 @RunWith(SpringJUnit4ClassRunner.class)
53 @ContextConfiguration("classpath:application-context-test.xml")
54 public class DmaapProducerTest {
55 private static final Logger LOG = LoggerFactory.getLogger(DmaapProducer.class);
58 ConfigurationManager configurationManager;
61 private DmaapProducer dmaapProducer;
64 //actually sends the message
68 public void pushComponentMessageTest() {
69 boolean oldVal = isActive();
71 Resource resource = new Resource();
72 resource.setUniqueId("mockUniqueId");
73 resource.setUUID("mockNameUUID");
74 resource.setResourceType(ResourceTypeEnum.VF);
75 resource.setComponentType(ComponentTypeEnum.RESOURCE);
76 resource.setName("mockName");
77 resource.setSystemName("mockSystemName");
78 resource.setVersion("1.0");
79 resource.setLifecycleState(LifecycleStateEnum.NOT_CERTIFIED_CHECKOUT);
80 resource.setLastUpdateDate(System.currentTimeMillis());
81 resource.setInvariantUUID("mockInvariantUUID");
82 resource.setDescription("mockDescription");
83 resource.setHighestVersion(true);
84 resource.setArchived(false);
86 List<CategoryDefinition> categories = new ArrayList<>();
87 CategoryDefinition cat = new CategoryDefinition();
88 cat.setName("mockCategory");
89 cat.setNormalizedName("mockCategory");
90 cat.setUniqueId("uniqueId");
91 SubCategoryDefinition subcat = new SubCategoryDefinition();
92 subcat.setName("mockSubCategory");
93 subcat.setNormalizedName("mockSubCategory");
94 subcat.setUniqueId("mockSubCategoryUniqueId");
95 cat.addSubCategory(subcat);
97 resource.setCategories(categories);
99 IComponentMessage message = new ComponentMessage(resource, ChangeTypeEnum.LIFECYCLE, new CatalogUpdateTimestamp(123, 1234));
100 ObjectMapper mapper = new ObjectMapper();
102 String jsonInString = mapper.writeValueAsString(message);
103 LOG.info("[DmaapProducer] pushing message =>{}",jsonInString);
104 //push msg by configuration => will send the message if configuration enables
105 //IStatus status = dmaapProducer.pushComponentMessage(message);
106 //will not test network connectivity to avoid build server automation fail
109 IStatus status = dmaapProducer.pushMessage(message);
110 assertThat(status.getResultStatus()).isEqualTo(SERVICE_DISABLED);
113 dmaapProducer.shutdown();
114 status = dmaapProducer.pushMessage(message);
115 assertThat(status.getResultStatus()).isEqualTo(FAIL);
117 } catch (JsonProcessingException e) {
118 // TODO Auto-generated catch block
120 } catch (Exception e) {
121 // TODO Auto-generated catch block
124 getConfigurationManager().getConfiguration().getDmaapProducerConfiguration().setActive(oldVal);
128 private boolean isActive(){
129 return getConfigurationManager().getConfiguration().getDmaapProducerConfiguration().getActive();
132 private void toggleInactive(){
133 getConfigurationManager().getConfiguration().getDmaapProducerConfiguration().setActive(false);
136 private void toggleActive(){
137 getConfigurationManager().getConfiguration().getDmaapProducerConfiguration().setActive(true);