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);
-  }
-}