1 files changed, 45 insertions, 0 deletions
diff --git a/openecomp-be/lib/openecomp-sdc-vendor-software-product-lib/openecomp-sdc-vendor-software-product-core/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/dao/impl/zusammen/convertor/ElementToComponentMonitoringUploadConvertor.java b/openecomp-be/lib/openecomp-sdc-vendor-software-product-lib/openecomp-sdc-vendor-software-product-core/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/dao/impl/zusammen/convertor/ElementToComponentMonitoringUploadConvertor.java
new file mode 100644
index 0000000000..dd3d122560
--- /dev/null
+++ b/openecomp-be/lib/openecomp-sdc-vendor-software-product-lib/openecomp-sdc-vendor-software-product-core/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/dao/impl/zusammen/convertor/ElementToComponentMonitoringUploadConvertor.java
@@ -0,0 +1,45 @@
+package org.openecomp.sdc.vendorsoftwareproduct.dao.impl.zusammen.convertor;
+
+import com.amdocs.zusammen.adaptor.inbound.api.types.item.Element;
+import com.amdocs.zusammen.adaptor.inbound.api.types.item.ElementInfo;
+import com.amdocs.zusammen.datatypes.item.Info;
+import org.openecomp.convertor.ElementConvertor;
+import org.openecomp.core.enrichment.types.MonitoringUploadType;
+import org.openecomp.core.utilities.file.FileUtils;
+import org.openecomp.sdc.vendorsoftwareproduct.dao.type.ComponentMonitoringUploadEntity;
+
+import java.nio.ByteBuffer;
+
+import static org.openecomp.sdc.vendorsoftwareproduct.dao.impl.zusammen.convertor.ElementToProcessConvertor.ARTIFACT_NAME;
+
+public class ElementToComponentMonitoringUploadConvertor extends ElementConvertor<ComponentMonitoringUploadEntity> {
+
+  @Override
+  public ComponentMonitoringUploadEntity convert(Element element) {
+    ComponentMonitoringUploadEntity mibEntity = new ComponentMonitoringUploadEntity();
+
+    mibEntity.setId(element.getElementId().getValue());
+    mibEntity.setArtifact(ByteBuffer.wrap(FileUtils.toByteArray(element.getData())));
+    mapInfoToComponentMonitoringUploadEntity(mibEntity, element.getInfo());
+    return mibEntity;
+  }
+
+  @Override
+  public ComponentMonitoringUploadEntity convert(ElementInfo elementInfo) {
+    ComponentMonitoringUploadEntity mibEntity = new ComponentMonitoringUploadEntity();
+
+    mibEntity.setId(elementInfo.getId().getValue());
+    mapInfoToComponentMonitoringUploadEntity(mibEntity, elementInfo.getInfo());
+    return mibEntity;
+  }
+
+
+  public void mapInfoToComponentMonitoringUploadEntity(ComponentMonitoringUploadEntity mibEntity,
+                                                       Info info) {
+
+    mibEntity.setArtifactName((String) info.getProperties().get(ARTIFACT_NAME));
+    mibEntity.setType(MonitoringUploadType.valueOf(info.getName()));
+  }
+
+
+}