1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
package org.openecomp.sdc.vendorsoftwareproduct.dao.impl.zusammen;
import com.amdocs.zusammen.adaptor.inbound.api.types.item.Element;
import com.amdocs.zusammen.adaptor.inbound.api.types.item.ElementInfo;
import com.amdocs.zusammen.adaptor.inbound.api.types.item.ZusammenElement;
import com.amdocs.zusammen.datatypes.Id;
import com.amdocs.zusammen.datatypes.SessionContext;
import com.amdocs.zusammen.datatypes.item.ElementContext;
import com.amdocs.zusammen.utils.fileutils.FileUtils;
import org.openecomp.core.zusammen.api.ZusammenAdaptor;
import org.openecomp.core.zusammen.api.ZusammenUtil;
import org.openecomp.sdc.vendorsoftwareproduct.dao.OrchestrationTemplateDao;
import org.openecomp.sdc.vendorsoftwareproduct.dao.type.UploadData;
import org.openecomp.sdc.vendorsoftwareproduct.dao.type.UploadDataEntity;
import org.openecomp.sdc.versioning.dao.types.Version;
import org.openecomp.sdc.versioning.dao.types.VersionStatus;
import java.io.ByteArrayInputStream;
import java.nio.ByteBuffer;
import java.util.Optional;
public class OrchestrationTemplateDaoZusammenImpl implements OrchestrationTemplateDao {
private ZusammenAdaptor zusammenAdaptor;
public OrchestrationTemplateDaoZusammenImpl(ZusammenAdaptor zusammenAdaptor) {
this.zusammenAdaptor = zusammenAdaptor;
}
@Override
public void registerVersioning(String versionableEntityType) {
}
@Override
public String getValidationData(String vspId, Version version) {
SessionContext context = ZusammenUtil.createSessionContext();
Id itemId = new Id(vspId);
ElementContext elementContext = new ElementContext(itemId,
VspZusammenUtil.getFirstVersionId(context, itemId, zusammenAdaptor),
VspZusammenUtil.getVersionTag(version));
Optional<ElementInfo> elementInfo = zusammenAdaptor
.getElementInfoByName(context, elementContext, null,
StructureElement.OrchestrationTemplate.name());
if (elementInfo.isPresent()) {
Optional<Element> element =
zusammenAdaptor.getElementByName(context, elementContext, elementInfo.get().getId(),
StructureElement.OrchestrationTemplateValidationData.name());
if (element.isPresent()) {
return new String(FileUtils.toByteArray(element.get().getData()));
}
}
return null;
}
@Override
public UploadDataEntity getOrchestrationTemplate(String vspId, Version version) {
UploadDataEntity uploadData = new UploadDataEntity();
SessionContext context = ZusammenUtil.createSessionContext();
Id itemId = new Id(vspId);
ElementContext elementContext = new ElementContext(itemId,
VspZusammenUtil.getFirstVersionId(context, itemId, zusammenAdaptor),
VspZusammenUtil.getVersionTag(version));
Optional<ElementInfo> elementInfo = zusammenAdaptor
.getElementInfoByName(context, elementContext, null,
StructureElement.OrchestrationTemplate.name());
if (elementInfo.isPresent()) {
Optional<Element> element =
zusammenAdaptor.getElementByName(context, elementContext, elementInfo.get().getId(),
StructureElement.OrchestrationTemplateValidationData.name());
element.ifPresent(element1 -> uploadData
.setValidationData(new String(FileUtils.toByteArray(element1.getData()))));
element =
zusammenAdaptor.getElementByName(context, elementContext, elementInfo.get().getId(),
StructureElement.OrchestrationTemplateContent.name());
element.ifPresent(element1 -> uploadData
.setContentData(ByteBuffer.wrap(FileUtils.toByteArray(element1.getData()))));
}
return uploadData;
}
@Override
public void updateOrchestrationTemplateData(String vspId, UploadData uploadData) {
ZusammenElement orchestrationTemplateElement =
VspZusammenUtil.buildStructuralElement(StructureElement.OrchestrationTemplate, null);
ZusammenElement orchestrationTemplateValidationDataElement =
VspZusammenUtil
.buildStructuralElement(StructureElement.OrchestrationTemplateValidationData, null);
orchestrationTemplateValidationDataElement.setData(new ByteArrayInputStream(uploadData
.getValidationData().getBytes()));
ZusammenElement orchestrationTemplateContent =
VspZusammenUtil.buildStructuralElement(StructureElement.OrchestrationTemplateContent, null);
orchestrationTemplateContent
.setData(new ByteArrayInputStream(uploadData.getContentData().array()));
orchestrationTemplateElement.addSubElement(orchestrationTemplateValidationDataElement);
orchestrationTemplateElement.addSubElement(orchestrationTemplateContent);
SessionContext context = ZusammenUtil.createSessionContext();
Id itemId = new Id(vspId);
ElementContext elementContext = new ElementContext(itemId,
VspZusammenUtil.getFirstVersionId(context, itemId, zusammenAdaptor));
zusammenAdaptor.saveElement(context, elementContext, orchestrationTemplateElement, "Update " +
"Orchestration Template");
}
}
|
