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
112
113
114
115
116
117
118
119
|
package org.onap.sdc.dcae.composition.impl;
import org.onap.sdc.common.onaplog.Enums.LogLevel;
import org.onap.sdc.common.onaplog.OnapLoggerError;
import org.onap.sdc.dcae.catalog.Catalog;
import org.onap.sdc.dcae.catalog.commons.Future;
import org.onap.sdc.dcae.catalog.engine.CatalogController;
import org.onap.sdc.dcae.catalog.engine.CatalogResponse;
import org.onap.sdc.dcae.catalog.engine.ElementRequest;
import org.onap.sdc.dcae.composition.restmodels.canvas.DcaeComponentCatalog;
import org.onap.sdc.dcae.composition.restmodels.sdc.Artifact;
import org.onap.sdc.dcae.composition.restmodels.sdc.Resource;
import org.onap.sdc.dcae.composition.restmodels.sdc.ResourceDetailed;
import org.onap.sdc.dcae.composition.util.DcaeBeConstants;
import org.onap.sdc.dcae.enums.AssetType;
import org.onap.sdc.dcae.errormng.ActionStatus;
import org.onap.sdc.dcae.errormng.ErrConfMgr;
import org.onap.sdc.dcae.utils.SdcRestClientUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
import java.util.zip.ZipEntry;
import java.util.zip.ZipInputStream;
@Component
public class CompositionCatalogBusinessLogic extends BaseBusinessLogic {
@Autowired
private CatalogController catalogController;
protected OnapLoggerError errLogger = OnapLoggerError.getInstance();
public ResponseEntity getModelById(String requestId, String theItemId) {
try {
ResourceDetailed resourceDetailed = fetchAndExtractTemplateAndSchema(theItemId, requestId);
Future<Catalog.Template> modelFuture = catalogController.getCatalog().template(resourceDetailed).withInputs().withOutputs().withNodes().withNodeProperties().withNodePropertiesAssignments().withNodeRequirements().withNodeCapabilities().withNodeCapabilityProperties()
.withNodeCapabilityPropertyAssignments().withPolicies().withPolicyProperties().withPolicyPropertiesAssignments().execute();
if(modelFuture.succeeded()) {
CatalogResponse response = new CatalogResponse(ElementRequest.EMPTY_REQUEST);
response.data().put("model", modelFuture.result().data());
return ResponseEntity.ok().body(response);
}
return ErrConfMgr.INSTANCE.buildErrorResponse(ActionStatus.GENERAL_ERROR, modelFuture.cause().getMessage());
} catch (Exception e) {
errLogger.log(LogLevel.ERROR, this.getClass().getName(), "Error fetching catalog model with id {}. Message: {}", theItemId, e);
return ErrConfMgr.INSTANCE.handleException(e, ErrConfMgr.ApiType.GET_MODEL, theItemId);
}
}
public ResponseEntity getTypeInfo(String theItemId, String theTypeName) {
try {
Future<Catalog.Type> theTypeInfoFuture = catalogController.getCatalog().type(theItemId, theTypeName).withHierarchy().withCapabilities().withRequirements().execute();
if(theTypeInfoFuture.succeeded()) {
CatalogResponse response = new CatalogResponse(ElementRequest.EMPTY_REQUEST);
response.data().put("type", theTypeInfoFuture.result().data());
return ResponseEntity.ok().body(response);
}
return ErrConfMgr.INSTANCE.buildErrorResponse(ActionStatus.GENERAL_ERROR, theTypeInfoFuture.cause().getMessage());
} catch (Exception e) {
errLogger.log(LogLevel.ERROR, this.getClass().getName(), "Exception processing catalog {}", e);
return ErrConfMgr.INSTANCE.handleException(e, ErrConfMgr.ApiType.GET_MODEL, theItemId);
}
}
public DcaeComponentCatalog getCatalog(String requestId) {
List<DcaeComponentCatalog.SubCategoryFolder> folders = sdcRestClient.getResources(AssetType.VF.name(), "DCAE Component", null, requestId).stream()
.filter(r -> DcaeBeConstants.LifecycleStateEnum.CERTIFIED == DcaeBeConstants.LifecycleStateEnum.findState(r.getLifecycleState()))
.collect(Collectors.groupingBy(Resource::getSubCategory)).entrySet().stream()
.map(e -> new DcaeComponentCatalog.SubCategoryFolder(e.getKey(), e.getValue())).collect(Collectors.toList());
DcaeComponentCatalog catalog = new DcaeComponentCatalog();
catalog.setElements(folders);
return catalog;
}
private ResourceDetailed fetchAndExtractTemplateAndSchema(String uuid, String requestId) throws IOException {
String toscaModelPath = "/sdc/v1/catalog/resources/".concat(uuid).concat("/toscaModel/");
if(!catalogController.getCatalog().hasCachedItem(uuid)){
ResourceDetailed resourceDetailed = new ResourceDetailed();
resourceDetailed.setUuid(uuid);
resourceDetailed.setToscaModelURL(toscaModelPath);
resourceDetailed.setArtifacts(extractToscaArtifactsFromCsar(sdcRestClient.getResourceToscaModel(uuid, requestId), toscaModelPath));
return resourceDetailed;
}
ResourceDetailed cachedVf = sdcRestClient.getResource(uuid, requestId);
cachedVf.getArtifacts().forEach(a -> a.setArtifactURL(toscaModelPath.concat(a.getArtifactName())));
return cachedVf;
}
private List<Artifact> extractToscaArtifactsFromCsar(byte[] csar, String toscaModelPath) throws IOException {
//we are only interested in unzipping files under Artifacts/Deployment/DCAE_TOSCA/
String dcaeToscaDir = "Artifacts/Deployment/DCAE_TOSCA/";
List<Artifact> extracted = new ArrayList<>();
try (ZipInputStream zis = new ZipInputStream(new ByteArrayInputStream(csar))) {
ZipEntry ze = zis.getNextEntry();
while (ze != null) {
if(ze.getName().startsWith(dcaeToscaDir)) {
String artifactName = ze.getName().replace(dcaeToscaDir,"");
extracted.add(SdcRestClientUtils.generateCatalogDcaeToscaArtifact(artifactName, toscaModelPath.concat(artifactName), extractFile(zis)));
}
ze = zis.getNextEntry();
}
return extracted;
}
}
}
|
