1 files changed, 0 insertions, 384 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/SyncService.java b/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/collaboration/SyncService.java
deleted file mode 100644
index 04a7e9ffb1..0000000000
--- a/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/collaboration/SyncService.java
+++ /dev/null
@@ -1,384 +0,0 @@
-package org.openecomp.core.zusammen.plugin.collaboration;
-
-import com.amdocs.zusammen.datatypes.Id;
-import com.amdocs.zusammen.datatypes.SessionContext;
-import com.amdocs.zusammen.datatypes.item.Action;
-import com.amdocs.zusammen.datatypes.item.ElementContext;
-import com.amdocs.zusammen.sdk.collaboration.types.CollaborationMergeChange;
-import com.amdocs.zusammen.sdk.collaboration.types.CollaborationMergeConflict;
-import com.amdocs.zusammen.sdk.collaboration.types.CollaborationMergeResult;
-import org.openecomp.core.zusammen.plugin.dao.types.ElementEntity;
-import org.openecomp.core.zusammen.plugin.dao.types.StageEntity;
-import org.openecomp.core.zusammen.plugin.dao.types.SynchronizationStateEntity;
-import org.openecomp.core.zusammen.plugin.dao.types.VersionEntity;
-
-import java.util.Collection;
-import java.util.Date;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
-import java.util.Set;
-import java.util.function.Function;
-import java.util.function.Predicate;
-import java.util.stream.Collectors;
-
-import static org.openecomp.core.zusammen.plugin.ZusammenPluginConstants.ROOT_ELEMENTS_PARENT_ID;
-
-public class SyncService {
-  private static final String PULL_NON_EXISTING_VERSION =
-      "Item Id %s, version Id %s: Non existing version cannot be synced.";
-  private static final String PUBLIC_SYNC_STATE_EXISTS_WITHOUT_ELEMENT =
-      "Item Id %s, version Id %s: Sync state of element with Id %s " +
-          "exists in public space while the element does not";
-  private static final String PRIVATE_UNPUBLISHED_SYNC_STATE_EXISTS_WITHOUT_ELEMENT =
-      "Item Id %s, version Id %s: Sync state of unpublished element with Id %s " +
-          "exists in private space while the element does not";
-
-  private VersionPublicStore versionPublicStore;
-  private VersionPrivateStore versionPrivateStore;
-  private VersionStageStore versionStageStore;
-  private ElementPublicStore elementPublicStore;
-  private ElementPrivateStore elementPrivateStore;
-  private ElementStageStore elementStageStore;
-
-  public SyncService(VersionPublicStore versionPublicStore,
-                     VersionPrivateStore versionPrivateStore,
-                     VersionStageStore versionStageStore,
-                     ElementPublicStore elementPublicStore,
-                     ElementPrivateStore elementPrivateStore,
-                     ElementStageStore elementStageStore) {
-    this.versionPublicStore = versionPublicStore;
-    this.versionPrivateStore = versionPrivateStore;
-    this.versionStageStore = versionStageStore;
-    this.elementPublicStore = elementPublicStore;
-    this.elementPrivateStore = elementPrivateStore;
-    this.elementStageStore = elementStageStore;
-  }
-
-  public CollaborationMergeResult sync(SessionContext context, Id itemId, Id versionId,
-                                       boolean force) {
-    SynchronizationStateEntity publicVersionSyncState =
-        versionPublicStore.getSynchronizationState(context, itemId, versionId)
-            .orElseThrow(() -> new IllegalStateException(
-                String.format(PULL_NON_EXISTING_VERSION, itemId.toString(), versionId.toString())));
-
-    Date publishTime = publicVersionSyncState.getPublishTime();
-
-    Optional<SynchronizationStateEntity> privateVersionSyncState =
-        versionPrivateStore.getSynchronizationState(context, itemId, versionId);
-
-    if (force || !privateVersionSyncState.isPresent() ||
-        !publishTime.equals(privateVersionSyncState.get().getPublishTime())) {
-      ElementContext elementContext =
-          new ElementContext(itemId, versionId, publicVersionSyncState.getRevisionId());
-
-      Collection<SynchronizationStateEntity> publicSyncStates =
-          elementPublicStore.listSynchronizationStates(context, elementContext);
-      Collection<SynchronizationStateEntity> privateSyncStates =
-          elementPrivateStore.listSynchronizationStates(context, elementContext);
-      Map<Id, SynchronizationStateEntity> publicSyncStateById = toMapById(publicSyncStates);
-
-      Set<Id> syncedElements = new HashSet<>();
-      if (force) {
-        List<SynchronizationStateEntity> dirtyPrivateSyncStates = privateSyncStates.stream()
-            .filter(SynchronizationStateEntity::isDirty)
-            .collect(Collectors.toList());
-
-        forceSyncDirtyElements(context, elementContext, dirtyPrivateSyncStates, publicSyncStateById,
-            syncedElements);
-      }
-
-      if (!privateVersionSyncState.isPresent() ||
-          !publishTime.equals(privateVersionSyncState.get().getPublishTime())) {
-        syncVersion(context, itemId, versionId, publishTime, privateVersionSyncState.isPresent());
-        syncElements(context, elementContext,
-            privateVersionSyncState.map(SynchronizationStateEntity::getPublishTime).orElse(null),
-            publicSyncStates, privateSyncStates, publicSyncStateById, syncedElements);
-      }
-    }
-
-    return createResult();
-  }
-
-  private CollaborationMergeResult createResult() {
-    CollaborationMergeResult result = new CollaborationMergeResult();
-    result.setChange(new CollaborationMergeChange());
-    result.setConflict(new CollaborationMergeConflict());
-    return result;
-  }
-
-  private void syncVersion(SessionContext context, Id itemId, Id versionId, Date publishTime,
-                           boolean versionExistOnPrivate) {
-    if (versionExistOnPrivate) {
-      stageVersion(context, itemId, new VersionEntity(versionId), Action.UPDATE, publishTime);
-    } else {
-      stageVersion(context, itemId, versionPublicStore.get(context, itemId, versionId)
-              .orElseThrow(() -> new IllegalArgumentException(String
-                  .format(PULL_NON_EXISTING_VERSION, itemId.toString(), versionId.toString()))),
-          Action.CREATE, publishTime);
-    }
-  }
-
-  private void syncElements(SessionContext context, ElementContext elementContext,
-                            Date previousSyncedPublishTime,
-                            Collection<SynchronizationStateEntity> publicSyncStates,
-                            Collection<SynchronizationStateEntity> privateSyncStates,
-                            Map<Id, SynchronizationStateEntity> publicSyncStateById,
-                            Set<Id> syncedElements) {
-    Map<Id, SynchronizationStateEntity> privateSyncStateById = toMapById(privateSyncStates);
-
-    Collection<SynchronizationStateEntity> updatedPublicSyncStates =
-        previousSyncedPublishTime == null
-            ? publicSyncStates
-            : publicSyncStates.stream()
-                .filter(syncState -> syncState.getPublishTime().after(previousSyncedPublishTime))
-                .collect(Collectors.toList());
-
-    syncPublicUpdatedElements(context, elementContext, updatedPublicSyncStates,
-        publicSyncStateById, privateSyncStateById, syncedElements);
-
-    List<SynchronizationStateEntity> onlyOnPrivatePublishedSyncStates =
-        privateSyncStates.stream()
-            .filter(syncState -> !publicSyncStateById.containsKey(syncState.getId()) &&
-                syncState.getPublishTime() != null)
-            .collect(Collectors.toList());
-
-    syncPublicDeletedElements(context, elementContext, onlyOnPrivatePublishedSyncStates,
-        publicSyncStateById, privateSyncStateById, syncedElements);
-  }
-
-  private void syncPublicUpdatedElements(SessionContext context, ElementContext elementContext,
-                                         Collection<SynchronizationStateEntity> updatedPublicSyncStates,
-                                         Map<Id, SynchronizationStateEntity> publicSyncStateById,
-                                         Map<Id, SynchronizationStateEntity> privateSyncStateById,
-                                         Set<Id> syncedElements) {
-    for (SynchronizationStateEntity publicSyncState : updatedPublicSyncStates) {
-      if (syncedElements.contains(publicSyncState.getId())) {
-        continue;
-      }
-
-      ElementEntity publicElement =
-          elementPublicStore.get(context, elementContext, publicSyncState.getId()).orElseThrow(
-              () -> new IllegalStateException(String
-                  .format(PUBLIC_SYNC_STATE_EXISTS_WITHOUT_ELEMENT,
-                      elementContext.getItemId().getValue(),
-                      elementContext.getVersionId().getValue(),
-                      publicSyncState.getId().getValue())));
-
-      SynchronizationStateEntity privateSyncState =
-          privateSyncStateById.get(publicSyncState.getId());
-
-      if (privateSyncState != null) {
-        if (!privateSyncState.isDirty()) {
-          // not changed on private
-          stageElement(context, elementContext, publicElement,
-              publicSyncState.getPublishTime(),
-              Action.UPDATE, false, null);
-          syncedElements.add(publicSyncState.getId());
-        } else {
-          Optional<ElementEntity> privateElement =
-              elementPrivateStore.get(context, elementContext, publicSyncState.getId());
-
-          if (privateElement.isPresent()) {
-            // updated on private - conflict if it has different hash
-            stageElement(context, elementContext, publicElement,
-                publicSyncState.getPublishTime(), Action.UPDATE,
-                !publicElement.getElementHash().equals(privateElement.get().getElementHash()),
-                null);
-
-            syncedElements.add(publicSyncState.getId());
-          } else {
-            // deleted on private - conflict tree
-            Set<Id> changeTreeElementIds =
-                stagePublicElementTree(context, elementContext, publicElement, publicSyncStateById,
-                    (treeElementIds) -> true);
-            syncedElements.addAll(changeTreeElementIds);
-          }
-        }
-      } else {
-        // not existing on private - new creation on public
-        Set<Id> changeTreeElementIds =
-            stagePublicElementTree(context, elementContext, publicElement, publicSyncStateById,
-                (treeElementIds) -> containsDirty(treeElementIds, privateSyncStateById));
-        syncedElements.addAll(changeTreeElementIds);
-      }
-    }
-  }
-
-  private void syncPublicDeletedElements(
-      SessionContext context, ElementContext elementContext,
-      Collection<SynchronizationStateEntity> onlyOnPrivatePublishedSyncStates,
-      Map<Id, SynchronizationStateEntity> publicSyncStateById,
-      Map<Id, SynchronizationStateEntity> privateSyncStateById,
-      Set<Id> syncedElements) {
-    for (SynchronizationStateEntity privateSyncState : onlyOnPrivatePublishedSyncStates) {
-      if (syncedElements.contains(privateSyncState.getId())) {
-        continue;
-      }
-
-      Optional<ElementEntity> privateElement =
-          elementPrivateStore.get(context, elementContext, privateSyncState.getId());
-
-      if (!privateElement.isPresent()) {
-        // deleted on private as well
-        stageElement(context, elementContext, new ElementEntity(privateSyncState.getId()),
-            null, Action.DELETE, false, null);
-        syncedElements.add(privateSyncState.getId());
-      } else {
-        Set<Id> changeTreeElementIds =
-            stageElementTree(context, elementContext, privateElement.get(),
-                elementPrivateStore, publicSyncStateById::containsKey,
-                (treeElementIds) -> containsDirty(treeElementIds, privateSyncStateById),
-                (elementId) -> null, Action.DELETE);
-        syncedElements.addAll(changeTreeElementIds);
-      }
-    }
-  }
-
-  private void forceSyncDirtyElements(SessionContext context, ElementContext elementContext,
-                                      List<SynchronizationStateEntity> dirtyPrivateSyncStates,
-                                      Map<Id, SynchronizationStateEntity> publicSyncStateById,
-                                      Set<Id> syncedElements) {
-    for (SynchronizationStateEntity privateSyncState : dirtyPrivateSyncStates) {
-      Optional<ElementEntity> privateElement =
-          elementPrivateStore.get(context, elementContext, privateSyncState.getId());
-      if (privateSyncState.getPublishTime() == null) {
-        stageElement(context, elementContext,
-            privateElement.orElseThrow(() -> new IllegalStateException(
-                String.format(PRIVATE_UNPUBLISHED_SYNC_STATE_EXISTS_WITHOUT_ELEMENT,
-                    elementContext.getItemId().getValue(),
-                    elementContext.getVersionId().getValue(),
-                    privateSyncState.getId().getValue()))),
-            null, Action.DELETE, false, null);
-      } else {
-        SynchronizationStateEntity publicSyncState =
-            publicSyncStateById.get(privateSyncState.getId());
-        if (publicSyncState != null) {
-          ElementEntity publicElement =
-              elementPublicStore.get(context, elementContext, privateSyncState.getId()).orElseThrow(
-                  () -> new IllegalStateException(String
-                      .format(PUBLIC_SYNC_STATE_EXISTS_WITHOUT_ELEMENT,
-                          elementContext.getItemId().getValue(),
-                          elementContext.getVersionId().getValue(),
-                          privateSyncState.getId().getValue())));
-
-          stageElement(context, elementContext, publicElement, publicSyncState.getPublishTime(),
-              privateElement.isPresent() ? Action.UPDATE : Action.CREATE, false, null);
-        } else {
-          stageElement(context, elementContext, privateElement.isPresent()
-                  ? privateElement.get()
-                  : new ElementEntity(privateSyncState.getId()),
-              null, Action.DELETE, false, null);
-        }
-      }
-      syncedElements.add(privateSyncState.getId());
-    }
-  }
-
-  private Set<Id> stagePublicElementTree(SessionContext context,
-                                         ElementContext elementContext,
-                                         ElementEntity publicElement,
-                                         Map<Id, SynchronizationStateEntity> publicSyncStateById,
-                                         Predicate<Set<Id>> isElementTreeConflicted) {
-
-
-    return stageElementTree(context, elementContext, publicElement,
-        elementPublicStore,
-        (elementId) -> elementPrivateStore.getDescriptor(context, elementContext, elementId)
-            .isPresent(),
-        isElementTreeConflicted,
-        (elementId) -> publicSyncStateById.get(elementId).getPublishTime(),
-        Action.CREATE);
-  }
-
-  private Set<Id> stageElementTree(SessionContext context, ElementContext elementContext,
-                                   ElementEntity element,
-                                   ElementStore elementStore,
-                                   Predicate<Id> isElementExist,
-                                   Predicate<Set<Id>> isElementTreeConflicted,
-                                   Function<Id, Date> stagePublishTimeGetter,
-                                   Action stageAction) {
-    ElementEntity elementTreeRoot = findRootElementOfChange(context, elementContext,
-        elementStore, isElementExist, element);
-
-    Set<Id> elementTreeIds = new HashSet<>();
-    elementTreeIds.add(elementTreeRoot.getId());
-
-    Set<Id> subElementIds = stageElementSubs(context, elementContext, elementStore, elementTreeRoot,
-        stagePublishTimeGetter, stageAction);
-    elementTreeIds.addAll(subElementIds);
-
-    boolean conflicted = isElementTreeConflicted.test(elementTreeIds);
-    stageElement(context, elementContext, elementTreeRoot,
-        stagePublishTimeGetter.apply(elementTreeRoot.getId()), stageAction, conflicted,
-        conflicted ? subElementIds : null);
-    return elementTreeIds;
-  }
-
-  private ElementEntity findRootElementOfChange(SessionContext context,
-                                                ElementContext elementContext,
-                                                ElementStore elementStore,
-                                                Predicate<Id> isElementExistOnOppositeStore,
-                                                ElementEntity element) {
-    return element.getId().equals(ROOT_ELEMENTS_PARENT_ID) ||
-        isElementExistOnOppositeStore.test(element.getParentId())
-        ? element
-        : findRootElementOfChange(context, elementContext, elementStore,
-            isElementExistOnOppositeStore,
-            elementStore.get(context, elementContext, element.getParentId())
-                .orElseThrow(() -> new IllegalStateException(
-                    String.format("Element %s exists while its parent element %s does not",
-                        element.getId(), element.getParentId()))));
-  }
-
-  private boolean containsDirty(Set<Id> elementIds,
-                                Map<Id, SynchronizationStateEntity> syncStateById) {
-    return elementIds.stream().anyMatch(elementId -> {
-      SynchronizationStateEntity privateSyncState = syncStateById.get(elementId);
-      return privateSyncState != null && privateSyncState.isDirty();
-    });
-  }
-
-  private Set<Id> stageElementSubs(SessionContext context, ElementContext elementContext,
-                                   ElementStore elementStore, ElementEntity parentElement,
-                                   Function<Id, Date> stagePublishTimeGetter, Action stageAction) {
-    Set<Id> elementTreeIds = new HashSet<>();
-    for (Id elementId : parentElement.getSubElementIds()) {
-      ElementEntity element = elementStore.get(context, elementContext, elementId).get();
-
-      stageElement(context, elementContext, element, stagePublishTimeGetter.apply(elementId),
-          stageAction, false, null);
-
-      elementTreeIds.add(elementId);
-      elementTreeIds.addAll(
-          stageElementSubs(context, elementContext, elementStore, element, stagePublishTimeGetter,
-              stageAction));
-    }
-    return elementTreeIds;
-  }
-
-  private void stageElement(SessionContext context, ElementContext elementContext,
-                            ElementEntity element, Date publishTime, Action action,
-                            boolean conflicted, Set<Id> conflictDependents) {
-    StageEntity<ElementEntity> elementStage =
-        new StageEntity<>(element, publishTime, action, conflicted);
-    if (conflictDependents != null) {
-      elementStage.setConflictDependents(
-          conflictDependents.stream().map(ElementEntity::new).collect(Collectors.toSet()));
-    }
-    elementStageStore.create(context, elementContext, elementStage);
-  }
-
-  private void stageVersion(SessionContext context, Id itemId, VersionEntity stageVersion,
-                            Action stageAction, Date publishTime) {
-    versionStageStore
-        .create(context, itemId, new StageEntity<>(stageVersion, publishTime, stageAction, false));
-  }
-
-  private Map<Id, SynchronizationStateEntity> toMapById(
-      Collection<SynchronizationStateEntity> syncStates) {
-    return syncStates.stream()
-        .collect(Collectors.toMap(SynchronizationStateEntity::getId, Function.identity()));
-  }
-}