diff options
author | shalomb <shalomb@amdocs.com> | 2018-01-02 13:48:40 +0200 |
---|---|---|
committer | Vitaly Emporopulo <Vitaliy.Emporopulo@amdocs.com> | 2018-01-02 14:00:34 +0000 |
commit | b38f18bb99a603012ec406053531c45fb4643d62 (patch) | |
tree | cbf8d7faacc50103737c84c76fdb3ee8ce1de7f3 /openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/collaboration/impl/ElementStageStoreImpl.java | |
parent | badc6daeca01c3c6dda5d2d5d1d7bacec2c24f48 (diff) |
Remove Zusammen cassandra plugin
Remove Zusammen cassandra plugin
Change dependency
Modify imports
Change-Id: Ice66fdd9f3970961723df476c8d1e38040504189
Issue-ID: SDC-862
Signed-off-by: shalomb <shalomb@amdocs.com>
Diffstat (limited to 'openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/collaboration/impl/ElementStageStoreImpl.java')
-rw-r--r-- | openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/collaboration/impl/ElementStageStoreImpl.java | 133 |
1 files changed, 0 insertions, 133 deletions
diff --git a/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/collaboration/impl/ElementStageStoreImpl.java b/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/collaboration/impl/ElementStageStoreImpl.java deleted file mode 100644 index f6c29432df..0000000000 --- a/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/collaboration/impl/ElementStageStoreImpl.java +++ /dev/null @@ -1,133 +0,0 @@ -package org.openecomp.core.zusammen.plugin.collaboration.impl; - -import com.amdocs.zusammen.datatypes.SessionContext; -import com.amdocs.zusammen.datatypes.item.Action; -import com.amdocs.zusammen.datatypes.item.ElementContext; -import com.amdocs.zusammen.datatypes.item.Resolution; -import com.amdocs.zusammen.plugin.statestore.cassandra.dao.types.ElementEntityContext; -import org.openecomp.core.zusammen.plugin.collaboration.ElementStageStore; -import org.openecomp.core.zusammen.plugin.dao.ElementStageRepository; -import org.openecomp.core.zusammen.plugin.dao.ElementStageRepositoryFactory; -import org.openecomp.core.zusammen.plugin.dao.types.ElementEntity; -import org.openecomp.core.zusammen.plugin.dao.types.StageEntity; - -import java.util.Collection; -import java.util.Optional; -import java.util.stream.Collectors; - -import static org.openecomp.core.zusammen.plugin.ZusammenPluginUtil.getPrivateElementContext; -import static org.openecomp.core.zusammen.plugin.ZusammenPluginUtil.getPrivateSpaceName; - -public class ElementStageStoreImpl implements ElementStageStore { - - @Override - public Collection<ElementEntity> listIds(SessionContext context, ElementContext elementContext) { - return getElementStageRepository(context) - .listIds(context, new ElementEntityContext(getPrivateSpaceName(context), - getPrivateElementContext(elementContext))); - } - - @Override - public Optional<StageEntity<ElementEntity>> get(SessionContext context, - ElementContext elementContext, - ElementEntity element) { - return getElementStageRepository(context).get(context, - new ElementEntityContext(getPrivateSpaceName(context), - getPrivateElementContext(elementContext)), - element); - } - - @Override - public Optional<StageEntity<ElementEntity>> getConflicted(SessionContext context, - ElementContext elementContext, - ElementEntity element) { - return get(context, elementContext, element).filter(StageEntity::isConflicted); - } - - @Override - public boolean hasConflicts(SessionContext context, ElementContext elementContext) { - return !getElementStageRepository(context).listConflictedIds(context, - new ElementEntityContext(getPrivateSpaceName(context), getPrivateElementContext(elementContext))).isEmpty(); - } - - @Override - public Collection<StageEntity<ElementEntity>> listConflictedDescriptors(SessionContext context, - ElementContext elementContext) { - ElementEntityContext privateContext = - new ElementEntityContext(getPrivateSpaceName(context), getPrivateElementContext - (elementContext)); - ElementStageRepository elementStageRepository = getElementStageRepository(context); - - return elementStageRepository.listConflictedIds(context, privateContext).stream() - .map(conflictedElement -> elementStageRepository - .getDescriptor(context, privateContext, conflictedElement).get()) - .collect(Collectors.toList()); - } - - @Override - public void create(SessionContext context, ElementContext elementContext, - StageEntity<ElementEntity> elementStage) { - getElementStageRepository(context) - .create(context, - new ElementEntityContext(getPrivateSpaceName(context), getPrivateElementContext(elementContext)), - elementStage); - } - - @Override - public void delete(SessionContext context, ElementContext elementContext, ElementEntity element) { - getElementStageRepository(context) - .delete(context, - new ElementEntityContext(getPrivateSpaceName(context), getPrivateElementContext(elementContext)), - element); - } - - - @Override - public void resolveConflict(SessionContext context, ElementContext elementContext, - ElementEntity element, Resolution resolution) { - Optional<StageEntity<ElementEntity>> stagedElement = - getConflicted(context, elementContext, element); - if (!stagedElement.isPresent()) { - return; - } - - ElementEntityContext privateContext = - new ElementEntityContext(getPrivateSpaceName(context), getPrivateElementContext - (elementContext)); - - switch (resolution) { - case YOURS: - resolveConflictByYours(context, privateContext, stagedElement.get()); - break; - case THEIRS: - resolveConflictByTheirs(context, privateContext, stagedElement.get()); - break; - case OTHER: // other = data updates only? no data deletions? if so, then: - // conflicted = false - // element = the input of resolve - // action = update - throw new UnsupportedOperationException("'Other' conflict resolution is not yet supported"); - default: - break; - } - } - - private void resolveConflictByYours(SessionContext context, ElementEntityContext privateContext, - StageEntity<ElementEntity> stagedElement) { - getElementStageRepository(context) - .markAsNotConflicted(context, privateContext, stagedElement.getEntity(), Action.IGNORE); - stagedElement.getConflictDependents().forEach(conflictDependant -> - getElementStageRepository(context) - .markAsNotConflicted(context, privateContext, conflictDependant, Action.IGNORE)); - } - - private void resolveConflictByTheirs(SessionContext context, ElementEntityContext privateContext, - StageEntity<ElementEntity> stagedElement) { - getElementStageRepository(context) - .markAsNotConflicted(context, privateContext, stagedElement.getEntity()); - } - - protected ElementStageRepository getElementStageRepository(SessionContext context) { - return ElementStageRepositoryFactory.getInstance().createInterface(context); - } -} |