summaryrefslogtreecommitdiffstats
path: root/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/collaboration/impl/VersionPrivateStoreImpl.java
diff options
context:
space:
mode:
authorshalomb <shalomb@amdocs.com>2018-01-02 13:48:40 +0200
committerVitaly Emporopulo <Vitaliy.Emporopulo@amdocs.com>2018-01-02 14:00:34 +0000
commitb38f18bb99a603012ec406053531c45fb4643d62 (patch)
treecbf8d7faacc50103737c84c76fdb3ee8ce1de7f3 /openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/collaboration/impl/VersionPrivateStoreImpl.java
parentbadc6daeca01c3c6dda5d2d5d1d7bacec2c24f48 (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/VersionPrivateStoreImpl.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/VersionPrivateStoreImpl.java117
1 files changed, 0 insertions, 117 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/VersionPrivateStoreImpl.java b/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/collaboration/impl/VersionPrivateStoreImpl.java
deleted file mode 100644
index 11e61ab5a9..0000000000
--- a/openecomp-be/lib/openecomp-core-lib/openecomp-zusammen-lib/openecomp-zusammen-plugin/src/main/java/org/openecomp/core/zusammen/plugin/collaboration/impl/VersionPrivateStoreImpl.java
+++ /dev/null
@@ -1,117 +0,0 @@
-package org.openecomp.core.zusammen.plugin.collaboration.impl;
-
-import com.amdocs.zusammen.datatypes.Id;
-import com.amdocs.zusammen.datatypes.SessionContext;
-import org.openecomp.core.zusammen.plugin.collaboration.VersionPrivateStore;
-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.Date;
-import java.util.Optional;
-
-import static org.openecomp.core.zusammen.plugin.ZusammenPluginUtil.getPrivateSpaceName;
-
-public class VersionPrivateStoreImpl implements VersionPrivateStore {
-
- Id revisionId = Id.ZERO;
-
- @Override
- public Optional<VersionEntity> get(SessionContext context, Id itemId, Id versionId) {
- return getVersionDao(context).get(context, getPrivateSpaceName(context), itemId, versionId);
- }
-
- @Override
- public Optional<SynchronizationStateEntity> getSynchronizationState(SessionContext context,
- Id itemId, Id versionId) {
-
- return getVersionSyncStateRepository(context)
- .get(context, new VersionContext(getPrivateSpaceName(context), itemId),
- new SynchronizationStateEntity(versionId, revisionId));
- }
-
- @Override
- public void create(SessionContext context, Id itemId, VersionEntity version) {
- String privateSpace = getPrivateSpaceName(context);
-
-
- getVersionDao(context).create(context, privateSpace, itemId, version);
- getVersionSyncStateRepository(context).create(context, new VersionContext(privateSpace,
- itemId),
- new SynchronizationStateEntity(version.getId(), revisionId, null, true));
- }
-
- @Override
- public void update(SessionContext context, Id itemId, VersionEntity version) {
-
- getVersionDao(context)
- .updateModificationTime(context, getPrivateSpaceName(context), itemId, version.getId(),
- version.getModificationTime());
- }
-
- @Override
- public void update(SessionContext context, Id itemId, VersionEntity version, Date publishTime,
- boolean dirty) {
- getVersionSyncStateRepository(context).updatePublishTime(context,
- new VersionContext(getPrivateSpaceName(context), itemId),
- new SynchronizationStateEntity(version.getId(), revisionId, publishTime, dirty));
- }
-
- @Override
- public void delete(SessionContext context, Id itemId, VersionEntity version) {
- String privateSpace = getPrivateSpaceName(context);
-
- getVersionDao(context).delete(context, privateSpace, itemId, version.getId());
- getVersionSyncStateRepository(context).delete(context, new VersionContext(privateSpace,
- itemId),
- new SynchronizationStateEntity(version.getId(), revisionId));
- }
-
- @Override
- public void markAsPublished(SessionContext context, Id itemId, Id versionId, Date publishTime) {
- getVersionSyncStateRepository(context)
- .updatePublishTime(context, new VersionContext(getPrivateSpaceName(context), itemId),
- new SynchronizationStateEntity(versionId, revisionId, publishTime, false));
- }
-
- @Override
- public void commitStagedCreate(SessionContext context, Id itemId, VersionEntity version,
- Date publishTime) {
- String privateSpace = getPrivateSpaceName(context);
-
- getVersionDao(context).create(context, privateSpace, itemId, version);
- getVersionSyncStateRepository(context).create(context, new VersionContext(privateSpace,
- itemId),
- new SynchronizationStateEntity(version.getId(), revisionId, publishTime, false));
- }
-
- @Override
- public void commitStagedUpdate(SessionContext context, Id itemId, VersionEntity version,
- Date publishTime) {
- update(context, itemId, version, publishTime, false);
- }
-
- @Override
- public void commitStagedIgnore(SessionContext context, Id itemId, VersionEntity version,
- Date publishTime) {
- getVersionSyncStateRepository(context).updatePublishTime(context,
- new VersionContext(getPrivateSpaceName(context), itemId),
- new SynchronizationStateEntity(version.getId(), revisionId, publishTime, false));
- }
-
-
-
-
- protected VersionDao getVersionDao(SessionContext context) {
- return VersionDaoFactory.getInstance().createInterface(context);
- }
-
- protected VersionSynchronizationStateRepository getVersionSyncStateRepository(
- SessionContext context) {
- return VersionSynchronizationStateRepositoryFactory.getInstance().createInterface(context);
- }
-}