aboutsummaryrefslogtreecommitdiffstats
path: root/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/collaboration/impl/VersionPublicStoreImpl.java
diff options
context:
space:
mode:
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/VersionPublicStoreImpl.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/VersionPublicStoreImpl.java135
1 files changed, 0 insertions, 135 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/VersionPublicStoreImpl.java b/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/collaboration/impl/VersionPublicStoreImpl.java
deleted file mode 100644
index aa628eb706..0000000000
--- a/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/collaboration/impl/VersionPublicStoreImpl.java
+++ /dev/null
@@ -1,135 +0,0 @@
-package org.openecomp.core.zusammen.plugin.collaboration.impl;
-
-import com.amdocs.zusammen.datatypes.Id;
-import com.amdocs.zusammen.datatypes.SessionContext;
-import com.amdocs.zusammen.datatypes.Space;
-import com.amdocs.zusammen.datatypes.itemversion.ItemVersionRevisions;
-import com.amdocs.zusammen.datatypes.itemversion.Revision;
-import org.openecomp.core.zusammen.plugin.collaboration.VersionPublicStore;
-import org.openecomp.core.zusammen.plugin.dao.VersionDao;
-import org.openecomp.core.zusammen.plugin.dao.VersionDaoFactory;
-import org.openecomp.core.zusammen.plugin.dao.VersionSynchronizationStateRepository;
-import org.openecomp.core.zusammen.plugin.dao.VersionSynchronizationStateRepositoryFactory;
-import org.openecomp.core.zusammen.plugin.dao.types.SynchronizationStateEntity;
-import org.openecomp.core.zusammen.plugin.dao.types.VersionContext;
-import org.openecomp.core.zusammen.plugin.dao.types.VersionEntity;
-
-import java.util.Comparator;
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
-import java.util.Optional;
-
-import static org.openecomp.core.zusammen.plugin.ZusammenPluginUtil.getSpaceName;
-
-public class VersionPublicStoreImpl implements VersionPublicStore {
- @Override
- public Optional<VersionEntity> get(SessionContext context, Id itemId, Id versionId) {
- return getVersionDao(context)
- .get(context, getSpaceName(context, Space.PUBLIC), itemId, versionId);
- }
-
- @Override
- public Optional<SynchronizationStateEntity> getSynchronizationState(SessionContext context,
- Id itemId, Id versionId) {
- Id revisionId = getLastItemVersionRevision(context, itemId,
- versionId);
- if (revisionId == null) {
- return Optional.empty();
- }
-
- return getVersionSyncStateRepository(context)
- .get(context, new VersionContext(getSpaceName(context, Space.PUBLIC), itemId),
- new SynchronizationStateEntity(versionId, revisionId));
- }
-
-
- @Override
- public void create(SessionContext context, Id itemId, VersionEntity version, Id revisionId,
- Map<Id, Id> versionElementIds, Date
- publishTime, String message) {
- String publicSpace = getSpaceName(context, Space.PUBLIC);
-
- getVersionDao(context).create(context, publicSpace, itemId, version);
-
- getVersionDao(context).createVersionElements(context, publicSpace, itemId, version.getId(),
- revisionId, versionElementIds, publishTime,message);
-
- getVersionSyncStateRepository(context).create(context, new VersionContext(publicSpace,
- itemId),
- new SynchronizationStateEntity(version.getId(), revisionId, publishTime, false));
- }
-
- @Override
- public void update(SessionContext context, Id itemId, VersionEntity version,
- Id revisionId, Map<Id, Id> versionElementIds, Date publishTime, String message) {
- String publicSpace = getSpaceName(context, Space.PUBLIC);
-
- getVersionDao(context).
- createVersionElements(context, publicSpace, itemId, version.getId(),
- revisionId, versionElementIds, publishTime,message);
-
- getVersionSyncStateRepository(context).
- updatePublishTime(context, new VersionContext(publicSpace, itemId),
- new SynchronizationStateEntity(version.getId(), revisionId, publishTime, false));
- }
-
- @Override
- public boolean checkHealth(SessionContext context) {
- return getVersionDao(context).checkHealth(context);
- }
-
- @Override
- public ItemVersionRevisions listItemVersionRevisions(SessionContext context, Id itemId,
- Id versionId) {
- VersionContext entityContext = new VersionContext(getSpaceName(context, Space.PUBLIC), itemId);
- List<SynchronizationStateEntity> versionRevisions = getVersionSyncStateRepository(context)
- .list(context, entityContext, new VersionEntity(versionId));
-
- if (versionRevisions == null || versionRevisions.size() == 0) {
- return null;
- }
-
- versionRevisions.sort(new Comparator<SynchronizationStateEntity>() {
- @Override
- public int compare(SynchronizationStateEntity o1, SynchronizationStateEntity o2) {
- if (o1.getPublishTime().after(o2.getPublishTime())) {
- return -1;
- } else {
- return 1;
- }
- }
- });
- ItemVersionRevisions itemVersionRevisions = new ItemVersionRevisions();
- versionRevisions.forEach(synchronizationStateEntity -> itemVersionRevisions.addChange
- (convertSyncState2Revision(synchronizationStateEntity)));
- return itemVersionRevisions;
- }
-
- private Revision convertSyncState2Revision(
- SynchronizationStateEntity synchronizationStateEntity) {
- Revision revision = new Revision();
- revision.setRevisionId(synchronizationStateEntity.getRevisionId());
- revision.setTime(synchronizationStateEntity.getPublishTime());
- revision.setMessage(synchronizationStateEntity.getMessage());
- revision.setUser(synchronizationStateEntity.getUser());
- return revision;
- }
-
-
- private Id getLastItemVersionRevision(SessionContext context, Id itemId, Id versionId) {
-
- ItemVersionRevisions versionRevisions = listItemVersionRevisions(context, itemId, versionId);
- if(versionRevisions ==null ) return null;
- return versionRevisions.getItemVersionRevisions().get(0).getRevisionId();
- }
-
- protected VersionDao getVersionDao(SessionContext context) {
- return VersionDaoFactory.getInstance().createInterface(context);
- }
-
- protected VersionSynchronizationStateRepository getVersionSyncStateRepository(
- SessionContext context) {
- return VersionSynchronizationStateRepositoryFactory.getInstance().createInterface(context);
- }
-}