diff options
Diffstat (limited to 'catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/version')
4 files changed, 0 insertions, 176 deletions
diff --git a/catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/version/GroupMembersUpdateOperation.java b/catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/version/GroupMembersUpdateOperation.java deleted file mode 100644 index 1b6f49df8b..0000000000 --- a/catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/version/GroupMembersUpdateOperation.java +++ /dev/null @@ -1,66 +0,0 @@ -package org.openecomp.sdc.be.components.impl.version; - -import static org.apache.commons.collections.CollectionUtils.isEmpty; - -import java.util.List; -import java.util.Map; - -import org.apache.commons.collections.MapUtils; -import org.openecomp.sdc.be.dao.api.ActionStatus; -import org.openecomp.sdc.be.impl.ComponentsUtils; -import org.openecomp.sdc.be.model.Component; -import org.openecomp.sdc.be.model.ComponentInstance; -import org.openecomp.sdc.be.model.GroupDefinition; -import org.openecomp.sdc.be.model.jsontitan.operations.GroupsOperation; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -@org.springframework.stereotype.Component -public class GroupMembersUpdateOperation implements PostChangeVersionOperation { - - private static final Logger log = LoggerFactory.getLogger(GroupMembersUpdateOperation.class); - private final GroupsOperation groupsOperation; - private final ComponentsUtils componentsUtils; - - public GroupMembersUpdateOperation(GroupsOperation groupsOperation, ComponentsUtils componentsUtils) { - this.groupsOperation = groupsOperation; - this.componentsUtils = componentsUtils; - } - - @Override - public ActionStatus onChangeVersion(Component container, ComponentInstance prevVersion, ComponentInstance newVersion) { - return updateGroupMembersOnChangeVersion(container, prevVersion, newVersion); - } - - private ActionStatus updateGroupMembersOnChangeVersion(Component container, ComponentInstance prevVersion, ComponentInstance newVersion) { - log.debug("#updateGroupMembersOnChangeVersion - replacing all group members for component instance {} with new component instance.", prevVersion.getUniqueId(), newVersion.getUniqueId()); - if (isEmpty(container.getGroups())) { - log.debug("#updateGroupMembersOnChangeVersion - container {} has no groups.", container.getUniqueId()); - return ActionStatus.OK; - } - List<GroupDefinition> groupsWithPrevInstAsMember = container.resolveGroupsByMember(prevVersion.getUniqueId()); - if (isEmpty(groupsWithPrevInstAsMember)) { - log.debug("#updateGroupMembersOnChangeVersion - container {} has no groups with component instance {} as member.", container.getUniqueId(), prevVersion.getUniqueId()); - return ActionStatus.OK; - } - replacePrevInstanceMemberWithNewInstance(prevVersion, newVersion, groupsWithPrevInstAsMember); - return updateGroups(container, groupsWithPrevInstAsMember); - } - - private ActionStatus updateGroups(Component container, List<GroupDefinition> groupsToUpdate) { - log.debug("#updateGroups - updating {} groups for container {}", groupsToUpdate.size(), container.getUniqueId()); - return groupsOperation.updateGroups(container, groupsToUpdate) - .either(groupsUpdated -> ActionStatus.OK, - err -> componentsUtils.convertFromStorageResponse(err, container.getComponentType())); - } - - private void replacePrevInstanceMemberWithNewInstance(ComponentInstance prevVersion, ComponentInstance newVersion, List<GroupDefinition> groupsWithPrevInstAsMember) { - groupsWithPrevInstAsMember.forEach(grp -> replacePrevInstanceMemberWithNewInstance(grp, prevVersion.getUniqueId(), newVersion.getUniqueId())); - } - - private void replacePrevInstanceMemberWithNewInstance(GroupDefinition groupDefinition, String prevInstanceId, String newInstanceId) { - Map<String, String> membersNameToId = groupDefinition.getMembers(); - String prevInstanceMemberName = MapUtils.invertMap(membersNameToId).get(prevInstanceId).toString(); - membersNameToId.replace(prevInstanceMemberName, newInstanceId); - } - -} diff --git a/catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/version/PolicyTargetsUpdateOperation.java b/catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/version/PolicyTargetsUpdateOperation.java deleted file mode 100644 index 1d27228c50..0000000000 --- a/catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/version/PolicyTargetsUpdateOperation.java +++ /dev/null @@ -1,67 +0,0 @@ -package org.openecomp.sdc.be.components.impl.version; - -import static org.apache.commons.collections.CollectionUtils.isEmpty; - -import java.util.List; -import java.util.function.UnaryOperator; - -import org.openecomp.sdc.be.dao.api.ActionStatus; -import org.openecomp.sdc.be.impl.ComponentsUtils; -import org.openecomp.sdc.be.model.Component; -import org.openecomp.sdc.be.model.ComponentInstance; -import org.openecomp.sdc.be.model.PolicyDefinition; -import org.openecomp.sdc.be.model.jsontitan.operations.ToscaOperationFacade; -import org.openecomp.sdc.be.model.operations.api.StorageOperationStatus; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -@org.springframework.stereotype.Component -public class PolicyTargetsUpdateOperation implements PostChangeVersionOperation { - - private static final Logger log = LoggerFactory.getLogger(PolicyTargetsUpdateOperation.class); - private final ToscaOperationFacade toscaOperationFacade; - private final ComponentsUtils componentsUtils; - - public PolicyTargetsUpdateOperation(ToscaOperationFacade toscaOperationFacade, ComponentsUtils componentsUtils) { - this.toscaOperationFacade = toscaOperationFacade; - this.componentsUtils = componentsUtils; - } - - @Override - public ActionStatus onChangeVersion(Component container, ComponentInstance prevVersion, ComponentInstance newVersion) { - return replacePolicyTargetsInstanceId(container, prevVersion, newVersion); - } - - private ActionStatus replacePolicyTargetsInstanceId(Component container, ComponentInstance prevVersion, ComponentInstance newVersion) { - log.debug("#replacePolicyTargetsInstanceId - replacing all policy targets for component instance {} with component instance {}", prevVersion.getUniqueId(), newVersion.getUniqueId()); - List<PolicyDefinition> policiesWithPrevInstanceAsTarget = container.resolvePoliciesByComponentInstanceTarget(prevVersion.getUniqueId()); - if (isEmpty(policiesWithPrevInstanceAsTarget)) { - return ActionStatus.OK; - } - replaceTargetsPrevInstanceIdWithNewInstanceId(prevVersion, newVersion, policiesWithPrevInstanceAsTarget); - return updatePolicies(container, policiesWithPrevInstanceAsTarget); - } - - private ActionStatus updatePolicies(Component policiesContainer, List<PolicyDefinition> policiesToUpdate) { - log.debug("#updatePolicies - updating {} policies for container {}", policiesToUpdate.size(), policiesContainer.getUniqueId()); - StorageOperationStatus updatePolicyResult = toscaOperationFacade.updatePoliciesOfComponent(policiesContainer.getUniqueId(), policiesToUpdate); - return componentsUtils.convertFromStorageResponse(updatePolicyResult, policiesContainer.getComponentType()); - } - - private void replaceTargetsPrevInstanceIdWithNewInstanceId(ComponentInstance prevVersion, ComponentInstance newVersion, List<PolicyDefinition> policiesWithPrevInstanceAsTarget) { - policiesWithPrevInstanceAsTarget.forEach(policy -> updatePolicyTargetWithNewInstanceVersion(policy, prevVersion.getUniqueId(), newVersion.getUniqueId())); - } - - private void updatePolicyTargetWithNewInstanceVersion(PolicyDefinition policyDefinition, String prevInstanceId, String newInstanceId) { - List<String> policyInstanceTargets = policyDefinition.resolveComponentInstanceTargets(); - if (isEmpty(policyInstanceTargets)) { - return; - } - policyInstanceTargets.replaceAll(prevInstanceIdByNewInstanceId(prevInstanceId, newInstanceId)); - } - - private UnaryOperator<String> prevInstanceIdByNewInstanceId(String prevInstanceId, String newInstanceId) { - return instId -> instId.equals(prevInstanceId) ? newInstanceId: instId; - } - -} diff --git a/catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/version/PostChangeVersionOperation.java b/catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/version/PostChangeVersionOperation.java deleted file mode 100644 index ee16c203bf..0000000000 --- a/catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/version/PostChangeVersionOperation.java +++ /dev/null @@ -1,11 +0,0 @@ -package org.openecomp.sdc.be.components.impl.version; - -import org.openecomp.sdc.be.dao.api.ActionStatus; -import org.openecomp.sdc.be.model.Component; -import org.openecomp.sdc.be.model.ComponentInstance; -@FunctionalInterface -public interface PostChangeVersionOperation { - - ActionStatus onChangeVersion(Component container, ComponentInstance prevVersion, ComponentInstance newVersion); - -} diff --git a/catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/version/PostChangeVersionOperationOrchestrator.java b/catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/version/PostChangeVersionOperationOrchestrator.java deleted file mode 100644 index 375d8e6e12..0000000000 --- a/catalog-be/src/main/java/org/openecomp/sdc/be/components/impl/version/PostChangeVersionOperationOrchestrator.java +++ /dev/null @@ -1,32 +0,0 @@ -package org.openecomp.sdc.be.components.impl.version; - -import java.util.Iterator; -import java.util.List; - -import org.openecomp.sdc.be.dao.api.ActionStatus; -import org.openecomp.sdc.be.model.Component; -import org.openecomp.sdc.be.model.ComponentInstance; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -@org.springframework.stereotype.Component -public class PostChangeVersionOperationOrchestrator { - - private static final Logger log = LoggerFactory.getLogger(PostChangeVersionOperationOrchestrator.class); - private final List<PostChangeVersionOperation> postChangeVersionOperations; - - public PostChangeVersionOperationOrchestrator(List<PostChangeVersionOperation> postChangeVersionOperations) { - this.postChangeVersionOperations = postChangeVersionOperations; - } - - public ActionStatus doPostChangeVersionOperations(Component container, ComponentInstance prevVersion, ComponentInstance newVersion) { - log.debug("#doPostChangeVersionOperations - starting post change version operations for component {}. from instance {} to instance {}", container.getUniqueId(), prevVersion.getUniqueId(), newVersion.getUniqueId()); - ActionStatus postOperationsResult = ActionStatus.OK; - Iterator<PostChangeVersionOperation> postChangeVersionIter = postChangeVersionOperations.iterator(); - while(postChangeVersionIter.hasNext() && postOperationsResult == ActionStatus.OK) { - postOperationsResult = postChangeVersionIter.next().onChangeVersion(container, prevVersion, newVersion); - } - return postOperationsResult; - } - -} |