aboutsummaryrefslogtreecommitdiffstats
path: root/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence
diff options
context:
space:
mode:
authorpriyanshu <pagarwal@amdocs.com>2018-07-16 19:25:05 +0530
committerpriyanshu <pagarwal@amdocs.com>2018-07-16 19:25:07 +0530
commit7e78cd19bbb2b0730fafc0b328a71c69f5730e16 (patch)
tree24b4b72ef67f64304bfee867076517c37896db5b /workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence
parent39c01dd3ccb69f53d2e9350994e25f6e64412aa4 (diff)
Workflow Docker containers
1. Implemented workflow init container. 2. Implemented workflow backend container. 3. Added a placeholder for frontend module container. 4. Modifiled directory structure and POM files. 5. Added a ReadMe with sample commands to detail how to run the containers. Change-Id: Ib110fcc104ce72ff28fce514a1475a032cc2d82b Issue-ID: SDC-1482 Signed-off-by: priyanshu <pagarwal@amdocs.com> Signed-off-by: vempo <vitaliy.emporopulo@amdocs.com> Signed-off-by: priyanshu <pagarwal@amdocs.com>
Diffstat (limited to 'workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence')
-rw-r--r--workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/ArtifactRepository.java18
-rw-r--r--workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/UniqueValueRepository.java10
-rw-r--r--workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/impl/ArtifactRepositoryImpl.java104
-rw-r--r--workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/ArtifactEntity.java16
-rw-r--r--workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/UniqueValueEntity.java23
-rw-r--r--workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/Workflow.java12
-rw-r--r--workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/WorkflowProperty.java9
-rw-r--r--workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/WorkflowVersion.java26
-rw-r--r--workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/WorkflowVersionState.java20
9 files changed, 0 insertions, 238 deletions
diff --git a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/ArtifactRepository.java b/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/ArtifactRepository.java
deleted file mode 100644
index a473f166..00000000
--- a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/ArtifactRepository.java
+++ /dev/null
@@ -1,18 +0,0 @@
-package org.onap.sdc.workflow.persistence;
-
-
-import java.util.Optional;
-import org.onap.sdc.workflow.persistence.types.ArtifactEntity;
-
-
-public interface ArtifactRepository {
-
- void update(String id, String versionId,ArtifactEntity artifactEntity);
-
- Optional<ArtifactEntity> get(String id, String versionId);
-
- void createStructure(String id, String versionId);
-
- void delete(String id, String versionId);
-
-}
diff --git a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/UniqueValueRepository.java b/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/UniqueValueRepository.java
deleted file mode 100644
index d374a404..00000000
--- a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/UniqueValueRepository.java
+++ /dev/null
@@ -1,10 +0,0 @@
-package org.onap.sdc.workflow.persistence;
-
-import org.onap.sdc.workflow.persistence.types.UniqueValueEntity;
-import org.springframework.data.cassandra.repository.CassandraRepository;
-import org.springframework.stereotype.Repository;
-
-@Repository
-public interface UniqueValueRepository extends CassandraRepository<UniqueValueEntity, UniqueValueEntity> {
-
-}
diff --git a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/impl/ArtifactRepositoryImpl.java b/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/impl/ArtifactRepositoryImpl.java
deleted file mode 100644
index 9a449f0d..00000000
--- a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/impl/ArtifactRepositoryImpl.java
+++ /dev/null
@@ -1,104 +0,0 @@
-package org.onap.sdc.workflow.persistence.impl;
-
-import static org.openecomp.core.zusammen.api.ZusammenUtil.buildStructuralElement;
-import static org.openecomp.core.zusammen.api.ZusammenUtil.createSessionContext;
-
-import com.amdocs.zusammen.adaptor.inbound.api.types.item.Element;
-import com.amdocs.zusammen.adaptor.inbound.api.types.item.ZusammenElement;
-import com.amdocs.zusammen.datatypes.SessionContext;
-import com.amdocs.zusammen.datatypes.item.Action;
-import com.amdocs.zusammen.datatypes.item.ElementContext;
-import java.io.ByteArrayInputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.util.Arrays;
-import java.util.Map;
-import java.util.Optional;
-import org.apache.commons.io.IOUtils;
-import org.onap.sdc.workflow.persistence.ArtifactRepository;
-import org.onap.sdc.workflow.persistence.types.ArtifactEntity;
-import org.openecomp.core.zusammen.api.ZusammenAdaptor;
-import org.openecomp.core.zusammen.api.ZusammenAdaptorFactory;
-import org.openecomp.sdc.datatypes.model.ElementType;
-import org.springframework.stereotype.Repository;
-
-@Repository
-public class ArtifactRepositoryImpl implements ArtifactRepository {
-
- private static final String FILE_NAME_PROPERTY = "fileName";
- private static final String EMPTY_DATA = "{}";
- private ZusammenAdaptor zusammenAdaptor = ZusammenAdaptorFactory.getInstance().createInterface();
-
-
- @Override
- public void update(String id, String versionId, ArtifactEntity artifactEntity) {
-
- ZusammenElement artifactElement = buildStructuralElement(ElementType.Artifact, Action.UPDATE);
- artifactElement.setData(artifactEntity.getArtifactData());
- artifactElement.getInfo().addProperty(FILE_NAME_PROPERTY, artifactEntity.getFileName());
-
- SessionContext context = createSessionContext();
- ElementContext elementContext = new ElementContext(id, versionId);
-
- zusammenAdaptor
- .saveElement(context, elementContext, artifactElement, "Update WorkflowVersion Artifact Element");
- }
-
- @Override
- public Optional<ArtifactEntity> get(String id, String versionId) {
- SessionContext context = createSessionContext();
- ElementContext elementContext = new ElementContext(id, versionId);
-
- Optional<Element> elementOptional =
- zusammenAdaptor.getElementByName(context, elementContext, null, ElementType.Artifact.name());
-
- if (!elementOptional.isPresent() || hasEmptyData(elementOptional.get().getData())) {
- return Optional.empty();
- }
-
- Element artifactElement = elementOptional.get();
-
- ArtifactEntity artifact = new ArtifactEntity(artifactElement.getInfo().getProperty(FILE_NAME_PROPERTY),
- artifactElement.getData());
-
- return Optional.of(artifact);
- }
-
- @Override
- public void createStructure(String id, String versionId) {
- SessionContext context = createSessionContext();
- ElementContext elementContext = new ElementContext(id, versionId);
-
- ZusammenElement artifactElement = buildStructuralElement(ElementType.Artifact, Action.CREATE);
- artifactElement.setData(new ByteArrayInputStream(EMPTY_DATA.getBytes()));
-
- zusammenAdaptor
- .saveElement(context, elementContext, artifactElement, "Create WorkflowVersion Artifact Element");
-
- }
-
- @Override
- public void delete(String id, String versionId) {
- SessionContext context = createSessionContext();
- ElementContext elementContext = new ElementContext(id, versionId);
-
- ZusammenElement artifactElement = buildStructuralElement(ElementType.Artifact, Action.UPDATE);
- artifactElement.setData(new ByteArrayInputStream(EMPTY_DATA.getBytes()));
- artifactElement.getInfo().getProperties().remove(FILE_NAME_PROPERTY);
-
- zusammenAdaptor
- .saveElement(context, elementContext, artifactElement, "Update WorkflowVersion Artifact Element");
-
- }
-
- private boolean hasEmptyData(InputStream elementData) {
-
- byte[] byteElementData;
- try {
- byteElementData = IOUtils.toByteArray(elementData);
- } catch (IOException ex) {
- return false;
- }
- return Arrays.equals(EMPTY_DATA.getBytes(), byteElementData);
- }
-}
diff --git a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/ArtifactEntity.java b/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/ArtifactEntity.java
deleted file mode 100644
index 8f24ecc9..00000000
--- a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/ArtifactEntity.java
+++ /dev/null
@@ -1,16 +0,0 @@
-package org.onap.sdc.workflow.persistence.types;
-
-import java.io.InputStream;
-import lombok.Data;
-
-@Data
-public class ArtifactEntity {
-
- private String fileName;
- private InputStream artifactData;
-
- public ArtifactEntity(String fileName, InputStream artifactData) {
- this.fileName = fileName;
- this.artifactData = artifactData;
- }
-}
diff --git a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/UniqueValueEntity.java b/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/UniqueValueEntity.java
deleted file mode 100644
index 925ec5cb..00000000
--- a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/UniqueValueEntity.java
+++ /dev/null
@@ -1,23 +0,0 @@
-package org.onap.sdc.workflow.persistence.types;
-
-import static org.springframework.data.cassandra.core.cql.PrimaryKeyType.PARTITIONED;
-
-import lombok.Data;
-import org.springframework.data.cassandra.core.mapping.PrimaryKeyColumn;
-import org.springframework.data.cassandra.core.mapping.Table;
-
-@Table("unique_value")
-@Data
-public class UniqueValueEntity {
-
- @PrimaryKeyColumn(ordinal = 0, type = PARTITIONED)
- private String type;
-
- @PrimaryKeyColumn(ordinal = 1, type = PARTITIONED)
- private String value;
-
- public UniqueValueEntity(String type, String value) {
- this.type = type;
- this.value = value;
- }
-}
diff --git a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/Workflow.java b/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/Workflow.java
deleted file mode 100644
index 8c66d820..00000000
--- a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/Workflow.java
+++ /dev/null
@@ -1,12 +0,0 @@
-package org.onap.sdc.workflow.persistence.types;
-
-
-import lombok.Data;
-
-@Data
-public class Workflow {
-
- private String id;
- private String name;
- private String description;
-}
diff --git a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/WorkflowProperty.java b/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/WorkflowProperty.java
deleted file mode 100644
index 6c2d804d..00000000
--- a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/WorkflowProperty.java
+++ /dev/null
@@ -1,9 +0,0 @@
-package org.onap.sdc.workflow.persistence.types;
-
-public final class WorkflowProperty {
-
- private WorkflowProperty() {
- }
-
- public static final String CATEGORY = "category";
-}
diff --git a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/WorkflowVersion.java b/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/WorkflowVersion.java
deleted file mode 100644
index db0999b6..00000000
--- a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/WorkflowVersion.java
+++ /dev/null
@@ -1,26 +0,0 @@
-package org.onap.sdc.workflow.persistence.types;
-
-import java.util.Date;
-import lombok.Data;
-
-
-@Data
-public class WorkflowVersion {
-
- private String id;
- private String name;
- private String description;
- private String baseId;
- private Date creationTime;
- private Date modificationTime;
- private WorkflowVersionState state;
-
-
- public WorkflowVersion(String id) {
- this.id = id;
- this.state = WorkflowVersionState.DRAFT;
- }
-
- public WorkflowVersion() {
- }
-}
diff --git a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/WorkflowVersionState.java b/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/WorkflowVersionState.java
deleted file mode 100644
index 9414fa17..00000000
--- a/workflow-designer-be/src/main/java/org/onap/sdc/workflow/persistence/types/WorkflowVersionState.java
+++ /dev/null
@@ -1,20 +0,0 @@
-package org.onap.sdc.workflow.persistence.types;
-
-import java.util.Arrays;
-import java.util.Collections;
-import java.util.List;
-
-public enum WorkflowVersionState {
-
- CERTIFIED, DRAFT(CERTIFIED);
-
- private final List<WorkflowVersionState> nextStates;
-
- WorkflowVersionState(WorkflowVersionState... nextStates) {
- this.nextStates = Collections.unmodifiableList(Arrays.asList(nextStates));
- }
-
- public List<WorkflowVersionState> getNextStates() {
- return nextStates;
- }
-}