/*- * ============LICENSE_START======================================================= * Copyright (C) 2019 Nordix Foundation. * ================================================================================ * 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. * See the License for the specific language governing permissions and * limitations under the License. * * SPDX-License-Identifier: Apache-2.0 * ============LICENSE_END========================================================= */ package org.onap.policy.common.endpoints.parameters; import java.util.List; import lombok.Getter; import lombok.Setter; import org.apache.commons.lang3.StringUtils; import org.onap.policy.common.parameters.GroupValidationResult; import org.onap.policy.common.parameters.ParameterGroupImpl; import org.onap.policy.common.parameters.ValidationStatus; import org.onap.policy.common.parameters.annotations.NotBlank; import org.onap.policy.common.parameters.annotations.NotNull; /** * Class to hold all parameters needed for topic properties. * * @author Ajith Sreekumar (ajith.sreekumar@est.tech) */ @NotNull @NotBlank @Getter @Setter public class TopicParameterGroup extends ParameterGroupImpl { private List topicSources; private List topicSinks; public TopicParameterGroup() { super(TopicParameterGroup.class.getSimpleName()); } /** * {@inheritDoc}. */ @Override public GroupValidationResult validate() { GroupValidationResult result = super.validate(); if (result.isValid() && (checkMissingMandatoryParams(topicSources) || checkMissingMandatoryParams(topicSinks))) { result.setResult(ValidationStatus.INVALID, "Mandatory parameters are missing. topic, servers " + "and topicCommInfrastructure must be specified."); } return result; } private boolean checkMissingMandatoryParams(List topicParametersList) { for (TopicParameters topicParameters : topicParametersList) { if (StringUtils.isBlank(topicParameters.getTopic()) || StringUtils.isBlank(topicParameters.getTopicCommInfrastructure()) || topicParameters.getServers().isEmpty()) { return true; } } return false; } }