DMaaP healthcheck cannot succeed when using Kafka, which in turn causes distribution to fail
Signed-off-by: Vasyl Razinkov <vasyl.razinkov@est.tech>
Change-Id: Ia6e1e35b9a2e819e38e62caeb797342948f34e92
Issue-ID: SDC-4542
*/
package org.openecomp.sdc.be.components.distribution.engine;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
-import java.util.concurrent.atomic.AtomicBoolean;
-import java.util.regex.Matcher;
-import java.util.regex.Pattern;
-import javax.annotation.PostConstruct;
-import javax.annotation.PreDestroy;
-import javax.annotation.Resource;
+import lombok.Setter;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
+import org.openecomp.sdc.be.components.kafka.KafkaHandler;
import org.openecomp.sdc.be.components.validation.ServiceDistributionValidation;
import org.openecomp.sdc.be.config.BeEcompErrorManager;
import org.openecomp.sdc.be.config.ConfigurationManager;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
+import javax.annotation.PostConstruct;
+import javax.annotation.PreDestroy;
+import javax.annotation.Resource;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
@Component("distributionEngine")
public class DistributionEngine implements IDistributionEngine {
private static final Logger logger = Logger.getLogger(DistributionEngine.class.getName());
private static final Pattern FQDN_PATTERN = Pattern.compile(
- "^([a-zA-Z0-9]|[a-zA-Z0-9][a-zA-Z0-9\\-]{0,61}[a-zA-Z0-9])(\\.([a-zA-Z0-9]|[a-zA-Z0-9][a-zA-Z0-9\\-]{0,61}[a-zA-Z0-9]))*(:[0-9]{2,4})*$",
- Pattern.CASE_INSENSITIVE);
+ "^([A-Z0-9]|[A-Z0-9][A-Z0-9\\-]{0,61}[A-Z0-9])(\\.([A-Z0-9]|[A-Z0-9][A-Z0-9\\-]{0,61}[A-Z0-9]))*(:[0-9]{2,4})*$",
+ Pattern.CASE_INSENSITIVE);
@Autowired
private EnvironmentsEngine environmentsEngine;
+ @Autowired
+ @Setter
+ private KafkaHandler kafkaHandler;
@Resource
private DistributionNotificationSender distributionNotificationSender;
@Resource
private void init() {
logger.trace("Enter init method of DistributionEngine");
DistributionEngineConfiguration distributionEngineConfiguration = ConfigurationManager.getConfigurationManager()
- .getDistributionEngineConfiguration();
+ .getDistributionEngineConfiguration();
boolean startDistributionEngine = distributionEngineConfiguration.isStartDistributionEngine();
logger.debug("Distribution engine activation parameter is {}", startDistributionEngine);
if (!startDistributionEngine) {
boolean isValidConfig = validateConfiguration(distributionEngineConfiguration);
if (!isValidConfig) {
BeEcompErrorManager.getInstance()
- .logBeUebSystemError(DistributionEngineInitTask.INIT_DISTRIBUTION_ENGINE_FLOW, "validate distribution configuration in init phase");
+ .logBeUebSystemError(DistributionEngineInitTask.INIT_DISTRIBUTION_ENGINE_FLOW, "validate distribution configuration in init phase");
this.distributionEngineClusterHealth.setHealthCheckUebConfigurationError();
return;
}
*/
protected boolean validateConfiguration(DistributionEngineConfiguration deConfiguration) {
String methodName = "validateConfiguration";
- boolean result = isValidServers(deConfiguration.getUebServers(), methodName, "uebServers");
- result = isValidParam(deConfiguration.getEnvironments(), methodName, "environments") && result;
- result = isValidParam(deConfiguration.getUebPublicKey(), methodName, "uebPublicKey") && result;
- result = isValidParam(deConfiguration.getUebSecretKey(), methodName, "uebSecretKey") && result;
+ boolean result = isValidParam(deConfiguration.getEnvironments(), methodName, "environments");
+
+ if (!kafkaHandler.isKafkaActive()) {
+ result = isValidServers(deConfiguration.getUebServers(), methodName, "uebServers") && result;
+ result = isValidParam(deConfiguration.getUebPublicKey(), methodName, "uebPublicKey") && result;
+ result = isValidParam(deConfiguration.getUebSecretKey(), methodName, "uebSecretKey") && result;
+ result = isValidObject(deConfiguration.getCreateTopic(), methodName, "createTopic") && result;
+ }
result = isValidParam(deConfiguration.getDistributionNotifTopicName(), methodName, "distributionNotifTopicName") && result;
result = isValidParam(deConfiguration.getDistributionStatusTopicName(), methodName, "distributionStatusTopicName") && result;
- result = isValidObject(deConfiguration.getCreateTopic(), methodName, "createTopic") && result;
result = isValidObject(deConfiguration.getDistributionStatusTopic(), methodName, "distributionStatusTopic") && result;
result = isValidObject(deConfiguration.getInitMaxIntervalSec(), methodName, "initMaxIntervalSec") && result;
result = isValidObject(deConfiguration.getInitRetryIntervalSec(), methodName, "initRetryIntervalSec") && result;
public ActionStatus notifyService(String distributionId, Service service, INotificationData notificationData, String envId, String envName,
User modifier) {
logger.debug(
- "Received notify service request. distributionId = {}, serviceUuid = {} serviceUid = {}, envName = {}, userId = {}, modifierName {}",
- distributionId, service.getUUID(), service.getUniqueId(), envName, service.getLastUpdaterUserId(), modifier);
+ "Received notify service request. distributionId = {}, serviceUuid = {} serviceUid = {}, envName = {}, userId = {}, modifierName {}",
+ distributionId, service.getUUID(), service.getUniqueId(), envName, service.getLastUpdaterUserId(), modifier);
String topicName = buildTopicName(envName);
ActionStatus notifyServiceStatus = Optional.ofNullable(environmentsEngine.getEnvironmentById(envId)).map(EnvironmentMessageBusData::new).map(
- messageBusData -> distributionNotificationSender
- .sendNotification(topicName, distributionId, messageBusData, notificationData, service, modifier))
- .orElse(ActionStatus.DISTRIBUTION_ENVIRONMENT_NOT_AVAILABLE);
+ messageBusData -> distributionNotificationSender
+ .sendNotification(topicName, distributionId, messageBusData, notificationData, service, modifier))
+ .orElse(ActionStatus.DISTRIBUTION_ENVIRONMENT_NOT_AVAILABLE);
logger.debug("Finish notifyService. status is {}", notifyServiceStatus);
return notifyServiceStatus;
}
if (status != StorageOperationStatus.OK) {
String envErrorDec = getEnvironmentErrorDescription(status);
BeEcompErrorManager.getInstance().logBeDistributionEngineSystemError(DistributionNotificationSender.DISTRIBUTION_NOTIFICATION_SENDING,
- "Environment name " + envName + " is not available. Reason : " + envErrorDec);
+ "Environment name " + envName + " is not available. Reason : " + envErrorDec);
}
return status;
}
import org.openecomp.sdc.be.components.impl.exceptions.ByActionStatusComponentException;
import org.openecomp.sdc.be.components.impl.exceptions.ByResponseFormatComponentException;
import org.openecomp.sdc.be.components.impl.exceptions.ComponentException;
+import org.openecomp.sdc.be.components.kafka.KafkaHandler;
import org.openecomp.sdc.be.components.path.ForwardingPathValidator;
import org.openecomp.sdc.be.components.utils.InterfaceOperationUtils;
import org.openecomp.sdc.be.components.utils.PropertiesUtils;
@org.springframework.stereotype.Component("serviceBusinessLogic")
public class ServiceBusinessLogic extends ComponentBusinessLogic {
- static final String IS_VALID = "isValid";
+ private static final String IS_VALID = "isValid";
private static final String THE_SERVICE_WITH_SYSTEM_NAME_LOCKED = "The service with system name {} locked. ";
private static final String FAILED_TO_LOCK_SERVICE_RESPONSE_IS = "Failed to lock service {}. Response is {}. ";
private static final String AUDIT_BEFORE_SENDING_RESPONSE = "audit before sending response";
private final ServiceCategoryValidator serviceCategoryValidator;
private final ServiceValidator serviceValidator;
private final GroupBusinessLogic groupBusinessLogic;
+ private final KafkaHandler kafkaHandler;
private ForwardingPathOperation forwardingPathOperation;
private AuditCassandraDao auditCassandraDao;
private ServiceTypeValidator serviceTypeValidator;
ComponentDescriptionValidator componentDescriptionValidator, ModelOperation modelOperation,
final ServiceRoleValidator serviceRoleValidator,
final ServiceInstantiationTypeValidator serviceInstantiationTypeValidator,
- final ServiceCategoryValidator serviceCategoryValidator, final ServiceValidator serviceValidator) {
+ final ServiceCategoryValidator serviceCategoryValidator, final ServiceValidator serviceValidator, KafkaHandler kafkaHandler) {
super(elementDao, groupOperation, groupInstanceOperation, groupTypeOperation, groupBusinessLogic, interfaceOperation,
interfaceLifecycleTypeOperation, artifactsBusinessLogic, artifactToscaOperation, componentContactIdValidator, componentNameValidator,
componentTagsValidator, componentValidator, componentIconValidator, componentProjectCodeValidator, componentDescriptionValidator);
this.serviceCategoryValidator = serviceCategoryValidator;
this.serviceValidator = serviceValidator;
this.groupBusinessLogic = groupBusinessLogic;
+ this.kafkaHandler = kafkaHandler;
}
@Autowired
log.trace("Update environment name to be {} instead of {}", configuredEnvName, envName);
envName = configuredEnvName;
}
- // DE194021
- ServletContext servletContext = request.getSession().getServletContext();
- boolean isDistributionEngineUp = getHealthCheckBL(servletContext).isDistributionEngineUp(); // DE
- if (!isDistributionEngineUp) {
- BeEcompErrorManager.getInstance().logBeSystemError("Distribution Engine is DOWN");
- log.debug("Distribution Engine is DOWN");
- response = componentsUtils.getResponseFormat(ActionStatus.GENERAL_ERROR);
- return Either.right(response);
+ if (!kafkaHandler.isKafkaActive()) {
+ // DE194021
+ ServletContext servletContext = request.getSession().getServletContext();
+ boolean isDistributionEngineUp = getHealthCheckBL(servletContext).isDistributionEngineUp(); // DE
+ if (!isDistributionEngineUp) {
+ BeEcompErrorManager.getInstance().logBeSystemError("Distribution Engine is DOWN");
+ log.debug("Distribution Engine is DOWN");
+ response = componentsUtils.getResponseFormat(ActionStatus.GENERAL_ERROR);
+ return Either.right(response);
+ }
}
Either<Service, StorageOperationStatus> serviceRes = toscaOperationFacade.getToscaElement(serviceId);
if (serviceRes.isRight()) {
log.debug("failed retrieving service");
response = componentsUtils
- .getResponseFormat(componentsUtils.convertFromStorageResponse(serviceRes.right().value(), ComponentTypeEnum.SERVICE), serviceId);
+ .getResponseFormat(componentsUtils.convertFromStorageResponse(serviceRes.right().value(), ComponentTypeEnum.SERVICE), serviceId);
componentsUtils.auditComponent(response, user, null, AuditingActionEnum.DISTRIBUTION_STATE_CHANGE_REQUEST,
- new ResourceCommonInfo(ComponentTypeEnum.SERVICE.getValue()), ResourceVersionInfo.newBuilder().build(), did);
+ new ResourceCommonInfo(ComponentTypeEnum.SERVICE.getValue()), ResourceVersionInfo.newBuilder().build(), did);
return Either.right(response);
}
Service service = serviceRes.left().value();
if (service.getLifecycleState() != LifecycleStateEnum.CERTIFIED) {
log.info("service {} is not available for distribution. Should be in certified state", service.getUniqueId());
ResponseFormat responseFormat = componentsUtils
- .getResponseFormat(ActionStatus.SERVICE_NOT_AVAILABLE_FOR_DISTRIBUTION, service.getVersion(), service.getName());
+ .getResponseFormat(ActionStatus.SERVICE_NOT_AVAILABLE_FOR_DISTRIBUTION, service.getVersion(), service.getName());
return Either.right(responseFormat);
}
String dcurrStatus = service.getDistributionStatus().name();
ActionStatus notifyServiceResponse = distributionEngine.notifyService(did, service, notificationData, envName, user);
if (notifyServiceResponse == ActionStatus.OK) {
Either<Service, ResponseFormat> updateStateRes = updateDistributionStatusForActivation(service, user,
- DistributionStatusEnum.DISTRIBUTED);
+ DistributionStatusEnum.DISTRIBUTED);
if (updateStateRes.isLeft() && updateStateRes.left().value() != null) {
updatedService = updateStateRes.left().value();
updatedStatus = updatedService.getDistributionStatus().name();
}
} else {
response = componentsUtils
- .getResponseFormatByDE(componentsUtils.convertFromStorageResponse(readyForDistribution, ComponentTypeEnum.SERVICE), envName);
+ .getResponseFormatByDE(componentsUtils.convertFromStorageResponse(readyForDistribution, ComponentTypeEnum.SERVICE), envName);
result = Either.right(response);
}
componentsUtils.auditComponent(response, user, service, AuditingActionEnum.DISTRIBUTION_STATE_CHANGE_REQUEST,
- new ResourceCommonInfo(service.getName(), ComponentTypeEnum.SERVICE.getValue()),
- ResourceVersionInfo.newBuilder().distributionStatus(dcurrStatus).build(),
- ResourceVersionInfo.newBuilder().distributionStatus(updatedStatus).build(), null, null, did);
+ new ResourceCommonInfo(service.getName(), ComponentTypeEnum.SERVICE.getValue()),
+ ResourceVersionInfo.newBuilder().distributionStatus(dcurrStatus).build(),
+ ResourceVersionInfo.newBuilder().distributionStatus(updatedStatus).build(), null, null, did);
return result;
}
"org.openecomp.sdc.be.components.csar",
"org.openecomp.sdc.be.components.property",
"org.openecomp.sdc.be.components.attribute",
+ "org.openecomp.sdc.be.components.kafka",
"org.openecomp.sdc.be.csar.security",
"org.openecomp.sdc.be.datamodel.utils",
"org.openecomp.sdc.be.components.upgrade",
org.openecomp.sdc.be.externalapi.servlet,
org.openecomp.sdc.be.components.scheduledtasks,
org.openecomp.sdc.be.facade.operations,
+ org.openecomp.sdc.be.components.kafka,
org.openecomp.sdc.be.components.impl">
</context:component-scan>
<bean class="org.openecomp.sdc.be.components.distribution.engine.config.DistributionEngineSpringConfig"/>
<bean class="org.openecomp.sdc.config.CatalogBESpringConfig"/>
<bean class="org.openecomp.sdc.config.MicrometerSpringConfig"/>
-
+ <bean class="org.openecomp.sdc.be.components.kafka.KafkaHandler"/>
<aop:config>
<aop:aspect id="lockAspect" ref="componentLockAspect">
serviceDistributionValidation, forwardingPathValidator, uiComponentDataConverter,
artifactToscaOperation, componentContactIdValidator, componentNameValidator,
componentTagsValidator, componentValidator, componentIconValidator, componentProjectCodeValidator, componentDescriptionValidator,
- modelOperation, null, null, null, null);
+ modelOperation, null, null, null, null, null);
bl.setUserAdmin(mockUserAdmin);
bl.setGraphLockOperation(graphLockOperation);
bl.setJanusGraphDao(mockJanusGraphDao);
artifactToscaOperation, componentContactIdValidator,
componentNameValidator, componentTagsValidator, componentValidator, componentIconValidator,
componentProjectCodeValidator, componentDescriptionValidator, modelOperation, null, null,
- null, null);
+ null, null, null);
private Service serviceToActivate;
private ActivationRequestInformation activationRequestInformation;
* 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.
package org.openecomp.sdc.be.components.distribution.engine;
-import org.junit.Before;
-import org.junit.Test;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.mockito.Mock;
+import org.mockito.Mockito;
+import org.mockito.MockitoAnnotations;
+import org.openecomp.sdc.be.components.kafka.KafkaHandler;
import org.openecomp.sdc.be.config.ConfigurationManager;
import org.openecomp.sdc.be.config.DistributionEngineConfiguration;
import org.openecomp.sdc.be.config.DistributionEngineConfiguration.ComponentArtifactTypesConfig;
import java.util.ArrayList;
import java.util.List;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertTrue;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.mockito.Mockito.when;
-public class DistributionEngineConfigTest {
+class DistributionEngineConfigTest {
- @Before
+ @Mock
+ private KafkaHandler kafkaHandler;
+
+ @BeforeEach
public void setup() {
+ MockitoAnnotations.openMocks(this);
+
ExternalConfiguration.setAppName("catalog-be");
ExternalConfiguration.setConfigDir("src/test/resources/config");
ExternalConfiguration.listenForChanges();
- ConfigurationSource configurationSource = new FSConfigurationSource(ExternalConfiguration.getChangeListener(), ExternalConfiguration.getConfigDir() + File.separator + ExternalConfiguration.getAppName());
-
- ConfigurationManager configurationManager = new ConfigurationManager(configurationSource);
+ new ConfigurationManager(new FSConfigurationSource(ExternalConfiguration.getChangeListener(), ExternalConfiguration.getConfigDir() + File.separator + ExternalConfiguration.getAppName()));
}
@Test
- public void validateMissingEnvironments() {
+ void validateMissingEnvironments() {
+
+ when(kafkaHandler.isKafkaActive()).thenReturn(false);
DistributionEngineConfiguration deConfiguration = new DistributionEngineConfiguration();
String uebSecretKey = "uebSecretKey";
DistributionEngine distributionEngine = new DistributionEngine();
-
+ distributionEngine.setKafkaHandler(kafkaHandler);
List<String> environments = new ArrayList<>();
environments.add("PROD");
deConfiguration.setEnvironments(environments);
deConfiguration.setInitRetryIntervalSec(3);
boolean isValid = distributionEngine.validateConfiguration(deConfiguration);
- assertTrue("check empty configuration", isValid);
+ assertTrue(isValid, "check empty configuration");
deConfiguration.setUebServers(null);
isValid = distributionEngine.validateConfiguration(deConfiguration);
- assertFalse("check empty configuration", isValid);
+ assertFalse(isValid, "check empty configuration");
deConfiguration.setUebServers(servers);
isValid = distributionEngine.validateConfiguration(deConfiguration);
- assertTrue("check empty configuration", isValid);
+ assertTrue(isValid, "check empty configuration");
deConfiguration.setEnvironments(null);
isValid = distributionEngine.validateConfiguration(deConfiguration);
- assertFalse("check empty configuration", isValid);
+ assertFalse(isValid, "check empty configuration");
deConfiguration.setEnvironments(environments);
isValid = distributionEngine.validateConfiguration(deConfiguration);
- assertTrue("check empty configuration", isValid);
+ assertTrue(isValid, "check empty configuration");
deConfiguration.setUebPublicKey(null);
isValid = distributionEngine.validateConfiguration(deConfiguration);
- assertFalse("check empty configuration", isValid);
+ assertFalse(isValid, "check empty configuration");
deConfiguration.setUebPublicKey(uebPublicKey);
isValid = distributionEngine.validateConfiguration(deConfiguration);
- assertTrue("check empty configuration", isValid);
+ assertTrue(isValid, "check empty configuration");
deConfiguration.setUebSecretKey(null);
isValid = distributionEngine.validateConfiguration(deConfiguration);
- assertFalse("check empty configuration", isValid);
+ assertFalse(isValid, "check empty configuration");
deConfiguration.setUebSecretKey(uebPublicKey);
isValid = distributionEngine.validateConfiguration(deConfiguration);
- assertTrue("check empty configuration", isValid);
+ assertTrue(isValid, "check empty configuration");
deConfiguration.setDistributionNotifTopicName(null);
isValid = distributionEngine.validateConfiguration(deConfiguration);
- assertFalse("check empty configuration", isValid);
+ assertFalse(isValid, "check empty configuration");
deConfiguration.setDistributionNotifTopicName(uebPublicKey);
isValid = distributionEngine.validateConfiguration(deConfiguration);
- assertTrue("check empty configuration", isValid);
+ assertTrue(isValid, "check empty configuration");
deConfiguration.setDistributionStatusTopicName(null);
isValid = distributionEngine.validateConfiguration(deConfiguration);
- assertFalse("check empty configuration", isValid);
+ assertFalse(isValid, "check empty configuration");
deConfiguration.setDistributionStatusTopicName(uebPublicKey);
isValid = distributionEngine.validateConfiguration(deConfiguration);
- assertTrue("check empty configuration", isValid);
+ assertTrue(isValid, "check empty configuration");
deConfiguration.setInitMaxIntervalSec(null);
isValid = distributionEngine.validateConfiguration(deConfiguration);
- assertFalse("check empty configuration", isValid);
+ assertFalse(isValid, "check empty configuration");
deConfiguration.setInitMaxIntervalSec(8);
isValid = distributionEngine.validateConfiguration(deConfiguration);
- assertTrue("check empty configuration", isValid);
+ assertTrue(isValid, "check empty configuration");
deConfiguration.setInitRetryIntervalSec(null);
isValid = distributionEngine.validateConfiguration(deConfiguration);
- assertFalse("check empty configuration", isValid);
+ assertFalse(isValid, "check empty configuration");
deConfiguration.setInitRetryIntervalSec(8);
isValid = distributionEngine.validateConfiguration(deConfiguration);
- assertTrue("check empty configuration", isValid);
+ assertTrue(isValid, "check empty configuration");
}
* 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.
package org.openecomp.sdc.be.components.distribution.engine;
import mockit.Deencapsulation;
-import org.junit.Assert;
-import org.junit.Before;
-import org.junit.Test;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
import org.mockito.ArgumentMatchers;
import org.mockito.InjectMocks;
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;
+import org.openecomp.sdc.be.components.kafka.KafkaHandler;
import org.openecomp.sdc.be.components.utils.OperationalEnvironmentBuilder;
import org.openecomp.sdc.be.config.Configuration;
import org.openecomp.sdc.be.config.DistributionEngineConfiguration;
-import org.openecomp.sdc.be.config.DistributionEngineConfiguration.DistributionStatusTopicConfig;
import org.openecomp.sdc.be.dao.api.ActionStatus;
import org.openecomp.sdc.be.model.Service;
import org.openecomp.sdc.be.model.User;
import java.util.stream.Collectors;
import java.util.stream.Stream;
-import static org.junit.Assert.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.mockito.ArgumentMatchers.any;
import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verifyNoInteractions;
import static org.mockito.Mockito.when;
-public class DistributionEngineTest{
+public class DistributionEngineTest {
- public static final String DISTRIBUTION_ID = "distId";
- public static final String ENV_ID = "envId";
- public static final String USER_ID = "userId";
- public static final String MODIFIER = "modifier";
+ public static final String DISTRIBUTION_ID = "distId";
+ public static final String ENV_ID = "envId";
+ public static final String USER_ID = "userId";
+ public static final String MODIFIER = "modifier";
- @InjectMocks
- private DistributionEngine testInstance;
+ @InjectMocks
+ private DistributionEngine testInstance;
- @Mock
- private EnvironmentsEngine environmentsEngine;
+ @Mock
+ private EnvironmentsEngine environmentsEngine;
+ @Mock
+ private KafkaHandler kafkaHandler;
+ @Mock
+ private DistributionNotificationSender distributionNotificationSender;
+ @Mock
+ private ServiceDistributionArtifactsBuilder serviceDistributionArtifactsBuilder;
- @Mock
- private DistributionNotificationSender distributionNotificationSender;
-
- @Mock
- private ServiceDistributionArtifactsBuilder serviceDistributionArtifactsBuilder;
-
- private DummyDistributionConfigurationManager distributionEngineConfigurationMock;
+ private DummyDistributionConfigurationManager distributionEngineConfigurationMock;
- private Map<String, OperationalEnvironmentEntry> envs;
+ private Map<String, OperationalEnvironmentEntry> envs;
private User modifier = new User();
private Configuration.EnvironmentContext environmentContext = mock(Configuration.EnvironmentContext.class);
- @Before
- public void setUpMock() throws Exception {
- MockitoAnnotations.openMocks(this);
- distributionEngineConfigurationMock = new DummyDistributionConfigurationManager();
- envs = getEnvs(ENV_ID);
+ @BeforeEach
+ public void setUpMock() throws Exception {
+ MockitoAnnotations.openMocks(this);
+ distributionEngineConfigurationMock = new DummyDistributionConfigurationManager();
+ envs = getEnvs(ENV_ID);
modifier.setUserId(USER_ID);
modifier.setFirstName(MODIFIER);
modifier.setLastName(MODIFIER);
when(environmentContext.getDefaultValue()).thenReturn("General_Revenue-Bearing");
when(distributionEngineConfigurationMock.getConfiguration().getEnvironmentContext())
- .thenReturn(environmentContext);
- }
+ .thenReturn(environmentContext);
+ }
@Test
- public void notifyService() throws Exception {
+ void notifyService() throws Exception {
NotificationDataImpl notificationData = new NotificationDataImpl();
Service service = new Service();
when(environmentsEngine.getEnvironmentById(ENV_ID)).thenReturn(envs.get(ENV_ID));
when(distributionEngineConfigurationMock.getConfigurationMock().getDistributionNotifTopicName()).thenReturn("topic");
when(distributionNotificationSender.sendNotification(eq("topic-ENVID"), eq(DISTRIBUTION_ID), any(EnvironmentMessageBusData.class),
any(NotificationDataImpl.class), any(Service.class), any(User.class)))
- .thenReturn(ActionStatus.OK);
+ .thenReturn(ActionStatus.OK);
ActionStatus actionStatus = testInstance.notifyService(DISTRIBUTION_ID, service, notificationData, ENV_ID, modifier);
assertEquals(ActionStatus.OK, actionStatus);
}
@Test
- public void notifyService_couldNotResolveEnvironment() throws Exception {
+ void notifyService_couldNotResolveEnvironment() throws Exception {
when(environmentsEngine.getEnvironments()).thenReturn(envs);
ActionStatus actionStatus = testInstance.notifyService(DISTRIBUTION_ID, new Service(), new NotificationDataImpl(), "someNonExisitngEnv", modifier);
assertEquals(ActionStatus.DISTRIBUTION_ENVIRONMENT_NOT_AVAILABLE, actionStatus);
}
@Test
- public void notifyService_failedWhileSendingNotification() throws Exception {
+ void notifyService_failedWhileSendingNotification() throws Exception {
NotificationDataImpl notificationData = new NotificationDataImpl();
Service service = new Service();
when(environmentsEngine.getEnvironmentById(ENV_ID)).thenReturn(envs.get(ENV_ID));
assertEquals(ActionStatus.GENERAL_ERROR, actionStatus);
}
- private Map<String, OperationalEnvironmentEntry> getEnvs(String... environmentIds) {
- Set<String> uebAddress = new HashSet<>();
- uebAddress.add("someAddress");
- return Stream.of(environmentIds)
- .map(id -> new OperationalEnvironmentBuilder().setEnvId(id).setDmaapUebAddress(uebAddress).build())
- .collect(Collectors.toMap(OperationalEnvironmentEntry::getEnvironmentId, Function.identity()));
- }
+ private Map<String, OperationalEnvironmentEntry> getEnvs(String... environmentIds) {
+ Set<String> uebAddress = new HashSet<>();
+ uebAddress.add("someAddress");
+ return Stream.of(environmentIds)
+ .map(id -> new OperationalEnvironmentBuilder().setEnvId(id).setDmaapUebAddress(uebAddress).build())
+ .collect(Collectors.toMap(OperationalEnvironmentEntry::getEnvironmentId, Function.identity()));
+ }
- private DistributionEngine createTestSubject() {
- return new DistributionEngine();
- }
+ private DistributionEngine createTestSubject() {
+ return new DistributionEngine();
+ }
- @Test(expected=NullPointerException.class)
- public void testInit() throws Exception {
- DistributionEngine testSubject;
+ @Test
+ public void testInit() throws Exception {
+ DistributionEngine testSubject;
- // default test
- testSubject = createTestSubject();
- Deencapsulation.invoke(testSubject, "init");
- }
+ // default test
+ testSubject = createTestSubject();
+ assertThrows(NullPointerException.class, () -> Deencapsulation.invoke(testSubject, "init"));
+ }
- @Test
- public void testShutdown() throws Exception {
- DistributionEngine testSubject;
+ @Test
+ void testShutdown() throws Exception {
+ DistributionEngine testSubject;
- // default test
- testSubject = createTestSubject();
- testSubject.shutdown();
- }
+ // default test
+ testSubject = createTestSubject();
+ testSubject.shutdown();
+ }
- @Test
- public void testValidateConfiguration() throws Exception {
- DistributionEngine testSubject;
+ @Test
+ void testValidateConfiguration() throws Exception {
+ when(kafkaHandler.isKafkaActive()).thenReturn(false);
+
+ DistributionEngine testSubject;
DistributionEngineConfiguration deConfiguration = new DistributionEngineConfiguration();
- deConfiguration.setDistributionStatusTopic((new DistributionStatusTopicConfig()));
+ deConfiguration.setDistributionStatusTopic((new DistributionEngineConfiguration.DistributionStatusTopicConfig()));
boolean result;
// default test
testSubject = createTestSubject();
+ testSubject.setKafkaHandler(kafkaHandler);
result = Deencapsulation.invoke(testSubject, "validateConfiguration", deConfiguration);
- }
-
- @Test
- public void testIsValidServers() throws Exception {
- DistributionEngine testSubject;
- List<String> uebServers = null;
- String methodName = "";
- String paramName = "";
- boolean result;
-
- // test 1
- testSubject = createTestSubject();
- uebServers = null;
- result = Deencapsulation.invoke(testSubject, "isValidServers",
- new Object[] { List.class, methodName, paramName });
- Assert.assertEquals(false, result);
- }
-
- @Test
- public void testIsValidFqdn() throws Exception {
- DistributionEngine testSubject;
- String serverFqdn = "";
- boolean result;
-
- // default test
- testSubject = createTestSubject();
- result = Deencapsulation.invoke(testSubject, "isValidFqdn", new Object[] { serverFqdn });
- }
-
- @Test
- public void testIsValidParam() throws Exception {
- DistributionEngine testSubject;
- String paramValue = "";
- String methodName = "";
- String paramName = "";
- boolean result;
-
- // default test
- testSubject = createTestSubject();
- result = Deencapsulation.invoke(testSubject, "isValidParam",
- new Object[] { paramValue, methodName, paramName });
- }
+ }
- @Test
- public void testIsValidParam_1() throws Exception {
- DistributionEngine testSubject;
- List<String> paramValue = null;
- String methodName = "";
- String paramName = "";
- boolean result;
+ @Test
+ void testIsValidServers() throws Exception {
+ DistributionEngine testSubject;
+ List<String> uebServers = null;
+ String methodName = "";
+ String paramName = "";
+ boolean result;
+
+ // test 1
+ testSubject = createTestSubject();
+ uebServers = null;
+ result = Deencapsulation.invoke(testSubject, "isValidServers",
+ new Object[]{List.class, methodName, paramName});
+ assertEquals(false, result);
+ }
- // default test
- testSubject = createTestSubject();
- result = Deencapsulation.invoke(testSubject, "isValidParam",
- new Object[] { List.class, methodName, paramName });
- }
+ @Test
+ void testIsValidFqdn() throws Exception {
+ DistributionEngine testSubject;
+ String serverFqdn = "";
+ boolean result;
+
+ // default test
+ testSubject = createTestSubject();
+ result = Deencapsulation.invoke(testSubject, "isValidFqdn", new Object[]{serverFqdn});
+ }
- @Test
- public void testIsValidObject() throws Exception {
- DistributionEngine testSubject;
- Object paramValue = null;
- String methodName = "";
- String paramName = "";
- boolean result;
+ @Test
+ void testIsValidParam() throws Exception {
+ DistributionEngine testSubject;
+ String paramValue = "";
+ String methodName = "";
+ String paramName = "";
+ boolean result;
+
+ // default test
+ testSubject = createTestSubject();
+ result = Deencapsulation.invoke(testSubject, "isValidParam",
+ new Object[]{paramValue, methodName, paramName});
+ }
- // test 1
- testSubject = createTestSubject();
- paramValue = null;
- result = Deencapsulation.invoke(testSubject, "isValidObject",
- new Object[] { Object.class, methodName, paramName });
- Assert.assertEquals(false, result);
- }
-
- @Test
- public void testGetEnvironmentErrorDescription() throws Exception {
- DistributionEngine testSubject;
- StorageOperationStatus status = null;
- String result;
+ @Test
+ void testIsValidParam_1() throws Exception {
+ DistributionEngine testSubject;
+ List<String> paramValue = null;
+ String methodName = "";
+ String paramName = "";
+ boolean result;
+
+ // default test
+ testSubject = createTestSubject();
+ result = Deencapsulation.invoke(testSubject, "isValidParam",
+ new Object[]{List.class, methodName, paramName});
+ }
- // default test
- testSubject = createTestSubject();
- result = Deencapsulation.invoke(testSubject, "getEnvironmentErrorDescription",
- StorageOperationStatus.DISTR_ENVIRONMENT_NOT_AVAILABLE);
- result = Deencapsulation.invoke(testSubject, "getEnvironmentErrorDescription",
- StorageOperationStatus.DISTR_ENVIRONMENT_NOT_FOUND);
- result = Deencapsulation.invoke(testSubject, "getEnvironmentErrorDescription",
- StorageOperationStatus.DISTR_ENVIRONMENT_SENT_IS_INVALID);
- result = Deencapsulation.invoke(testSubject, "getEnvironmentErrorDescription",
- StorageOperationStatus.ARTIFACT_NOT_FOUND);
- }
-
- @Test
- public void testIsEnvironmentAvailable() throws Exception {
- DistributionEngine testSubject;
- String envName = "";
- StorageOperationStatus result;
+ @Test
+ void testIsValidObject() throws Exception {
+ DistributionEngine testSubject;
+ Object paramValue = null;
+ String methodName = "";
+ String paramName = "";
+ boolean result;
+
+ // test 1
+ testSubject = createTestSubject();
+ paramValue = null;
+ result = Deencapsulation.invoke(testSubject, "isValidObject",
+ new Object[]{Object.class, methodName, paramName});
+ assertEquals(false, result);
+ }
- // test 1
- testSubject = createTestSubject();
- envName = null;
- result = testSubject.isEnvironmentAvailable(envName);
- Assert.assertEquals(StorageOperationStatus.DISTR_ENVIRONMENT_SENT_IS_INVALID, result);
+ @Test
+ void testGetEnvironmentErrorDescription() throws Exception {
+ DistributionEngine testSubject;
+ StorageOperationStatus status = null;
+ String result;
+
+ // default test
+ testSubject = createTestSubject();
+ result = Deencapsulation.invoke(testSubject, "getEnvironmentErrorDescription",
+ StorageOperationStatus.DISTR_ENVIRONMENT_NOT_AVAILABLE);
+ result = Deencapsulation.invoke(testSubject, "getEnvironmentErrorDescription",
+ StorageOperationStatus.DISTR_ENVIRONMENT_NOT_FOUND);
+ result = Deencapsulation.invoke(testSubject, "getEnvironmentErrorDescription",
+ StorageOperationStatus.DISTR_ENVIRONMENT_SENT_IS_INVALID);
+ result = Deencapsulation.invoke(testSubject, "getEnvironmentErrorDescription",
+ StorageOperationStatus.ARTIFACT_NOT_FOUND);
+ }
- // test 2
- testSubject = createTestSubject();
- envName = "mock";
- result = testSubject.isEnvironmentAvailable(envName);
- Assert.assertEquals(StorageOperationStatus.DISTR_ENVIRONMENT_NOT_FOUND, result);
- }
+ @Test
+ void testIsEnvironmentAvailable() throws Exception {
+ DistributionEngine testSubject;
+ String envName = "";
+ StorageOperationStatus result;
+
+ // test 1
+ testSubject = createTestSubject();
+ envName = null;
+ result = testSubject.isEnvironmentAvailable(envName);
+ assertEquals(StorageOperationStatus.DISTR_ENVIRONMENT_SENT_IS_INVALID, result);
+
+ // test 2
+ testSubject = createTestSubject();
+ envName = "mock";
+ result = testSubject.isEnvironmentAvailable(envName);
+ assertEquals(StorageOperationStatus.DISTR_ENVIRONMENT_NOT_FOUND, result);
+ }
- //TODO Create test coverage for this method
+ //TODO Create test coverage for this method
/*@Test
public void testIsEnvironmentAvailable_1() throws Exception {
DistributionEngine testSubject;
result = testInstance.isEnvironmentAvailable();
}*/
- @Test(expected=NullPointerException.class)
- public void testDisableEnvironment() throws Exception {
- DistributionEngine testSubject;
- String envName = "";
-
- // default test
- testSubject = createTestSubject();
- testSubject.disableEnvironment(envName);
- }
-
- @Test
- public void testBuildTopicName() throws Exception {
- DistributionEngine testSubject;
- String envName = "";
- String result;
-
- // default test
- testSubject = createTestSubject();
- result = Deencapsulation.invoke(testSubject, "buildTopicName", new Object[] { envName });
- }
-
- @Test
- public void testIsReadyForDistribution() throws Exception {
- DistributionEngine testSubject;
- Service service = null;
- String envName = "";
- StorageOperationStatus result;
+ @Test
+ void testDisableEnvironment() throws Exception {
+ DistributionEngine testSubject;
+ String envName = "";
- // default test
- testSubject = createTestSubject();
- result = testSubject.isReadyForDistribution(envName);
- }
+ // default test
+ testSubject = createTestSubject();
+ assertThrows(NullPointerException.class, () -> testSubject.disableEnvironment(envName));
+ }
+ @Test
+ void testBuildTopicName() throws Exception {
+ DistributionEngine testSubject;
+ String envName = "";
+ String result;
+
+ // default test
+ testSubject = createTestSubject();
+ result = Deencapsulation.invoke(testSubject, "buildTopicName", new Object[]{envName});
+ }
- @Test
- public void testGetEnvironmentById() throws Exception {
- DistributionEngine testSubject;
- String opEnvId = "";
- OperationalEnvironmentEntry result;
+ @Test
+ void testIsReadyForDistribution() throws Exception {
+ DistributionEngine testSubject;
+ Service service = null;
+ String envName = "";
+ StorageOperationStatus result;
+
+ // default test
+ testSubject = createTestSubject();
+ result = testSubject.isReadyForDistribution(envName);
+ }
- // default test
- when(environmentsEngine.getEnvironmentById(ArgumentMatchers.anyString())).thenReturn(new OperationalEnvironmentEntry());
- result = testInstance.getEnvironmentById(opEnvId);
- }
- @Test
- public void testBuildServiceForDistribution() throws Exception {
- Service service = new Service();
- String distributionId = "";
- String workloadContext = "";
- INotificationData result;
+ @Test
+ void testGetEnvironmentById() throws Exception {
+ DistributionEngine testSubject;
+ String opEnvId = "";
+ OperationalEnvironmentEntry result;
+
+ // default test
+ when(environmentsEngine.getEnvironmentById(ArgumentMatchers.anyString())).thenReturn(new OperationalEnvironmentEntry());
+ result = testInstance.getEnvironmentById(opEnvId);
+ }
- // default test
- //testSubject = createTestSubject();
- when(serviceDistributionArtifactsBuilder.buildResourceInstanceForDistribution(ArgumentMatchers.any(), ArgumentMatchers.any(), ArgumentMatchers.any())).thenReturn(new NotificationDataImpl());
- result = testInstance.buildServiceForDistribution(service, distributionId, workloadContext);
- }
+ @Test
+ void testBuildServiceForDistribution() throws Exception {
+ Service service = new Service();
+ String distributionId = "";
+ String workloadContext = "";
+ INotificationData result;
+
+ // default test
+ //testSubject = createTestSubject();
+ when(serviceDistributionArtifactsBuilder.buildResourceInstanceForDistribution(ArgumentMatchers.any(), ArgumentMatchers.any(), ArgumentMatchers.any())).thenReturn(new NotificationDataImpl());
+ result = testInstance.buildServiceForDistribution(service, distributionId, workloadContext);
+ }
}
interfaceLifecycleTypeOperation, artifactBl, distributionEngine, componentInstanceBusinessLogic, serviceDistributionValidation,
forwardingPathValidator, uiComponentDataConverter, artifactToscaOperation, componentContactIdValidator, componentNameValidator,
componentTagsValidator, componentValidator, componentIconValidator, componentProjectCodeValidator, componentDescriptionValidator,
- modelOperation, serviceRoleValidator, serviceInstantiationTypeValidator, serviceCategoryValidator, serviceValidator);
+ modelOperation, serviceRoleValidator, serviceInstantiationTypeValidator, serviceCategoryValidator, serviceValidator, null);
bl.setComponentContactIdValidator(componentContactIdValidator);
bl.setComponentIconValidator(componentIconValidator);
bl.setComponentTagsValidator(componentTagsValidator);
*/
package org.openecomp.sdc.be.components.kafka;
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertFalse;
-import static org.junit.jupiter.api.Assertions.assertNotNull;
-import static org.junit.jupiter.api.Assertions.assertTrue;
-import static org.mockito.ArgumentMatchers.any;
-import static org.mockito.Mockito.doThrow;
-import static org.mockito.Mockito.when;
-
import com.google.gson.JsonSyntaxException;
+import fj.data.Either;
import org.apache.kafka.common.KafkaException;
-import org.junit.jupiter.api.extension.ExtendWith;
-import org.mockito.junit.jupiter.MockitoExtension;
+import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.Mock;
-
-import java.util.ArrayList;
-import fj.data.Either;
-import java.util.List;
-
+import org.mockito.junit.jupiter.MockitoExtension;
import org.openecomp.sdc.be.components.distribution.engine.CambriaErrorResponse;
-import org.openecomp.sdc.be.components.distribution.engine.NotificationDataImpl;
import org.openecomp.sdc.be.components.distribution.engine.INotificationData;
+import org.openecomp.sdc.be.components.distribution.engine.NotificationDataImpl;
import org.openecomp.sdc.be.distribution.api.client.CambriaOperationStatus;
+import java.util.ArrayList;
+import java.util.List;
+
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.doThrow;
+import static org.mockito.Mockito.when;
@ExtendWith(MockitoExtension.class)
-public class KafkaHandlerTest {
+class KafkaHandlerTest {
@Mock
private SdcKafkaConsumer mockSdcKafkaConsumer;
private KafkaHandler kafkaHandler;
+ @BeforeEach
+ void setup() {
+ kafkaHandler = new KafkaHandler(mockSdcKafkaConsumer, mockSdcKafkaProducer, true);
+ }
+
@Test
- public void testIsKafkaActiveTrue(){
- KafkaHandler kafkaHandler = new KafkaHandler(mockSdcKafkaConsumer, mockSdcKafkaProducer, true);
+ void testIsKafkaActiveTrue() {
assertTrue(kafkaHandler.isKafkaActive());
}
@Test
- public void testIsKafkaActiveFalse(){
- KafkaHandler kafkaHandler = new KafkaHandler(mockSdcKafkaConsumer, mockSdcKafkaProducer, true);
+ void testIsKafkaActiveFalse() {
kafkaHandler.setKafkaActive(false);
assertFalse(kafkaHandler.isKafkaActive());
}
@Test
- public void testFetchFromTopicSuccess(){
+ void testFetchFromTopicSuccess() {
String testTopic = "testTopic";
List<String> mockedReturnedMessages = new ArrayList<>();
mockedReturnedMessages.add("message1");
mockedReturnedMessages.add("message2");
- KafkaHandler kafkaHandler = new KafkaHandler(mockSdcKafkaConsumer, mockSdcKafkaProducer, true);
when(mockSdcKafkaConsumer.poll(any())).thenReturn(mockedReturnedMessages);
Either<Iterable<String>, CambriaErrorResponse> response = kafkaHandler.fetchFromTopic(testTopic);
Iterable<String> actualReturnedMessages = response.left().value();
}
@Test
- public void testFetchFromTopicFail(){
+ void testFetchFromTopicFail() {
String testTopic = "testTopic";
- KafkaHandler kafkaHandler = new KafkaHandler(mockSdcKafkaConsumer, mockSdcKafkaProducer, true);
when(mockSdcKafkaConsumer.poll(any())).thenThrow(new KafkaException());
Either<Iterable<String>, CambriaErrorResponse> response = kafkaHandler.fetchFromTopic(testTopic);
CambriaErrorResponse responseValue = response.right().value();
}
@Test
- public void testSendNotificationSuccess(){
+ void testSendNotificationSuccess() {
String testTopic = "testTopic";
- KafkaHandler kafkaHandler = new KafkaHandler(mockSdcKafkaConsumer, mockSdcKafkaProducer, true);
INotificationData testData = new NotificationDataImpl();
CambriaErrorResponse response = kafkaHandler.sendNotification(testTopic, testData);
assertEquals(response.getOperationStatus(), CambriaOperationStatus.OK);
}
@Test
- public void testSendNotificationKafkaException(){
+ void testSendNotificationKafkaException() {
String testTopic = "testTopic";
- KafkaHandler kafkaHandler = new KafkaHandler(mockSdcKafkaConsumer, mockSdcKafkaProducer, true);
INotificationData testData = new NotificationDataImpl();
doThrow(KafkaException.class).when(mockSdcKafkaProducer).send(any(), any());
CambriaErrorResponse response = kafkaHandler.sendNotification(testTopic, testData);
}
@Test
- public void testSendNotificationJsonSyntaxException(){
+ void testSendNotificationJsonSyntaxException() {
String testTopic = "testTopic";
- KafkaHandler kafkaHandler = new KafkaHandler(mockSdcKafkaConsumer, mockSdcKafkaProducer, true);
INotificationData testData = new NotificationDataImpl();
doThrow(JsonSyntaxException.class).when(mockSdcKafkaProducer).send(any(), any());
CambriaErrorResponse response = kafkaHandler.sendNotification(testTopic, testData);
}
@Test
- public void testSendNotificationFlushException(){
+ void testSendNotificationFlushException() {
String testTopic = "testTopic";
- KafkaHandler kafkaHandler = new KafkaHandler(mockSdcKafkaConsumer, mockSdcKafkaProducer, true);
INotificationData testData = new NotificationDataImpl();
doThrow(KafkaException.class).when(mockSdcKafkaProducer).flush();
CambriaErrorResponse response = kafkaHandler.sendNotification(testTopic, testData);
import org.springframework.test.context.junit.jupiter.SpringJUnitConfig;
@SpringJUnitConfig(locations = "classpath:paths/path-context.xml")
-public class ForwardingPathBusinessLogicTest extends BaseForwardingPathTest {
+class ForwardingPathBusinessLogicTest extends BaseForwardingPathTest {
@BeforeAll
static void setup() {
configurationManager =
- new ConfigurationManager(new FSConfigurationSource(ExternalConfiguration.getChangeListener(), "src/test/resources/config/catalog-be"));
+ new ConfigurationManager(new FSConfigurationSource(ExternalConfiguration.getChangeListener(), "src/test/resources/config/catalog-be"));
}
@Test
- public void shouldFailToUpdateForwardingPathSincePathDoesNotExist() {
+ void shouldFailToUpdateForwardingPathSincePathDoesNotExist() {
Assertions.assertThrows(ComponentException.class, () -> {
Service service = initForwardPath();
bl.updateForwardingPath(FORWARDING_PATH_ID, service, user, true);
}
@Test
- public void shouldFailToDeleteForwardingPathSincePathDoesNotExist() {
+ void shouldFailToDeleteForwardingPathSincePathDoesNotExist() {
Assertions.assertThrows(ComponentException.class, () -> {
initForwardPath();
bl.deleteForwardingPaths("delete_forward_test", Sets.newHashSet(FORWARDING_PATH_ID), user, true);
}
@Test
- public void shouldSucceedCreateAndDeleteForwardingPath() {
+ void shouldSucceedCreateAndDeleteForwardingPath() {
Service createdService = createService();
Service service = initForwardPath();
assertNotNull(service);
// should return the created path
Either<UiComponentDataTransfer, ResponseFormat> uiResaponse = bl.getComponentDataFilteredByParams(createdService.getUniqueId(), user,
- Lists.newArrayList(ComponentFieldsEnum.FORWARDING_PATHS.getValue()));
+ Lists.newArrayList(ComponentFieldsEnum.FORWARDING_PATHS.getValue()));
assertTrue(uiResaponse.isLeft());
UiServiceDataTransfer uiServiceDataTransfer = (UiServiceDataTransfer) uiResaponse.left().value();
Map<String, ForwardingPathDataDefinition> forwardingPaths = uiServiceDataTransfer.getForwardingPaths();
// make sure changes were applied
uiResaponse = bl.getComponentDataFilteredByParams(createdService.getUniqueId(), user,
- Lists.newArrayList(ComponentFieldsEnum.FORWARDING_PATHS.getValue()));
+ Lists.newArrayList(ComponentFieldsEnum.FORWARDING_PATHS.getValue()));
assertTrue(uiResaponse.isLeft());
uiServiceDataTransfer = (UiServiceDataTransfer) uiResaponse.left().value();
Map<String, ForwardingPathDataDefinition> forwardingPathsUpdated = uiServiceDataTransfer.getForwardingPaths();
// nothing to return now
uiResaponse = bl.getComponentDataFilteredByParams(createdService.getUniqueId(), user,
- Lists.newArrayList(ComponentFieldsEnum.COMPONENT_INSTANCES.getValue(), ComponentFieldsEnum.FORWARDING_PATHS.getValue()));
+ Lists.newArrayList(ComponentFieldsEnum.COMPONENT_INSTANCES.getValue(), ComponentFieldsEnum.FORWARDING_PATHS.getValue()));
assertTrue(uiResaponse.isLeft());
uiServiceDataTransfer = (UiServiceDataTransfer) uiResaponse.left().value();
forwardingPaths = uiServiceDataTransfer.getForwardingPaths();
================================================================================
-->
<beans xmlns:aop="http://www.springframework.org/schema/aop"
- xmlns:context="http://www.springframework.org/schema/context"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xmlns="http://www.springframework.org/schema/beans"
- xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
+ xmlns:context="http://www.springframework.org/schema/context"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xmlns="http://www.springframework.org/schema/beans"
+ xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd">
<aop:aspectj-autoproxy proxy-target-class="true"/>
<bean class="org.openecomp.sdc.be.dao.config.DAOSpringConfig"/>
<bean class="org.openecomp.sdc.be.components.path.beans.ForwardingPathToscaOperationFacade"
- id="tosca-operation-facade"/>
+ id="tosca-operation-facade"/>
<bean class="org.openecomp.sdc.be.components.path.beans.InMemoryJanusGraphClient"
- id="janusgraph-client"/>
+ id="janusgraph-client"/>
<bean class="org.openecomp.sdc.be.components.path.beans.ArtifactCassandraDaoMock"
- id="artifact-cassandra-dao"/>
+ id="artifact-cassandra-dao"/>
<bean class="org.openecomp.sdc.be.components.path.beans.AuditCassandraDaoMock"
- id="audit-cassandra-dao"/>
+ id="audit-cassandra-dao"/>
<bean class="org.openecomp.sdc.be.components.path.beans.FeatureToggleDaoMock"
- id="feature_toggle_dao"/>
+ id="feature_toggle_dao"/>
<bean class="org.openecomp.sdc.be.components.path.beans.EnvironmentCassandraDaoMock"
- id="operational-environment-dao"/>
+ id="operational-environment-dao"/>
<bean class="org.openecomp.sdc.be.components.path.beans.SdcSchemaFilesCassandraDaoMock"
- id="sdc-schema-files-cassandra-dao"/>
+ id="sdc-schema-files-cassandra-dao"/>
<bean class="org.openecomp.sdc.be.components.path.beans.ToscaModelImportCassandraDaoMock"
- id="tosca-model-import-cassandra-dao"/>
+ id="tosca-model-import-cassandra-dao"/>
<bean class="org.openecomp.sdc.be.client.onboarding.impl.OnboardingClientImpl"
- id="onboarding-client"/>
+ id="onboarding-client"/>
<bean class="org.openecomp.sdc.be.catalog.impl.DmaapProducer" id="dmaapProducer"/>
<bean class="org.openecomp.sdc.be.catalog.impl.DmaapProducerHealth" id="dmaapProducerHealth"/>
<bean class="org.openecomp.sdc.be.components.lifecycle.LifecycleBusinessLogic"
- id="lifecycleBusinessLogic"/>
+ id="lifecycleBusinessLogic"/>
<bean class="org.openecomp.sdc.be.components.path.beans.DistributionEngineMock"
- id="distributionEngine"/>
+ id="distributionEngine"/>
<bean class="org.openecomp.sdc.be.components.path.beans.ForwardingPathValidatorMock"
- id="forwardingPathValidator"/>
+ id="forwardingPathValidator"/>
<bean class="org.openecomp.sdc.be.components.attribute.AttributeDeclarationOrchestrator"
- id="attributeDeclarationOrchestrator"/>
- <bean
- class="org.openecomp.sdc.be.components.attribute.ComponentInstanceOutputAttributeDeclarator"/>
+ id="attributeDeclarationOrchestrator"/>
+ <bean class="org.openecomp.sdc.be.components.attribute.ComponentInstanceOutputAttributeDeclarator"/>
<bean class="org.openecomp.sdc.be.components.attribute.ComponentInstanceAttributeDeclarator"/>
+ <bean class="org.openecomp.sdc.be.components.kafka.KafkaHandler"/>
<context:annotation-config/>
<context:component-scan
- base-package="
+ base-package="
org.openecomp.sdc.be.dao.janusgraph,
org.openecomp.sdc.be.model.jsonjanusgraph,
org.openecomp.sdc.be.model.operations.impl,
org.openecomp.sdc.be.components.csar,
org.openecomp.sdc.be.impl,
org.openecomp.sdc.be.tosca,
+ org.openecomp.sdc.be.components.kafka,
org.openecomp.sdc.be.dao.impl">
</context:component-scan>
*/
package org.openecomp.sdc.be.config;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+import org.openecomp.sdc.common.api.BasicConfiguration;
+import org.openecomp.sdc.common.http.config.ExternalServiceConfig;
+
import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
-import org.openecomp.sdc.common.api.BasicConfiguration;
-import org.openecomp.sdc.common.http.config.ExternalServiceConfig;
+@Getter
+@Setter
public class DistributionEngineConfiguration extends BasicConfiguration {
private List<String> uebServers;
private Integer opEnvRecoveryIntervalSec;
private Integer allowedTimeBeforeStaleSec;
- public List<String> getUebServers() {
- return uebServers;
- }
-
- public void setUebServers(List<String> uebServers) {
- this.uebServers = uebServers;
- }
-
- public String getDistributionNotifTopicName() {
- return distributionNotifTopicName;
- }
-
- public void setDistributionNotifTopicName(String distributionNotifTopicName) {
- this.distributionNotifTopicName = distributionNotifTopicName;
- }
-
- public String getDistributionStatusTopicName() {
- return distributionStatusTopicName;
- }
-
- public void setDistributionStatusTopicName(String distributionStatusTopicName) {
- this.distributionStatusTopicName = distributionStatusTopicName;
- }
-
- public String getKafkaBootStrapServers() {
- return kafkaBootStrapServers;
- }
-
- public void setKafkaBootStrapServers(String kafkaBootStrapServers) {
- this.kafkaBootStrapServers = kafkaBootStrapServers;
- }
-
- public Integer getInitRetryIntervalSec() {
- return initRetryIntervalSec;
- }
-
- public void setInitRetryIntervalSec(Integer initRetryIntervalSec) {
- this.initRetryIntervalSec = initRetryIntervalSec;
- }
-
- public ComponentArtifactTypesConfig getDistribNotifServiceArtifactTypes() {
- return distribNotifServiceArtifactTypes;
- }
-
- public void setDistribNotifServiceArtifactTypes(ComponentArtifactTypesConfig distribNotifServiceArtifactTypes) {
- this.distribNotifServiceArtifactTypes = distribNotifServiceArtifactTypes;
- }
-
- public ComponentArtifactTypesConfig getDistribNotifResourceArtifactTypes() {
- return distribNotifResourceArtifactTypes;
- }
-
- public void setDistribNotifResourceArtifactTypes(ComponentArtifactTypesConfig distribNotifResourceArtifactTypes) {
- this.distribNotifResourceArtifactTypes = distribNotifResourceArtifactTypes;
- }
-
- public String getUebPublicKey() {
- return uebPublicKey;
- }
-
- public void setUebPublicKey(String uebPublicKey) {
- this.uebPublicKey = uebPublicKey;
- }
-
- public String getUebSecretKey() {
- return uebSecretKey;
- }
-
- public void setUebSecretKey(String uebSecretKey) {
- this.uebSecretKey = uebSecretKey;
- }
-
- public List<String> getEnvironments() {
- return environments;
- }
-
public void setEnvironments(List<String> environments) {
Set<String> set = new HashSet<>();
if (environments != null) {
}
}
- public DistributionStatusTopicConfig getDistributionStatusTopic() {
- return distributionStatusTopic;
- }
-
- public void setDistributionStatusTopic(DistributionStatusTopicConfig distributionStatusTopic) {
- this.distributionStatusTopic = distributionStatusTopic;
- }
-
- public Integer getInitMaxIntervalSec() {
- return initMaxIntervalSec;
- }
-
- public void setInitMaxIntervalSec(Integer initMaxIntervalSec) {
- this.initMaxIntervalSec = initMaxIntervalSec;
- }
-
- public CreateTopicConfig getCreateTopic() {
- return createTopic;
- }
-
- public void setCreateTopic(CreateTopicConfig createTopic) {
- this.createTopic = createTopic;
- }
-
- public boolean isStartDistributionEngine() {
- return startDistributionEngine;
- }
-
- public void setStartDistributionEngine(boolean startDistributionEngine) {
- this.startDistributionEngine = startDistributionEngine;
- }
-
- public DistributionNotificationTopicConfig getDistributionNotificationTopic() {
- return distributionNotificationTopic;
- }
-
- public void setDistributionNotificationTopic(DistributionNotificationTopicConfig distributionNotificationTopic) {
- this.distributionNotificationTopic = distributionNotificationTopic;
- }
-
- public int getDefaultArtifactInstallationTimeout() {
- return defaultArtifactInstallationTimeout;
- }
-
- public void setDefaultArtifactInstallationTimeout(int defaultArtifactInstallationTimeout) {
- this.defaultArtifactInstallationTimeout = defaultArtifactInstallationTimeout;
- }
-
- public int getCurrentArtifactInstallationTimeout() {
- return currentArtifactInstallationTimeout;
- }
-
- public void setCurrentArtifactInstallationTimeout(int currentArtifactInstallationTimeout) {
- this.currentArtifactInstallationTimeout = currentArtifactInstallationTimeout;
- }
-
- public boolean isUseHttpsWithDmaap() {
- return useHttpsWithDmaap;
- }
-
- public void setUseHttpsWithDmaap(boolean useHttpsWithDmaap) {
- this.useHttpsWithDmaap = useHttpsWithDmaap;
- }
-
- public Integer getOpEnvRecoveryIntervalSec() {
- return opEnvRecoveryIntervalSec;
- }
-
- public void setOpEnvRecoveryIntervalSec(Integer opEnvRecoveryIntervalSec) {
- this.opEnvRecoveryIntervalSec = opEnvRecoveryIntervalSec;
- }
-
- public Integer getAllowedTimeBeforeStaleSec() {
- return allowedTimeBeforeStaleSec;
- }
-
- public void setAllowedTimeBeforeStaleSec(Integer allowedTimeBeforeStaleSec) {
- this.allowedTimeBeforeStaleSec = allowedTimeBeforeStaleSec;
- }
-
- public ExternalServiceConfig getAaiConfig() {
- return aaiConfig;
- }
-
- public void setAaiConfig(ExternalServiceConfig aaiConfig) {
- this.aaiConfig = aaiConfig;
- }
-
- public ExternalServiceConfig getMsoConfig() {
- return msoConfig;
- }
-
- public void setMsoConfig(ExternalServiceConfig msoConfig) {
- this.msoConfig = msoConfig;
- }
-
+ @Getter
+ @AllArgsConstructor
public enum ArtifcatTypeEnum {
- MURANO_PKG("MURANO-PKG"), HEAT("HEAT"), DG_XML("DG_XML");
- String value;
-
- private ArtifcatTypeEnum(String value) {
- this.value = value;
- }
+ MURANO_PKG("MURANO-PKG"),
+ HEAT("HEAT"),
+ DG_XML("DG_XML");
+ private final String value;
- public String getValue() {
- return value;
- }
}
+ @Getter
+ @Setter
public static class DistribNotifServiceArtifacts {
- Map<String, Object> service;
- Map<String, Object> resource;
+ private Map<String, Object> service;
+ private Map<String, Object> resource;
- public Map<String, Object> getService() {
- return service;
- }
-
- public void setService(Map<String, Object> service) {
- this.service = service;
- }
-
- public Map<String, Object> getResource() {
- return resource;
- }
-
- public void setResource(Map<String, Object> resource) {
- this.resource = resource;
- }
}
+ @Getter
+ @Setter
public static class NotifArtifactTypes {
- List<String> info;
- List<String> lifecycle;
-
- public List<String> getInfo() {
- return info;
- }
-
- public void setInfo(List<String> info) {
- this.info = info;
- }
-
- public List<String> getLifecycle() {
- return lifecycle;
- }
+ private List<String> info;
+ private List<String> lifecycle;
- public void setLifecycle(List<String> lifecycle) {
- this.lifecycle = lifecycle;
- }
}
+ @Getter
+ @Setter
public static class NotifArtifactTypesResource {
- List<ArtifcatTypeEnum> lifecycle;
+
private List<ArtifcatTypeEnum> lifecycle;
}
+ @Getter
+ @Setter
+ @ToString
public static class CreateTopicConfig {
private Integer partitionCount;
private Integer replicationCount;
- public Integer getPartitionCount() {
- return partitionCount;
- }
-
- public void setPartitionCount(Integer partitionCount) {
- this.partitionCount = partitionCount;
- }
-
- public Integer getReplicationCount() {
- return replicationCount;
- }
-
- public void setReplicationCount(Integer replicationCount) {
- this.replicationCount = replicationCount;
- }
-
- @Override
- public String toString() {
- return "CreateTopicConfig [partitionCount=" + partitionCount + ", replicationCount=" + replicationCount + "]";
- }
}
+ @Getter
+ @Setter
+ @ToString
public static class EnvironmentConfig {
private String name;
private List<String> uebServers;
- public String getName() {
- return name;
- }
-
- public void setName(String name) {
- this.name = name;
- }
-
- public List<String> getUebServers() {
- return uebServers;
- }
-
- public void setUebServers(List<String> uebServers) {
- this.uebServers = uebServers;
- }
-
- @Override
- public String toString() {
- return "EnvironmentConfig [name=" + name + ", uebServers=" + uebServers + "]";
- }
}
+ @Getter
+ @Setter
+ @ToString
public static class DistributionStatusTopicConfig {
private Integer pollingIntervalSec;
private String consumerGroup;
private String consumerId;
- public Integer getPollingIntervalSec() {
- return pollingIntervalSec;
- }
-
- public void setPollingIntervalSec(Integer pollingIntervalSec) {
- this.pollingIntervalSec = pollingIntervalSec;
- }
-
- public Integer getFetchTimeSec() {
- return fetchTimeSec;
- }
-
- public void setFetchTimeSec(Integer fetchTimeSec) {
- this.fetchTimeSec = fetchTimeSec;
- }
-
- public String getConsumerGroup() {
- return consumerGroup;
- }
-
- public void setConsumerGroup(String consumerGroup) {
- this.consumerGroup = consumerGroup;
- }
-
- public String getConsumerId() {
- return consumerId;
- }
-
- public void setConsumerId(String consumerId) {
- this.consumerId = consumerId;
- }
-
- @Override
- public String toString() {
- return "DistributionStatusTopicConfig [pollingIntervalSec=" + pollingIntervalSec + ", fetchTimeSec=" + fetchTimeSec + ", consumerGroup="
- + consumerGroup + ", consumerId=" + consumerId + "]";
- }
}
+ @Getter
+ @Setter
+ @ToString
public static class DistributionNotificationTopicConfig {
private Integer maxWaitingAfterSendingSeconds;
private Integer maxThreadPoolSize;
private Integer minThreadPoolSize;
- public Integer getMaxWaitingAfterSendingSeconds() {
- return maxWaitingAfterSendingSeconds;
- }
-
- public void setMaxWaitingAfterSendingSeconds(Integer maxWaitingAfterSendingSeconds) {
- this.maxWaitingAfterSendingSeconds = maxWaitingAfterSendingSeconds;
- }
-
- public Integer getMaxThreadPoolSize() {
- return maxThreadPoolSize;
- }
-
- public void setMaxThreadPoolSize(Integer maxThreadPoolSize) {
- this.maxThreadPoolSize = maxThreadPoolSize;
- }
-
- public Integer getMinThreadPoolSize() {
- return minThreadPoolSize;
- }
-
- public void setMinThreadPoolSize(Integer minThreadPoolSize) {
- this.minThreadPoolSize = minThreadPoolSize;
- }
-
- @Override
- public String toString() {
- return "DistributionNotificationTopicConfig [maxWaitingAfterSendingSeconds=" + maxWaitingAfterSendingSeconds + ", maxThreadPoolSize="
- + maxThreadPoolSize + ", minThreadPoolSize=" + minThreadPoolSize + "]";
- }
}
+ @Getter
+ @Setter
+ @ToString
public static class ComponentArtifactTypesConfig {
private List<String> info;
private List<String> lifecycle;
- public List<String> getInfo() {
- return info;
- }
-
- public void setInfo(List<String> info) {
- this.info = info;
- }
-
- public List<String> getLifecycle() {
- return lifecycle;
- }
-
- public void setLifecycle(List<String> lifecycle) {
- this.lifecycle = lifecycle;
- }
-
- @Override
- public String toString() {
- return "ArtifactTypesConfig [info=" + info + ", lifecycle=" + lifecycle + "]";
- }
}
}
* 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.
package org.openecomp.sdc.be.config;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
import java.util.Collections;
import java.util.List;
-import static com.google.code.beanmatchers.BeanMatchers.hasValidBeanConstructor;
-import static com.google.code.beanmatchers.BeanMatchers.hasValidBeanToString;
-import static com.google.code.beanmatchers.BeanMatchers.hasValidGettersAndSetters;
-import static com.google.code.beanmatchers.BeanMatchers.hasValidGettersAndSettersExcluding;
-import static org.hamcrest.CoreMatchers.allOf;
-import static org.hamcrest.MatcherAssert.assertThat;
-import static org.junit.Assert.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+class DistributionEngineConfigurationTest {
-public class DistributionEngineConfigurationTest {
+ @Test
+ void validateSetGetEnvironments() {
+ final String testEnvironment = "testEnvironment";
+ DistributionEngineConfiguration distributionEngineConfiguration = new DistributionEngineConfiguration();
+ distributionEngineConfiguration.setEnvironments(Collections.singletonList(testEnvironment));
- @Test
- public void validateBean() {
- assertThat(DistributionEngineConfiguration.class, allOf(
- hasValidBeanConstructor(),
- hasValidGettersAndSettersExcluding("environments")
- ));
- }
+ List<String> response = distributionEngineConfiguration.getEnvironments();
- @Test
- public void validateDistribNotifServiceArtifactsBean() {
- assertThat(DistributionEngineConfiguration.DistribNotifServiceArtifacts.class, allOf(
- hasValidBeanConstructor(),
- hasValidGettersAndSetters()
- ));
- }
-
- @Test
- public void validateNotifArtifactTypesBean() {
- assertThat(DistributionEngineConfiguration.NotifArtifactTypes.class, allOf(
- hasValidBeanConstructor(),
- hasValidGettersAndSetters()
- ));
- }
-
- @Test
- public void validateNotifArtifactTypesResourceBean() {
- assertThat(DistributionEngineConfiguration.NotifArtifactTypesResource.class, allOf(
- hasValidBeanConstructor(),
- hasValidGettersAndSetters()
- ));
- }
-
- @Test
- public void validateCreateTopicConfigBean() {
- assertThat(DistributionEngineConfiguration.CreateTopicConfig.class, allOf(
- hasValidBeanConstructor(),
- hasValidGettersAndSetters(),
- hasValidBeanToString()
- ));
- }
-
- @Test
- public void validateEnvironmentConfigBean() {
- assertThat(DistributionEngineConfiguration.EnvironmentConfig.class, allOf(
- hasValidBeanConstructor(),
- hasValidGettersAndSetters(),
- hasValidBeanToString()
- ));
- }
-
- @Test
- public void validateDistributionStatusTopicConfigBean() {
- assertThat(DistributionEngineConfiguration.DistributionStatusTopicConfig.class, allOf(
- hasValidBeanConstructor(),
- hasValidGettersAndSetters(),
- hasValidBeanToString()
- ));
- }
-
- @Test
- public void validateDistributionNotificationTopicConfigBean() {
- assertThat(DistributionEngineConfiguration.DistributionNotificationTopicConfig.class, allOf(
- hasValidBeanConstructor(),
- hasValidGettersAndSetters(),
- hasValidBeanToString()
- ));
- }
-
- @Test
- public void validateComponentArtifactTypesConfigBean() {
- assertThat(DistributionEngineConfiguration.ComponentArtifactTypesConfig.class, allOf(
- hasValidBeanConstructor(),
- hasValidGettersAndSetters()
- ));
- }
-
- @Test
- public void validateSetGetEnvironments() {
- final String testEnvironment = "testEnvironment";
- DistributionEngineConfiguration distributionEngineConfiguration = new DistributionEngineConfiguration();
- distributionEngineConfiguration.setEnvironments(Collections.singletonList(testEnvironment));
-
- List<String> response = distributionEngineConfiguration.getEnvironments();
-
- assertEquals(response.size(), 1);
- assertEquals(response.get(0), testEnvironment);
- }
+ assertEquals(1, response.size());
+ assertEquals(testEnvironment, response.get(0));
+ }
}
Code Review / sdc.git / commitdiff